回调在NIO.2库中的行为

Question

我正在构建一个小型客户机/服务器聊天应用程序。在尝试使用经典的NIO.2库来模拟它之后，我遇到了NIO。

我用分类器NIO对NIO.2库进行了“模拟”，目的是在通过ArrayBlockingQueue成对连接的多个线程中使用多个选择器，以避免网络读写时间。

我的问题是，如何使用AsynchronousSocketChannels和CompletionHandlers同时处理NIO.2库中的多个事件(根据我的理解，这是回调)？

经典的NIO库使用Selectors，它在select调用key set之后交付。然后可以迭代这个key set，并且可以一个接一个地处理每个事件(读、接受和写)。

另一方面，NIO.2回调没有这样的序列。他们是异步的。那么，如果两个客户端同时向服务器发送一条消息，会发生什么情况呢？

那么两个回调同时运行吗？如果是，那怎么做？它们是否在单独的线程中运行？

如果我从每个回调中获取这些消息，并试图像前面提到的ArrayBlockingQueue那样将它们排队，那么它们是否会等待对方呢？

Answer 1

那么，如果两个客户端同时向服务器发送一条消息，会发生什么情况呢？

客户端不与服务器共享公共连接。服务器端，您将使用回调调用两个客户端的AsynchronousSocketChannel#read，这将在一些字节到达时触发。

因此，两个回调可以同时运行(因为它们是异步的)，但是它们对于每个客户机仍然是独立的，所以不会出现问题。

它们是否在单独的线程中运行？

这取决于后台AsynchronousChannelGroup的线程池(您可以自己指定或使用默认组)。

我用NIO.2创建了一个简单的网络库，我认为它可以帮助您：https://github.com/jhg023/SimpleNet