ListenUDP
描述:
在给定端口上侦听报文。 默认行为为每个数据报文生成数据流,但是为了获得更高的吞吐量,可以增加批量最大消息数属性以指定在单个数据流中批处理的数据报的数量。 通过指定发送主机和发送主机端口属性,可以限制此组件侦听来自特定远程主机和端口的数据报文,否则它将侦听来自所有主机和端口的数据报文。
标签:
ingest, udp, listen, source, 监听
参数:
如下列表中,必填参数则标识为加粗. 其他未加粗参数,则表示为可选参数。表中同时提到参数默认值设置, 并且 参数还支持 表达式语言.
名字 | 默认值 | 允许值列表 | 描述 |
---|---|---|---|
本地网络接口 | 在特定局域网内,用于限制侦听本地网络接口的名称 支持表达式语言 (仅支持变量) | ||
端口号 | 通信监听端口。 支持表达式语言 (仅支持变量) | ||
接收缓存大小 | 65507 B | 用于接收消息的每个缓冲区的大小。 根据传入消息的预期大小适当调整此值。 | |
消息队列大小 | 10000 | 用于缓冲从底层通道传输到组件的消息的内部队列的最大值。 将此值设置得更高可以在传入消息的浪涌期间将更多消息缓冲在内存中,但会增加组件使用的总内存。 | |
Socket缓冲大小 | 1 MB | 应使用的套接字缓冲区的最大值。 这是对操作系统的建议,以指示套接字缓冲区应该有多大。 如果此值设置得太低,缓冲区可能会在读取数据之前填满,并且传入的数据将被丢弃。 | |
字符编码 | UTF-8 | 指定接收数据的字符集编码 | |
分批数量 | 1 | 要添加到单个数据流的最大消息数。 如果有多条消息可用,它们将与<消息分隔符>一起配置连接到此的最大消息数 | |
消息分隔符 | \n | 指定将多个消息捆绑在一起时在消息之间放置的分隔符(请参阅<批量最大消息数>属性)。 | |
远程主机 | 远程主机的IP或名称。 仅接受来自指定发送主机端口和此主机的数据报。 提高性能。 可以是系统属性或环境变量。 支持表达式语言 (仅支持变量) | ||
远程端口号 | 远程主机用于发送数据报的端口。 仅接受来自指定发送主机和此端口的数据报。 提高性能。 可以是系统属性或环境变量。 支持表达式语言 (仅支持变量) |
连线:
名字 | 描述 |
---|---|
success | 成功接受的消息将发送到该连线。 |
读取属性:
未提供。
写入属性:
名字 | 描述 |
---|---|
udp.sender | 发送消息的主机 |
udp.port | 接收消息的发送端口 |
状态管理:
该组件不保存状态。
限制:
该组件没有限制
输入流要求:
组件禁止提供输入流。
系统资源考量:
未提供。