ListenUDP 2025.5.31.15¶

捆绑包¶

org.apache.nifi | nifi-standard-nar

描述¶

监听给定端口上的数据报包。默认行为为每个数据报生成一个 FlowFile，但是为了提高吞吐量，可以增加“批处理大小上限”属性以指定单个 FlowFile 中要批处理的数据报的数量。通过指定“发送主机”和“发送主机端口”属性，可以将该处理器限制为监听来自特定远程主机和端口的数据报，否则它将监听来自所有主机和端口的数据报。

标签¶

ingest、listen、source、udp

输入要求¶

FORBIDDEN

支持敏感的动态属性¶

false

属性¶

属性	描述
字符集	指定接收到数据的字符集。
本地网络接口	本地网络接口的名称，用于限制对特定 LAN 的监听。
最大批处理大小	添加到单个 FlowFile 的消息的最大数量。如果有多条消息可用，则使用 <Message Delimiter> 将这些消息合并在一起，但不能超过此配置的最大消息数
消息队列的最大大小	内部队列的最大大小，用于缓冲从底层通道传输到处理器的消息。将此值设置得较高可在传入消息大量涌入时将更多消息缓冲到内存中，但会增加处理器的总内存使用量。
套接字缓冲区的最大大小	应使用的套接字缓冲区的最大大小。此值用于向操作系统建议套接字缓冲区的大小。如果此值设置过低，缓冲区可能在数据读取之前就已填满，导致传入的数据被丢弃。
消息分隔符	指定当将多条消息捆绑在一起时，在消息之间放置的分隔符（参见 <Max Batch Size> 属性）。
端口	监听通信的端口。
接收缓冲区大小	用于接收消息的每个缓冲区的大小。根据传入的消息的预期大小适当调整此值。
发送主机	远程主机的 IP 或名称。仅接受来自指定“发送主机端口”和此主机的数据报。改进了性能。可以是系统属性或环境变量。
发送主机端口	远程主机使用端口发送数据报。仅接受来自指定“发送主机”和此端口的数据报。改进了性能。可以是系统属性或环境变量。

关系¶

名称	描述
success	成功接收的消息将从此关系中发出。

写入属性¶

名称	描述
udp.sender	消息的发送主机。
udp.port	所收到消息的发送端口。