c++ - 了解TCP中的kqueue

我正在关注有关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

我不明白：

我是否可以设置nevents = BACKLOG，即并发连接数？如果没有，事件应该是什么？
为什么我要检查event_list[i].flags & EV_EOF？我最好的猜测是，如果套接字坐在队列中时连接失败，那么我想从队列中删除该套接字吗？但是，为什么我要再次打电话给kevent？
在与上一点相同的部分中，我称为close(fd)。那是对的吗？伊拉德曼教程有一些额外的巫术，但我不明白为什么。
如果我理解正确，当我准备阅读部分消息时，kqueue可能会返回。我怎么知道消息何时完成？

如果相关，我正在使用OSX。

最佳答案

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

没有。

不需要BACKLOG == nevents。

您可以一次或一次从队列中挑选事件，这主要取决于您的喜好并最大程度地减少系统调用与内存/堆栈空间之间的关系。

也很少会让所有连接同时触发事件...花费这么多内存没有真正意义-特别是当您考虑大量并发时，可能意味着大内存可能会导致高速缓存未命中并可能导致性能下降。
EV_EOF

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

这意味着您必须指定一个可能引发此标志的过滤器。那是什么过滤器？您在听这些事件吗？

您可以在man page中找到这些

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

我个人认为，当write失败而不是引发事件时，可以检查这些极端情况。
调用close是合理的...确实取决于您想要什么。我可能只保留连接以读取数据。或调用shutdown，因为它被认为更礼貌（但这些天可能并不重要）。
你不知道这与TCP / IP无关。

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

TCP / IP层包装数据包。在野外，这些通常限制为1500个字节，并且互联网的许多部分都运行在576个字节上。您可以在MTU上搜索更多信息。

边注：

您可能想将新客户端添加到kqueue。
我会考虑在每个周期重置nchanges值。

关于c++ - 了解TCP中的kqueue，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/43745430/

Kqueue

c++ - 了解TCP中的kqueue