TcpNioConnection关闭抛出ClosedChannelException，求最大客户端连接数配置方案

官方推荐方案：直接配置maxConnections参数 #

Spring Integration的TcpNioServerConnectionFactory本身就提供了最大连接数的配置能力，完全不需要自己监听事件手动处理。你只需要在构建nioServer时添加.maxConnections(maxClient)即可——当连接数超过阈值时，新的连接请求会被自动拒绝，不会触发异常。

修改你的Integration Flow代码如下：

IntegrationFlows.from(Tcp.inboundGateway(Tcp.nioServer(port)
         .soReceiveBufferSize(512)
         .deserializer(new MessageDeserializer())
         .serializer(new MessageSerializer())
         .maxConnections(1) // 这里设置你的最大客户端连接数，比如示例中的1
         )) 
            .log()
            .transform(Transformers.objectToString())
            .handle("outboundService", "processAndSendMessage")
            .get();

这个参数的作用是：当当前活跃连接数达到最大值时，新的连接请求会被立即拒绝，不会进入后续的连接建立流程，自然也就不会出现你遇到的ClosedChannelException。

原代码导致异常的原因分析 #

你当前的实现存在几个关键问题：

1. 时机错误：TcpConnectionOpenEvent是在连接已经完全建立、通道已经被注册到NIO选择器之后才发布的。这时候你调用nioConnection.close()，但工厂线程还在执行通道注册的逻辑，导致尝试注册一个已关闭的通道，抛出ClosedChannelException。
2. 线程不安全：ArrayList不是线程安全集合，在多连接并发场景下，connectionIdList.add/remove会出现并发修改问题，导致连接数统计不准确。
3. 逻辑倒置：你应该在连接被接受但未完成建立时就拒绝，而不是等连接完全建立后再关闭。

自定义处理方案（不推荐，优先用官方配置） #

如果因为特殊需求必须自己控制连接数，正确的做法是通过TcpConnectionInterceptor或者扩展TcpNioServerConnectionFactory的方式，在连接接受阶段就判断并拒绝，而不是依赖事件监听。示例代码如下：

public class ConnectionLimitInterceptor implements TcpConnectionInterceptor {

    private final int maxConnections;
    private final AtomicInteger activeConnections = new AtomicInteger(0);

    public ConnectionLimitInterceptor(int maxConnections) {
        this.maxConnections = maxConnections;
    }

    @Override
    public void onOpen(TcpConnection connection) {
        if (activeConnections.incrementAndGet() > maxConnections) {
            try {
                connection.close();
            } catch (IOException e) {
                // 按需处理异常
            } finally {
                activeConnections.decrementAndGet();
            }
            return;
        }
        // 传递给下一个拦截器或默认处理逻辑
        if (getNext() != null) {
            getNext().onOpen(connection);
        }
    }

    @Override
    public void onClose(TcpConnection connection) {
        activeConnections.decrementAndGet();
        if (getNext() != null) {
            getNext().onClose(connection);
        }
    }

    // 实现接口其他方法（如onMessage等），直接传递给下一个拦截器即可
}

然后在连接工厂中添加拦截器：

Tcp.nioServer(port)
    .interceptor(new ConnectionLimitInterceptor(1))
    // 其他配置项...

但再次强调，官方的maxConnections已经封装了成熟的线程安全统计、连接拒绝逻辑，完全满足你的需求，不需要自己重复造轮子。

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