Linux网络编程之TCP/IP实现高并发网络服务器设计指南

目录

引言：

多进程服务器

例程分享：

多线程服务器

 例程分享：

I/O多路复用服务器

select

例程分享：

poll

例程分享：

epoll

例程分享：

总结建议

引言：

        随着互联网的迅猛发展，服务器面临着越来越多的并发请求。如何设计一个能够高效处理大量并发请求的服务器成为了一个关键问题。本文将介绍几种常见的高并发服务器设计方案，包括多进程服务器、多线程服务器、I/O多路复用服务器和epoll服务器，并分析它们的优缺点，以便读者能够选择适合自己需求的设计方案。

多进程服务器

利用fork创建子进程处理每个连接请求。

优点：充分利用多核CPU的计算能力，隔离不同连接之间的资源。

 缺点：父进程需要设置较大的文件描述符限制，进程创建和切换开销较大。

相关API函数：fork、waitpid、socket、bind、listen、accept、read、write、close

实现要点:

  • 父进程close子进程socket,避免泄漏。
  • 信号处理回收子进程。
  • 每个子进程处理一个连接请求。

例程分享：

/*
服务器监听端口,接收客户端连接。
对每个连接fork子进程处理请求。
子进程循环接收客户端数据,转换大小写后返回。
父进程关闭连接socket,信号函数回收子进程。
客户端连接后循环发送接收数据。
使用多进程处理连接请求,充分利用多核CPU。
fork创建进程,waitpid和信号处理回收子进程。
父子进程同步处理,避免混乱。
*//* server.c */#include <stdio.h>   // 标准IO头文件#include <string.h>  // 字符串处理头文件#include <netinet/in.h> // socket编程头文件#include <arpa/inet.h> // IP地址转换头文件#include <signal.h> // 信号处理头文件#include <sys/wait.h> // 等待子进程头文件#include <sys/types.h> // 数据类型头文件#include "wrap.h" // socket函数封装头文件#define MAXLINE 80  // 最大读写字节数#define SERV_PORT 800 // 服务器端口号// 信号处理函数,回收子进程
void do_sigchild(int num) {while (waitpid(0, NULL, WNOHANG) > 0);
}int main(void) {// socket地址结构struct sockaddr_in servaddr, cliaddr;// 客户端地址长度socklen_t cliaddr_len;// 监听和连接socketint listenfd, connfd;// 数据缓冲区char buf[MAXLINE];// 客户端IP字符串char str[INET_ADDRSTRLEN];int i, n; // 循环变量和读字节数pid_t pid; // 进程ID// 安装信号处理函数struct sigaction newact;newact.sa_handler = do_sigchild;sigemptyset(&newact.sa_mask);newact.sa_flags = 0;sigaction(SIGCHLD, &newact, NULL);// 创建监听socketlistenfd = Socket(AF_INET, SOCK_STREAM, 0);// 初始化服务器地址结构bzero(&servaddr, sizeof(servaddr));servaddr.sin_family = AF_INET;servaddr.sin_addr.s_addr = htonl(INADDR_ANY);servaddr.sin_port = htons(SERV_PORT);// 绑定地址和端口Bind(listenfd, (struct sockaddr *)&servaddr, sizeof(servaddr));// 设置监听队列长度Listen(listenfd, 20);// 循环接收客户端连接请求while (1) {Copy codecliaddr_len = sizeof(cliaddr);// 接收一个客户端连接connfd = Accept(listenfd, (struct sockaddr *)&cliaddr, &cliaddr_len);// Fork一个子进程处理连接pid = fork(); if (pid == 0) {// 子进程关闭监听socketClose(listenfd);// 处理客户端请求while (1) {// 接收客户端数据 n = Read(connfd, buf, MAXLINE);// 判断客户端是否关闭if (n == 0) {printf("the other side has been closed.\n");break;}// 打印客户端信息printf("received from %s at PORT %d\n",  inet_ntop(AF_INET, &cliaddr.sin_addr, str, sizeof(str)),ntohs(cliaddr.sin_port));// 转换为大写for (i = 0; i < n; i++)buf[i] = toupper(buf[i]);// 发送转换后数据Write(connfd, buf, n);}// 关闭连接 Close(connfd);return 0;} else if (pid > 0) {// 父进程关闭连接socketClose(connfd); } elseperr_exit("fork");
}// 关闭监听socket
Close(listenfd);return 0;
}/* client.c */#include <stdio.h>#include <string.h>#include <unistd.h>#include <netinet/in.h>#include "wrap.h"#define MAXLINE 80
#define SERV_PORT 6666int main(int argc, char *argv[]) {// 服务器地址结构struct sockaddr_in servaddr;// 数据缓冲区char buf[MAXLINE];// socket和读字节数int sockfd, n;// 创建socketsockfd = Socket(AF_INET, SOCK_STREAM, 0);// 初始化服务器地址结构bzero(&servaddr, sizeof(servaddr));servaddr.sin_family = AF_INET;inet_pton(AF_INET, "127.0.0.1", &servaddr.sin_addr);servaddr.sin_port = htons(SERV_PORT);// 连接服务器Connect(sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr));// 循环发送接收数据while (fgets(buf, MAXLINE, stdin) != NULL) {Copy code// 发送数据到服务器Write(sockfd, buf, strlen(buf));  // 从服务器读取数据n = Read(sockfd, buf, MAXLINE);// 判断服务器是否关闭if (n == 0) {printf("the other side has been closed.\n");break;} else// 输出服务器返回数据Write(STDOUT_FILENO, buf, n);}// 关闭连接Close(sockfd);return 0;
}

