TcpOutboundGateway超时异常咨询：服务器响应未被客户端捕获

针对你遇到的服务器已响应但客户端捕获不到、怀疑服务器主动关闭Socket的问题，结合你的配置代码，给出以下具体解决步骤：

一、修复缓存连接失效问题 #

你使用了CachingClientConnectionFactory缓存连接，但服务器主动关闭连接后，缓存里的无效连接会被继续复用，直接导致请求超时。

1. 启用连接存活检查 #

要么利用内置连接测试功能，要么手动检查连接状态：

// Visa连接工厂示例，Mastercard同理
CachingClientConnectionFactory cachingFactory = new CachingClientConnectionFactory(tcpNioClientConnectionFactory, 50);
cachingFactory.setTestConnection(true); // 开启连接测试，获取连接时自动验证是否存活

或者手动实现连接检查逻辑：

return new CachingClientConnectionFactory(tcpNioClientConnectionFactory, 50) {
    @Override
    public TcpConnection getConnection() throws IOException {
        TcpConnection conn = super.getConnection();
        if (!conn.isOpen()) {
            this.releaseConnection(conn);
            conn = super.getConnection();
        }
        return conn;
    }
};

2. 设置缓存连接空闲超时 #

让缓存自动清理长时间未使用的连接，避免被服务器主动回收：

cachingFactory.setIdleTimeout(30000); // 30秒空闲后自动移除连接

二、添加TCP心跳维持连接 #

服务器通常会关闭长时间无数据交互的连接，配置心跳可以避免这种情况：

// 给TcpNioClientConnectionFactory添加心跳相关配置
tcpNioClientConnectionFactory.setSoKeepAlive(true); // 启用TCP内置心跳机制
tcpNioClientConnectionFactory.setSoTimeout(10000); // 设置读取超时为10秒

// 或者自定义定时心跳（需要先定义TaskScheduler Bean）
tcpNioClientConnectionFactory.setTaskScheduler(taskScheduler());
tcpNioClientConnectionFactory.setHeartbeatInterval(5000); // 每5秒发送一次心跳

额外定义TaskScheduler Bean：

@Bean
public TaskScheduler taskScheduler() {
    ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
    scheduler.setPoolSize(2);
    scheduler.setThreadNamePrefix("tcp-heartbeat-");
    return scheduler;
}

三、监听连接关闭事件，及时清理无效连接 #

通过Spring事件监听机制，一旦检测到连接关闭，立即从缓存中移除对应无效连接：

@EventListener
public void onConnectionClosed(TcpConnectionClosedEvent event) {
    log.info("连接已关闭: {}", event.getConnectionId());
    if (event.getConnectionFactory() instanceof CachingClientConnectionFactory) {
        ((CachingClientConnectionFactory) event.getConnectionFactory())
                .releaseConnection(event.getConnection());
    }
}

四、验证序列化/反序列化逻辑 #

确认ByteArrayCrLfSerializer是否与服务器响应格式匹配：

• 检查服务器响应是否确实以\r\n作为结束符，如果不是，更换对应序列化器（比如固定长度场景用ByteArrayRawSerializer，或自定义序列化逻辑）。
• 开启DEBUG日志查看原始接收数据，排查格式问题：

logging.level.org.springframework.integration.tcp=DEBUG

五、调整请求超时时间 #

当前5秒的超时设置可能过短，根据实际网络环境和服务器响应速度调整：

tcpOutboundGateway.setRequestTimeout(10_000); // 改为10秒，可按需调整

六、统一配置未请求消息处理 #

你仅给Mastercard配置了unsolicitedMessageChannelName，如果服务器给Visa发送主动消息（比如系统通知），会导致Visa连接阻塞，无法接收正常响应，需给Visa也配置该参数：

// 在outboundGatewayVisa中添加
tcpOutboundGateway.setUnsolicitedMessageChannelName("unsolicited");

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