Java Server ayant de nombreux clients connectés sans goulot d’étranglement

Donc, ce que j’essaie de faire, c’est d’avoir un socket qui reçoit les entrées du client, de placer le client dans la queue, puis de renvoyer un message à chaque client dans la queue lorsque mon algorithme retourne vrai.

Cette queue devrait prendre en charge quelques centaines de clients à la fois, mais en même temps, ne pas mettre le serveur en attente pour qu’il puisse faire ce qu’il est censé faire.

C’est ce que j’ai jusqu’à présent:

private static final int PORT = 25566; private static final int THREADS = 4; private ExecutorService service; public void init() throws IOException, IllegalStateException { ServerSocket serverSocket; serverSocket = new ServerSocket(PORT); service = Executors.newCachedThreadPool(); Socket socket; while(true) { socket = serverSocket.accept(); System.out.println ("Connection established with " + socket.getInetAddress().toSsortingng()); service.execute(() -> { Scanner scanner = null; PrintWriter output = null; Ssortingng line = null; try { scanner = new Scanner(new InputStreamReader(socket.getInputStream())); output = new PrintWriter(socket.getOutputStream()); } catch(IOException e) { e.printStackTrace(); } try { if (scanner == null || output == null) throw new IllegalStateException("Scanner/PrintWriter is " + "null!"); line = scanner.nextLine(); while (line.compareTo("QUIT") != 0) { /* This is where input comes in, queue for the algorithm, algorithm happens then returns appropriate values */ output.flush(); line = scanner.nextLine(); } } finally { try { System.out.println ("Closing connection with " + socket.getInetAddress().toSsortingng()); if(scanner != null) { scanner.close(); } if(output != null) { output.close(); } socket.close(); } catch(IOException e) { e.printStackTrace(); } } }); } } 

Maintenant, ce que je pense va arriver avec ceci, si les files d’attente atteignent des niveaux suffisamment élevés, mon pool de threads gênera complètement le serveur car tous les threads sont utilisés pour gérer les clients dans la file d’attente et il n’y aura pas traitement suffisant pour l’algorithme.

• Modification de la couleur d’un cercle dans une application client-serveur
• Obtenir une erreur Connectiontimedout lors de la création d’un SocketServer distant en Java
• L’importation javax.persistence ne peut pas être résolue après la suppression de Server Runtime Environment
• java coding: interface publique étendue à distance
• Comment puis-je télécharger des fichiers sur mon projet Google App Engine sans le déployer?

EDIT: Après un tas de tests, je pense que cela fonctionnera si dans l’algorithme il retourne la valeur puis se déconnecte, n’attendant pas la réponse de l’utilisateur mais demandant au client de se reconnecter une fois que certaines conditions sont remplies.

• Dois-je installer Java pour déployer une application dans Tomcat?
• Comment append un serveur d’exécution à plusieurs projets existants dans Eclipse (outils Kepler avec Oracle) à la fois
• débogage d’une extension Neo4j non gérée
• Tomcat ne démarre pas. Où étais-je mal?
• Recevoir un message du serveur netty nio java