了解TCP中的Kqueue

Question

我正在遵循有关Kqueue的教程(特别是http://eradman.com/posts/kqueue-tcp.html和https://wiki.netbsd.org/tutorials/kqueue_tutororial/(，我不明白一些部分。这是我的(编辑(代码：

// assume internal_socket is listening
void run_server(int internal_socket) {
    const int nchanges = 1;
    const int nevents = BACKLOG;
    struct kevent change_list[nchanges];
    struct kevent event_list[nevents];
    int kq = kqueue();
    if (kq == -1) {
        // error
    }
    EV_SET(&change_list, sock_internal, EVFILT_READ, EV_ADD, 0, 0, 0);
    while (true) {
        int nev = kevent(kq, change_list, nchanges, event_list, nevents, NULL);
        if (nev == -1) {
            // error
        }
        for (int i = 0; i < nev; ++i) {
            if (event_list[i].flags & EV_EOF) {
                int fd = event_list[i].ident;
                EV_SET(&change_list, fd, EVFILT_READ, EV_DELETE, 0, 0, NULL);
                if (kevent(kq, &change_list, nchanges, NULL, 0, NULL) == -1) {
                    // error
                }
                close(fd);
            } else if (event_list[i].ident == sock_internal) {
                int fd = accept(event_list[i].ident, ...);
                // do stuff
            } else if (event_list[i].flags == EVFILT_READ) {
                int bytes_read = recv(event_list[i].ident, ...);
                // do stuff
            }
        } // for
    } // while (true)
} // func

我不明白：

1. 我是否可以设置nevents =积压的权利，即并发连接的数量？如果不是，那么Nevents应该是什么？

2. 为什么要检查event_list[i].flags & EV_EOF？我最好的猜测是，如果插座坐在队列中时，连接失败，那么我想从队列中删除该插座？但是为什么我再次致电Kevent？

3. 在与上一点的同一部分中，我致电close(fd)。那是对的吗？Eradman教程有一些额外的巫术，但我不明白为什么。

4. 如果我正确理解，当我准备阅读部分消息时，Kqueue可以返回。我怎么知道消息何时完成？

，如果它相关，我正在处理OSX。

Answer 1

关于代码/问题的快速思考：

1. no。

   不需要BACKLOG == nevents。

   您可以一次从一个队列中选择一个事件，或者一次一次从一个队列中选择，这主要是关于您的偏好和最小化系统调用与内存/堆栈空间的最小化。

   也不是很少有所有连接同时发射事件...花费太多的记忆并没有真正的意义 - 尤其是当您考虑较大的并发时，可能意味着大记忆可能会导致cache遗漏，甚至可能发生。绩效处罚。

2. ev_eof

   过滤器可能会设置此标志以指示特定于滤波器的EOF条件

   这意味着您必须指定可能会升高此标志的过滤器。哪个过滤器？这些事件您正在听吗？

   您可以在man页面

   中找到这些

   插座中的一个示例是客户端断开read容量的连接，但将插座的write容量留在原位时。比，EVFILT_WRITE过滤器(如果设置(将调用EV_EOF标志。

   就我个人认为，当write失败而不是举起事件时，我认为可以检查这些边缘案例。

3. 调用close是合理的...真的取决于您想要的。我可能只能保持连接以读取数据。或者也许是调用shutdown，因为它被认为更有礼貌(但现在可能没关系(。

4. 你不这样做。这不是TCP/IP问题。

   消息包装应通过正在实现的协议(即Websockets/http(执行。每个协议都有不同的消息包装/完成设计。

   TCP/IP层包装数据包。在野外，这些通常仅限于1500个字节，而互联网的许多部分则以576个字节运行。您可以使用Google MTU以获取更多信息。

侧音：

• 您可能想将新客户添加到kqueue。

• 我将考虑每个周期重置nchanges值。