Calculer Girl
  1. Calculer Girl
  3. ServerSocketChannel pour accepter plus de connexions du même client
Intereting Posts
Quelle est la responsabilité de l’application ngnix ou apache in rails? utiliser la commande tee pour redirect la sortie vers un fichier dans un répertoire inexistant Un guide complet pour déployer django avec nginx et uwsgi (qui fonctionne)? http et https redirect vers un autre lien avec un sous-domaine générique Dans Apache freemarker template Comment récupérer des valeurs par clés dans un hashmap sans avoir à les parcourir en tant que liste Utilisation de deux souris pour effectuer des actions complètement différentes dans Windows Nom du processus pour la fenêtre active dans Windows 8/10 bits de permission nommés pipes Reportez-vous à / sélectionnez un lecteur basé uniquement sur son étiquette? (c.-à-d. pas la lettre de lecteur) Nombre de threads MySQL_connected ralentir mon site NGINX dit que “le client n’a envoyé aucun certificate SSL requirejs lors de la lecture des en-têtes de demande du client” comment résoudre les problèmes? bash – vérifie si la chaîne contient newline Surveiller l’état du serveur, du processus, des services et du planificateur de tâches Résolution des variables de macro dans une session de serveur RPM – Paramètres de temps d’installation

ServerSocketChannel pour accepter plus de connexions du même client

mon serveur doit accepter les nouvelles connexions du même client. Parce que mon client se reconnecte après 10 heures de connexion. C’est un serveur / client pour le protocole iscsi et mon client est un initiateur Microsoft iscsi.

Je voudrais donc une suggestion. Aujourd’hui, j’ai un pool de threads de taille 4, mon serveur peut donc accepter 4 connexions à partir du même client. Mais ce nombre pourrait augmenter à mesure que mon temps de connexion est important. Le code est ci-dessous …. Dois-je terminer le threadPool et renvoyer la connexion? C’est la meilleure approche?

Merci d’avance. 

ExecutorService threadPool = Executors.newFixedThreadPool(4); // Create a blocking server socket and check for connections try { // Create a blocking server socket channel on the specified/default port System.out.println("0"); serverSocketChannel = ServerSocketChannel.open(); // Making sure the socket is bound to the address used in the config. serverSocketChannel.socket().bind( new InetSocketAddress(getConfig().getTargetAddress(), getConfig().getPort())); System.out.println("0.1"); serverSocketChannel.configureBlocking(true); System.out.println("0.2"); System.out.println("1"); while (running) { System.out.println("2"); // Accept the connection request. // If serverSocketChannel is blocking, this method blocks. // The returned channel is in blocking mode. final SocketChannel socketChannel = serverSocketChannel.accept(); System.out.println("3"); // deactivate Nagle algorithm socketChannel.socket().setTcpNoDelay(true); connection = new TargetConnection(socketChannel, true); System.out.println("4 - "); try { final ProtocolDataUnit pdu = connection.receivePdu(); // confirm OpCode if (pdu.getBasicHeaderSegment().getOpCode() != OperationCode.LOGIN_REQUEST) throw new InternetSCSIException(); // get initiatorSessionID LoginRequestParser parser = (LoginRequestParser) pdu.getBasicHeaderSegment().getParser(); ISID initiatorSessionID = parser.getInitiatorSessionID(); /* * TODO get (new or existing) session based on TSIH But since we don't do session reinstatement and * MaxConnections=1, we can just create a new one. */ TargetSession session = new TargetSession(this, connection, initiatorSessionID, parser.getCommandSequenceNumber(), parser.getExpectedStatusSequenceNumber()); // set ExpCmdSN (PDU is immediate, hence no ++) sessions.add(session); System.out.println("5 - sessions.size(): " + sessions.size()); threadPool.submit(connection);// ignore returned Future // connection.call(); } catch (DigestException | InternetSCSIException | SettingsException e) { System.out.println("TargetServer: " + new ToSsortingngBuilder(sessions).reflectionToSsortingng(sessions).toSsortingng()); LOGGER.info("Throws Exception", e); continue; } }