ListenTCP
描述:
监听接收TCP连接并从每个使用分隔符消息的连接中读取数据,默认方式是每个消息将产生一个单独的输出数据流。然而,需要通过控制增加数据的<批量大小>来提高数据的吞吐量。<接收缓存大小>参数必须尽可能的设置得足够大,以期望满足数据的接收。意味着,如果每个行分隔符的数据是100kb,那么<接收缓存大小>必须设置得大于该100kb值。
标签:
listen, tcp, tls, ssl, 监听
参数:
如下列表中,必填参数则标识为加粗. 其他未加粗参数,则表示为可选参数。表中同时提到参数默认值设置, 并且 参数还支持 表达式语言.
名字 | 默认值 | 允许值列表 | 描述 |
---|---|---|---|
本地网络接口 | 用于严格限制监听指定局域网内的本地网络接口名。 支持表达式语言 (仅支持变量) | ||
端口号 | 用于监听通信的端口号。 支持表达式语言 (仅支持变量) | ||
接收缓存大小 | 65507 B | 用于接收消息的缓存大小。 根据传入消息的预期大小适当调整此值。 | |
消息队列大小 | 10000 | 传输频道用于传输内部队列的缓存消息的最大值,将此值设置得更高将允许在传入消息激增期间在内存中缓冲更多的消息,但是相应的就会增加了组件使用的总内存。 | |
Socket缓存大小 | 1 MB | 用于Socket缓存的数据量大小。根据操作系统建议所需要设置的最大缓存,如果设置太低,缓存将在数据被读取时过早的被占满,并导致输入数据被丢失。 | |
字符编码 | UTF-8 | 指定接收数据的字符集编码 | |
分批数量 | 1 | 添加到单个数据流中的最大消息数。将用于将多个消息通过 <消息批量分隔符>来连接的最大消息数 | |
消息批量分隔符 | \n | 当需要将多个消息捆绑在一起时,可设置多个消息之间的分隔符(参加 <批量大小> 参数). | |
最大TCP连接数 | 2 | 同时可接受数据的最大TCP连接数 | |
SSL服务 | 控制器服务API: RestrictedSSLContextService 实现: StandardRestrictedSSLContextService | 用于SSL的服务,设置后,消息将通过加密信道来接收 | |
客户端认证 | 必须 | - 请求 - 必须 - 不需要 | 当使用SSL服务时的客户端认证策略。仅当提供SSL服务设置时有效 |
响应会话服务 | 控制器服务API: KeyValueLookupService 实现: CommonKeyValueLookupService | 该服务用于记录当前TCP响应会话。 |
连线:
名字 | 描述 |
---|---|
success | 成功接收消息后的数据流将输出到此连接 |
读取属性:
未提供。
写入属性:
名字 | 描述 |
---|---|
tcp.sender | 发送消息的主机 |
tcp.port | 当收到消息的发送消息主机端口号 |
tcp.messages | 接收到的消息 |
tcp.context.identifier | 发送消息的标识符 |
tcp.context.charset | 发送消息的字符集编码 |
tcp.response.delimiter | 发送消息的分隔符 |
状态管理:
该组件不保存状态。
限制:
该组件没有限制
输入流要求:
组件禁止提供输入流。
系统资源考量:
未提供。