gpt4 book ai didi

c++ - 了解 TCP 中的 kqueue

转载 作者:行者123 更新时间:2023-11-28 01:49:03 25 4
gpt4 key购买 nike

我正在学习有关 kqueue 的教程(特别是 http://eradman.com/posts/kqueue-tcp.htmlhttps://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 即并发连接数是否正确?如果不是,nevents 应该是什么?

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

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

  4. 如果我理解正确,kqueue 可以在我准备好读取部分消息时返回。我怎么知道消息何时完成?

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

最佳答案

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

  1. 没有。

    没有要求 BACKLOG == nevents

    您可以一次从队列中挑选一个或几十个事件,这主要取决于您的偏好,并尽量减少系统调用与内存/堆栈空间。

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

  2. EV_EOF

    Filters may set this flag to indicate filter-specific EOF condition

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

    您可以在 man page 中找到这些

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

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

  3. 调用 close 是合理的...实际上取决于您想要什么。我可能保持连接只是为了读取数据。或者调用 shutdown ,因为它被认为更有礼貌(但现在可能并不那么重要)。

  4. 你不知道。这不是 TCP/IP 问题。

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

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

旁注:

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

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

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

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com