多线程服务器

一个进程内创建线程处理每个连接请求。

 优点：高效利用多核CPU，创建和销毁线程开销较小。

 缺点：需要调整进程的文件描述符限制，需要进行线程同步，线程退出时需要进行资源清理。

 相关API函数：pthread_create、pthread_detach、pthread_join、pthread_mutex_init、pthread_mutex_lock、pthread_mutex_unlock、socket、bind、listen、accept、read、write、close

要点:

  • 调整进程文件描述符限制
  • 共享数据同步
  • 线程退出处理,防止资源泄漏
  • 过多线程会降低性能

 例程分享：

/*
服务器端创建监听套接字,绑定地址并监听。
主循环调用accept接收客户端连接,为每个客户端创建线程do_work处理请求。
do_work通过read接收客户端数据,转换为大写后返回。
客户端创建连接后,循环发送数据和读取服务器返回数据。
服务器使用线程处理每个连接请求,可以处理大量连接。
通过传递参数,线程可以获取客户端信息。
设置线程分离态,自动回收资源,实现高效的多线程服务器。
*//* server.c */#include <stdio.h> // 标准输入输出头文件#include <string.h> // 字符串处理头文件#include <netinet/in.h> // socket编程头文件#include <arpa/inet.h> // inet地址转换头文件#include <pthread.h> // 线程编程头文件#include "wrap.h" // 封装的socket函数头文件#define MAXLINE 80 //最大读取字符数#define SERV_PORT 6666 //服务器端口// 用于传递给线程的客户信息
struct s_info {
struct sockaddr_in cliaddr; // 客户socket地址
int connfd; // 客户端连接套接字
};// 线程处理函数
void *do_work(void *arg) {int n,i;struct s_info *ts = (struct s_info*)arg; // 获取传递的参数char buf[MAXLINE]; // 数据缓冲区char str[INET_ADDRSTRLEN]; // 存储socket地址的字符串// 设置线程为分离态,线程结束时自动释放资源pthread_detach(pthread_self());while (1) {// 获取客户端发送的数据n = Read(ts->connfd, buf, MAXLINE);  if (n == 0) { // 对端关闭连接printf("the other side has been closed.\n");break;}// 打印客户端信息printf("received from %s at PORT %d\n",inet_ntop(AF_INET, &(*ts).cliaddr.sin_addr, str, sizeof(str)),ntohs((*ts).cliaddr.sin_port));// 将数据转换为大写for (i = 0; i < n; i++)buf[i] = toupper(buf[i]);// 发送转换后的数据Write(ts->connfd, buf, n);}// 关闭客户端连接Close(ts->connfd);
}int main(void) {struct sockaddr_in servaddr, cliaddr; // 本地和客户端的socket地址socklen_t cliaddr_len; // 客户端socket地址长度int listenfd, connfd; // 监听和连接套接字int i = 0; pthread_t tid; // 线程idstruct s_info ts[256]; // 存储所有客户端信息的数组// 创建监听套接字listenfd = Socket(AF_INET, SOCK_STREAM, 0);// 初始化本地socket地址结构bzero(&servaddr, sizeof(servaddr));servaddr.sin_family = AF_INET; servaddr.sin_addr.s_addr = htonl(INADDR_ANY);servaddr.sin_port = htons(SERV_PORT);// 绑定监听套接字到本地地址Bind(listenfd, (struct sockaddr *)&servaddr, sizeof(servaddr));// 设置监听队列长度Listen(listenfd, 20);printf("Accepting connections ...\n");// 循环接收客户端连接while (1) {  // 接收一个客户端连接cliaddr_len = sizeof(cliaddr);connfd = Accept(listenfd, (struct sockaddr *)&cliaddr, &cliaddr_len);// 保存客户信息ts[i].cliaddr = cliaddr;  ts[i].connfd = connfd;// 为客户端创建线程处理请求pthread_create(&tid, NULL, do_work, (void*)&ts[i]);i++;}return 0;
}/* client.c */#include <stdio.h>#include <string.h>#include <unistd.h>#include <netinet/in.h>#include "wrap.h"#define MAXLINE 80
#define SERV_PORT 6666int main(int argc, char *argv[])struct sockaddr_in servaddr; // 服务器端地址结构char buf[MAXLINE]; // 数据缓冲区int sockfd, n; // 套接字和读返回值// 创建流式套接字sockfd = Socket(AF_INET, SOCK_STREAM, 0);// 初始化服务器地址结构bzero(&servaddr, sizeof(servaddr));servaddr.sin_family = AF_INET;inet_pton(AF_INET, "127.0.0.1", &servaddr.sin_addr); servaddr.sin_port = htons(SERV_PORT);// 连接服务器Connect(sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr));// 循环发送数据和读取服务器返回数据while (fgets(buf, MAXLINE, stdin) != NULL) {   // 向服务器发送数据Write(sockfd, buf, strlen(buf));  // 从服务器读取数据n = Read(sockfd, buf, MAXLINE);// 判断服务器是否关闭if (n == 0)printf("the other side has been closed.\n");else// 输出服务器返回数据Write(STDOUT_FILENO, buf, n);}// 关闭socket连接Close(sockfd);return 0;
}

