이 비 차단 서버를 멀티 스레드로 만들려면 어떻게해야합니까?

Question

작은 자바 서버 유형 앱에 여러 연결을 허용하려고합니다. 있는 그대로 작동하지만 하나의 연결이 열렸다가 멈 추면 모든 후속 연결이 중단됩니다. 나는 스레드가 속한 추적을 유지하면서 자신의 스레드에서 약 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); 
    } 
} 

Answer 1

내 솔루션은 ThreadPool을 생성하는 Netty 및 Executor입니다. 실행기 마녀 ChannelBuffer를 매개 변수로 호출하는 처리기 do Netty의 파이프 라인을 추가하기 만하면됩니다. 모든 클라이언트 요청이 별도의 스레드에 의해 처리됩니다. examples

Answer 2

소켓 서버를 작성해야 할 때마다 하위 수준의 JVM 클래스는 사용하지 않는 것이 좋습니다. 그 이유는 모든 핵심적인 세부 사항을 처리해야하기 때문입니다.

대신 Apache Mina을 사용합니다. 고성능 논 블로킹 멀티 쓰레드 소켓 서버를 작성하기위한 자바 라이브러리.

미나 (Mina)를 사용할 때의 이점은 코드를 모듈화하고 관리하기 쉽게 만드는 clean architecture (IoFilters, 프로토콜 디코더)을 시행한다는 것입니다.

Answer 3

NIO 서버를 학습 연습으로 쓰고 싶지 않다면 Netty을 사용하는 것이 좋습니다. Peter가 언급 한 Mina와 마찬가지로 고성능 서버를 작성하기위한 라이브러리이기도합니다.

최근에 내 자신의 NIO 코드를이 라이브러리로 옮겨서 코드를 훨씬 더 명확하게 만들었습니다.