ListenTCP 2025.5.31.15¶

Pacote¶

org.apache.nifi | nifi-standard-nar

Descrição¶

Ouve as conexões TCP de entrada e lê os dados de cada conexão usando um separador de linha como demarcador de mensagem. O comportamento padrão é que cada mensagem produza uma única FlowFile, mas isso pode ser controlado aumentando-se o tamanho do lote para um valor maior para aumentar a taxa de transferência. O tamanho do buffer de recebimento deve ser definido com o tamanho das maiores mensagens que se espera receber, ou seja, se a cada 100 KB houver um separador de linha, o tamanho de buffer de recebimento deverá ser maior que 100 KB. O processador pode ser configurado para usar um serviço de contexto SSL para permitir apenas conexões seguras. Quando clientes conectados apresentam certificados para autenticação TLS mútua, os nomes distintos do emissor e do assunto do certificado do cliente são adicionados aos FlowFiles de saída como atributos. O processador não realiza a autorização com base nos valores de nome distinto, mas como esses valores são anexados aos FlowFiles de saída, a autorização pode ser implementada com base nesses atributos.

Tags¶

listen, ssl, tcp, tls

Requisito de entrada¶

FORBIDDEN

Oferece suporte a propriedades dinâmicas confidenciais¶

falso

Propriedades¶

Propriedade	Descrição
Conjunto de caracteres	Especifica o conjunto de caracteres dos dados recebidos.
Autenticação do cliente	A política de autenticação de cliente a ser usada para o contexto SSL. Usado somente se for fornecido um serviço de contexto SSL.
Interface de rede local	O nome de uma interface de rede local a ser usada para restringir a escuta de uma LAN específica.
Tamanho máximo do lote	O número máximo de mensagens a serem adicionadas a um único FlowFile. Se houver várias mensagens disponíveis, elas serão concatenadas junto com o <Delimitador de mensagens> até o número máximo de mensagens configurado
Número máximo de conexões TCP	O número máximo de threads de trabalho disponíveis para atender às conexões TCP.
Tamanho máximo da fila de mensagens	O tamanho máximo da fila interna usada para armazenar em buffer as mensagens que estão sendo transferidas do canal subjacente para o processador. A configuração desse valor mais alto permite que mais mensagens sejam armazenadas em buffer na memória durante os picos de mensagens recebidas, mas aumenta a memória total usada pelo processador durante esses picos.
Tamanho máximo do buffer do soquete	O tamanho máximo do buffer do soquete que deve ser usado. Essa é uma sugestão para o sistema operacional para indicar o tamanho do buffer do soquete. Se esse valor for definido como muito baixo, o buffer poderá se encher antes que os dados possam ser lidos, e os dados recebidos serão descartados.
Delimitador de mensagens	Especifica o delimitador a ser colocado entre as mensagens quando várias mensagens são agrupadas (consulte a propriedade <Max Batch Size>).
Porta	A porta de escuta para comunicação.
Tamanho do buffer de recepção	O tamanho de cada buffer usado para receber mensagens. Ajuste esse valor adequadamente com base no tamanho esperado das mensagens recebidas.
Serviço de contexto SSL	O Controller Service a ser usado para obter um contexto SSL. Se essa propriedade for definida, as mensagens serão recebidas por meio de uma conexão segura.
idle-timeout	O tempo que a conexão de um cliente permanecerá aberta se nenhum dado for recebido. O padrão de 0 segundos deixará as conexões abertas até que sejam fechadas pelo cliente.
pool-receive-buffers	Habilita ou desabilita o agrupamento de buffers que o processador usa para tratar bytes recebidos em conexões de soquete. A estrutura aloca buffers conforme necessário durante o processamento.

Relações¶

Nome	Descrição
success	As mensagens recebidas com sucesso serão enviadas para essa relação.

Grava atributos¶

Nome	Descrição
tcp.sender	O host de origem das mensagens.
tcp.port	A porta de envio em que as mensagens foram recebidas.
client.certificate.issuer.dn	Para conexões que usam TLS mútuo, o nome distinto da autoridade de certificação que emitiu o certificado do cliente é anexado ao FlowFile.
client.certificate.subject.dn	Para conexões que usam o TLS mútuo, o nome distinto do proprietário do certificado do cliente (sujeito) é anexado ao FlowFile.