Spring Integration TCP Outbound Gateway replyChannel收不到数据超时如何解决

核心问题排查与配置修正 #

1. 缺失TCP消息序列化/反序列化配置 #

TCP是流式传输协议，Spring Integration TCP组件默认需要明确指定消息分界规则，也就是序列化器/反序列化器，否则无法正确识别服务端返回的响应边界，会一直等待数据直到超时。

你原生Java代码是自己处理了消息的读取终止逻辑，比如按固定长度、换行符、自定义长度头之类的，换到Spring Integration需要对应配置到连接工厂里，常见的配置可选：

• 以换行符作为消息结束标记，使用ByteArrayLfSerializer
• 固定长度消息，使用ByteArrayFixedLengthSerializer
• 自定义长度头（比如前2字节存消息长度），使用ByteArrayLengthHeaderSerializer
• 也可以自定义序列化器实现org.springframework.core.serializer.Serializer和Deserializer接口

配置示例：

<bean id="serializer" class="org.springframework.integration.ip.tcp.serializer.ByteArrayLfSerializer" />

<int-ip:tcp-connection-factory id="cfClient"
type="client"
host="localhost"
port="8376"
single-use="false"
so-timeout="30000"
connect-timeout="120"
serializer="serializer"
deserializer="serializer"/>

2. 出站网关未绑定回复通道 #

你当前配置的tcp-outbound-gateway没有指定reply-channel属性，服务端返回的响应不会自动路由到你定义的replyChannel里，自然触发不了replyHandler方法。修正配置：

<int-ip:tcp-outbound-gateway id="outGateway"
request-channel="tcpChannel"
connection-factory="cfClient"
request-timeout="10000"
remote-timeout="10000"
reply-channel="replyChannel"/>

3. @MessagingGateway返回值适配 #

你定义的Rs2TCPMessagingGateway接口sendISOMessage方法有String返回值，默认会使用临时回复通道接收响应。如果你需要同时让响应返回给网关调用方，又触发replyHandler逻辑，可以把replyChannel改成发布订阅通道：

<int:publish-subscribe-channel id="replyChannel" />

如果不需要网关方法返回值，直接改成void即可。

额外排查建议 #

• 开启Spring Integration DEBUG日志，观察消息的流转路径，确认响应是否被正确解码、是否路由到了正确的通道
• 确认服务端返回的响应格式和你配置的反序列化器规则完全匹配，比如有没有带结束标记、长度头是否正确
• 检查single-use="false"的配置是否符合你的业务场景，如果服务端是每个请求对应一个新连接，要改成true

内容的提问来源于stack exchange，提问作者Krishna Chaitanya