Single Threaded Server dans multithread en JAVA

Question

Je dois convertir ce serveur mono-thread en multithread, donc je suis en mesure de traiter une demande multiple d'un serveur:

public class YASGP { 
    public static void main(String args[]) throws IOException { 
     ServerSocket server; 
     try{ 
      server = new ServerSocket(5559); 

     System.out.println("Listening for connection on port 5559 ...."); 

     while (true) { 
      Socket clientSocket = server.accept(); 
      InputStreamReader isr = new InputStreamReader(clientSocket.getInputStream()); 
      BufferedReader reader = new BufferedReader(isr); 
      String line = reader.readLine(); 
      new Thread(new WorkerRunnable(clientSocket)).start(); 
      while (!line.isEmpty()) { 
       System.out.println("----- " + line); 
       if (!line.contains("OPTIONS")) { 
        // System.out.println("Non c'è nulla!!!"); 
       } else { 
        timeS = line.substring(line.indexOf("timeS=") + 6, line.indexOf("&url")); 
        url = line.substring(line.indexOf("url=") + 4, line.lastIndexOf("&param")); 
        param = line.substring(line.indexOf("&param=") + 7, line.indexOf("HTTP")); 
       } 
       line = reader.readLine(); 
      } 
      } 
     } 
    }catch (IOException e) { 
     System.out.println("Could not listen on port: 4001"); 
} 
} 
private static class RequestHandlingClass { 
     public RequestHandlingClass(Socket clientSocket) { 
     } 
    } 
} 

Comment puis-je convertir ? Merci à tous

Answer 1

supprimer le code « de traitement du client » du serveur comme suit

public static void main(String args[]) throws IOException { 
     ServerSocket server; 
     try{ 
      server = new ServerSocket(5559); 
      System.out.println("Listening for connection on port 5559 ...."); 

      while (true) { 
       Socket clientSocket = server.accept(); 
       new Thread(new WorkerRunnable(clientSocket)).start(); 
      } 

     }catch (IOException e) { 
      System.out.println("Could not listen on port: 4001"); 
     } 
    } 

alors le code que vous avez levé sur va dans la méthode d'exécution de la classe workerRunnable.

Answer 2

Je recommande u utiliser le excutorService api.Since il sera responsable tout votre problème de filetage pour u derrière la scène

ExecutorService executor = Executors.newSingleThreadExecutor(); 
executor.submit(() -> { 
    //Your code here 
});