TCP 网关
入站 TCP 网关TcpInboundGateway
和出站 TCP 网关TcpOutboundGateway
分别使用 Server 和 Client 端连接工厂。
每个连接一次可以处理一个请求或响应。
入站网关,在构造包含传入有效负载的消息并将其发送到requestChannel
等待响应,并通过将响应消息写入连接来发送响应消息中的有效负载。
对于入站网关,您必须保留或填充ip_connectionId header,因为它用于将消息关联到连接。
源自网关的消息会自动设置标头。
如果回复是作为新消息构建的,则需要设置 header。
可以从传入消息中捕获标头值。 |
与入站适配器一样,入站网关通常使用type="server"
connection factory,用于侦听传入的连接请求。
在某些情况下,您可能希望反向建立连接,以便入站网关连接到外部服务器,然后等待并回复该连接上的入站邮件。
此拓扑通过使用client-mode="true"
在入站网关上。
在这种情况下,连接工厂的类型必须为client
并且必须具有single-use
设置为false
.
两个附加属性支持此机制。
这retry-interval
指定 (以毫秒为单位) 框架在连接失败后尝试重新连接的频率。
这scheduler
供应一个TaskScheduler
以计划连接尝试并测试连接是否仍处于活动状态。
如果网关已启动,您可以通过发送<control-bus/>
命令:@adapter_id.retryConnection()
并使用@adapter_id.isClientModeConnected()
.
出站网关在通过连接发送消息后,等待响应,构建响应消息,并将其放在回复通道上。 通过连接进行的通信是单线程的。 一次只能处理一条消息。 如果另一个线程在收到当前响应之前尝试发送消息,它将阻塞,直到任何先前的请求完成(或超时)。 但是,如果将客户端连接工厂配置为一次性连接,则每个新请求都会获得自己的连接并立即得到处理。 以下示例配置入站 TCP 网关:
<int-ip:tcp-inbound-gateway id="inGateway"
request-channel="tcpChannel"
reply-channel="replyChannel"
connection-factory="cfServer"
reply-timeout="10000"/>
如果使用配置了默认序列化器或反序列化器的连接工厂,则 messages 为\r\n
delimited data 和网关可以由简单的客户端(如 telnet)使用。
以下示例显示了出站 TCP 网关:
<int-ip:tcp-outbound-gateway id="outGateway"
request-channel="tcpChannel"
reply-channel="replyChannel"
connection-factory="cfClient"
request-timeout="10000"
remote-timeout="10000"/> <!-- or e.g. remote-timeout-expression="headers['timeout']" -->
这client-mode
当前不适用于出站网关。
从版本 5.2 开始,可以使用属性closeStreamAfterSend
.
如果连接出厂配置为single-use
(每个请求/回复的新连接)网关将关闭输出流;这会向服务器发出 EOF 信号。
如果服务器使用 EOF 来确定消息的结尾,而不是流中的某个分隔符,但保持连接打开以接收回复,则这非常有用。
通常,调用线程将在网关中阻塞,等待回复(或超时)。
从版本 5.3 开始,您可以设置async
属性,并且发送线程被释放以执行其他工作。
回复(或错误)将在接收线程上发送。
这仅适用于使用TcpNetClientConnectionFactory
,则在使用 NIO 时将忽略它,因为存在争用条件,即在收到回复后发生的套接字错误可以在回复之前传递给网关。
使用共享连接 (singleUse=false ),则新请求(当另一个请求正在处理中时)将被阻止,直到收到当前回复。
考虑使用CachingClientConnectionFactory 如果您希望在长期连接池上支持并发请求。 |
从版本 5.4 开始,入站可以使用unsolicitedMessageChannel
.
未经请求的入站消息以及延迟回复(客户端超时)将发送到此通道。
要在服务器端支持此功能,您现在可以注册多个TcpSender
s 替换为连接工厂。
网关和通道适配器会自动注册自身。
从服务器发送未经请求的邮件时,您必须添加相应的IpHeaders.CONNECTION_ID
发送到发送的消息。