I/O多路复用服务器

select/poll/epoll使单线程可以同时处理多个连接请求。

select

优点: 可移植,使用简单。

缺点: 连接数受限,监听效率低。

要点:

  • select监听读写事件
  • 每次循环重置监听描述符
  • 根据返回就绪数遍历处理事件
  • 根据描述符状态处理连接关闭等
例程分享：
/*
服务器端初始化socket地址,创建监听套接字。
使用select()监听套接字可读事件。
调用accept()接收客户端连接请求。
添加新的连接到select监听的文件描述符集。
循环扫描就绪文件描述符,调用read()接收客户端数据。
对数据进行处理后,调用write()返回给客户端。
客户端创建连接后,循环read()和write()实现双向通信。
服务器使用select()处理多个连接,但依然是同步阻塞模型
*//* server.c *//* server.c */
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include "wrap.h" // 这是一个自定义的头文件，封装了socket函数#define MAXLINE 80 // 缓冲区的最大长度
#define SERV_PORT 6666 // 服务器端口号int main(int argc, char *argv[])
{int i, maxi, maxfd, listenfd, connfd, sockfd;int nready, client[FD_SETSIZE]; // FD_SETSIZE通常为1024ssize_t n;fd_set rset, allset; // 用于select()的文件描述符集char buf[MAXLINE]; // 数据缓冲区char str[INET_ADDRSTRLEN]; // 地址字符串缓冲区socklen_t cliaddr_len;struct sockaddr_in cliaddr, servaddr; // 客户端和服务器地址结构listenfd = Socket(AF_INET, SOCK_STREAM, 0); // 创建一个socketbzero(&servaddr, sizeof(servaddr)); // 清零服务器地址结构servaddr.sin_family = AF_INET; // 设置地址族为IPv4servaddr.sin_addr.s_addr = htonl(INADDR_ANY); // 监听任何接口servaddr.sin_port = htons(SERV_PORT); // 设置端口号Bind(listenfd, (struct sockaddr *)&servaddr, sizeof(servaddr)); // 将socket绑定到地址Listen(listenfd, 20); // 监听连接，队列长度为20maxfd = listenfd; // 初始化maxfdmaxi = -1; // 初始化maxifor (i = 0; i < FD_SETSIZE; i++)client[i] = -1; // 初始化client[]FD_ZERO(&allset); // 清空allsetFD_SET(listenfd, &allset); // 将listenfd添加到allsetfor ( ; ; ) { // 主服务器循环rset = allset; // 每次循环都重置rsetnready = select(maxfd+1, &rset, NULL, NULL, NULL); // 调用select()if (nready < 0)perr_exit("select error"); // 如果select()返回错误，退出if (FD_ISSET(listenfd, &rset)) { // 如果有新的客户端正在连接cliaddr_len = sizeof(cliaddr);connfd = Accept(listenfd, (struct sockaddr *)&cliaddr, &cliaddr_len); // 接受新的连接printf("received from %s at PORT %d\n",inet_ntop(AF_INET, &cliaddr.sin_addr, str, sizeof(str)),ntohs(cliaddr.sin_port)); // 打印客户端的地址和端口for (i = 0; i < FD_SETSIZE; i++) {if (client[i] < 0) {client[i] = connfd; // 将接受的文件描述符保存在client[]中break;}}if (i == FD_SETSIZE) {fputs("too many clients\n", stderr); // 如果连接的客户端过多，打印错误并退出exit(1);}FD_SET(connfd, &allset); // 将新的文件描述符添加到allsetif (connfd > maxfd)maxfd = connfd; // 如果需要，更新maxfdif (i > maxi)maxi = i; // 如果需要，更新maxiif (--nready == 0)continue; // 如果没有更多的就绪文件描述符，继续下一次循环}for (i = 0; i <= maxi; i++) { // 检查哪些客户端有数据准备好读取if ( (sockfd = client[i]) < 0)continue;if (FD_ISSET(sockfd, &rset)) {if ( (n = Read(sockfd, buf, MAXLINE)) == 0) {Close(sockfd); // 如果客户端已经关闭了连接，也关闭服务器端FD_CLR(sockfd, &allset); // 从allset中移除文件描述符client[i] = -1; // 从client[]中移除文件描述符} else {int j;for (j = 0; j < n; j++)buf[j] = toupper(buf[j]); // 将数据转换为大写Write(sockfd, buf, n); // 将数据写回客户端}if (--nready == 0)break; // 如果没有更多的就绪文件描述符，跳出循环}}}close(listenfd); // 关闭监听的socketreturn 0;
}/* client.c *//* client.c */
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <netinet/in.h>
#include "wrap.h" // 这是一个自定义的头文件，封装了socket函数#define MAXLINE 80 // 缓冲区的最大长度
#define SERV_PORT 6666 // 服务器端口号int main(int argc, char *argv[])
{struct sockaddr_in servaddr; // 服务器地址结构char buf[MAXLINE]; // 数据缓冲区int sockfd, n; // Socket文件描述符和读取的字节数sockfd = Socket(AF_INET, SOCK_STREAM, 0); // 创建一个socketbzero(&servaddr, sizeof(servaddr)); // 清零服务器地址结构servaddr.sin_family = AF_INET; // 设置地址族为IPv4inet_pton(AF_INET, "127.0.0.1", &servaddr.sin_addr); // 设置服务器的IP地址servaddr.sin_port = htons(SERV_PORT); // 设置端口号Connect(sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr)); // 连接到服务器while (fgets(buf, MAXLINE, stdin) != NULL) { // 主客户端循环Write(sockfd, buf, strlen(buf)); // 将输入写入服务器n = Read(sockfd, buf, MAXLINE); // 读取服务器的响应if (n == 0)printf("the other side has been closed.\n"); // 如果服务器已经关闭了连接，打印一条消息elseWrite(STDOUT_FILENO, buf, n); // 将服务器的响应写入stdout}Close(sockfd); // 关闭socketreturn 0;
}

