NIOサーバーがクライアントを聞くことができません

Question

こんにちは私は単純なJava NIOサーバーを実装しようとしています。ソケットセレクタはセレクタにsocketChannelを登録します。したがって、私はクライアントに耳を傾け、いくつかの応答を返信したい。 socketChannelがセレクタに登録された後、クライアント（NIO以外）が何らかのデータを送信しても、Serverは読み取ることができません。生成されたキーはまだ反復されています。

詳細表示：サーバー側：

**First thread**: 

ます。public void実行（）{ ながら、（真）{

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：単一のスレッドで実行すると、同じプログラムが動作しますが、上記の方法で実装された場合、クライアントに耳を傾けません。 この問題を解決するのを手伝ってください。

Answer 1

「2番目のスレッド」としてマークしたものが両方のスレッドで使用されているかのように見えます（Runnable/Threadの実装と実際のスレッドを混同していますか？特に、私はnew Listenerの構成を推測し、スレッドを開始します。最初のスレッドでaddSocketChannelに電話をかけています。したがって、競合状態が存在します。

また、selectorを静的にすることは賢明ではありません。

Answer 2

読んで別のスレッドから読んで作品、ここにコードで明らかな問題があります。

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

ここでは、イテレータからキーセットを取っているが、これまでのセレクタを選択（）またはselectNow（）やって何のコードがありませんので、このセットは常に空になります。

Iterator i = keysSet.iterator();   
    while (i.hasNext()) { 
     SelectionKey key = (SelectionKey) i.next(); 
    } 
    if (key.isReadable()) { 
     //read and do something 
    } 
} 

これもコンパイルされませんが、キーに「読み取り」のチェックはしばらくの間、ブロック内で行わなければなりません。

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

2つの問題：これが行われる前に、チャネルが非ブロックモードに設定する必要があり、あなたは、キーは、あなたが選択を実行するたびに返される場合を除き、SelectionKey.OP_WRITEを設定するべきではありません。

実際に書き込みを行う予定がある場合は、SelectionKey.OP_WRITEを設定する必要があります。

最後に、ここで2つのスレッドを使用することは非常に慣習的ではありません。これを行うには、ServerSocketChannelをセレクタにOP_ACCEPTで登録し、読み込み/書き込みと同じスレッドでServerSocketでacceptを実行します。