Spring Integration中CachingClientConnectionFactory连接池无法复用连接问题

问题原因 #

TcpOutboundGateway默认开启closeConnectionOnSend=true，会导致每次请求响应完成后主动关闭连接——哪怕配置了CachingClientConnectionFactory，被关闭的连接也无法回到连接池复用，只能每次创建新连接。

解决方案 #

1. 修改TcpOutboundGateway配置，禁用请求后关闭连接 #

在创建TcpOutboundGateway的Bean时，添加setCloseConnectionOnSend(false)，让请求完成后将连接归还到连接池：

@Bean
@ServiceActivator(inputChannel = "outboundChannel")
public MessageHandler outboundGateway(@Qualifier("clientConnectionFactoryForOutbound") AbstractClientConnectionFactory clientConnectionFactory) {
    TcpOutboundGateway tcpOutboundGateway = new TcpOutboundGateway();
    tcpOutboundGateway.setConnectionFactory(clientConnectionFactory);
    tcpOutboundGateway.setUnsolicitedMessageChannelName("unsolicitedChannel");
    // 关键配置：禁止请求后关闭连接，让连接回到缓存池
    tcpOutboundGateway.setCloseConnectionOnSend(false);
    return tcpOutboundGateway;
}

2. 优化底层连接工厂配置，避免连接被服务器主动关闭 #

为TcpNioClientConnectionFactory开启TCP保活机制，防止空闲连接被服务器端主动断开，同时可添加连接池的空闲清理、有效性验证配置：

@Bean("clientConnectionFactoryForOutbound")
public AbstractClientConnectionFactory clientConnectionFactoryForOutbound() {
    TcpNioClientConnectionFactory tcpNioClientConnectionFactory = new TcpNioClientConnectionFactory(host, port);
    tcpNioClientConnectionFactory.setUsingDirectBuffers(true);
    tcpNioClientConnectionFactory.setApplicationEventPublisher(applicationEventPublisher);
    tcpNioClientConnectionFactory.setConnectTimeout(5);
    tcpNioClientConnectionFactory.setSerializer(customSerializerDeserializer());
    tcpNioClientConnectionFactory.setDeserializer(customSerializerDeserializer());
    // 开启TCP保活，防止空闲连接被服务器关闭
    tcpNioClientConnectionFactory.setSoKeepAlive(true);
    
    var cachingClientConnectionFactory = new CachingClientConnectionFactory(tcpNioClientConnectionFactory, 3);
    cachingClientConnectionFactory.setSingleUse(false);
    // 可选：设置空闲连接超时时间，自动清理长时间未使用的连接（单位：毫秒）
    cachingClientConnectionFactory.setMaxIdleTime(300000);
    // 可选：取出连接时验证有效性，避免使用已失效的连接
    cachingClientConnectionFactory.setValidateConnection(true);
    
    return cachingClientConnectionFactory;
}

额外说明 #

• setSingleUse(false)：你已正确配置该属性，它告知连接池连接可被多次复用，无需每次用完销毁。
• setValidateConnection(true)：当连接池中的空闲连接被服务器主动关闭时，该配置会在取出连接前验证有效性，无效则自动创建新连接，避免抛出连接异常。
• setMaxIdleTime：设置空闲连接的最大存活时间，超过时间的连接会被自动清理，避免资源浪费。

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