poll

优点: 没有连接数限制。

缺点: 依然轮询模型,效率低。

要点:

  • pollfd结构体监听事件
  • 每次循环遍历pollfd处理就绪事件
  • 根据返回事件和错误处理连接状态
例程分享：
/*
服务器端:
创建监听socket,绑定地址并监听
使用pollfd数组保存所有连接的文件描述符
调用poll监听socket上的事件,主要是POLLRDNORM读事件
当监听socket有事件时,表示有新连接,调用accept获取新连接
将新连接的文件描述符添加到pollfd数组中,继续监听读事件
当连接socket有读事件时,调用read读取客户端数据
对数据进行转换处理,调用write将数据返回给客户端
根据返回事件和错误情况判断连接是否正常
客户端:
创建socket,连接服务器地址
循环调用read读取用户输入
调用write将用户输入发送给服务器
调用read读取服务器返回数据
将服务器数据输出到标准输出
关闭连接
*//* server.c */
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <poll.h>
#include <errno.h>
#include "wrap.h" // 这是一个自定义的头文件，封装了socket函数#define MAXLINE 80 // 缓冲区的最大长度
#define SERV_PORT 6666 // 服务器端口号
#define OPEN_MAX 1024 // 最大的打开文件描述符数量int main(int argc, char *argv[])
{int i, j, maxi, listenfd, connfd, sockfd;int nready;ssize_t n;char buf[MAXLINE], str[INET_ADDRSTRLEN];socklen_t clilen;struct pollfd client[OPEN_MAX]; // pollfd结构体数组，用于存储多个文件描述符struct sockaddr_in cliaddr, servaddr; // 客户端和服务器地址结构listenfd = Socket(AF_INET, SOCK_STREAM, 0); // 创建一个socketbzero(&servaddr, sizeof(servaddr)); // 清零服务器地址结构servaddr.sin_family = AF_INET; // 设置地址族为IPv4servaddr.sin_addr.s_addr = htonl(INADDR_ANY); // 监听任何接口servaddr.sin_port = htons(SERV_PORT); // 设置端口号Bind(listenfd, (struct sockaddr *)&servaddr, sizeof(servaddr)); // 将socket绑定到地址Listen(listenfd, 20); // 监听连接，队列长度为20client[0].fd = listenfd;client[0].events = POLLRDNORM; // listenfd监听普通读事件for (i = 1; i < OPEN_MAX; i++)client[i].fd = -1; // 用-1初始化client[]里剩下元素maxi = 0; // client[]数组有效元素中最大元素下标for ( ; ; ) { // 主服务器循环nready = poll(client, maxi+1, -1); // 调用poll()函数，阻塞等待文件描述符就绪if (client[0].revents & POLLRDNORM) { // 有客户端链接请求clilen = sizeof(cliaddr);connfd = Accept(listenfd, (struct sockaddr *)&cliaddr, &clilen); // 接受新的连接printf("received from %s at PORT %d\n",inet_ntop(AF_INET, &cliaddr.sin_addr, str, sizeof(str)),ntohs(cliaddr.sin_port)); // 打印客户端的地址和端口for (i = 1; i < OPEN_MAX; i++) {if (client[i].fd < 0) {client[i].fd = connfd; // 找到client[]中空闲的位置，存放accept返回的connfdbreak;}}if (i == OPEN_MAX)perr_exit("too many clients"); // 如果连接的客户端过多，打印错误并退出client[i].events = POLLRDNORM; // 设置刚刚返回的connfd，监控读事件if (i > maxi)maxi = i; // 更新client[]中最大元素下标if (--nready <= 0)continue; // 没有更多就绪事件时,继续回到poll阻塞}for (i = 1; i <= maxi; i++) { // 检测client[]if ((sockfd = client[i].fd) < 0)continue;if (client[i].revents & (POLLRDNORM | POLLERR)) { // 如果有数据可读或者有错误发生if ((n = Read(sockfd, buf, MAXLINE)) < 0) {if (errno == ECONNRESET) { // 当收到 RST标志时/* connection reset by client */printf("client[%d] aborted connection\n", i);Close(sockfd); // 关闭socketclient[i].fd = -1; // 从client[]中移除文件描述符} else {perr_exit("read error"); // 如果读取错误，退出}} else if (n == 0) {/* connection closed by client */printf("client[%d] closed connection\n", i);Close(sockfd); // 关闭socketclient[i].fd = -1; // 从client[]中移除文件描述符} else {for (j = 0; j < n; j++)buf[j] = toupper(buf[j]); // 将数据转换为大写Writen(sockfd, buf, n); // 将数据写回客户端}if (--nready <= 0)break; // 如果没有更多的就绪文件描述符，跳出循环}}}return 0;
}/* client.c */
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <netinet/in.h>
#include "wrap.h" // 这是一个自定义的头文件，封装了socket函数#define MAXLINE 80 // 缓冲区的最大长度
#define SERV_PORT 6666 // 服务器端口号int main(int argc, char *argv[])
{struct sockaddr_in servaddr; // 服务器地址结构char buf[MAXLINE]; // 数据缓冲区int sockfd, n; // Socket文件描述符和读取的字节数sockfd = Socket(AF_INET, SOCK_STREAM, 0); // 创建一个socketbzero(&servaddr, sizeof(servaddr)); // 清零服务器地址结构servaddr.sin_family = AF_INET; // 设置地址族为IPv4inet_pton(AF_INET, "127.0.0.1", &servaddr.sin_addr); // 设置服务器的IP地址servaddr.sin_port = htons(SERV_PORT); // 设置端口号Connect(sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr)); // 连接到服务器while (fgets(buf, MAXLINE, stdin) != NULL) { // 主客户端循环Write(sockfd, buf, strlen(buf)); // 将输入写入服务器n = Read(sockfd, buf, MAXLINE); // 读取服务器的响应if (n == 0)printf("the other side has been closed.\n"); // 如果服务器已经关闭了连接，打印一条消息elseWrite(STDOUT_FILENO, buf, n); // 将服务器的响应写入stdout}Close(sockfd); // 关闭socketreturn 0;
}

