为什么总是5个连接没有附加程序？

我已经尝试使用以下参数重复您的问题：

1. 服务器使用epoll来管理连接。
2. 我做了3000个连接。
3. 连接被阻塞。
4. 服务器基本上被简化为仅处理连接，并且执行非常复杂的工作。

我不能重复这个问题。 这是我的服务器源代码。

 #include <stddef.h> #include <stdint.h> #include <stdbool.h> #include <stdlib.h> #include <stdio.h> #include <errno.h> #include <netdb.h> #include <sys/types.h> #include <sys/socket.h> #include <sys/epoll.h> #include <err.h> #include <sysexits.h> #include <string.h> #include <unistd.h> struct { int numfds; int numevents; struct epoll_event *events; } connections = { 0, 0, NULL }; static int create_srv_socket(const char *port) { int fd = -1; int rc; struct addrinfo *ai = NULL, hints; memset(&hints, 0, sizeof(hints)); hints.ai_flags = AI_PASSIVE; if ((rc = getaddrinfo(NULL, port, &hints, &ai)) != 0) errx(EX_UNAVAILABLE, "Cannot create socket: %s", gai_strerror(rc)); if ((fd = socket(ai->ai_family, ai->ai_socktype, ai->ai_protocol)) < 0) err(EX_OSERR, "Cannot create socket"); if (bind(fd, ai->ai_addr, ai->ai_addrlen) < 0) err(EX_OSERR, "Cannot bind to socket"); rc = 1; if (setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &rc, sizeof(rc)) < 0) err(EX_OSERR, "Cannot setup socket options"); if (listen(fd, 25) < 0) err(EX_OSERR, "Cannot setup listen length on socket"); return fd; } static int create_epoll(void) { int fd; if ((fd = epoll_create1(0)) < 0) err(EX_OSERR, "Cannot create epoll"); return fd; } static bool epoll_join(int epollfd, int fd, int events) { struct epoll_event ev; ev.events = events; ev.data.fd = fd; if ((connections.numfds+1) >= connections.numevents) { connections.numevents+=1024; connections.events = realloc(connections.events, sizeof(connections.events)*connections.numevents); if (!connections.events) err(EX_OSERR, "Cannot allocate memory for events list"); } if (epoll_ctl(epollfd, EPOLL_CTL_ADD, fd, &ev) < 0) { warn("Cannot add socket to epoll set"); return false; } connections.numfds++; return true; } static void epoll_leave(int epollfd, int fd) { if (epoll_ctl(epollfd, EPOLL_CTL_DEL, fd, NULL) < 0) err(EX_OSERR, "Could not remove entry from epoll set"); connections.numfds--; } static void cleanup_old_events(void) { if ((connections.numevents - 1024) > connections.numfds) { connections.numevents -= 1024; connections.events = realloc(connections.events, sizeof(connections.events)*connections.numevents); } } static void disconnect(int fd) { shutdown(fd, SHUT_RDWR); close(fd); return; } static bool read_and_reply(int fd) { char buf[128]; int rc; memset(buf, 0, sizeof(buf)); if ((rc = recv(fd, buf, sizeof(buf), 0)) <= 0) { rc ? warn("Cannot read from socket") : 1; return false; } if (send(fd, buf, rc, MSG_NOSIGNAL) < 0) { warn("Cannot send to socket"); return false; } return true; } int main() { int srv = create_srv_socket("8558"); int ep = create_epoll(); int rc = -1; struct epoll_event *ev = NULL; if (!epoll_join(ep, srv, EPOLLIN)) err(EX_OSERR, "server cannot join epollfd"); while (1) { int i, cli; rc = epoll_wait(ep, connections.events, connections.numfds, -1); if (rc < 0 && errno == EINTR) continue; else if (rc < 0) err(EX_OSERR, "Cannot properly perform epoll wait"); for (i=0; i < rc; i++) { ev = &connections.events[i]; if (ev->data.fd != srv) { if (ev->events & EPOLLIN) { if (!read_and_reply(ev->data.fd)) { epoll_leave(ep, ev->data.fd); disconnect(ev->data.fd); } } if (ev->events & EPOLLERR || ev->events & EPOLLHUP) { if (ev->events & EPOLLERR) warn("Error in in fd: %d", ev->data.fd); else warn("Closing disconnected fd: %d", ev->data.fd); epoll_leave(ep, ev->data.fd); disconnect(ev->data.fd); } } else { if (ev->events & EPOLLIN) { if ((cli = accept(srv, NULL, 0)) < 0) { warn("Could not add socket"); continue; } epoll_join(ep, cli, EPOLLIN); } if (ev->events & EPOLLERR || ev->events & EPOLLHUP) err(EX_OSERR, "server FD has failed", ev->data.fd); } } cleanup_old_events(); } } 

这里是客户端：

 from socket import * import time scks = list() for i in range(0, 3000): s = socket(AF_INET, SOCK_STREAM) s.connect(("localhost", 8558)) scks.append(s) time.sleep(600) 

在本地机器上运行时，我得到了使用端口8558（1个监听，3000个客户端插座和3000个服务器端插座）的6001个插座。

 $ ss -ant | grep 8558 | wc -l 6001 

当检查客户端连接的IP连接数时，我得到3000。

 # lsof -p$(pgrep python) | grep IPv4 | wc -l 3000 

我也尝试了与远程机器上的服务器测试成功。

我建议你试着去做。

另外尝试完全关闭iptables，以防万一它的一些连接跟踪怪癖。 有时/proc的iptables选项也可以帮助你。 所以试试sysctl -w net.netfilter.nf_conntrack_tcp_be_liberal=1 。

编辑：我做了另一个测试，产生你在你身边看到的输出。 你的问题是你正在关闭服务器端的连接。

我可以复制类似于您所看到的执行以下操作的结果：

• 在读取一些数据到我的服务器后，调用shutdown(fd, SHUT_RD) 。
• send(fd, buf, sizeof(buf))在服务器上send(fd, buf, sizeof(buf)) 。

这样做后，可以看到以下行为。

• 在客户端，我得到了3000个连接在netstat / ss中用ESTABLISHED打开。
• 在lsof输出中，我得到了2880（我是如何关机的）性质。
• 其余的连接lsof -i:8558 | grep -v ES lsof -i:8558 | grep -v ES在CLOSE_WAIT中。

这只发生在半关机连接上。

因此，我怀疑这是您的客户端或服务器程序中的一个错误。 您要么发送一些东西到服务器所反对的服务器上，要么服务器因某种原因无效地关闭连接。

你需要确认什么状态的“异常”连接（如close_wait或其他）。

在这个阶段，我也认为这是一个编程问题，并不属于serverfault。 没有看到客户/服务器的相关部分来源，任何人都不可能找出故障的原因。 尽管我非常有信心，但这与操作系统处理连接的方式无关。