gpt4 book ai didi

java - java nio ServerSocketChannel accept 如何工作?

转载 作者:塔克拉玛干 更新时间:2023-11-01 22:44:26 28 4
gpt4 key购买 nike

我不明白 NIO 是如何工作的。这是一个示例代码:

// Create the server socket channel
ServerSocketChannel server = ServerSocketChannel.open();
// nonblocking I/O
server.configureBlocking(false);
// host-port 8000
server.socket().bind(new java.net.InetSocketAddress(host,8000));

// Create the selector
Selector selector = Selector.open();
// Recording server to selector (type OP_ACCEPT)
server.register(selector,SelectionKey.OP_ACCEPT);

while (true) {
selector.select(); // blocking operation
Iterator it = selector.selectedKeys().iterator();
while (it.hasNext()) {
SelectionKey selKey = (SelectionKey) it.next();

// THE MOST INTRIGUING PART HERE!!!
if (selKey.isAcceptable()) {
ServerSocketChannel ssChannel = (ServerSocketChannel) selKey.channel();
SocketChannel sc = ssChannel.accept();
}
it.remove();
}
}

这里我有几个问题:

  1. selKey.channel() 返回一个 ServerSocketChannel 是否与我们在开始时使用 ServerSocketChannel.open() 创建的 channel 完全相同?如果不是,那是什么?
  2. 更重要的问题:在大多数其他教程中 selKey.channel();步骤被跳过,他们只使用 SocketChannel client = server.accept();例如这里:http://www.onjava.com/pub/a/onjava/2002/09/04/nio.html?page=2在这里:http://www.developer.com/java/article.php/10922_3837316_2/Non-Blocking-IO-Made-Possible-in-Java.htm那么,server.accept() 如何知道我们处理的当前 key ?
  3. http://www.developer.com/java/article.php/10922_3837316_2/Non-Blocking-IO-Made-Possible-in-Java.htm他们甚至建议在新线程中接受 channel 。我猜想有可能会出现下面的情况。

    key1 someClient1 acceptable
    key2 someClient2 not acceptable
    key3 someClient3 acceptable

    startThread1
    startThread3

    scheduler decides to give time to thread3 instead of thread1

    thread3 -> socket.accept() <- actually accepts client1
    thread1 -> socket.accept() <- actually accepts client3

那么,您能否解释一下选择器如何与 ServerSocketChannel 和 accept 方法一起工作?因为我不明白#accept 接受客户的顺序以及这个顺序与 selectedKeys 有何关系。

  1. 我可以简单地执行以下操作吗:

    int availableClients = 0;
    while (it.hasNext()) {
    SelectionKey selKey = (SelectionKey) it.next();

    if (selKey.isAcceptable()) {
    ++availableClients;
    }
    it.remove();
    }
    for (int i = 0; i < availableClients; ++i) {
    SocketChannel sc = server.accept();
    doSomething(sc);
    }

最佳答案

selKey.channel() return a ServerSocketChannel is it exactly the same channel we created in the beginning with ServerSocketChannel.open()?

是的。

More important question: in most other tutorials selKey.channel(); step is skipped and they simply use SocketChannel client = server.accept(); For example here: http://www.onjava.com/pub/a/onjava/2002/09/04/nio.html?page=2 and here: http://www.developer.com/java/article.php/10922_3837316_2/Non-Blocking-IO-Made-Possible-in-Java.htm So, how does server.accept() knows about current key we process?

事实并非如此。他们假设只有一个 ServerSocketChannel。你的方式更好:它更通用。

In http://www.developer.com/java/article.php/10922_3837316_2/Non-Blocking-IO-Made-Possible-in-Java.htm they even suggest to accept channel in new thread.

我不知道为什么。这是一个非阻塞调用。它会立即返回。这个建议毫无意义。忽略它。这是六年前质量很差的教程,但十三年前就有更好的教程了。试试 Oracle 教程。这个的作者好像一点都不明白非阻塞模式的意义。为每个事件使用单独的线程的建议是完全荒谬的。他也不明白如何使用 OP_WRITE。他对 cancel() 做出了错误的断言。我可以继续。他是否执行过这段代码值得怀疑:他当然没有以任何方式调查它的行为。如何编写不可扩展的 NIO 服务器。相当了不起。

I guess it is possible that the following situation may occur.

我什至不明白为什么您会同时在两个线程中接受,更不用说它接受哪个客户端对任一线程来说可能很重要了。这是在不存在的情况下发明的困难。

So, could you please explain how selector works in pair with ServerSocketChannel and accept method? Because I don't understand in which order #accept accepts clients and how this order related to selectedKeys.

accept() 方法返回积压队列中的下一个套接字,只要积压队列非空,OP_ACCEPT 就会触发。它非常简单,没有神秘感。该订单根本不“与选定的键相关”。所选键是 ServerSocketChannel 的键。

编辑:看来你有一个重大的误解。考虑:

  1. 您为 OP_ACCEPT 创建并注册了一个 ServerSocketChannel
  2. 两个客户端同时连接。
  3. 现在只有一个 SelectionKey 存在,因此在选定键集中只有一个:ServerSocketChannel
  4. 然后您在该键上处理您的 isAcceptable() 案例;接受一个或两个连接;为 OP_READ.
  5. 注册这些 channel
  6. 现在存在三个选择键,并且不在选定键集中,因为您清除了它。
  7. 两个客户端都发送了一些数据。
  8. 现在您有两个选择键可以在选定键集中读取。

好吗?

Can I simply do the following:

当然可以,但是为什么呢?将简单的事情复杂化并没有什么好处。按照第一种方式进行。

关于java - java nio ServerSocketChannel accept 如何工作?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/28441151/

28 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com