了解 TCP 中的 kqueue

Question

我正在关注关于 kqueue 的教程（特别是 http://eradman.com/posts/kqueue-tcp.html 和 https://wiki.netbsd.org/tutorials/kqueue_tutorial/），有些部分我不明白。这是我的（编辑过的）代码：

// 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 = BACKLOG 即并发连接数是否正确？如果不是，应该是什么？

2. 为什么要检查event_list[i].flags & EV_EOF？我最好的猜测是，如果套接字位于队列中时连接失败，那么我想从队列中删除该套接字？但是为什么我又要调用 kevent 呢？

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

4. 如果我理解正确，当我准备好阅读部分消息时，kqueue 可能会返回。我如何知道消息何时完成？

如果相关，我正在使用 OS X。

Answer 1

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

1. 没有。

   不要求BACKLOG == nevents。

   您可以一次从队列中选择一个或数十个事件，这主要取决于您的偏好，并最大限度地减少系统调用与内存/堆栈空间。

   您也不会经常让所有连接同时触发事件...花费那么多内存没有实际意义 - 特别是当您考虑大并发时，可能意味着大内存可能导致缓存未命中并可能导致性能惩罚。

2. EV_EOF

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

   这意味着您必须指定一个可能引发此标志的过滤器。哪些过滤器可以做到这一点？您正在收听这些事件吗？

   你可以在man page找到这些

   在套接字中的一个示例是，当客户端断开read 容量但保留套接字的write 容量时。然后，EVFILT_WRITE 过滤器（如果设置）将调用 EV_EOF 标志。

   我个人认为，当write 失败而不是引发事件时，可以检查这些边缘情况。

3. 调用close 是合理的......真的取决于你想要什么。我可能只为了读取数据而保持连接。或者调用shutdown，因为它被认为更礼貌（但现在可能没那么重要了）。

4. 你没有。这不是 TCP/IP 问题。

   消息包装应由正在实施的协议（即 Websockets / HTTP）执行。每个协议都有不同的消息包装/完成设计。

   TCP/IP 层封装数据包。在野外，这些通常限制为 1500 字节，互联网的许多部分运行在 576 字节上。您可以谷歌 MTU 了解更多信息。

旁注：

• 您可能希望将新客户端添加到kqueue。

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