郑州做网站的专业公司有哪些/烟台seo

郑州做网站的专业公司有哪些,烟台seo,南通市规划建设局网站,在线作图免费网站一、单循环服务器模型 1. 核心特征 while(1){newfd accept();recv();close(newfd);}2. 典型应用场景 HTTP短连接服务&#xff08;早期Apache&#xff09;CGI快速处理简单测试服务器 3. 综合代码 #include <stdio.h> #include <sys/types.h> /* See NO…

一、单循环服务器模型

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 ④ …
阅读更多...
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. 首部固定部分 源端口&…
阅读更多...
05.基于 TCP 的远程计算器：从协议设计到高并发实现

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

&#x1f4d6; 目录 &#x1f4cc; 前言&#x1f50d; 需求分析 &#x1f914; 我们需要解决哪些问题&#xff1f; &#x1f3af; 方案设计 &#x1f4a1; 服务器架构 &#x1f680; 什么是协议&#xff1f;为什么要设计协议&#xff1f; &#x1f4cc; 结构化数据的传输问题 …
阅读更多...
《OpenCV》—— dlib（换脸操作）

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

文章目录 dlib换脸介绍仿射变换在 dlib 换脸中的应用 换脸操作 dlib换脸介绍 dlib 换脸是基于 dlib 库实现的一种人脸替换技术&#xff0c;以下是关于它的详细介绍&#xff1a; 原理 人脸检测&#xff1a;dlib 库中包含先进的人脸检测器&#xff0c;如基于 HOG&#xff08;方向…
阅读更多...
江科大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; 重点 算法…
阅读更多...
【一起学Rust | Tauri2.0框架】基于 Rust 与 Tauri 2.0 框架实现软件开机自启

【一起学Rust | Tauri2.0框架】基于 Rust 与 Tauri 2.0 框架实现软件开机自启

文章目录 前言 一、准备工作1.1 环境搭建1.2 创建 Tauri 项目1.3 添加依赖 二、实现开机自启的基本原理2.1 开机自启的基本概念2.2 Tauri 应用的生命周期 三、Windows 平台实现3.1 Windows 注册表机制3.2 实现步骤3.3 注意事项 四、Linux 平台实现4.1 Linux systemd 服务4.2 实…
阅读更多...
一周热点-OpenAI 推出了 GPT-4.5，这可能是其最后一个非推理模型

一周热点-OpenAI 推出了 GPT-4.5，这可能是其最后一个非推理模型

在人工智能领域，大型语言模型一直是研究的热点。OpenAI 的 GPT 系列模型在自然语言处理方面取得了显著成就。GPT-4.5 是 OpenAI 在这一领域的又一力作，它在多个方面进行了升级和优化。 1 新模型的出现 GPT-4.5 目前作为研究预览版发布。与 OpenAI 最近的 o1 和 o3 模型不同，…
阅读更多...
element-plus中form表单组件的使用

element-plus中form表单组件的使用

1.如何让每个表单项对齐&#xff1f; 问题描述&#xff1a;如下图&#xff0c;每个表单项的输入框/下拉框/日期选择器是没有对齐的&#xff0c;我们希望它们纵向是对齐的。 解决方案&#xff1a;给el-form标签&#xff0c;加上label-width"100px"即可。意思就是给每个…
阅读更多...
OpenManus-通过源码方式本地运行OpenManus，含踩坑及处理方案，chrome.exe位置修改

OpenManus-通过源码方式本地运行OpenManus，含踩坑及处理方案，chrome.exe位置修改

前言&#xff1a;最近 Manus 火得一塌糊涂啊&#xff0c;OpenManus 也一夜之间爆火&#xff0c;那么作为程序员应该来尝尝鲜 1、前期准备 FastGithub&#xff1a;如果有科学上网且能正常访问 github 则不需要下载此软件&#xff0c;此软件是提供国内直接访问 githubGit&#…
阅读更多...
【最新】DeepSeek 实用集成工具有那些？

【最新】DeepSeek 实用集成工具有那些？

deepseek 系列github仓库地址 【主页】deepseek-aiDeepSeek-R1DeepSeek-V3DeepSeek-VL2【本文重点介绍】awesome-deepseek-integration 注意&#xff1a;以下内容来自awesome-deepseek-integration DeepSeek 实用集成&#xff08;awesome-deepseek-integration&#xff09; 将…
阅读更多...
开源！速度100Kb/s的有线和无线双模ESP32S3芯片的DAP-Link调试器

开源！速度100Kb/s的有线和无线双模ESP32S3芯片的DAP-Link调试器

开源&#xff01;速度100Kb/s的有线和无线双模ESP32S3芯片的DAP-Link调试器 目录 开源&#xff01;速度100Kb/s的有线和无线双模ESP32S3芯片的DAP-Link调试器本项目未经授权&#xff0c;禁止商用&#xff01;本项目未经授权&#xff0c;禁止商用&#xff01;本项目未经授权&…
阅读更多...
Flink测试环境Standalone模式部署实践

Flink测试环境Standalone模式部署实践

1.JDK环境 参考官方文档&#xff1a; https://nightlies.apache.org/flink/flink-docs-release-1.20/release-notes/flink-1.18/ 2.下载Flink&#xff1a;https://flink.apache.org/downloads/ 本次验证用的是&#xff1a;https://www.apache.org/dyn/closer.lua/flink/flink…
阅读更多...
macOS 终端优化

macOS 终端优化

macOS 安装、优化、还原、升级 Oh My Zsh 完全指南 &#x1f680; Oh My Zsh 是 macOS 终端增强的利器&#xff0c;它能提供强大的自动补全、主题定制和插件支持&#xff0c;让你的终端更高效、更炫酷。本文将全面介绍 如何安装、优化、还原、重新安装和升级 Oh My Zsh&#x…
阅读更多...
计算机网络--访问一个网页的全过程

计算机网络--访问一个网页的全过程

文章目录 访问一个网页的全过程应用层在浏览器输入URL网址http://www.aspxfans.com:8080/news/index.aspboardID5&ID24618&page1#r_70732423通过DNS获取IP地址生成HTTP请求报文应用层最后 传输层传输层处理应用层报文建立TCP连接传输层最后 网络层网络层对TCP报文进行处…
阅读更多...
【BUG】类文件具有错误的版本 61.0, 应为 52.0，请删除该文件或确保该文件位于正确的类路径子目录中。

【BUG】类文件具有错误的版本 61.0, 应为 52.0，请删除该文件或确保该文件位于正确的类路径子目录中。

报错&#xff1a; [ERROR] 类文件具有错误的版本 61.0, 应为 52.0 [ERROR] 请删除该文件或确保该文件位于正确的类路径子目录中。 报错截图&#xff1a; 原因&#xff1a;Java 版本和 Spring 不兼容&#xff0c;显示 Spring 版本过高 解决方法 1. 使用更高版本的 J…
阅读更多...
Java 大视界 -- 区块链赋能 Java 大数据：数据可信与价值流转（84）

Java 大视界 -- 区块链赋能 Java 大数据：数据可信与价值流转（84）

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

Copyright @ 2022~2023