ソケットサーバーと複数のクライアントとのJava

Question

複数のクライアントをリッスンするソケットサーバーを作成する必要があります。同時に6つのクライアントがサーバに接続しており、各クライアントが同時にいくつかのコマンドをサーバに送信しているとします。これらのクライアントが1秒ごとにサーバーにメッセージを送信すると、サーバー側の6つのクライアントからのメッセージを処理して、テーブルに格納し、各クライアントに確認応答を送信することができます。

これらの入力をクライアントから処理するにはどうすればよいですか。クライアントからこれらの入力を処理するために6つのスレッドを作成する必要があるかどうか。

私はこの問題に近づくように考えてください。

Answer 1

これを行うためにサーブレットコンテナを使用できない理由は何ですか？これはServlet + Tomcat/Jettyのコード行10行です。

Answer 2

クライアント接続ごとに新しいスレッドを作成し、処理するデータを探すために、各スレッドのストリームのブロッキング読み取りを継続します。

class Server { 

    ClientThread threads[]; 
    int    size; 
    ServerSocket serverSocket; 
    boolean   active; 

    Server() throws Exception { 
     /* initialize connection */ 
     active = true; 
     listen(); 
    } 

    void listen() throws Exception { 
     while (active) { 
      Socket clientSocket = serverSocket.accept(); 
      threads[ size++ ] = new ClientThread(clientSocket); 
      threads[ size - 1 ].start(); 
     } 
    } 
} 

class ClientThread extends Thread { 

    OutputStream out; 
    InputStream  in; 
    boolean   active; 

    ClientThread(Socket clientSocket) throws Exception { 
     out = clientSocket.getOutputStream(); 
     in = clientSocket.getInputStream(); 
    } 

    public void run() { 
     active = true; 
     while (active) { 
      listen(); 
     } 
    } 

    private void listen() { 
     try { 
      int res = process(in.read()); 
      out.write(res); 
     } catch (Exception e) {} 
    } 

    private int process(int b) { 
     return -1; 
    } 
}