概述:
上一篇我们使用了本地的进程间通信管道去验证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模型,说难不难,说简单也不易,多看几篇就熟。