0

我有以下情况：

  • 服务器打开一个 ServerSocketChannel 并接受客户端连接。
  • 每个连接（socketA）都在一个新线程中处理。
  • 在线程内部，我打开一个新的 SocketChannel (socketB)，它连接另一台服务器。
  • 原来的客户端连接（socketA）此时处于空闲状态。
  • 新的 SocketChannel 从服务器读取数据（阻塞）。

现在我中断线程。我预计 socketB 将被中断并关闭，而 socketA 将继续工作。不幸的是socketA也会被中断。

知道可能是什么问题吗？

我使用以下测试方法来重现该行为：

private void testServerSocket() throws IOException, InterruptedException
{
    final InetSocketAddress     address         = new InetSocketAddress( "localhost", 12345 );
    final ServerSocketChannel   serverChannel   = ServerSocketChannel.open();
    serverChannel.socket().bind( address );

    final SocketChannel socketChannel   = serverChannel.accept();

    // start communication in new thread
    final Thread    thread  = new Thread( new Runnable() { @Override public void run() { testWrite( socketChannel ); } } );

    thread.start();

    // wait a little bit
    Thread.sleep( 5000 );

    // interrupt thread, will interrupt the socketChannel.read in testRead()
    thread.interrupt();
    thread.join();

    socketChannel.close();
    serverChannel.close();
}

void testWrite( SocketChannel socketA )
{
    try
    {
        // write to client
        socketA.write( ByteBuffer.wrap( "0123456789".getBytes() ) );

        // open new socket to another server
        testRead();

        // throws ClosedByInterruptException
        socketA.write( ByteBuffer.wrap( "0123456789".getBytes() ) );
    }
    catch( final IOException e )
    {
        e.printStackTrace();
    }
}

void testRead()
{
    try
    {
        final InetSocketAddress address   = new InetSocketAddress( "localhost", 12346 );
        final SocketChannel     socketB   = SocketChannel.open( address );

        // server doesn't send, so this call will block and interrupted 
        socketB.read( ByteBuffer.wrap( new byte[10] ) );

        socketB.close();
    }
    catch( final IOException e )
    {
        e.printStackTrace();
    }
}
4

1 回答 1

1

您需要通过在inThread.interrupted()之后调用来清除线程的中断状态。实际上，您应该在那里抓到并做。否则，这种情况仍然存在并且也会中断写入。IOExceptiontestRead()ClosedByInterruptException

于 2012-12-17T12:13:47.877 回答