epoll

优点：提高程序在大量并发连接中的系统CPU利用率，能够高效处理大量并发请求。

缺点：需要调整进程的文件描述符限制，需要进行连接管理。

要点:

  • epoll_create创建句柄
  • epoll_ctl注册和控制事件
  • epoll_wait等待就绪事件
  • 根据就绪事件处理请求
例程分享：
/*
服务器端：
服务器端的代码主要完成以下任务：创建一个TCP socket并绑定到指定的IP地址和端口。
使用epoll创建一个事件监听列表，并将监听socket添加到这个列表中。
进入一个无限循环，使用epoll_wait()函数等待事件的发生。
当新的客户端连接时，接受连接并将新的socket添加到epoll的监听列表中。
当已连接的客户端发送数据时，读取数据，将数据转换为大写，然后将数据回写到客户端。
当客户端关闭连接时，从epoll的监听列表中移除这个socket，并关闭这个socket。
客户端端：
客户端的代码主要完成以下任务：创建一个TCP socket并连接到服务器。
进入一个无限循环，从stdin读取输入，将输入写入服务器，然后读取服务器的响应并将响应写入stdout。
当服务器关闭连接时，打印一条消息并退出循环。
*//* server.c */
// ...省略部分代码...// 创建一个TCP socket
listenfd = Socket(AF_INET, SOCK_STREAM, 0);// 清零服务器地址结构
bzero(&servaddr, sizeof(servaddr));
// 设置地址族为IPv4
servaddr.sin_family = AF_INET;
// 监听任何接口
servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
// 设置端口号
servaddr.sin_port = htons(SERV_PORT);// 将socket绑定到地址
Bind(listenfd, (struct sockaddr *) &servaddr, sizeof(servaddr));// 监听连接，队列长度为20
Listen(listenfd, 20);// 创建epoll实例
efd = epoll_create(OPEN_MAX);
if (efd == -1)perr_exit("epoll_create");// 设置监听事件为EPOLLIN（可读事件），并将listenfd添加到epoll的监听列表中
tep.events = EPOLLIN; tep.data.fd = listenfd;
res = epoll_ctl(efd, EPOLL_CTL_ADD, listenfd, &tep);
if (res == -1)perr_exit("epoll_ctl");// 主服务器循环
while (1) {// 调用epoll_wait()函数，阻塞等待文件描述符就绪nready = epoll_wait(efd, ep, OPEN_MAX, -1);if (nready == -1)perr_exit("epoll_wait");// 遍历就绪的文件描述符for (i = 0; i < nready; i++) {// 如果不是可读事件，跳过if (!(ep[i].events & EPOLLIN))continue;// 如果是新的客户端连接if (ep[i].data.fd == listenfd) {// 接受新的连接clilen = sizeof(cliaddr);connfd = Accept(listenfd, (struct sockaddr *)&cliaddr, &clilen);printf("received from %s at PORT %d\n", inet_ntop(AF_INET, &cliaddr.sin_addr, str, sizeof(str)), ntohs(cliaddr.sin_port));// 将新的socket添加到epoll的监听列表中tep.events = EPOLLIN; tep.data.fd = connfd;res = epoll_ctl(efd, EPOLL_CTL_ADD, connfd, &tep);if (res == -1)perr_exit("epoll_ctl");} else {// 如果是已连接的客户端发送的数据sockfd = ep[i].data.fd;n = Read(sockfd, buf, MAXLINE);if (n == 0) {// 如果客户端关闭了连接，从epoll的监听列表中移除这个socket，并关闭这个socketres = epoll_ctl(efd, EPOLL_CTL_DEL, sockfd, NULL);if (res == -1)perr_exit("epoll_ctl");Close(sockfd);printf("client[%d] closed connection\n", j);} else {// 如果接收到数据，将数据转换为大写，然后将数据回写到客户端for (j = 0; j < n; j++)buf[j] = toupper(buf[j]);Writen(sockfd, buf, n);}}}
}
// 关闭监听socket和epoll实例
close(listenfd);
close(efd);
return 0;/* client.c */
// ...省略部分代码...// 创建一个TCP socket
sockfd = Socket(AF_INET, SOCK_STREAM, 0);// 清零服务器地址结构
bzero(&servaddr, sizeof(servaddr));
// 设置地址族为IPv4
servaddr.sin_family = AF_INET;
// 设置服务器的IP地址
inet_pton(AF_INET, "127.0.0.1", &servaddr.sin_addr);
// 设置端口号
servaddr.sin_port = htons(SERV_PORT);// 连接到服务器
Connect(sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr));// 主客户端循环
while (fgets(buf, MAXLINE, stdin) != NULL) {// 将输入写入服务器Write(sockfd, buf, strlen(buf));// 读取服务器的响应n = Read(sockfd, buf, MAXLINE);if (n == 0)// 如果服务器已经关闭了连接，打印一条消息printf("the other side has been closed.\n");else// 将服务器的响应写入stdoutWrite(STDOUT_FILENO, buf, n);
}// 关闭socket
Close(sockfd);
return 0;

