- VisualStudio2022插件的安装及使用-编程手把手系列文章
- pprof-在现网场景怎么用
- C#实现的下拉多选框,下拉多选树,多级节点
- 【学习笔记】基础数据结构:猫树
一直听说epoll的饥饿场景,但是从未在实际环境中面对过,那么能不能模拟出来呢?实际的情况是怎样呢?
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <fcntl.h>
#include <sys/epoll.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#define MAX_EVENTS 1024
#define LISTEN_BACKLOG 10
int epoll_fd;
void do_read(int fd);
int main() {
int server_fd, nfds, i;
struct epoll_event event, events[MAX_EVENTS];
struct sockaddr_in server_addr, client_addr;
socklen_t client_addr_len = sizeof(client_addr);
int client_fd;
// 创建 socket
server_fd = socket(AF_INET, SOCK_STREAM, 0);
if (server_fd == -1) {
perror("socket");
return 1;
}
// 设置 socket 选项
int opt = 1;
if (setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt)) == -1) {
perror("setsockopt");
close(server_fd);
return 1;
}
// 绑定 socket
memset(&server_addr, 0, sizeof(server_addr));
server_addr.sin_family = AF_INET;
server_addr.sin_addr.s_addr = INADDR_ANY;
server_addr.sin_port = htons(8080);
if (bind(server_fd, (struct sockaddr *)&server_addr, sizeof(server_addr)) == -1) {
perror("bind");
close(server_fd);
return 1;
}
// 监听 socket
if (listen(server_fd, LISTEN_BACKLOG) == -1) {
perror("listen");
close(server_fd);
return 1;
}
// 创建 epoll 实例
epoll_fd = epoll_create1(0);
if (epoll_fd == -1) {
perror("epoll_create1");
close(server_fd);
return 1;
}
// 注册服务器 socket
event.events = EPOLLIN;
event.data.fd = server_fd;
if (epoll_ctl(epoll_fd, EPOLL_CTL_ADD, server_fd, &event) == -1) {
perror("epoll_ctl");
close(server_fd);
close(epoll_fd);
return 1;
}
printf("Server listening on port 8080...\n");
while (1) {
// 等待事件就绪
nfds = epoll_wait(epoll_fd, events, MAX_EVENTS, -1);
if (nfds == -1) {
perror("epoll_wait");
close(server_fd);
close(epoll_fd);
return 1;
}
// 处理就绪事件
for (i = 0; i < nfds; i++) {
if (events[i].data.fd == server_fd) {
// 接受新连接
client_fd = accept(server_fd, (struct sockaddr *)&client_addr, &client_addr_len);
if (client_fd == -1) {
perror("accept");
continue;
}
if (fcntl(client_fd , F_SETFL, O_NONBLOCK) == -1) {
perror("fcntl");
close(client_fd);
continue;
}
// 注册客户端 socket
event.events = EPOLLIN;
event.data.fd = client_fd;
if (epoll_ctl(epoll_fd, EPOLL_CTL_ADD, client_fd, &event) == -1) {
perror("epoll_ctl");
close(client_fd);
continue;
}
printf("New connection from %s:%d\n", inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port));
} else {
do_read(events[i].data.fd);
}
}
}
close(server_fd);
close(epoll_fd);
return 0;
}
void do_read(int fd) {
// 处理客户端数据
char buf[1024];
while(1) {
ssize_t bytes_read = read(fd, buf, sizeof(buf));
if (bytes_read == -1) {
perror("read");
close(fd);
if (epoll_ctl(epoll_fd, EPOLL_CTL_DEL, fd, NULL) == -1) {
perror("epoll_ctl");
}
break;
} else if (bytes_read == 0) {
printf("Client disconnected\n");
close(fd);
if (epoll_ctl(epoll_fd, EPOLL_CTL_DEL, fd, NULL) == -1) {
perror("epoll_ctl");
}
break;
} else {
printf("Received data: %d\n", bytes_read);
if (write(fd, buf, bytes_read) != bytes_read) {
perror("write");
close(fd);
if (epoll_ctl(epoll_fd, EPOLL_CTL_DEL, fd, NULL) == -1) {
perror("epoll_ctl");
}
break;
}
if (bytes_read < 1024) {
break;
}
}
}
}
cat /dev/random 2>/dev/null | nc 127.0.0.1 8080 >/dev/null
nc 127.0.0.1 8080
从代码中可以知道,read一直都有数据读取,一直在处理数据,导致其他句柄无法处理数据。也就是说,其实是我们的代码造成了所谓的饥饿,那么也可以从我们的代码层面上去解决这个问题,思路官方man page中已经提到了,将fd维护一个list,均匀的读写数据即可.
最后此篇关于模拟epoll的饥饿场景的文章就讲到这里了,如果你想了解更多关于模拟epoll的饥饿场景的内容请搜索CFSDN的文章或继续浏览相关文章,希望大家以后支持我的博客! 。
我正在使用 epoll 编写媒体服务器。 fds 都设置为非阻塞,我正在使用边缘触发事件。我知道对于 EPOLLIN,我需要循环读取 fd,直到返回 EAGAIN。但是写作呢? 当我想写入时,我将数据
很难说出这里问的是什么。这个问题模棱两可、含糊不清、不完整、过于宽泛或言辞激烈,无法以目前的形式合理回答。如需帮助澄清此问题以便可以重新打开,visit the help center . 8年前关闭
简短的问题,但对我来说很难理解。 为什么 ePoll 的扩展性比 Poll 更好? 最佳答案 poll 系统调用每次都需要将您的文件描述符列表复制到内核。这只会发生一次 epoll_ctl ,但不是每
情况: 多个进程共享同一个文件描述符表。 每个进程监听自己的 epoll 实例。 所有套接字和涉及它们的调用都是非阻塞的。 在这些进程中,只有进程A将监听套接字添加到它的epoll实例。 进程 A 知
我有几个线程,其中一个在循环中调用 epoll_wait,其他线程可以打开需要由第一个线程 epoll 的连接。是否可以只使用 epoll_ctl 添加新套接字,而另一个线程在 epoll_wait
众所周知,我们可以将poll/select与Netmap结合使用:http://info.iet.unipi.it/~luigi/netmap/ 是否可以使用epoll以及将epoll与Netmap一
我正在使用 epoll 和大量 fd 编写应用程序。 为了改进 fd 对应用程序相关 DB 的搜索,我想传递给 epoll 应用程序信息,例如 DB 数组中的索引。 我想过使用data->ptr(ep
我有一个多线程 epoll 服务器。我创建了一个 epoll fd,然后我将让 X 个线程休眠,等待 epoll_wait() 来自 SAME epoll fd 的任何事件。 现在我的问题是:如何唤醒
我有两个线程在 epoll 上运行。一个线程尝试与服务器建立 TCP 连接,使用 EPOLL_CTL_ADD 选项将套接字添加到 epoll-fd。 另一个线程负责等待添加到 epoll-fd 的 S
我正在使用 Cassandra,在启动期间,Netty 会打印一 strip 有堆栈跟踪的警告: Found Netty's native epoll transport in the classpa
epoll_wait、select 和 poll 函数都提供超时。然而使用epoll,其分辨率可达1ms。 Select 和 ppoll 是唯一提供亚毫秒级超时的。 这意味着最好以 1 毫秒的间隔做其
我正在使用 epoll 进行网络编程。我想知道检测用户断开连接的最佳方法。现在,我正在使用带有超时的选择来查看接收缓冲区中是否有信号并且在一定时间内没有信号然后关闭套接字连接。 我认为可能还有其他更适
epoll 是 Linux 系统中常用的多路复用 I/O 组件,一般用于监听 socket 是否能够进行 I/O 操作。那么,epoll 能监听普通文件吗? 我们先通过下面的例子来验证一下,e
我正在使用 epoll 将大消息写入使用 HTTP 协议(protocol)的服务器。 fds 都设置为非阻塞,我正在使用边缘触发事件。我知道对于 EPOLLIN,我需要循环读取 fd,直到返回 EA
我使用python的socket和epoll来制作一个Web服务器。我的操作系统是Linux CentOS 6,我的python版本是python 2.7.8。我的源代码是: # -*-coding:
我的 TCP 服务器中有一个 epoll 事件循环来处理客户端连接并从客户端读取数据。 while(1) { int n, i; n = epoll_wait(efd, events,
我有一个项目,我正在从普通的 select() 转换,但由于我运行的测试有超过 1000 个连接,我决定将其更改为 epoll。 我的代码可以正常工作,但遇到了一个问题,我正在尝试找出解决问题的最佳方
我是 linux 系统编程的新手,所以请多多关照。我必须通过 RS-422 在 8N1 模式下以波特率 921600 从串行端口 (/dev/ttyX) 读取数据,没有奇偶校验。stty 输出信号表示
我从here得到了基础知识关于 epoll。我知道epoll可以监控多个FD并处理。 我的问题是:重事件是否会阻塞服务器,所以我必须使用多线程? 例如,服务器的epoll正在监控2个套接字A和B。现在
我正在使用 epoll 进行网络编程。我想知道如何处理客户端断开连接。我阅读了 api 文档,epoll_wait 有一个超时参数。但是,如果 epoll_wait 函数或正在连接的客户端超时,我会感
我是一名优秀的程序员,十分优秀!