TCP缓存连接未正常工作，求CachingClientConnectionFactory机制解惑

一、CachingClientConnectionFactory核心工作逻辑 #

它基于Apache Commons Pool实现TCP连接复用，核心流程：

• 获取连接时，优先从空闲池捞可用连接，有则直接复用；无可用连接时，若活动连接数未达池上限则新建连接；活动连接数已达上限时，等待配置的超时时间，超时仍获取不到则抛出PoolItemNotAvailableException
• 连接使用完成后必须调用close()，否则不会归还至空闲池，会持续占用活动连接配额
• 空闲连接会根据idleTimeout和maxIdleTime自动清理，避免无效资源占用

二、连接池耗尽问题根源 #

从你描述的发送101条消息即触发异常的现象来看，核心问题是连接使用后未正确归还至空闲池，导致活动连接数持续增长至池上限（100），后续请求无可用连接配额。常见触发场景：

1. 代码中未调用Connection.close()或CachingClientConnectionFactory.releaseConnection()
2. 消息发送过程中抛出异常，导致归还逻辑未执行（如未将归还代码放入finally块）
3. 配置缺失空闲超时、连接回收策略等关键参数，无法自动清理空闲连接

三、具体排查与修复方案 #

1. 配置代码检查 #

如果你的配置未设置空闲超时与回收参数，示例如下：

@Bean
public CachingClientConnectionFactory connectionFactory() {
    CachingClientConnectionFactory factory = new CachingClientConnectionFactory("localhost", 3000);
    factory.setPoolSize(100);
    // 缺失空闲超时与连接回收配置
    return factory;
}

修复：添加空闲超时配置，确保空闲连接能被自动回收：

factory.setIdleTimeout(30000); // 30秒空闲后归还至空闲池
factory.setMaxIdleTime(60000); // 空闲超过1分钟直接销毁连接

2. 消息发送逻辑检查 #

如果发送代码未正确关闭连接，示例如下：

public void sendMessage(String message) throws Exception {
    Connection connection = connectionFactory.createConnection();
    OutputStream os = connection.getOutputStream();
    os.write(message.getBytes());
    os.flush();
    // 未调用connection.close()，连接持续占用活动配额
}

修复：使用try-with-resources自动关闭连接（推荐），或在finally块中手动关闭：

// try-with-resources自动执行close()归还连接
public void sendMessage(String message) throws Exception {
    try (Connection connection = connectionFactory.createConnection()) {
        OutputStream os = connection.getOutputStream();
        os.write(message.getBytes());
        os.flush();
    }
}

手动关闭方案：

public void sendMessage(String message) throws Exception {
    Connection connection = null;
    try {
        connection = connectionFactory.createConnection();
        OutputStream os = connection.getOutputStream();
        os.write(message.getBytes());
        os.flush();
    } finally {
        if (connection != null) {
            try {
                connection.close();
            } catch (IOException e) {
                // 记录异常日志，避免吞异常
                e.printStackTrace();
            }
        }
    }
}

3. 客户端日志验证 #

从日志中排查以下关键信息：

• 每次消息发送后是否有Released connection相关日志
• activeConnections指标是否持续增长至100后不再下降
• 是否存在连接异常日志，导致归还逻辑未执行

4. Node.js服务端检查 #

若服务端收到消息后主动关闭连接，会导致客户端连接失效无法复用，示例错误代码：

// 错误写法：收到消息立即关闭连接
server.on('connection', (socket) => {
    socket.on('data', (data) => {
        console.log('Received:', data.toString());
        socket.end(); // 主动关闭连接，客户端连接变为无效
    });
});

修复服务端：保持连接存活以支持复用：

server.on('connection', (socket) => {
    socket.on('data', (data) => {
        console.log('Received:', data.toString());
        // 不主动关闭连接，保留连接供后续请求复用
    });
    socket.on('error', (err) => {
        console.log('Socket error:', err);
    });
});

四、修复验证 #

修复完成后发送101条消息：

• 前100条消息会创建100个连接，使用完成后归还至空闲池
• 第101条消息会复用空闲池中的连接，不会触发PoolItemNotAvailableException
• 客户端日志会交替出现Acquired connection from pool与Released connection to pool记录

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