如何用Java实现多端口监听且各端口配独立线程池的服务端

一、无需NIO的实现方案（更简单易维护） #

实现机制 #

完全可以不依赖NIO实现需求，核心逻辑如下：
你已经实现了单端口监听的服务类（内部封装了独立的ServerSocket、专属线程池、阻塞accept逻辑），只需要为每个监听端口实例化一个独立的单端口服务对象，再将每个服务对象提交到独立线程运行即可。
每个端口的监听线程彼此隔离，accept阻塞不会互相影响，每个端口的请求都提交到自身专属的线程池处理，完全满足端口维度的资源隔离要求。

代码示例 #

假设你现有单端口服务类为SinglePortServer，构造方法可传入监听端口、线程池配置参数，启动代码如下：

int[] listenPorts = {4000, 4001, 6000};
for (int port : listenPorts) {
    // 每个端口实例化独立服务，内部持有专属线程池
    SinglePortServer portServer = new SinglePortServer(port, 10, 50, 60); // 示例参数：核心线程数、最大线程数、空闲回收时间
    // 每个服务跑在独立线程，避免accept阻塞互相影响
    new Thread(portServer, "监听端口-"+port).start();
}

二、NIO版本的修正与适配方案 #

原有代码问题修复 #

你原有NIO代码的SERVER CANNOT BE RESOLVED报错是因为ServerSocketChannel是循环内的局部变量，处理逻辑里没有从SelectionKey中获取对应通道，同时单线程串行处理业务的问题可以通过绑定端口专属线程池解决。

实现逻辑 #

1. 为每个监听端口创建独立的专属线程池
2. 注册ServerSocketChannel到Selector时，将端口对应的线程池作为附件绑定到SelectionKey上
3. Selector线程仅处理轻量的accept操作，收到连接后从Key的附件中取出对应端口的线程池，将业务处理逻辑提交到该线程池执行，避免业务逻辑阻塞Selector线程

修正后代码示例 #

Selector selector = Selector.open();
int[] ports = {4000,4001,6000};
// 存储每个端口对应的专属线程池
Map<Integer, ExecutorService> portThreadPoolMap = new HashMap<>();

for (int port : ports) {
   ServerSocketChannel server = ServerSocketChannel.open();
   server.configureBlocking(false);
   server.socket().bind(new InetSocketAddress(port));
   // 为当前端口创建独立线程池，可根据不同端口的业务需求自定义配置
   ExecutorService portThreadPool = Executors.newFixedThreadPool(20);
   portThreadPoolMap.put(port, portThreadPool);
   // 注册时绑定端口和对应线程池作为附件
   server.register(selector, SelectionKey.OP_ACCEPT, new Object[]{port, portThreadPool});
}

while (selector.isOpen()) {
   selector.select();
   Set<SelectionKey> readyKeys = selector.selectedKeys();
   Iterator<SelectionKey> iterator = readyKeys.iterator();
   while (iterator.hasNext()) {
      SelectionKey key = iterator.next();
      // 必须手动移除已处理的key，否则会重复触发
      iterator.remove();
      if (key.isAcceptable()) {
         // 从key的附件中获取当前端口对应的线程池
         Object[] attachment = (Object[]) key.attachment();
         ExecutorService targetThreadPool = (ExecutorService) attachment[1];
         // 从key中获取当前的ServerSocketChannel，解决变量无法解析问题
         ServerSocketChannel server = (ServerSocketChannel) key.channel();
         SocketChannel client = server.accept();
         Socket socket = client.socket();
         // 提交到对应端口的专属线程池处理业务
         targetThreadPool.submit(new HandlerRichieste(socket, this));
      }
   }
}

选型建议 #

• 若监听端口数量较少（少于20个），优先选择非NIO的BIO方案，逻辑简单、排查问题成本低
• 若监听端口数量较多，优先选择NIO方案，可节省大量监听线程的资源开销

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