标签：epoll 网络 阻塞 LT IO ET include servaddr
概述：
上一篇我们使用了本地的进程间通信管道去验证epoll的LT和ET模型。
下面我们继续使用网络套接字去验证epoll的LT和ET模型，这两篇文章都是为了验证epoll的两种模型，你可以挑一篇看即可，代码无需死记，因为作用不大，主要还是起验证作用。
1 使用网络套接字验证epoll的LT和ET
1.1 epoll的LT，ET模型是否阻塞和非阻塞总结
同样像上一篇一样，先总结epoll的两种模型。
- 1）epoll的LT模型支持阻塞和非阻塞。
- 2）epoll的ET模型只支持非阻塞，不支持阻塞。
1.2 epoll的LT
案例：客户端不断每隔5s像服务器发送10字节的数据，而服务器每次只读5字节内容，当我们使用LT模型时，服务器会读取剩余的5字节数据。
注意编码细节：为了方便测试，我们不像往常那样将lfd挂在epoll_wait红黑树上监听，我们整个程序只监听一个cfd即可(项目中不会这样使用)，也就是整个程序只能连接一个客户端，多的话会没反应。
server.c
#include <stdio.h>
#include <string.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <signal.h>
#include <sys/wait.h>
#include <sys/types.h>
#include <sys/epoll.h>
#include <unistd.h>
#define MAXLINE 10
#define SERV_PORT 9000
int main(void)
{
struct sockaddr_in servaddr, cliaddr;
socklen_t cliaddr_len;
int listenfd, connfd;
char buf[MAXLINE];
char str[INET_ADDRSTRLEN];
int efd;
listenfd = 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);
struct epoll_event event;
struct epoll_event resevent[10];
int res, len;
efd = epoll_create(10);
//event.events = EPOLLIN | EPOLLET; /* ET 边沿触发 */
event.events = EPOLLIN; /* 默认 LT 水平触发 */
printf("Accepting connections ...\n");
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));
event.data.fd = connfd;
epoll_ctl(efd, EPOLL_CTL_ADD, connfd, &event);
while (1) {
res = epoll_wait(efd, resevent, 10, -1);
//printf("res %d\n", res);
if (resevent[0].data.fd == connfd) {
len = read(connfd, buf, MAXLINE/2);
write(STDOUT_FILENO, buf, len);
sleep(1);
}
}
return 0;
}
client.c
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#define MAXLINE 10
#define SERV_PORT 9000
int main(int argc, char *argv[])
{
struct sockaddr_in servaddr;
char buf[MAXLINE];
int sockfd, i;
char ch = 'a';
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 (1) {
//aaaa\n
for (i = 0; i < MAXLINE/2; i++)
buf[i] = ch;
buf[i-1] = '\n';
ch++;
//bbbb\n
for (; i < MAXLINE; i++)
buf[i] = ch;
buf[i-1] = '\n';
ch++;
//aaaa\nbbbb\n
write(sockfd, buf, sizeof(buf));
sleep(5);
}
close(sockfd);
return 0;
}
1）首先客户端发送10字节数据，服务器先读5个字节，剩余5个字节在套接字的缓冲区，由于我们设置了LT模型，所以会使epoll_wait返回继续读取剩余5字节。
2）又过5s后，客户端又发送10字节，服务器继续按第一步这样读取，不断重复。
1.3epoll的ET
epoll的ET将上面服务器的代码从LT改成ET即可。但是由于epol的ET模型只支持非阻塞模型不支持阻塞模型(cfd默认是阻塞)，所以上面代码从LT改成ET虽然能执行，但是我们注意到改完之后变成ET模型的阻塞。某些场合很容易出现问题，当read改成readn后，readn的作用是只有读到一定字节才能返回，否则阻塞。那么epoll_wait和readn都会阻塞，当readn因客户端发送数据不足而阻塞时，此时尽管客户端再发送数据，epoll_wait也不能返回，因为readn卡住了，导致程序出现卡死。所以我们说ET模型是不支持阻塞。
实际上这一步上一篇用管道测试时简单模拟了现象，虽然没啥问题，但是绝对不能使用epoll的ET模型的阻塞。我也在测试时标注了这一点。
所以这里就不测试ET的阻塞了，因为意义不大，通过上面的解释理解后，记住epoll的总结就行。
2 总结epoll的LT和ET
同样拿上一篇的总结过来。
- 1）epoll的LT模型支持阻塞和非阻塞。
- 2）epoll的ET模型只支持非阻塞，不支持阻塞(看2.3的第4点)。
- 3）select，poll，epoll这些IO复用函数可以用在管道，mmap映射，套接字等文件描述符的场合。
好了，本篇就是我们想要讲述的epoll的LT和ET模型，说难不难，说简单也不易，多看几篇就熟。
标签：epoll,网络,阻塞,LT,IO,ET,include,servaddr 来源： https://blog.csdn.net/weixin_44517656/article/details/113483014
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。