ListenTCP 2025.5.31.15¶

번들¶

org.apache.nifi | nifi-standard-nar

설명¶

수신 TCP 연결을 수신 대기하고 줄 바꿈 구분자를 메시지 구분 기호로 사용하여 각 연결에서 데이터를 읽습니다. 기본 동작은 각 메시지가 단일 FlowFile 을 생성하는 것이지만, 처리량을 높이려면 배치 크기를 더 큰 값으로 늘려서 제어할 수 있습니다. 수신 버퍼 크기는 수신할 것으로 예상되는 가장 큰 메시지만큼 설정해야 합니다. 즉, 100kb마다 줄 바꿈이 있는 경우 수신 버퍼 크기는 100kb보다 커야 합니다. 프로세서는 SSL 컨텍스트 서비스를 사용하여 보안 연결만 허용하도록 구성할 수 있습니다. 연결된 클라이언트가 상호 TLS 인증을 위해 인증서를 제시하면 클라이언트 인증서의 발급자 및 주체의 고유 이름이 발신 FlowFiles 에 특성으로 추가됩니다. 프로세서는 고유 이름 값을 기반으로 승인 성능을 수행하지 않지만 이러한 값이 발신 FlowFiles 에 첨부되어 있으므로 이러한 특성을 기반으로 승인을 구현할 수 있습니다.

태그¶

listen, ssl, tcp, tls

입력 요구 사항¶

FORBIDDEN

민감한 동적 속성 지원¶

false

속성¶

속성	설명
문자 세트	수신된 데이터의 문자 세트를 지정합니다.
클라이언트 인증	SSL 컨텍스트에 사용할 클라이언트 인증 정책입니다. SSL 컨텍스트 서비스가 제공되는 경우에만 사용됩니다.
로컬 네트워크 인터페이스	특정 LAN 에 대한 수신을 제한하는 데 사용할 로컬 네트워크 인터페이스의 이름입니다.
Max Batch Size	1개의 FlowFile 에 추가할 수 있는 최대 메시지 수입니다. 여러 메시지를 사용할 수 있는 경우 <메시지 구분 기호>를 사용하여 구성된 최대 메시지 수까지 연결됩니다.
최대 TCP 연결 수	TCP 연결을 서비스하는 데 사용할 수 있는 최대 작업자 스레드 수입니다.
메시지 큐의 최대 크기	기본 채널에서 프로세서로 전송되는 메시지를 버퍼링하는 데 사용되는 내부 큐의 최대 크기입니다. 이 값을 높게 설정하면 수신 메시지가 급증하는 동안 더 많은 메시지를 메모리에 버퍼링할 수 있지만, 이러한 급증 중에 프로세서가 사용하는 총 메모리가 증가합니다.
소켓 버퍼의 최대 크기	사용해야 하는 소켓 버퍼의 최대 크기입니다. 이것은 소켓 버퍼의 크기를 나타내는 운영 체제에 대한 제안입니다. 이 값을 너무 낮게 설정하면 데이터를 읽기 전에 버퍼가 가득 차서 수신 데이터가 삭제될 수 있습니다.
메시지 구분 기호	여러 메시지를 함께 묶어 배치할 때 메시지 사이에 배치할 구분 기호를 지정합니다(<Max Batch Size> 속성 참조).
Port	통신을 위해 수신 대기할 포트입니다.
수신 버퍼 크기	메시지를 수신하는 데 사용되는 각 버퍼의 크기입니다. 수신 메시지의 예상 크기에 따라 이 값을 적절히 조정하십시오.
SSL 컨텍스트 서비스	SSL 컨텍스트를 얻기 위해 사용할 컨트롤러 서비스입니다. 이 속성을 설정하면 보안 연결을 통해 메시지를 수신합니다.
유휴 시간 제한	데이터가 수신되지 않은 경우 클라이언트의 연결이 열려 있는 상태로 유지되는 시간입니다. 기본값인 0초는 클라이언트가 연결을 닫을 때까지 연결이 열린 상태로 유지됩니다.
pool-receive-buffers	프로세서가 소켓 연결에서 수신한 바이트 처리에 사용하는 버퍼 풀링을 사용하거나 사용하지 않도록 설정합니다. 프레임워크는 처리 중에 필요에 따라 버퍼를 할당합니다.

관계¶

이름	설명
성공	성공적으로 수신된 메시지는 이 관계로 전송됩니다.

Writes 특성¶

이름	설명
tcp.sender	메시지를 보내는 호스트입니다.
tcp.port	메시지가 수신된 발신 포트입니다.
client.certificate.issuer.dn	상호 TLS 를 사용하는 연결의 경우 클라이언트의 인증서를 발급한 인증 기관의 고유 이름이 FlowFile 에 첨부됩니다.
client.certificate.subject.dn	상호 TLS 를 사용하는 연결의 경우 클라이언트 인증서 소유자(주체)의 고유 이름이 FlowFile 에 첨부됩니다.