如何使这个非阻塞服务器成为多线程？

我想允许多个连接到一个小型的Java服务器类型的应用程序。它可以正常工作，但如果一个连接打开然后挂起，则所有后续连接都将挂起。我不知道如何去在自己的线程处理每个连接，高达约20个并发的人，同时跟踪哪个线程属于哪个客户端等我到目前为止的代码是：如何使这个非阻塞服务器成为多线程？

private void init() { 
    try { 
     // Create the server socket channel 
     ServerSocketChannel server = ServerSocketChannel.open(); 
     // nonblocking I/O 
     server.configureBlocking(false); 
     // host-port 
     server.socket().bind(new InetSocketAddress(host, port)); 
     System.out.println("Server connected on " + host + ":" + port); 
     // Create the selector 
     Selector selector = Selector.open(); 
     // Recording server to selector (type OP_ACCEPT) 
     server.register(selector, SelectionKey.OP_ACCEPT); 
     // Infinite server loop 
     for (;;) { 
      // Waiting for events 
      selector.select(); 
      // Get keys 
      Set keys = selector.selectedKeys(); 
      Iterator i = keys.iterator(); 
      // For each keys... 
      while (i.hasNext()) { 
       SelectionKey key = (SelectionKey) i.next(); 
       // Remove the current key 
       i.remove(); 
       // if isAccetable = true 
       // then a client required a connection 
       if (key.isAcceptable()) { 
        // get client socket channel 
        SocketChannel client = server.accept(); 
        // Non Blocking I/O 
        client.configureBlocking(false); 
        // recording to the selector (reading) 
        client.register(selector, SelectionKey.OP_READ); 
        continue; 
       } 
       // then the server is ready to read 
       if (key.isReadable()) { 
        SocketChannel client = (SocketChannel) key.channel(); 
        // Read byte coming from the client 
        int BUFFER_SIZE = 32; 
        ByteBuffer buffer = ByteBuffer.allocate(BUFFER_SIZE); 
        try { 
         client.read(buffer); 
        } catch (Exception e) { 
         // client is no longer active 
         e.printStackTrace(); 
         continue; 
        } 
        buffer.flip(); 
        Charset charset = Charset.forName("ISO-8859-1"); 
        CharsetDecoder decoder = charset.newDecoder(); 
        CharBuffer charBuffer = decoder.decode(buffer); 
        Handler dataHandler = new Handler(); 
        client.write(ByteBuffer.wrap(dataHandler.processInput(charBuffer.toString()).getBytes())); 
        client.socket().close(); 
        continue; 
       } 
      } 
     } 
    } catch (IOException ex) { 
     Logger.getLogger(Server.class.getName()).log(Level.SEVERE, null, ex); 
    } 
}

来源

2011-01-26 zcourts

我只想用阻塞NIO，并且每个客户端一个线程，它会更简单，可扩展到10K的连接。它也可以更高效。 – 2011-01-26 09:18:17