JavaNIO:ServerSocketCannel接受套接字请求，客户端接收接受，但服务器不记录接受

Question

我正在尝试基于非阻塞NIO消息开发自己的通信库。我已经阅读了1000篇关于它的教程和书中的章节，我认为最后我有了一些可以在几乎没有同时连接的情况下工作的东西。但是当我在服务器端有很多连接共存时，我遇到了一些问题。

我有4个私有方法的典型选择器实现：accept、finishConnect、read和write。我的问题在于前两个：接受和完成连接。

当客户端打开一个新的套接字，并且一个可接受的键唤醒选择器时，将执行以下代码。

private void accept(SelectionKey key) {
    try {
        ServerSocketChannel ssc = (ServerSocketChannel) key.channel();
        SocketChannel sc = ssc.accept();
        sc.configureBlocking(false);
        LOGGER.debug("Socket " + sc.hashCode() + "-" + sc.socket().toString() + " connexion completed");
        changeInterest(sc, SelectionKey.OP_READ);
        eventManager.addEvent(new ConnectionEstablished(sc));
    } catch (Throwable e) {
        NIOException ne = new NIOException(NIOException.ErrorType.ACCEPTING_CONNECTION, e);
        eventManager.addEvent(new ErrorEvent(null, ne));
    }
}

在客户端，我有一个连接方法的实现，一旦服务器处理其可接受的套接字密钥，就会调用该方法。

private void finishConnect(SelectionKey key) {
    SocketChannel sc = (SocketChannel) key.channel();
    try {
        if (sc.finishConnect()) {
            eventManager.addEvent(new ConnectionEstablished(sc));
            LOGGER.debug("Socket " + sc.hashCode() + "-" + sc.socket().toString() + " connection finished");
        } else {
            LOGGER.debug("REFUSED " + sc + " - " + sc.socket().toString());
            refusedConnection(sc, null);
            key.cancel();
        }
    } catch (Exception e) {
        refusedConnection(sc, e);
        key.cancel();
    }
}

问题是，当我创建一些被接受的连接时，客户端执行finishConnect消息（我可以看到使用的端口建立的套接字连接）。但是我在服务器端找不到这个连接接受，没有使用这些端口的连接完成日志消息！！

我怀疑ssc之间可能会出现异常。accept（）和日志调用，所以我添加了一些额外的日志消息，以检查哪个指令正在破坏所有内容。对于进入accept方法的所有键，序列都已完成。

如果我甚至看不到日志上的任何错误消息，这怎么可能呢？

编辑：我对一次打开的套接字的数量做了一些测试。当客户端开始运行时，服务器上只有一个openSocket：服务器套接字。之后，它有多达200个同时打开的套接字，在客户端执行结束时，服务器会回到1个打开的套接字。我想它们永远不会被计算在内

到目前为止，我已经做了一个变通方法，可以监控节点上共存连接的数量，并延迟新连接的接受，直到该数量减少到给定的阈值。然而，我想知道出了什么问题。

谢谢你的帮助。

Answer 1

正如EJP所说，问题出在待办事项队列上。我使用bind（SocketAddress local）方法绑定ServerSocketChannel。

当套接字请求到达JVM时，它会进入待办事项队列，并在那里等待，直到侦听器触发接受相应密钥的过程。实际问题在于这个队列的大小，使用bind方法，它最多可以存储50个连接。

当连接请求达到峰值时，队列会出现溢出，其中一些请求会丢失。为了避免这种情况发生，方法bind（SocketAddress local，int backlog）允许更改队列的容量并增加它。

另一方面，在非阻塞模式下工作时，客户端节点上的选择器不需要接受连接来处理OP_CONNECT密钥。接收SYN-ACK TCP消息将触发选择器中的相应键。

Answer 2

由于积压工作队列的存在，在执行accept（）之前完成大量客户机连接是完全合适的。所以这里没有需要解决的实际问题。

但是您是否执行过accept（）方法？这就是你需要调查的问题。