ListenUDP 2025.10.2.19

捆绑包

org.apache.nifi | nifi-standard-nar

描述

Listens for Datagram Packets on a given port. The default behavior produces a FlowFile per datagram, however for higher throughput the Max Batch Size property may be increased to specify the number of datagrams to batch together in a single FlowFile. This processor can be restricted to listening for datagrams from a specific remote host and port by specifying the Sending Host and Sending Host Port properties, otherwise it will listen for datagrams from all hosts and ports.

标签

ingest、listen、source、udp

输入要求

FORBIDDEN

支持敏感的动态属性

false

属性

属性

描述

字符集

指定接收到数据的字符集。

本地网络接口

本地网络接口的名称,用于限制对特定 LAN 的监听。

最大批处理大小

添加到单个 FlowFile 的消息的最大数量。如果有多条消息可用,则使用 <Message Delimiter> 将这些消息合并在一起,但不能超过此配置的最大消息数

消息队列的最大大小

内部队列的最大大小,用于缓冲从底层通道传输到处理器的消息。将此值设置得较高可在传入消息大量涌入时将更多消息缓冲到内存中,但会增加处理器的总内存使用量。

套接字缓冲区的最大大小

应使用的套接字缓冲区的最大大小。此值用于向操作系统建议套接字缓冲区的大小。如果此值设置过低,缓冲区可能在数据读取之前就已填满,导致传入的数据被丢弃。

消息分隔符

指定当将多条消息捆绑在一起时,在消息之间放置的分隔符(参见 <Max Batch Size> 属性)。

端口

监听通信的端口。

接收缓冲区大小

用于接收消息的每个缓冲区的大小。根据传入的消息的预期大小适当调整此值。

发送主机

远程主机的 IP 或名称。仅接受来自指定“发送主机端口”和此主机的数据报。改进了性能。可以是系统属性或环境变量。

发送主机端口

远程主机使用端口发送数据报。仅接受来自指定“发送主机”和此端口的数据报。改进了性能。可以是系统属性或环境变量。

关系

名称

描述

success

成功接收的消息将从此关系中发出。

写入属性

名称

描述

udp.sender

消息的发送主机。

udp.port

所收到消息的发送端口。

语言: 中文