Tạo ServerSocket trong một chuỗi riêng biệt?

Question

Tôi gặp sự cố khi sử dụng số ServerSocket trong đơn đăng ký của mình.

Tôi đang tạo ServerSocket trong hàm tạo của ứng dụng của mình. Hàm khởi tạo của socket gọi phương thức accept() để đợi máy khách kết nối.

Vấn đề là phương pháp accept() đang đóng băng toàn bộ ứng dụng của tôi cho đến khi khách hàng kết nối. Vì vậy, tôi muốn hỏi nếu có một thay thế để tạo ra toàn bộ ServerSocket trong một chủ đề riêng biệt, rằng các nhà xây dựng của ServerSocket và phương pháp accept() của nó được gọi là bên cạnh ứng dụng chính của tôi?

Edit:

Nhờ Olivier cho những lời khuyên, đưa .Đồng ý vào một Runnable và tạo ra một threadpool để xử lý các clientconnections.

Thats mã của tôi ngay bây giờ:

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."); 
       } 

      } 
     }; 

Everythings chạy tốt! Cảm ơn!

Answer 1

Thông thường, tôi sử dụng các chủ đề N + 1 cho điều này: một cho ServerSocket, để tránh chặn toàn bộ ứng dụng chờ khách hàng kết nối; và N chủ đề để xử lý các yêu cầu của khách hàng, N là kích thước của hồ bơi thread (Tôi khuyên bạn nên sử dụng một hồ bơi thread trên tạo ra một chủ đề mới cho mỗi khách hàng).

Dưới đây là một ví dụ (chỉ cần mã hóa nó, bạn có thể muốn có quản lý ngoại lệ tốt hơn và như vậy, nhưng đây là một ví dụ làm việc tối thiểu)

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(); 
      } 
     } 
    } 

}