编程语言
首页 > 编程语言> > 网络编程之IO复用机制(多路IO转接)之使用网络套接字验证epoll的LT和ET08

网络编程之IO复用机制(多路IO转接)之使用网络套接字验证epoll的LT和ET08

作者:互联网

概述:
上一篇我们使用了本地的进程间通信管道去验证epoll的LT和ET模型。
下面我们继续使用网络套接字去验证epoll的LT和ET模型,这两篇文章都是为了验证epoll的两种模型,你可以挑一篇看即可,代码无需死记,因为作用不大,主要还是起验证作用。

1 使用网络套接字验证epoll的LT和ET

1.1 epoll的LT,ET模型是否阻塞和非阻塞总结
同样像上一篇一样,先总结epoll的两种模型。

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

同样拿上一篇的总结过来。

好了,本篇就是我们想要讲述的epoll的LT和ET模型,说难不难,说简单也不易,多看几篇就熟。

标签:epoll,网络,阻塞,LT,IO,ET,include,servaddr
来源: https://blog.csdn.net/weixin_44517656/article/details/113483014