ListenTCP 2025.5.31.15¶

Bundle¶

org.apache.nifi | nifi-standard-nar

Description¶

Écoute les connexions TCP entrantes et lit les données de chaque connexion en utilisant un séparateur de ligne comme délimiteur de message. Le comportement par défaut est que chaque message produit un seul FlowFile, mais il est possible de le contrôler en augmentant la taille du lot à une valeur plus grande pour un débit plus élevé. La taille de la mémoire tampon de réception doit être aussi grande que les plus grands messages que l’on s’attend à recevoir, c’est-à-dire que si tous les 100 kb il y a un séparateur de ligne, alors la taille de la mémoire tampon de réception doit être supérieure à 100 kb. Le processeur peut être configuré pour utiliser un service contextuel SSL afin de n’autoriser que les connexions sécurisées. Lorsque des clients connectés présentent des certificats pour l’authentification mutuelle TLS, les noms distinctifs de l’émetteur et de l’objet du certificat du client sont ajoutés auxFlowFiles sortants en tant qu’attributs. Le processeur n’effectue pas d’autorisation sur la base des valeurs du nom distinctif, mais comme ces valeurs sont attachées au FlowFiles sortant, l’autorisation peut être mise en œuvre sur la base de ces attributs.

Balises¶

listen, ssl, tcp, tls

Exigences en matière d’entrées¶

FORBIDDEN

Prend en charge les propriétés dynamiques sensibles¶

false

Propriétés¶

Propriété	Description
Jeu de caractères	Spécifie le jeu de caractères des données reçues.
Authentification du client	La politique d’authentification client à utiliser pour le contexte SSL. Utilisé uniquement si un service contextuel SSL est fourni.
Interface du réseau local	Le nom d’une interface de réseau local à utiliser pour restreindre l’écoute à un LAN spécifique.
Max Batch Size	Le nombre maximum de messages à ajouter à un seul FlowFile. Si plusieurs messages sont disponibles, ils seront concaténés avec le délimiteur de message <> jusqu’à ce que le nombre maximum de messages configuré soit atteint
Nombre maximal de connexions TCP	Nombre maximal de threads de travailleur disponibles pour le service des connexions TCP.
Taille maximale de la file d’attente des messages	Taille maximale de la file d’attente interne utilisée pour mettre en mémoire tampon les messages transférés du canal sous-jacent au processeur. Un paramètre plus élevé permet de mettre davantage de messages en mémoire tampon lors des pics de messages entrants, mais augmente la mémoire totale utilisée par le processeur lors de ces pics.
Taille maximale de la mémoire tampon du socket	La taille maximale de la mémoire tampon de la socket qui doit être utilisée. Il s’agit d’une suggestion au système d’exploitation pour indiquer la taille de la mémoire tampon de la socket. Si cette valeur est trop faible, la mémoire tampon risque de se remplir avant que les données puissent être lues, et les données entrantes seront abandonnées.
Délimiteur de message	Spécifie le délimiteur à placer entre les messages lorsque plusieurs messages sont regroupés (voir la propriété <Max Batch Size>).
Port	Le port sur lequel la communication doit être écoutée.
Taille du tampon de réception	La taille de chaque tampon utilisé pour recevoir des messages. Ajustez cette valeur de manière appropriée en fonction de la taille prévue des messages entrants.
Service contextuel SSL	Le Controller Service à utiliser pour obtenir un contexte SSL. Si cette propriété est définie, les messages seront reçus via une connexion sécurisée.
idle-timeout	Durée pendant laquelle la connexion d’un client restera ouverte si aucune donnée n’est reçue. La valeur par défaut de 0 seconde laisse les connexions ouvertes jusqu’à ce qu’elles soient fermées par le client.
pool-receive-buffers	Permet d’activer ou de désactiver le pooling des connexions que le processeur utilise pour traiter les octets reçus sur les connexions de sockets. Le framework alloue des tampons en fonction des besoins pendant le traitement.

Relations¶

Nom	Description
success	Les messages reçus avec succès seront envoyés à cette relation.

Écrit les attributs¶

Nom	Description
tcp.sender	L’hôte émetteur des messages.
tcp.port	Le port émetteur où les messages ont été reçus.
client.certificate.issuer.dn	Pour les connexions utilisant TLS, le nom distinctif de l’autorité de certification qui a délivré le certificat du client est joint au FlowFile.
client.certificate.subject.dn	Pour les connexions utilisant l’adresse TLS, le nom distinctif du propriétaire du certificat du client (sujet) est joint au FlowFile.