AsynchronousServerSocketChannelが確立された接続をクローズしない

Question

AsynchronousServerSocketChannelを使用してリスナーを実装しました。チャネルを開き、ポートにバインドして接続を受け入れます。私はメッセージを聞いて読むことができます。リスナーがデータを受け入れているチャネルを閉じた後の問題イベント。

次のようにサーバーチャネルのソケット接続を閉じます。ここで

this.serverChannel.close(); 
this.serverChannel = null; 

は接続

this.serverChannel 
       .accept(null, 
         new java.nio.channels.CompletionHandler<AsynchronousSocketChannel, Void>() { 

          @Override 
          public void completed(
            AsynchronousSocketChannel result, 
            Void attachment) { 
           acceptConnections(); 
           read(new HSLParsingContext(), result); 
          } 

          @Override 
          public void failed(Throwable exc, Void attachment) { 
           if (!(exc instanceof AsynchronousCloseException)) 

         }); 

public void read(final HSLParsingContext context, 
      final AsynchronousSocketChannel channel) { 

     try { 

      channel.read(context.buffer, null, 
        new java.nio.channels.CompletionHandler<Integer, Void>() { 

         @Override 
         public void completed(Integer bytesRead, Void attachment) { 
          try { 
           HSLSysLogTcpListener.this.logger.infoFmt(
             "Bytes received: %s ", bytesRead); 
           if (bytesRead > 0) { 
            messageHandler(context, false); 
           } 

           if (bytesRead == -1) { 
            // when nothing is there to read in the 
            // channel make sure there 
            // is nothing in the content buffer before 
            // closing the channel 
            if (context.content.length() > 0) { 
             messageHandler(context, true); 
            } 
            throw new EOFException(); 
           } 

           // keep reading data asynchronously 
           read(context, channel); 
          } catch (Exception e) { 
           failed(e, null); 
          } 
         } 

         @Override 
         public void failed(Throwable e, Void attachment) { 
          logReadFailureAndClose(channel, e); 
         } 
        }); 
     } catch (Throwable e) { 
      logReadFailureAndClose(channel, e); 
     } 

私は一種のacceptメソッドによって開かよりAsynchronousSocketChannelが閉じていないと感じるの受け入れを完了ハンドラです。したがって、私はAsynchronousServerSocketChannelを閉じた後にmessagesイベントを受け取ります。

はserversocketchannel.Pleaseを閉じているときに、私は完全にAsynchronousServerSocketChannelを停止した最高のを知っていると、それはAsynchronousSocketChannel

Answer 1

asscoiated AsynchronousSocketChannelを閉鎖する方法としてあるの確立された接続に

Iを閉じていない

AsynchronousServerSocketChannel同意する。それはしません。それはそれを意味するものではありません。サーバーソケットチャネルを閉じて、他のものを閉じる必要はありません。

受け入れられたソケットを閉じるには、自分で閉じなければなりません。あなたが投稿していないlogReadFailureAndClose()に近いことが起こるか、起こるはずです。サーバーソケットチャンネルを閉じることは、それとは関係ありません。同時にすべてを閉じるには、受け入れられたソケットの最新リストが必要であり、サーバーソケットチャネルを閉じるときにそれらをすべて閉じます。