网络编程-----服务器（多路复用IO 和 TCP并发模型）

一、单循环服务器模型

1. 核心特征
while(1){newfd = accept();recv();close(newfd);}
2. 典型应用场景
  • HTTP短连接服务（早期Apache）
  • CGI快速处理
  • 简单测试服务器
3. 综合代码
#include <stdio.h>
#include <sys/types.h>	       /* See NOTES */
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/ip.h> /* superset of previous */
#include <arpa/inet.h>
#include <strings.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>int main(int argc, const char *argv[])
{if (argc != 3){printf("Usage: %s <port> <ip>\n",argv[0]);return -1;}//1.socket 创建通信一端 int fd = socket(AF_INET,SOCK_STREAM,0);if (fd < 0){perror("socket fail\n");return -1;}struct sockaddr_in seraddr;bzero(&seraddr,sizeof(seraddr));seraddr.sin_family = AF_INET;seraddr.sin_port = htons(atoi(argv[1]));seraddr.sin_addr.s_addr = inet_addr(argv[2]);printf("fd = %d\n",fd);//2.bind -- 绑定服务器端的地址信息 if (bind(fd,(const struct sockaddr*)&seraddr,sizeof(seraddr)) < 0){perror("connect fail");return -1;}printf("connect success!\n");//3.listen -- 设置监听 if (listen(fd,5) < 0){perror("listen fail");return -1;}while (1){//4.acceptint connfd = accept(fd,NULL,NULL);if (connfd < 0){perror("accept fail");return -1;}printf("----client --- connectted\n");char buf[1024];char sbuf[1024];while (1){recv(connfd,buf,sizeof(buf),0);printf("c: %s\n",buf);if (strncmp(buf,"quit",4) == 0){close(connfd);break;}sprintf(sbuf,"server + %s\n",buf);send(connfd,sbuf,strlen(sbuf)+1,0);}}close(fd);return 0;
}
4. 优缺点分析
优点缺点
实现简单无法处理并发请求
无资源竞争问题长连接会阻塞后续请求
适合低负载场景吞吐量低（QPS < 100）

二、多进程并发模型

