ListenTCP 2025.10.9.21¶
번들¶
org.apache.nifi | nifi-standard-nar
설명¶
수신 TCP 연결을 수신 대기하고 줄 바꿈 구분자를 메시지 구분 기호로 사용하여 각 연결에서 데이터를 읽습니다. 기본 동작은 각 메시지가 단일 FlowFile 을 생성하는 것이지만, 처리량을 높이려면 배치 크기를 더 큰 값으로 늘려서 제어할 수 있습니다. 수신 버퍼 크기는 수신할 것으로 예상되는 가장 큰 메시지만큼 설정해야 합니다. 즉, 100kb마다 줄 바꿈이 있는 경우 수신 버퍼 크기는 100kb보다 커야 합니다. 프로세서는 SSL 컨텍스트 서비스를 사용하여 보안 연결만 허용하도록 구성할 수 있습니다. 연결된 클라이언트가 상호 TLS 인증을 위해 인증서를 제시하면 클라이언트 인증서의 발급자 및 주체의 고유 이름이 발신 FlowFiles 에 특성으로 추가됩니다. 프로세서는 고유 이름 값을 기반으로 승인 성능을 수행하지 않지만 이러한 값이 발신 FlowFiles 에 첨부되어 있으므로 이러한 특성을 기반으로 승인을 구현할 수 있습니다.
입력 요구 사항¶
FORBIDDEN
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
|---|---|
Batching Message Delimiter |
여러 메시지를 함께 묶어 배치할 때 메시지 사이에 배치할 구분 기호를 지정합니다(<Max Batch Size> 속성 참조). |
문자 세트 |
수신된 데이터의 문자 세트를 지정합니다. |
클라이언트 인증 |
SSL 컨텍스트에 사용할 클라이언트 인증 정책입니다. SSL 컨텍스트 서비스가 제공되는 경우에만 사용됩니다. |
로컬 네트워크 인터페이스 |
특정 LAN 에 대한 수신을 제한하는 데 사용할 로컬 네트워크 인터페이스의 이름입니다. |
Max Batch Size |
1개의 FlowFile 에 추가할 수 있는 최대 메시지 수입니다. 여러 메시지를 사용할 수 있는 경우 <메시지 구분 기호>를 사용하여 구성된 최대 메시지 수까지 연결됩니다. |
메시지 큐의 최대 크기 |
기본 채널에서 프로세서로 전송되는 메시지를 버퍼링하는 데 사용되는 내부 큐의 최대 크기입니다. 이 값을 높게 설정하면 수신 메시지가 급증하는 동안 더 많은 메시지를 메모리에 버퍼링할 수 있지만, 이러한 급증 중에 프로세서가 사용하는 총 메모리가 증가합니다. |
소켓 버퍼의 최대 크기 |
사용해야 하는 소켓 버퍼의 최대 크기입니다. 이것은 소켓 버퍼의 크기를 나타내는 운영 체제에 대한 제안입니다. 이 값을 너무 낮게 설정하면 데이터를 읽기 전에 버퍼가 가득 차서 수신 데이터가 삭제될 수 있습니다. |
Port |
통신을 위해 수신 대기할 포트입니다. |
수신 버퍼 크기 |
메시지를 수신하는 데 사용되는 각 버퍼의 크기입니다. 수신 메시지의 예상 크기에 따라 이 값을 적절히 조정하십시오. |
SSL 컨텍스트 서비스 |
SSL 컨텍스트를 얻기 위해 사용할 컨트롤러 서비스입니다. 이 속성을 설정하면 보안 연결을 통해 메시지를 수신합니다. |
Worker Threads |
TCP 연결을 서비스하는 데 사용할 수 있는 최대 작업자 스레드 수입니다. |
유휴 시간 제한 |
데이터가 수신되지 않은 경우 클라이언트의 연결이 열려 있는 상태로 유지되는 시간입니다. 기본값인 0초는 클라이언트가 연결을 닫을 때까지 연결이 열린 상태로 유지됩니다. |
pool-receive-buffers |
프로세서가 소켓 연결에서 수신한 바이트 처리에 사용하는 버퍼 풀링을 사용하거나 사용하지 않도록 설정합니다. 프레임워크는 처리 중에 필요에 따라 버퍼를 할당합니다. |
관계¶
이름 |
설명 |
|---|---|
성공 |
성공적으로 수신된 메시지는 이 관계로 전송됩니다. |
Writes 특성¶
이름 |
설명 |
|---|---|
tcp.sender |
메시지를 보내는 호스트입니다. |
tcp.port |
메시지가 수신된 발신 포트입니다. |
client.certificate.issuer.dn |
상호 TLS 를 사용하는 연결의 경우 클라이언트의 인증서를 발급한 인증 기관의 고유 이름이 FlowFile 에 첨부됩니다. |
client.certificate.subject.dn |
상호 TLS 를 사용하는 연결의 경우 클라이언트 인증서 소유자(주체)의 고유 이름이 FlowFile 에 첨부됩니다. |