总结建议

        epoll服务器根据不同的需求和场景，我们可以选择不同的高并发服务器设计方案。多进程服务器、多线程服务器、I/O多路复用服务器和epoll服务器都有各自的优缺点和适用场景。通过分享的例程和相关API函数的介绍，读者可以更好地理解和选择适合自己需求的设计方案，从而高效处理大量并发请求，满足互联网快速发展的需求。

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

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

相关文章

C#自动实现Dll(OCX)控件注册的两种方法

C#自动实现Dll(OCX)控件注册的两种方法

尽管MS为我们提供了丰富的.net framework库&#xff0c;我们的程序C#开发带来了极大的便利&#xff0c;但是有时候&#xff0c;一些特定功能的控件库还是需要由第三方提供或是自己编写。当需要用到Dll引用的时候&#xff0c;我们通常会通过“添加引用”的方式将它们纳入到项目中…
阅读更多...
PyCharm+Python3转换xls文件为xlsx文件格式

PyCharm+Python3转换xls文件为xlsx文件格式

import os import os.path import win32com.client as win32"""主函数功能测试""" if __name__ __main__:xlsFilePath os.path.join(os.getcwd() "\\" "通知单.xls")# 文件存在就加载&#xff0c;不存在就提示检查。if …
阅读更多...
全网最详细 Python如何读取NIFTI格式图像（.nii文件）和 .npy格式文件和pkl标签文件内容

