使用CachingClientConnectionFactory获取TCP客户端打开连接ID是否可行？

关于getOpenConnectionIds()方法的说明 #

AbstractConnectionFactory中的getOpenConnectionIds()方法确实主要为TCP服务器端设计。服务器端连接工厂（如TcpNetServerConnectionFactory）会维护所有主动接入的客户端连接集合，而客户端连接工厂（AbstractClientConnectionFactory及其子类，包括TcpNetClientConnectionFactory）并未实现该方法的核心逻辑——客户端是主动发起连接，连接池的连接由CachingClientConnectionFactory缓存，它本身不会暴露连接ID集合，因此直接调用该方法会返回空结果。

可行解决方案：自定义连接监听器跟踪连接ID #

通过Spring Integration提供的ConnectionListener接口，可以监听客户端连接的创建与销毁事件，从而记录和维护所有活跃连接的ID。

1. 实现连接跟踪监听器

创建一个实现ConnectionListener的类，用于跟踪连接的开闭状态并维护连接ID列表：

import org.springframework.integration.ip.tcp.connection.ConnectionListener;
import org.springframework.integration.ip.tcp.connection.TcpConnection;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CopyOnWriteArrayList;

public class ClientConnectionTracker implements ConnectionListener {
    private final List<String> openConnectionIds = new CopyOnWriteArrayList<>();

    @Override
    public void onOpen(TcpConnection connection) {
        openConnectionIds.add(connection.getConnectionId());
    }

    @Override
    public void onClose(TcpConnection connection) {
        openConnectionIds.remove(connection.getConnectionId());
    }

    // 返回当前活跃连接ID的只读副本
    public List<String> getOpenConnectionIds() {
        return new ArrayList<>(openConnectionIds);
    }
}

2. 将监听器添加到底层连接工厂

在配置类中，将监听器注册给TcpNetClientConnectionFactory（CachingClientConnectionFactory的目标工厂）：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.integration.ip.tcp.connection.CachingClientConnectionFactory;
import org.springframework.integration.ip.tcp.connection.TcpNetClientConnectionFactory;

@Configuration
public class TcpClientConfig {

    @Bean
    public TcpNetClientConnectionFactory tcpNetClientConnectionFactory() {
        TcpNetClientConnectionFactory factory = new TcpNetClientConnectionFactory("your-server-host", 9000);
        // 可添加其他客户端配置，如连接超时、SO参数等
        return factory;
    }

    @Bean
    public ClientConnectionTracker clientConnectionTracker() {
        return new ClientConnectionTracker();
    }

    @Bean
    public CachingClientConnectionFactory cachingClientConnectionFactory(
            TcpNetClientConnectionFactory tcpNetFactory,
            ClientConnectionTracker connectionTracker) {
        CachingClientConnectionFactory cachingFactory = new CachingClientConnectionFactory(tcpNetFactory, 10);
        // 给底层客户端工厂添加连接监听器
        tcpNetFactory.addConnectionListener(connectionTracker);
        return cachingFactory;
    }
}

3. 获取并打印活跃连接ID

在需要打印连接ID的业务代码中，注入ClientConnectionTracker并调用其方法：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class ConnectionIdPrinter {

    private final ClientConnectionTracker connectionTracker;

    @Autowired
    public ConnectionIdPrinter(ClientConnectionTracker connectionTracker) {
        this.connectionTracker = connectionTracker;
    }

    public void printOpenConnectionIds() {
        System.out.println("当前活跃连接ID列表：");
        connectionTracker.getOpenConnectionIds().forEach(System.out::println);
    }
}

补充说明 #

• CopyOnWriteArrayList用于保证多线程环境下的线程安全，避免连接开闭时的并发修改问题。
• 该方案可以准确跟踪连接池中的所有活跃连接，包括被缓存但未被使用的连接（只要连接处于打开状态）。
• 避免使用反射访问CachingClientConnectionFactory的内部缓存，这种方式依赖框架内部实现，版本升级时可能出现兼容问题。

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