別のスレッドでServerSocketを作成しますか？

Question

私のアプリケーションでServerSocketを使用する際に問題があります。

私はアプリケーションのコンストラクタにServerSocketを作成しています。ソケットのコンストラクタは、クライアントが接続するのを待つためにaccept()メソッドを呼び出します。

問題は、クライアントが接続するまで、accept()メソッドがアプリケーション全体をフリーズしていることです。だから別のスレッドでServerSocket全体を作成する代わりに、ServerSocketのコンストラクタとそのaccept()メソッドがメインアプリケーションの横に呼び出されているかどうかを尋ねたいと思いますか？

編集：アドバイスオリヴィエへ

おかげで、実行可能に.acceptを入れてclientconnectionsを処理するスレッドプールを作成します。今私のコードザッツ

：罰金を実行している

public void start(){ 

     final ExecutorService clientProcessingPool = Executors.newFixedThreadPool(10); 

     Runnable serverTask = new Runnable() { 
      @Override 
      public void run() { 

       try { 
        serverSocket = new ServerSocket(port); 

        while (true) { 
         Socket clientSocket = serverSocket.accept(); 
         objectout = new ObjectOutputStream(clientSocket.getOutputStream()); 
         clientProcessingPool.submit(new ClientTask(clientSocket,objectout)); 
        } 
       } catch (IOException e) { 
        System.err.println("Accept failed."); 
       } 

      } 
     }; 

何もかも！ありがとう！

Answer 1

通常、このためにN + 1スレッドを使用します.1つはServerSocket用で、クライアントが接続するのを待っているアプリケーション全体をブロックしないようにします。クライアントの要求を処理するためのN個のスレッド（スレッドプールのサイズはNです）（クライアントごとに新しいスレッドを作成するよりもスレッドプールを使用することをお勧めします）。別のスレッドでソケットに関連するコードを移動しようとした。ここ

は例（ちょうどそれをコード化され、あなたがより良い例外管理などを持っている場合がありますが、これは、最小限の作業例です）

public class Server { 

    public static void main(String[] args) { 
     new Server().startServer(); 
    } 

    public void startServer() { 
     final ExecutorService clientProcessingPool = Executors.newFixedThreadPool(10); 

     Runnable serverTask = new Runnable() { 
      @Override 
      public void run() { 
       try { 
        ServerSocket serverSocket = new ServerSocket(8000); 
        System.out.println("Waiting for clients to connect..."); 
        while (true) { 
         Socket clientSocket = serverSocket.accept(); 
         clientProcessingPool.submit(new ClientTask(clientSocket)); 
        } 
       } catch (IOException e) { 
        System.err.println("Unable to process client request"); 
        e.printStackTrace(); 
       } 
      } 
     }; 
     Thread serverThread = new Thread(serverTask); 
     serverThread.start(); 

    } 

    private class ClientTask implements Runnable { 
     private final Socket clientSocket; 

     private ClientTask(Socket clientSocket) { 
      this.clientSocket = clientSocket; 
     } 

     @Override 
     public void run() { 
      System.out.println("Got a client !"); 

      // Do whatever required to process the client's request 

      try { 
       clientSocket.close(); 
      } catch (IOException e) { 
       e.printStackTrace(); 
      } 
     } 
    } 

}