全网最详细 Python如何读取NIFTI格式图像（.nii文件）和 .npy格式文件和pkl标签文件内容

在医学图像处理中&#xff0c;我们经常使用一种NIFTI格式图像&#xff08;.nii文件&#xff09;&#xff0c;现在我们来看看 什么是.nii文件&#xff1f;该如何读取.nii文件&#xff1f; 1. NIFTI格式图像 什么是NIFTI&#xff08;Neuroimaging Informatics Technology Initia…
阅读更多...
十三、PyQt5的QFileDialog文件打开、文件保存、文件夹选择对话框

十三、PyQt5的QFileDialog文件打开、文件保存、文件夹选择对话框

import PyQt5.QtCore,PyQt5.QtGui # 获取文件路径对话框 file_name = QFileDialog.getOpenFileName(self,"打开文件","C:\\Users\\Administrator\\Desktop","Txt files(*.txt)") ##"open file Dialog "为文件对话框的标题，第三个是打…
阅读更多...
Spring Boot 最佳实践（三）模板引擎FreeMarker集成

Spring Boot 最佳实践（三）模板引擎FreeMarker集成

一、FreeMaker介绍 FreeMarker是一款免费的Java模板引擎&#xff0c;是一种基于模板和数据生成文本&#xff08;HMLT、电子邮件、配置文件、源代码等&#xff09;的工具&#xff0c;它不是面向最终用户的&#xff0c;而是一款程序员使用的组件。 FreeMarker最初设计是用来在M…
阅读更多...
Android开发之通过浏览器链接打开任意app页面

Android开发之通过浏览器链接打开任意app页面

老套路先上图&#xff1a; 先说下上面的流程&#xff0c;第一张图是模拟浏览器的网页点击链接打开app,第二张图系统弹框提示是否打开app,第三张图已打开APP&#xff0c;弹出的吐司是打开APP携带的数据 具体实现分为两步&#xff0c;第一步配置你要打开的activity页面如下&…
阅读更多...
windows2008C盘清理

windows2008C盘清理

因为原来的设计&#xff0c;现在C盘的空间只有2G了&#xff0c;今天在网上看到了清理的方法&#xff0c;居然清理出4G出来&#xff0c;先把方法记录下来&#xff0c;以备以后使用。我们建议您通过以下方法来清理C盘空间&#xff1a;1.尽量不要在C盘安装应用软件&#xff0c;在软…
阅读更多...
DVWA下载、安装、使用（漏洞测试环境搭建）教程

DVWA下载、安装、使用（漏洞测试环境搭建）教程

DVWA&#xff08;Damn Vulnerable Web Application&#xff09;是一个用来进行安全脆弱性鉴定的PHP/MySQL Web应用&#xff0c;旨在为安全专业人员测试自己的专业技能和工具提供合法的环境&#xff0c;帮助web开发者更好的理解web应用安全防范的过程。 一共有十个模块&#xf…
阅读更多...
Spring Boot 最佳实践（四）模板引擎Thymeleaf集成

Spring Boot 最佳实践（四）模板引擎Thymeleaf集成

## 一、Thymeleaf介绍 Thymeleaf是一种Java XML / XHTML / HTML5模板引擎&#xff0c;可以在Web和非Web环境中使用。它更适合在基于MVC的Web应用程序的视图层提供XHTML / HTML5&#xff0c;但即使在脱机环境中&#xff0c;它也可以处理任何XML文件。它提供了完整的Spring Fram…
阅读更多...
Centos7安装Postgresql 13 详细步骤（远程连接）

Centos7安装Postgresql 13 详细步骤（远程连接）

版本信息 CentOS &#xff1a; 7.6 postgresql&#xff1a; 10.012 安装 可以参考官网PostgreSQL: Linux downloads (Red Hat family) &#xff03;安装存储库RPM&#xff1a; sudo yum install -y https://download.postgresql.org/pub/repos/yum/reporpms/EL-7-x86_64/pgd…
阅读更多...
mysql复制： 一个master对应1个slave

mysql复制： 一个master对应1个slave

