Le serveur NIO ne peut pas écouter le client

Question

Salut J'essaie de mettre en œuvre un serveur Java NIO simple; qui enregistre le socketChannel avec le sélecteur. Par conséquent, je souhaite écouter le client et envoyer une réponse en retour. Après que le socketChannel est enregistré avec le sélecteur, même si le client (non NIO) envoie des données, le serveur n'est pas capable de lire; howerver la clé générée est toujours itérée.

détaillée: Côté serveur:

**First thread**: 

public void run() { while (true) {

ServerSocketChannel serverSocketChannel = ServerSocketChannel.open(); 
    serverSocketChannel.configureBlocking(true); 
    serverSocketChannel.socket().bind(inetAdressOfServer); 
    SocketChannel clientChannel = serverSocketChannel.accept(); 
    new Listener("").addSocketChannel(clientChannel); 

}} 

**Second Thread**: 

    static Selector selector = Selector.open(); 
    public boolean addSocketChannel(SocketChannel clientChannel) { 

     SelectionKey key = clientSocketChannel.register(selector, selector.OP_READ|SelectionKey.OP_WRITE);    
     key.attach(new ChannelCallback(clientSocketChannel)); 
     return key.isValid(); 
    } 

    public void run() { 

     Set keysSet = selector.keys(); 
     Iterator i = keysSet.iterator();   
     while (i.hasNext()) { 
      SelectionKey key = (SelectionKey) i.next(); 
     } 

     if (key.isReadable()) { 
      //read and do something 
     } 
    } 



Client Side: 

Socket socket = new Socket(serverIP, serverPort);  
DataOutputStream dos = new DataOutputStream(socket.getOutputStream());  
dos.writeBytes(str + "\n"); 

NB: Lorsque vous avez terminé en fil unique, le même programme fonctionne, mais Lorsqu'elle est mise en œuvre de la manière mentionnée ci-dessus, elle ne doit pas écouter le client. S'il vous plaît aidez-moi à résoudre ce problème.

Answer 1

Il est très difficile de voir ce que vous avez fait, mais il semble que ce que vous avez marqué comme "deuxième thread" est utilisé par les deux threads (confusion sur l'implémentation Runnable/extension Thread et threads réels?). En particulier, je devine le new Listener construit et commence un fil. Vous appelez alors addSocketChannel dans le premier fil de discussion. Par conséquent, il existe une condition de concurrence. Il est également une mauvaise idée de faire selector statique.

Answer 2

Lecture de travaux lus à partir d'un autre fil, voici les problèmes évidents avec votre code.

public void run() { 
    Set keysSet = selector.keys(); 

Ici vous prenez le jeu de clés de la iterator, mais il n'y a pas de code jamais faire select() ou selectNow() sur le sélecteur, donc ce jeu sera toujours vide. Ceci ne compile même pas, la vérification de 'read' sur la clé doit être faite à l'intérieur du bloc-temps.

SelectionKey key = clientSocketChannel.register(selector, 
               SelectionKey.OP_READ | 
               SelectionKey.OP_WRITE);    

Deux problèmes: Le canal doit être réglé en mode non-bloquant avant cela se fait et SelectionKey.OP_WRITE ne doit pas être réglé à moins que vous voulez que la clé à retourner chaque fois que vous exécutez une sélection.

Vous ne devez définir SelectionKey.OP_WRITE que si vous envisagez d'effectuer une écriture. Enfin, l'utilisation de deux fils est très peu conventionnelle. La méthode recommandée pour cela consiste à enregistrer le ServerSocketChannel dans le sélecteur avec OP_ACCEPT et à exécuter l'acceptation sur le ServerSocket sur le même thread que read/write.