1. 核心实现
while(1) {int newfd = accept(listen_fd, ...);pid_t pid = fork();if (pid == 0) {  // 子进程close(listen_fd);handle_connection(newfd);close(newfd);exit(0);} else if (pid > 0) {  // 父进程close(newfd);waitpid(-1, NULL, WNOHANG);  // 非阻塞回收}
}
2. 进程管理优化
// 使用信号处理避免僵尸进程
signal(SIGCHLD, SIG_IGN);  // 忽略子进程结束信号// 或使用waitpid循环
while (waitpid(-1, NULL, WNOHANG) > 0);
3. 典型应用
  • 传统Apache的prefork模式
  • FTP服务器
  • 数据库连接池
4. 资源消耗对比
资源类型进程创建开销示例系统调用
内存需要复制整个PCBfork()
CPU上下文切换成本高schedule()
文件描述符需要显式关闭继承的fdclose()
5. 优缺点分析
优点缺点
可以完成多个进程的实时交互回收资源不方便
信息的完整性可以保证。每次fork 占用系统资源多
适合低负载场景可能出现僵尸进程

6. 综合代码

#include <stdio.h>
#include <sys/types.h>	       /* See NOTES */
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/ip.h> /* superset of previous */
#include <arpa/inet.h>
#include <strings.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <signal.h>
#include <sys/wait.h>void handler(int signo)
{wait(NULL);
}int init_server(const char *ip,unsigned short port)
{//1.socket 创建通信一端 int fd = socket(AF_INET,SOCK_STREAM,0);if (fd < 0){perror("socket fail\n");return -1;}struct sockaddr_in seraddr;bzero(&seraddr,sizeof(seraddr));seraddr.sin_family = AF_INET;seraddr.sin_port = htons(port);seraddr.sin_addr.s_addr = inet_addr(ip);//2.bind -- 绑定服务器端的地址信息 if (bind(fd,(const struct sockaddr*)&seraddr,sizeof(seraddr)) < 0){perror("connect fail");return -1;}//3.listen -- 设置监听 if (listen(fd,5) < 0){perror("listen fail");return -1;}return fd;
}int client_handler(int connfd)
{char buf[1024];char sbuf[1024];int ret = 0;while (1){ret = recv(connfd,buf,sizeof(buf),0);if (ret < 0){perror("client_handler recv fail");ret = -1;}printf("c: %s\n",buf);if (strncmp(buf,"quit",4) == 0){close(connfd);ret = 1;break;}sprintf(sbuf,"server + %s\n",buf);ret = send(connfd,sbuf,strlen(sbuf)+1,0);if (ret < 0){perror("client_handler send fail");ret = -1;}}return ret;}int main(int argc, const char *argv[])
{if (argc != 3){printf("Usage: %s <ip> <port>\n",argv[0]);return -1;}signal(SIGCHLD,handler);int fd = init_server(argv[1],atoi(argv[2]));if (fd < 0){printf("init_server fail\n");return -1;}while (1){//4.acceptint connfd = accept(fd,NULL,NULL);if (connfd < 0){perror("accept fail");return -1;}pid_t pid = fork();if (pid < 0){perror("fork fail");return -1;}if (pid == 0){int ret = 0;if ((ret = client_handler(connfd)) < 0){printf("client_handler fail");return -1;}if (ret == 1){printf("child exit...\n");exit(EXIT_SUCCESS);}}}close(fd);return 0;
}

三、多线程并发模型

1. 核心实现（POSIX线程）
while(1) {int newfd = accept(listen_fd, ...);pthread_t tid;pthread_create(&tid, NULL, thread_handler, (void*)newfd);pthread_detach(tid);  // 分离线程自动回收
}void* thread_handler(void* arg) {int fd = (int)arg;// 处理请求close(fd);return NULL;
}
2. 线程安全控制
// 使用互斥锁保护共享资源
pthread_mutex_t lock = PTHREAD_MUTEX_INITIALIZER;void safe_write(int fd, const char* data) {pthread_mutex_lock(&lock);write(fd, data, strlen(data));pthread_mutex_unlock(&lock);
}
3. 典型应用
  • Java Tomcat
  • IIS应用池
  • 实时通信服务器
4. 性能指标对比
指标进程模型线程模型
创建速度慢（10-100ms）快（0.1-1ms）
上下文切换成本高（切换页表等）低（共享地址空间）
内存占用高（独立资源）低（共享资源）
5. 优缺点分析
优点缺点
可以完成多个进程的实时交互线程共享进程资源
创建速度快，调度快稳定性 较差
适合低负载场景安全性 较差 

6. 综合代码

#include <stdio.h>
#include <pthread.h>
#include <sys/types.h>	       /* See NOTES */
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/ip.h> /* superset of previous */
#include <arpa/inet.h>
#include <strings.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <signal.h>
#include <sys/wait.h>
#include <errno.h>int init_server(const char *ip,unsigned short port)
{//1.socket 创建通信一端 int fd = socket(AF_INET,SOCK_STREAM,0);if (fd < 0){perror("socket fail\n");return -1;}struct sockaddr_in seraddr;bzero(&seraddr,sizeof(seraddr));seraddr.sin_family = AF_INET;seraddr.sin_port = htons(port);seraddr.sin_addr.s_addr = inet_addr(ip);//2.bind -- 绑定服务器端的地址信息 if (bind(fd,(const struct sockaddr*)&seraddr,sizeof(seraddr)) < 0){perror("connect fail");return -1;}//3.listen -- 设置监听 if (listen(fd,5) < 0){perror("listen fail");return -1;}return fd;
}void* client_handler(void *arg)
{int connfd = *(int *)arg;char buf[1024];char sbuf[1024];long int ret = 0;while (1){ret = recv(connfd,buf,sizeof(buf),0);if (ret < 0){perror("client_handler recv fail");ret = -1;}printf("c: %s\n",buf);if (strncmp(buf,"quit",4) == 0){close(connfd);ret = 1;break;}sprintf(sbuf,"server + %s\n",buf);ret = send(connfd,sbuf,strlen(sbuf)+1,0);if (ret < 0){perror("client_handler send fail");ret = -1;}}return (void*)ret;}int main(int argc, const char *argv[])
{if (argc != 3){printf("Usage: %s <ip> <port>\n",argv[0]);return -1;}int fd = init_server(argv[1],atoi(argv[2]));if (fd < 0){printf("init_server fail\n");return -1;}while (1){//4.acceptint connfd = accept(fd,NULL,NULL);if (connfd < 0){perror("accept fail");return -1;}pthread_t tid;int ret = pthread_create(&tid,NULL,client_handler,&connfd);if(ret != 0){errno = ret;perror("pthread_create fail");return -1;}pthread_detach(tid);//设置分离属性,由系统回收资源}close(fd);return 0;
}

四、并发的服务器模型 ---更高程度上的并发 

（一）fcntl 函数与 I/O 模型详解

1. 函数原型
#include <unistd.h>
#include <fcntl.h>int fcntl(int fd, int cmd, ... /* arg */ );
2. 主要操作类型
命令功能描述参数要求
F_DUPFD复制文件描述符指定最小可用fd值
F_GETFD/F_SETFD获取/设置文件描述符标志标志值
F_GETFL/F_SETFL获取/设置文件状态标志新标志值
F_GETOWN/F_SETOWN获取/设置异步I/O所有权进程ID或组ID

（二）非阻塞I/O设置示例

1. 设置流程
int flag = fcntl(connfd,F_GETFL,0);flag = flag | O_NONBLOCK;fcntl(connfd,F_SETFL,flag);
2. 行为变化对比
操作阻塞模式非阻塞模式
read()阻塞直到数据到达立即返回，无数据时返回EAGAIN
write()阻塞直到缓冲区空间可用立即返回，空间不足返回EAGAIN
accept()阻塞直到有新连接立即返回，无连接时返回EAGAIN

（三）I/O 模型对比

1. 阻塞I/O模型
2. 非阻塞I/O模型

#include <stdio.h>
#include <sys/types.h>	       /* See NOTES */
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/ip.h> /* superset of previous */
#include <arpa/inet.h>
#include <strings.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>#include <fcntl.h>
int main(int argc, const char *argv[])
{if (argc != 3){printf("Usage: %s <port> <ip>\n",argv[0]);return -1;}//1.socket 创建通信一端 int fd = socket(AF_INET,SOCK_STREAM,0);if (fd < 0){perror("socket fail\n");return -1;}struct sockaddr_in seraddr;bzero(&seraddr,sizeof(seraddr));seraddr.sin_family = AF_INET;seraddr.sin_port = htons(atoi(argv[1]));seraddr.sin_addr.s_addr = inet_addr(argv[2]);printf("fd = %d\n",fd);//2.bind -- 绑定服务器端的地址信息 if (bind(fd,(const struct sockaddr*)&seraddr,sizeof(seraddr)) < 0){perror("connect fail");return -1;}printf("connect success!\n");//3.listen -- 设置监听 if (listen(fd,5) < 0){perror("listen fail");return -1;}while (1){//4.acceptint connfd = accept(fd,NULL,NULL);if (connfd < 0){perror("accept fail");return -1;}printf("----client --- connectted\n");char buf[1024];char sbuf[1024];int flag = fcntl(connfd,F_GETFL,0);flag = flag | O_NONBLOCK;fcntl(connfd,F_SETFL,flag);while (1){recv(connfd,buf,sizeof(buf),0);printf("c: %s\n",buf);if (strncmp(buf,"quit",4) == 0){close(connfd);break;}sprintf(sbuf,"server + %s\n",buf);send(connfd,sbuf,strlen(sbuf)+1,0);}}close(fd);return 0;
}

（四）信号驱动 I/O 详解

1. 设置异步标志
// 获取当前文件状态标志
int flags = fcntl(fd, F_GETFL);
if (flags == -1) {perror("fcntl F_GETFL");exit(EXIT_FAILURE);
}// 添加异步I/O标志
if (fcntl(fd, F_SETFL, flags | O_ASYNC) == -1) {perror("fcntl F_SETFL");exit(EXIT_FAILURE);
}
2. 指定信号接收者
// 设置当前进程为信号接收者
if (fcntl(fd, F_SETOWN, getpid()) == -1) {perror("fcntl F_SETOWN");exit(EXIT_FAILURE);
}
3. 注册信号处理函数
// 更安全的sigaction替代signal
struct sigaction sa;
sa.sa_flags = SA_RESTART;
sa.sa_handler = sigio_handler;
sigemptyset(&sa.sa_mask);if (sigaction(SIGIO, &sa, NULL) == -1) {perror("sigaction");exit(EXIT_FAILURE);
}
4. 基本处理逻辑
#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>
#include <errno.h>
#include <string.h>
#include <signal.h>int g_fd;void handler(int signo)
{char buf[1024];read(g_fd,buf,sizeof(buf));if (strncmp(buf,"quit",4) == 0)return;printf("buf = %s\n",buf);}int main(int argc, const char *argv[])
{if (mkfifo(argv[1],0666) < 0 && errno != EEXIST){perror("mkfifo fail");return -1;}printf("mkfifo success\n");int fd = open(argv[1], O_RDONLY);if (fd < 0){perror("open fail");return -1;}g_fd = fd;int flag = fcntl(fd,F_GETFL,0);flag = flag | O_ASYNC;//设置为异步通信fcntl(fd,F_SETFL,flag);fcntl(fd,F_SETOWN,getpid());//所有者signal(SIGIO,handler);int i = 0;while (1){printf("i = %d\n",i);sleep(1);++i;}close(fd);return 0;
}
5.核心局限性分析
问题类型具体表现解决思路
信号合并快速连续信号可能被合并使用实时信号（SIGRTMIN+）
多fd区分困难无法直接判断哪个fd触发信号每个fd绑定不同信号（不现实）
异步安全限制信号处理函数中操作受限仅设置标志，主循环处理
性能瓶颈高频率信号导致CPU占用高配合epoll使用

（五）select 函数详解

一、函数原型与参数解析

#include <sys/select.h>int select(int nfds, fd_set *readfds, fd_set *writefds,fd_set *exceptfds, struct timeval *timeout);
参数说明
参数类型说明
nfdsint监控的文件描述符最大值 +1（优化内核检查范围）
readfdsfd_set*监控可读事件的描述符集合（可NULL）
writefdsfd_set*监控可写事件的描述符集合（可NULL）
exceptfdsfd_set*监控异常事件的描述符集合（可NULL）
timeouttimeval*超时时间：<br>• NULL：阻塞等待<br>• 0：立即返回<br>• 正数：定时等待
返回值
  • 成功：返回就绪的文件描述符总数（可能为0）
  • 失败：返回-1并设置errno
  • 超时：返回0

二、核心操作宏

宏功能示例
FD_ZERO清空描述符集合FD_ZERO(&read_fds);
FD_SET添加描述符到集合FD_SET(sockfd, &read_fds);
FD_CLR从集合中移除描述符FD_CLR(sockfd, &read_fds);
FD_ISSET检测描述符是否在集合中if(FD_ISSET(sockfd, &read_fds))

三、典型使用流程

1. 初始化描述符集合
fd_set read_fds;
FD_ZERO(&read_fds);
FD_SET(listen_fd, &read_fds);
int max_fd = listen_fd;
2. 等待事件就绪
struct timeval tv = {5, 0}; // 5秒超时
fd_set tmp_fds = read_fds;int ready = select(max_fd + 1, &tmp_fds, NULL, NULL, &tv);
if (ready == -1) {if (errno == EINTR) continue; // 处理信号中断perror("select error");break;
} else if (ready == 0) {printf("Timeout\n");continue;
}
3. 处理就绪事件
for (int fd = 0; fd <= max_fd; fd++) {if (FD_ISSET(fd, &tmp_fds)) {if (fd == listen_fd) {// 处理新连接int new_fd = accept(listen_fd, ...);FD_SET(new_fd, &read_fds);max_fd = (new_fd > max_fd) ? new_fd : max_fd;} else {// 处理客户端数据ssize_t n = read(fd, ...);if (n <= 0) {close(fd);FD_CLR(fd, &read_fds);}}}
}

四、关键注意事项

  1. 集合重用问题
    select返回后，集合会被修改为就绪的fd集合，每次调用前必须重新初始化：

    fd_set tmp_fds = read_fds; // 使用临时集合

  2. 超时时间重置
    timeout参数会被修改为剩余时间，循环调用时需要重新设置：

    struct timeval tv = {5, 0};
while(1) {select(..., &tv);tv.tv_sec = 5; // 必须重置
}

  3. 最大fd限制
    受FD_SETSIZE限制（通常1024），超出会导致未定义行为

  4. 性能问题
    每次调用需要从用户态复制整个fd_set到内核态，时间复杂度O(n)

#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>
#include <errno.h>
#include <string.h>
int main(int argc, const char *argv[])
{if (mkfifo(argv[1],0666) < 0 && errno != EEXIST){perror("mkfifo fail");return -1;}printf("mkfifo success\n");int fd = open(argv[1], O_RDONLY);if (fd < 0){perror("open fail");return -1;}char buf[1024] = {0};//1.建表fd_set readfds;FD_ZERO(&readfds);//2.添加要关心的fdFD_SET(0,&readfds);FD_SET(fd,&readfds);//3.select函数监控fd_set backfds;struct timeval tv = {5,0};while(1){backfds = readfds;//每次循环回来拿到的都是最原始数据int nfds = fd + 1;//因为另一个是0,所以最大也就是ｆｄint ret = select(nfds,&backfds,NULL,NULL,&tv);if(ret < 0){perror("select fail");return -1;}if(ret > 0){for(int i = 0;i < nfds;i++)//也可以是1024,但没必要 {if(FD_ISSET(i,&backfds)){if(i == 0){fgets(buf,sizeof(buf),stdin);if (strncmp(buf,"quit",4) == 0)break;printf("buf = %s\n",buf);}else if(i == fd){read(fd,buf,sizeof(buf));if (strncmp(buf,"quit",4) == 0)break;printf("buf = %s\n",buf);}}}}}close(fd);return 0;
}

可以从客户端读取数据，也可以自身从键盘输入

tcp多客户端连接到服务器

#include <stdio.h>
#include <sys/types.h>	       /* See NOTES */
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/ip.h> /* superset of previous */
#include <arpa/inet.h>
#include <strings.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <sys/select.h>int main(int argc, const char *argv[])
{if (argc != 3){printf("Usage: %s <port> <ip>\n",argv[0]);return -1;}//1.socket 创建通信一端 int fd = socket(AF_INET,SOCK_STREAM,0);if (fd < 0){perror("socket fail\n");return -1;}struct sockaddr_in seraddr;bzero(&seraddr,sizeof(seraddr));seraddr.sin_family = AF_INET;seraddr.sin_port = htons(atoi(argv[1]));seraddr.sin_addr.s_addr = inet_addr(argv[2]);printf("fd = %d\n",fd);//2.bind -- 绑定服务器端的地址信息 if (bind(fd,(const struct sockaddr*)&seraddr,sizeof(seraddr)) < 0){perror("connect fail");return -1;}printf("connect success!\n");//3.listen -- 设置监听 if (listen(fd,5) < 0){perror("listen fail");return -1;}//1.准备表 fd_set readfds;FD_ZERO(&readfds);//2.添加要监控的fdFD_SET(fd,&readfds);int connfd = 0;fd_set backfds;int i = 0;int nfds = fd + 1;while (1){backfds = readfds;int ret = select(nfds,&backfds,NULL,NULL,NULL);if (ret < 0){perror("select fail");return -1;}if (ret > 0){for (i = 0; i < nfds; ++i){if (FD_ISSET(i,&backfds)){if (i == fd){//4.acceptconnfd = accept(fd,NULL,NULL);if (connfd < 0){perror("accept fail");return -1;}FD_SET(connfd,&readfds);nfds = nfds > connfd + 1 ? nfds:connfd + 1;}else {char buf[1024];char sbuf[1024];recv(i,buf,sizeof(buf),0);printf("c: %s\n",buf);if (strncmp(buf,"quit",4) == 0){	close(i);FD_CLR(i,&readfds); }sprintf(sbuf,"server + %s\n",buf);send(i,sbuf,strlen(sbuf)+1,0);}}}}}close(fd);return 0;
}

并发模型对比

模型实现方式优点缺点
多进程fork()隔离性好资源消耗大
多线程pthread_create()资源共享高效同步复杂度高
I/O多路复用select/poll/epoll高并发低开销编程复杂度较高
信号驱动SIGIO+fcntl实时性好信号处理复杂
异步I/Oaio_*系列函数真正的异步操作系统支持不统一

（六）epoll 

一、核心函数解析

1. epoll_create：创建 epoll 实例
#include <sys/epoll.h>
int epoll_create(int size);
  • 参数：
    • size：内核初始分配数据结构的建议值（Linux 2.6.8+ 后忽略，但需 > 0）
  • 返回值：
    • 成功：epoll 文件描述符 (epfd)
    • 失败：-1，设置 errno
  • 注意：
    • 需手动调用 close(epfd) 释放资源
    • 典型用法：epoll_create1(0)（更推荐，支持 EPOLL_CLOEXEC 标志）
2. epoll_ctl：管理监控列表
int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event);

  • 操作类型 (op)：

    操作说明
    EPOLL_CTL_ADD添加 fd 到监控列表（重复添加报 EEXIST 错误）
    EPOLL_CTL_MOD修改已注册 fd 的事件（未注册的 fd 报 ENOENT 错误）
    EPOLL_CTL_DEL从监控列表删除 fd（内核会忽略 event 参数）

  • 事件结构：

    struct epoll_event {uint32_t     events;  // 监控的事件类型（位掩码）epoll_data_t data;    // 用户数据（可携带 fd、指针等）
};typedef union epoll_data {void    *ptr;int      fd;uint32_t u32;uint64_t u64;
} epoll_data_t;
3. epoll_wait：等待事件就绪
int epoll_wait(int epfd, struct epoll_event *events, int maxevents, int timeout);
  • 参数：
    • events：输出参数，存储就绪事件数组
    • maxevents：最多返回的事件数量（需 ≤ 数组长度）
    • timeout：超时时间（ms），-1 表示阻塞，0 表示立即返回
  • 返回值：
    • 成功：就绪事件数量
    • 超时：0
    • 错误：-1，设置 errno

二、事件类型与触发模式

1. 基础事件类型
事件类型说明
EPOLLIN数据可读（包括对端关闭）
EPOLLOUT数据可写（注意：可能触发虚假就绪）
EPOLLRDHUP对端关闭连接或关闭写方向（需内核 ≥ 2.6.17）
EPOLLPRI紧急数据可读（如 TCP 带外数据）
EPOLLERR错误条件（自动监控，无需手动设置）
EPOLLHUP挂起（如管道对端关闭，自动监控）
2. 高级控制标志
标志说明
EPOLLET边沿触发模式（默认水平触发 LT）
EPOLLONESHOT单次触发，事件处理后需用 EPOLL_CTL_MOD 重新激活

三、触发模式对比

特性水平触发 (LT)边沿触发 (ET)
触发条件只要缓冲区有数据/空间就会触发仅在缓冲区状态变化时触发一次
数据读取可部分读取，下次仍会触发必须一次性读取到 EAGAIN
性能适合低频大块数据适合高频高并发场景
实现复杂度简单需配合非阻塞 I/O 和循环读写
适用场景简单交互、文件传输实时通信、高并发服务器

实例：

基于 epoll 的简单 TCP 服务器，可以同时处理多个客户端连接

#include <stdio.h>
#include <sys/types.h>	       /* See NOTES */
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/ip.h> /* superset of previous */
#include <arpa/inet.h>
#include <strings.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <sys/select.h>
#include <sys/epoll.h>// 将文件描述符添加到 epoll 实例中
int add_fd(int epfd,int fd)
{struct epoll_event ev;ev.events = EPOLLIN;// 监听可读事件ev.data.fd = fd;// 设置文件描述符if(epoll_ctl(epfd,EPOLL_CTL_ADD,fd,&ev) < 0){perror("epoll_ctl fail");return -1;}return 0;
}
// 从 epoll 实例中删除文件描述符
int del_fd(int epfd,int fd)
{struct epoll_event ev;ev.events = EPOLLIN;ev.data.fd = fd;if(epoll_ctl(epfd,EPOLL_CTL_DEL,fd,&ev) < 0){perror("epoll_ctl fail");return -1;}return 0;
}int main(int argc, const char *argv[])
{if (argc != 3){printf("Usage: %s <port> <ip>\n",argv[0]);return -1;}//1.socket 创建通信一端 int fd = socket(AF_INET,SOCK_STREAM,0);if (fd < 0){perror("socket fail\n");return -1;}struct sockaddr_in seraddr;bzero(&seraddr,sizeof(seraddr));seraddr.sin_family = AF_INET;seraddr.sin_port = htons(atoi(argv[1]));seraddr.sin_addr.s_addr = inet_addr(argv[2]);//2.bind -- 绑定服务器端的地址信息 if (bind(fd,(const struct sockaddr*)&seraddr,sizeof(seraddr)) < 0){perror("connect fail");return -1;}printf("connect success!\n");//3.listen -- 设置监听 if (listen(fd,5) < 0){perror("listen fail");return -1;}//1.准备表 int epfd = epoll_create(2);if(epfd < 0){perror("epoll_create fail");return -1;}//2.添加要监控的fdadd_fd(epfd,fd); // 添加监听 socket 到 epollint connfd = 0;struct epoll_event result[1024];// 保存 epoll_wait 返回的事件int maxevents = 1024;//指定 epoll_wait 函数最多可以返回的事件数量。int ret = 0;int i = 0;int tm = 3000;//3swhile (1){// 等待 epoll 事件ret = epoll_wait(epfd,result,maxevents,tm);if (ret < 0){perror("epoll_wait fail");return -1;}else if (ret == 0) {printf("epoll_wait timeout\n");//处理超时}else if(ret > 0){for (i = 0; i < ret; ++i){// 如果是监听 socket 有事件，说明有新连接if (result[i].data.fd == fd)//作用为监听的fd{//4.acceptconnfd = accept(fd,NULL,NULL);if (connfd < 0){perror("accept fail");return -1;}// 将新连接的 socket 添加到 epolladd_fd(epfd,connfd);}else //通信的fd{// 处理客户端数据connfd = result[i].data.fd;//取触发事件的文件描述符char buf[1024];char sbuf[1024];recv(connfd,buf,sizeof(buf),0);printf("c: %s\n",buf);if (strncmp(buf,"quit",4) == 0){	del_fd(epfd,connfd);close(connfd);continue;}sprintf(sbuf,"server + %s\n",buf);send(connfd,sbuf,strlen(sbuf)+1,0);}}}}close(fd);return 0;
}

基于 epoll 的简单 TCP 服务器，可以同时处理多个客户端连接（边沿触发模式）

#include <stdio.h>
#include <sys/types.h>	       /* See NOTES */
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/ip.h> /* superset of previous */
#include <arpa/inet.h>
#include <strings.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <sys/select.h>
#include <sys/epoll.h>
#include <errno.h>
#include <fcntl.h>// 将文件描述符添加到 epoll 实例中
int add_fd(int epfd,int fd)
{struct epoll_event ev;ev.events = EPOLLIN|EPOLLET;// 监听可读事件，并使用边缘触发模式ev.data.fd = fd;// 设置文件描述符if(epoll_ctl(epfd,EPOLL_CTL_ADD,fd,&ev) < 0){perror("epoll_ctl fail");return -1;}return 0;
}
// 从 epoll 实例中删除文件描述符
int del_fd(int epfd,int fd)
{struct epoll_event ev;ev.events = EPOLLIN;ev.data.fd = fd;if(epoll_ctl(epfd,EPOLL_CTL_DEL,fd,&ev) < 0){perror("epoll_ctl fail");return -1;}return 0;
}
// 设置文件描述符为非阻塞模式
void set_nonblock(int fd)
{int flag = fcntl(fd,F_GETFL,0);// 获取当前文件状态标志flag = flag|O_NONBLOCK;// 设置非阻塞标志fcntl(fd,F_SETFL,flag);// 更新文件状态标志
}int main(int argc, const char *argv[])
{if (argc != 3){printf("Usage: %s <port> <ip>\n",argv[0]);return -1;}//1.socket 创建通信一端 int fd = socket(AF_INET,SOCK_STREAM,0);if (fd < 0){perror("socket fail\n");return -1;}struct sockaddr_in seraddr;bzero(&seraddr,sizeof(seraddr));seraddr.sin_family = AF_INET;seraddr.sin_port = htons(atoi(argv[1]));seraddr.sin_addr.s_addr = inet_addr(argv[2]);//2.bind -- 绑定服务器端的地址信息 if (bind(fd,(const struct sockaddr*)&seraddr,sizeof(seraddr)) < 0){perror("connect fail");return -1;}printf("connect success!\n");//3.listen -- 设置监听 if (listen(fd,5) < 0){perror("listen fail");return -1;}//1.准备表 int epfd = epoll_create(2);if(epfd < 0){perror("epoll_create fail");return -1;}//2.添加要监控的fd
// 添加监听 socket 到 epoll，并设置为非阻塞模式add_fd(epfd,fd); set_nonblock(fd);int connfd = 0;struct epoll_event result[1024];// 保存 epoll_wait 返回的事件int maxevents = 1024;//指定 epoll_wait 函数最多可以返回的事件数量。int ret = 0;int i = 0;int tm = 3000;//3swhile (1){// 等待 epoll 事件ret = epoll_wait(epfd,result,maxevents,tm);if (ret < 0){perror("epoll_wait fail");return -1;}else if (ret == 0) {printf("epoll_wait timeout\n");//处理超时}else if(ret > 0){for (i = 0; i < ret; ++i){// 如果是监听 socket 有事件，说明有新连接if (result[i].data.fd == fd)//作用为监听的fd{//4.acceptconnfd = accept(fd,NULL,NULL);if (connfd < 0){perror("accept fail");return -1;}set_nonblock(connfd);// 设置新连接为非阻塞模式// 将新连接的 socket 添加到 epolladd_fd(epfd,connfd);}else //通信的fd{// 处理客户端数据connfd = result[i].data.fd;//取触发事件的文件描述符char buf[1024];char sbuf[1024];while(1){ret = recv(connfd,buf,1,0);printf("c: %s\n",buf);if(ret < 0){if(errno == EWOULDBLOCK||errno == EAGAIN)break;// 非阻塞模式下，没有更多数据可读}if (strncmp(buf,"quit",4) == 0){	del_fd(epfd,connfd);close(connfd);continue;}sprintf(sbuf,"server + %s\n",buf);send(connfd,sbuf,strlen(sbuf)+1,0);}}}}}close(fd);return 0;
}

（七）select、poll、epoll 的比较

select 的缺点：

  1. select 监听文件描述符最大个数为 1024。

  2. select 监听的文件描述符集合在用户层，需要应用层和内核层互相传递数据。

  3. select 需要循环遍历一次才能找到产生的事件。

  4. select 只能工作在水平触发模式（低速模式），无法工作在边沿触发模式（高速模式）。

poll 的缺点：

  1. poll 监听文件描述符不受上限限制。

  2. poll 监听的文件描述符集合在用户层，需要内核层向用户层传递数据。

  3. poll 需要循环遍历一次才能找到产生的事件。

  4. poll 只能工作在水平触发模式（低速模式），无法工作在边沿触发模式（高速模式）。

epoll 的优点：

  1. epoll 创建内核事件表，不受到文件描述符上限限制。

  2. epoll 监听的事件表在内核中，直接在内核中监测事件效率高。

  3. epoll 会直接获得产生事件的文件描述符的信息，而不需要遍历检测。

  4. epoll 既能工作在水平触发模式，也能工作在边沿触发模式。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/diannao/73082.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

typora高亮方案+鼠标侧键一键改色

typora高亮方案+鼠标侧键一键改色

引言 在typora里面有一个自定义的高亮, <mark></mark>>但是单一颜色就太难看了, 我使用人工智能, 搜索全网艺术家, 汇集了几种好看的格式,并且方便大家侧键一键 调用, 是不是太方便啦 ! 示例 午夜模式 春意盎然 深海蓝调 石墨文档 秋日暖阳 蜜桃宣言 使用方法 …
阅读更多...
swift -(5) 汇编分析结构体、类的内存布局

swift -(5) 汇编分析结构体、类的内存布局

一、结构体 在 Swift 标准库中&#xff0c;绝大多数的公开类型都是结构体&#xff0c;而枚举和类只占很小一部分 比如Bool、 Int、 Double、 String、 Array、 Dictionary等常见类型都是结构体 ① struct Date { ② var year: Int ③ var month: Int ④ …
阅读更多...
从零开始学机器学习——初探分类器

从零开始学机器学习——初探分类器

首先给大家介绍一个很好用的学习地址：https://cloudstudio.net/columns 在上一节中，我们已经完成了对所有经过均衡和清洗的菜品数据的准备工作。接下来，我们将考虑使用多种算法，也就是不同的分类器，来构建模型。我们将利用这个数据集和各种分类器，基于一组特定的配料，预…
阅读更多...
黑色RGB是什么

黑色RGB是什么

>好的&#xff0c;用户现在问的是“黑色rgb是什么”。我需要先理解用户的问题。之前用户在使用MATLAB调整网格线颜色时&#xff0c;可能看到了默认颜色是黑色&#xff0c;或者之前我提到过默认颜色是[0.15 0.15 0.15]&#xff0c;而用户可能现在想知道黑色的RGB值具体是什么…
阅读更多...
做到哪一步才算精通SQL

做到哪一步才算精通SQL

做到哪一步才算精通SQL-Structured Query Language 数据定义语言 DDL for StructCREATE&#xff1a;用来创建数据库、表、索引等对象ALTER&#xff1a;用来修改已存在的数据库对象DROP&#xff1a;用来删除整个数据库或者数据库中的表TRUNCATE&#xff1a;用来删除表中所有的行…
阅读更多...
《深度解析DeepSeek-M8：量子经典融合，重塑计算能效格局》

《深度解析DeepSeek-M8：量子经典融合，重塑计算能效格局》

在科技飞速发展的今天&#xff0c;量子计算与经典算法的融合成为了前沿领域的焦点。DeepSeek-M8的“量子神经网络混合架构”&#xff0c;宛如一把钥匙&#xff0c;开启了经典算法与量子计算协同推理的全新大门&#xff0c;为诸多复杂问题的解决提供了前所未有的思路。 量子计算…
阅读更多...
解决电脑问题（2）——主板问题

解决电脑问题（2）——主板问题

当电脑主板出现问题时&#xff0c;可以尝试以下解决方法&#xff1a; 外观检查与清洁 检查硬件连接&#xff1a;仔细查看主板上的各种硬件连接&#xff0c;包括 CPU、内存、显卡、硬盘、电源等的连接线是否松动或损坏。确保所有插头都牢固地插入相应的插槽中&#xff0c;如有松…
阅读更多...
Java 大视界 -- Java 大数据在智能家居能源管理与节能优化中的应用（120）

Java 大视界 -- Java 大数据在智能家居能源管理与节能优化中的应用（120）

&#x1f496;亲爱的朋友们&#xff0c;热烈欢迎来到 青云交的博客&#xff01;能与诸位在此相逢&#xff0c;我倍感荣幸。在这飞速更迭的时代&#xff0c;我们都渴望一方心灵净土&#xff0c;而 我的博客 正是这样温暖的所在。这里为你呈上趣味与实用兼具的知识&#xff0c;也…
阅读更多...
【网络】TCP常考知识点详解

【网络】TCP常考知识点详解

TCP报文结构 TCP报文由**首部&#xff08;Header&#xff09;和数据&#xff08;Data&#xff09;**两部分组成。首部包括固定部分&#xff08;20字节&#xff09;和可选选项&#xff08;最多40字节&#xff09;&#xff0c;总长度最大为60字节。 1. 首部固定部分 源端口&…
阅读更多...
算法1-6 一元三次方程求解

算法1-6 一元三次方程求解

题目描述 有形如&#xff1a;ax3bx2cxd0 这样的一个一元三次方程。给出该方程中各项的系数&#xff08;a,b,c,d 均为实数&#xff09;&#xff0c;并约定该方程存在三个不同实根&#xff08;根的范围在 −100 至 100 之间&#xff09;&#xff0c;且根与根之差的绝对值 ≥1。要…
阅读更多...
05.基于 TCP 的远程计算器：从协议设计到高并发实现

05.基于 TCP 的远程计算器：从协议设计到高并发实现

&#x1f4d6; 目录 &#x1f4cc; 前言&#x1f50d; 需求分析 &#x1f914; 我们需要解决哪些问题&#xff1f; &#x1f3af; 方案设计 &#x1f4a1; 服务器架构 &#x1f680; 什么是协议&#xff1f;为什么要设计协议&#xff1f; &#x1f4cc; 结构化数据的传输问题 …
阅读更多...
大数据面试之路 (一) 数据倾斜

大数据面试之路 (一) 数据倾斜

记录大数据面试历程 数据倾斜 大数据岗位 &#xff0c;数据倾斜面试必问的一个问题。 一、数据倾斜的表现与原因 表现 某个或某几个Task执行时间过长&#xff0c;其他Task快速完成。 Spark/MapReduce作业卡在某个阶段&#xff08;如reduce阶段&#xff09;&#xff0c;日志显…
阅读更多...
仅仅使用pytorch来手撕transformer架构(3)：编码器模块和编码器类的实现和向前传播

仅仅使用pytorch来手撕transformer架构(3)：编码器模块和编码器类的实现和向前传播

仅仅使用pytorch来手撕transformer架构(2)&#xff1a;编码器模块和编码器类的实现和向前传播 往期文章&#xff1a; 仅仅使用pytorch来手撕transformer架构(1)&#xff1a;位置编码的类的实现和向前传播 最适合小白入门的Transformer介绍 仅仅使用pytorch来手撕transformer…
阅读更多...
《OpenCV》—— dlib（换脸操作）

《OpenCV》—— dlib（换脸操作）

文章目录 dlib换脸介绍仿射变换在 dlib 换脸中的应用 换脸操作 dlib换脸介绍 dlib 换脸是基于 dlib 库实现的一种人脸替换技术&#xff0c;以下是关于它的详细介绍&#xff1a; 原理 人脸检测&#xff1a;dlib 库中包含先进的人脸检测器&#xff0c;如基于 HOG&#xff08;方向…
阅读更多...
机器学习中的梯度下降是什么意思？

机器学习中的梯度下降是什么意思？

梯度下降&#xff08;Gradient Descent&#xff09;是机器学习中一种常用的优化算法&#xff0c;用于最小化损失函数&#xff08;Loss Function&#xff09;。通过迭代调整模型参数&#xff0c;梯度下降帮助模型逐步逼近最优解&#xff0c;从而提升模型的性能。 1.核心思想 梯…
阅读更多...
三、Docker 集群管理与应用

三、Docker 集群管理与应用

&#xff08;一&#xff09;项目案例 1、准备主机 &#xff08;1&#xff09;关闭防火墙&#xff0c;或者开放TCP端口2377&#xff08;用于集群管理通信&#xff09;、TCP/UPD端口7946&#xff08;用于节点之间的通信&#xff09;、UDP端口4789&#xff08;用于overlay网络流…
阅读更多...
网络DNS怎么更改?

网络DNS怎么更改?

访问速度慢或某些网站无法打开?改变网络DNS设置可能会帮助解决这些问题。本文将详细介绍如何更改网络DNS&#xff0c;包括更改的原因、具体步骤。 一、为什么要更改DNS? 更改DNS的原因有很多&#xff0c;以下是一些主要的考虑因素&#xff1a;某些公共DNS服务器的响应速度比…
阅读更多...
江科大51单片机笔记【12】DS18B20温度传感器（上）

江科大51单片机笔记【12】DS18B20温度传感器（上）

写在前言 此为博主自学江科大51单片机&#xff08;B站&#xff09;的笔记&#xff0c;方便后续重温知识 在后面的章节中&#xff0c;为了防止篇幅过长和易于查找&#xff0c;我把一个小节分成两部分来发&#xff0c;上章节主要是关于本节课的硬件介绍、电路图、原理图等理论…
阅读更多...
基于springboot+vue的佳途旅行分享预约平台

基于springboot+vue的佳途旅行分享预约平台

一、系统架构 前端&#xff1a;vue2 | element-ui | html 后端&#xff1a;springboot | mybatis-plus 环境&#xff1a;jdk1.8 | mysql | maven | node 二、代码及数据库 三、功能介绍 01. web端-注册 02. web端-登录 03. web端-系统主页1 04. web端-系统主页2 05. we…
阅读更多...
【数据结构】2算法及分析

【数据结构】2算法及分析

0 章节 &#xff11;&#xff0e;&#xff14;到1&#xff0e;&#xff15;小节。 掌握算法概念、特性、描述、算法性能时间复杂度和空间复杂度&#xff1b; 理解递归含义&#xff1f; 掌握实现递归的条件和时机&#xff1b; 应用简单递归问题的算法设计&#xff1b; 重点 算法…
阅读更多...
最新文章

Copyright @ 2022~2023