2019独角兽企业重金招聘Python工程师标准>>> 复制的步骤&#xff1a;1.在主库上开启二进制日志&#xff0c;把数据更改记录到二进制日志(binary log)中. mysql会按照事物提交的顺序而非每条语句的执行顺序来记录二进制日志&#xff0c;在记录二进制日志后&#xff…
阅读更多...
python3、sqlmap下载与安装教程

python3、sqlmap下载与安装教程

一 、前提 需要安装python3&#xff0c;可以参考其他教程 二 、下载 官网下载http://sqlmap.org/ 三 、安装 将下载的sqlmap.zip解压到文件夹sqlmap中&#xff0c;并拷贝到Python安装路径下 四、 配置 在桌面上创建一个cmd进入python的快捷方式&#xff08;这步可以不做…
阅读更多...
Spring Boot 最佳实践（五）Spring Data JPA 操作 MySQL 8

Spring Boot 最佳实践（五）Spring Data JPA 操作 MySQL 8

## 一、Spring Data JPA 介绍 JPA&#xff08;Java Persistence API&#xff09;Java持久化API&#xff0c;是 Java 持久化的标准规范&#xff0c;Hibernate是持久化规范的技术实现&#xff0c;而Spring Data JPA是在 Hibernate 基础上封装的一款框架。 开发环境 Spring Boo…
阅读更多...
Windows MinGW配置C、C++编译环境

Windows MinGW配置C、C++编译环境

写在前面的前面&#xff1a;这篇文章vscode和cpp插件版本有点老了&#xff0c;仅供大家参考&#xff0c;最新的和最详细的更新见我的另一篇文章&#xff1a;整理&#xff1a;Visual Studio Code (vscode) 配置C、C环境/编写运行C、C&#xff08;主要Windows、简要Linux&#xf…
阅读更多...
Burpsuite超详细安装教程

Burpsuite超详细安装教程

版权声明&#xff1a;本文为博主原创文章&#xff0c;遵循 CC 4.0 BY-SA 版权协议&#xff0c;转载请附上原文出处链接和本声明。 本文转载于链接&#xff1a;https://blog.csdn.net/LUOBIKUN/article/details/87457545 Burpsuite的超详细安装教程 概述工具分享安装一&#xff…
阅读更多...
分析容灾备份建设需求

分析容灾备份建设需求

重要信息系统灾难备份需求分析应包括对数据处理中心的风险分析和对重要信息系统的业务分析&#xff0c;以确定灾难恢复目标。① 数据处理中心风险分析分析数据处理中心的风险&#xff0c;如物理安全&#xff0c;数据安全&#xff0c;人为因素&#xff0c;已有的容灾备份建设和L…
阅读更多...
使用Hexo搭建个人博客的终极资料

使用Hexo搭建个人博客的终极资料

# 一、前言 Hexo 是一个基于 NodeJs 博客框架&#xff0c;可以快速的帮我们搭建一个博客系统&#xff0c;Hexo使用的是Markdown&#xff08;下文简称MD&#xff09;解析文章的&#xff0c;在几秒内即可利用靓丽的主体生成静态网页。 推荐使用 Hexo 有三大理由&#xff1a; 有…
阅读更多...
Linux Ubuntu 安装编译Opencv 3.4.3 C++开发环境

Linux Ubuntu 安装编译Opencv 3.4.3 C++开发环境

在安装Autoware之前&#xff0c;需要先安装Opencv&#xff0c;之前在Windows下安装了Opencv&#xff0c;挺复杂的。不过&#xff0c;在Ubuntu 16.04环境中配置安装Opencv相对来说&#xff0c;比较简单。 Linux Ubuntu 安装编译Opencv 3.4.3 C开发环境 1.1 下载Opencv 3.4.3 …
阅读更多...
[原创]状态值在数据库中的检索

[原创]状态值在数据库中的检索

对于关系型数据库而言&#xff0c;针对表的检索&#xff0c;一般来说&#xff0c;建立合适的索引就可以达到很好的检索效果。&#xff08;这里不包含表设计的合理与否&#xff09;比如像状态列这样可选择性非常低的值&#xff0c;该如何检索&#xff1f; 其实这个已经不是关系…
阅读更多...
Spring Boot（六）集成 MyBatis 操作 MySQL 8

Spring Boot（六）集成 MyBatis 操作 MySQL 8

## 一、简介 1.1 MyBatis介绍 MyBatis 是一款优秀的持久层框架&#xff0c;它支持定制化 SQL、存储过程以及高级映射。MyBatis 避免了几乎所有的 JDBC代码和手动设置参数以及获取结果集。 1.2 MyBatis发展史 MyBatis 原本是apache的一个开源项目iBatis, 2010年这个项目由ap…
阅读更多...
最新文章

Copyright @ 2022~2023