java.nio.channels.ServerSocketChannel未正确关闭

Question

我有一个java.nio.channels.ServerSocketChannel，我初步推荐如下：

while(true)
{
    ServerSocketChannel channel = ServerSocketChannel.open();
    InetSocketAddress serverSocket = new InetSocketAddress(host,port);
    channel.bind(serverSocket);
    SocketChannel ch = channel.accept();

    // Later on when I have read off data from a client, I want to shut this 
    // connection down and restart listening.
    channel.socket().close(); //Just trying to close the associated socket 
    // too because earlier approaches failed
    channel.close();
}

当我从客户端发送第一条消息时，它成功传送到服务器并退出客户端程序。然后麻烦开始了。当我再次初始化客户端并尝试在第一次建立与服务器相同的端口和地址时，我得到了一个

java.net.BindException：地址已在使用中：connect

异常，即使我关闭了相关的通道/套接字。我一直在更新ServerSocketChannel和InetSocketAddressobjects，因为我的客户端实例必须在写入后关闭，我必须脱离该通道，因为我不能在它关闭后重用一个通道，我必须每次都创建一个新对象。我的理论是因为每次重新分配channel引用，孤立对象变成GC肉，但由于close（）方法显然不能正常工作，因此通道仍处于活动状态，直到GC收集它，我的端口才会被占用。尽管如此，我尝试在while循环之前保持ServerSocketChannel和InetSocketAddress对象的初始化，但是这没有帮助，并且在第一次写入之后发生了同样的异常，就像之前一样。

 ServerSocketChannel channel = ServerSocketChannel.open();
 InetSocketAddress serverSocket = new InetSocketAddress(host,port);
 channel.bind(serverSocket);

 while (true)
 {
    SocketChannel ch = channel.accept();
    //read from a client
 }

为清楚起见，这是我从客户端连接的方式：

        SocketChannel ch=SocketChannel.open();
        ch.bind(new InetSocketAddress("localhost", 8077));
        InetSocketAddress address=new InetSocketAddress("localhost",8079);
                    //the address and port of the server
        System.out.print(ch.connect(address));
        ByteBuffer buf=ByteBuffer.allocate(48);
        buf.clear();
        buf.put("Hellooooooooooooooooooooooooo".getBytes());
        buf.flip();
        while(buf.hasRemaining()) {
            ch.write(buf);
        }
        ch.close();

Answer 1

另一答案

Answer 2

另一答案