在單獨的線程中創建ServerSocket？

Question

我在我的應用程序中使用ServerSocket時遇到問題。

我在我的應用程序的構造函數中創建了ServerSocket。套接字的構造函數調用accept()方法來等待客戶端連接。

問題是，accept()方法凍結我的整個應用程序，直到客戶端連接。所以我想問一下，是否有另一種方法可以在單獨的線程中創建整個ServerSocket，ServerSocket及其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個線程：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(); 
      } 
     } 
    } 

}