NIO Server 无法监听客户端

Question

您好，我正在尝试实现一个简单的 Java NIO 服务器；它将 socketChannel 注册到选择器。因此，我希望听取客户的意见并发送一些回复。 socketChannel注册到selector后，即使client(non NIO)发送了一些数据，Server也无法读取；但是生成的密钥仍在迭代中。

详细视图：服务器端：

**First thread**:

公共无效运行（）{ 而（真）{

    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");

注意：在单线程中完成时，相同的程序可以工作，但是以上述方式实现时会导致它不听客户端。 请帮我解决这个问题。

Answer 1

从另一个线程读取作品，这是您的代码明显的问题。

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

这里你从迭代器中获取键集，但是没有代码在选择器上执行 select() 或 selectNow()，所以这个集总是空的。

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

这甚至无法编译，必须在 while 块内完成对键的“读取”检查。

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

两个问题：在完成之前应该将通道设置为非阻塞模式，并且不应该设置 SelectionKey.OP_WRITE，除非您希望每次运行选择时都返回键。

如果你真的打算写，你应该只设置 SelectionKey.OP_WRITE。

最后，这里使用两个线程是非常规的。这样做的推荐方法是使用 OP_ACCEPT 将 ServerSocketChannel 注册到 Selector，并在与读/写相同的线程上运行 ServerSocket 上的接受。

Answer 2

很难看出你在那里做了什么，但看起来你标记为“第二个线程”的东西被两个线程使用（在实现Runnable/扩展Thread和实际线程时有些混淆？ ）。特别是，我猜测new Listener 构造并启动了一个线程。然后您在第一个线程中调用addSocketChannel。因此，存在竞争条件。

另外，将selector 设为静态也是一个糟糕的主意。