ServerSocket in einem separaten Thread erstellen?

Question

Ich habe ein Problem mit der Verwendung einer ServerSocket in meiner Anwendung.

Ich erstelle die ServerSocket im Konstruktor meiner Anwendung. Der Konstruktor des Sockets ruft die Methode accept() auf, um darauf zu warten, dass ein Client eine Verbindung herstellt.

Das Problem ist, dass die accept() Methode meine gesamte Anwendung einfriert, bis ein Client verbindet. Also würde ich gerne fragen, ob es eine Alternative zum Erstellen der gesamten ServerSocket in einem separaten Thread gibt, dass der Konstruktor der ServerSocket und seine accept() Methode neben meiner Hauptanwendung aufgerufen wird?

Edit:

Dank Olivier für die Beratung, die .Accept in ein lauffähiges setzen und die Schaffung eines Thread die clientconnections zu behandeln.

Das ist jetzt mein Code:

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

      } 
     }; 

Every läuft gut! Vielen Dank!

Answer 1

Normalerweise verwende ich N + 1 Threads für dieses: eins für den ServerSocket, um zu vermeiden, die gesamte Anwendung zu blockieren, die darauf wartet, dass ein Client eine Verbindung herstellt; und N Threads, um die Anforderungen des Clients zu verarbeiten, wobei N die Größe des Thread-Pools ist (ich empfehle, einen Thread-Pool zu verwenden, um einen neuen Thread pro Client zu erstellen). Hier

ist ein Beispiel (es gerade codiert, möchten Sie vielleicht eine bessere Verwaltung von Ausnahmen und so haben, aber dies ist ein minimales Arbeitsbeispiel)

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

}