linux网络编程(五)epoll进阶

简介: linux网络编程(五)epoll进阶

1. 事件模型


EPOLL事件有两种模型:

Edge Triggered (ET) 边缘触发只有数据到来才触发,不管缓存区中是否还有数据。

Light Triggered (LT) 水平触发只要有数据都会触发。


思考如下步骤:

1.假定我们已经把一个用来从管道中读取数据的文件描述符(rfd)添加到epoll描述符。

2.管道的另一端写入了2KB的数据

3.调用epoll_wait,并且它会返回rfd,说明它已经准备好读取操作

4.读取1KB的数据

5.调用epoll_wait…… 在这个过程中,有两种工作模式:


1.1 ET模式


ET模式即Edge Triggered工作模式。


如果我们在第1步将rfd添加到epoll描述符的时候使用了EPOLLET标志,那么在第5步调用epoll_wait之后将有可能会挂起,因为剩余的数据还存在于文件的输入缓冲区内,而且数据发出端还在等待一个针对已经发出数据的反馈信息。只有在监视的文件句柄上发生了某个事件的时候ET工作模式才会汇报事件。因此在第5步的时候,调用者可能会放弃等待仍在存在于文件输入缓冲区内的剩余数据。epoll工作在ET模式的时候,必须使用非阻塞套接口,以避免由于一个文件句柄的阻塞读/阻塞写操作把处理多个文件描述符的任务饿死。最好以下面的方式调用ET模式的epoll接口,在后面会介绍避免可能的缺陷。


1)基于非阻塞文件句柄

2)只有当read或者write返回EAGAIN(非阻塞读,暂时无数据)时才需要挂起、等待。但这并不是说每次read时都需要循环读,直到读到产生一个EAGAIN才认为此次事件处理完成,当read返回的读到的数据长度小于请求的数据长度时,就可以确定此时缓冲中已没有数据了,也就可以认为此事读事件已处理完成。


1.2 LT模式


LT模式即Level Triggered工作模式。


与ET模式不同的是,以LT方式调用epoll接口的时候,它就相当于一个速度比较快的poll,无论后面的数据是否被使用。


1.3 比较


LT(level triggered):LT是缺省的工作方式,并且同时支持block和no-block socket。在这种做法中,内核告诉你一个文件描述符是否就绪了,然后你可以对这个就绪的fd进行IO操作。如果你不作任何操作,内核还是会继续通知你的,所以,这种模式编程出错误可能性要小一点。传统的select/poll都是这种模型的代表。


ET(edge-triggered):ET是高速工作方式,只支持no-block socket。在这种模式下,当描述符从未就绪变为就绪时,内核通过epoll告诉你。然后它会假设你知道文件描述符已经就绪,并且不会再为那个文件描述符发送更多的就绪通知。请注意,如果一直不对这个fd作IO操作(从而导致它再次变成未就绪),内核不会发送更多的通知(only once).


2. 实例一


基于管道epoll ET触发模式

#include <stdio.h>
#include <stdlib.h>
#include <sys/epoll.h>
#include <errno.h>
#include <unistd.h>
#define MAXLINE 10
int main(int argc, char *argv[])
{
  int efd, i;
  int pfd[2];
  pid_t pid;
  char buf[MAXLINE], ch = 'a';
  pipe(pfd);
  pid = fork();
  if (pid == 0) {
  close(pfd[0]);
  while (1) {
    for (i = 0; i < MAXLINE/2; i++)
    buf[i] = ch;
    buf[i-1] = '\n';
    ch++;
    for (; i < MAXLINE; i++)
    buf[i] = ch;
    buf[i-1] = '\n';
    ch++;
    write(pfd[1], buf, sizeof(buf));
    sleep(2);
  }
  close(pfd[1]);
  } else if (pid > 0) {
  struct epoll_event event;
  struct epoll_event resevent[10];
  int res, len;
  close(pfd[1]);
  efd = epoll_create(10);
  /* event.events = EPOLLIN; */
  event.events = EPOLLIN | EPOLLET;  /* ET 边沿触发 ,默认是水平触发 */
  event.data.fd = pfd[0];
  epoll_ctl(efd, EPOLL_CTL_ADD, pfd[0], &event);
  while (1) {
    res = epoll_wait(efd, resevent, 10, -1);
    printf("res %d\n", res);
    if (resevent[0].data.fd == pfd[0]) {
    len = read(pfd[0], buf, MAXLINE/2);
    write(STDOUT_FILENO, buf, len);
    }
  }
  close(pfd[0]);
  close(efd);
  } else {
  perror("fork");
  exit(-1);
  }
  return 0;
}


3. 实例二


基于网络C/S模型的epoll ET触发模式

server
/* 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 8080
int main(void)
{
  struct sockaddr_in servaddr, cliaddr;
  socklen_t cliaddr_len;
  int listenfd, connfd;
  char buf[MAXLINE];
  char str[INET_ADDRSTRLEN];
  int i, 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 边沿触发 ,默认是水平触发 */
  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);
  }
  }
  return 0;
}
client
/* client.c */
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <netinet/in.h>
#define MAXLINE 10
#define SERV_PORT 8080
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) {
  for (i = 0; i < MAXLINE/2; i++)
    buf[i] = ch;
  buf[i-1] = '\n';
  ch++;
  for (; i < MAXLINE; i++)
    buf[i] = ch;
  buf[i-1] = '\n';
  ch++;
  write(sockfd, buf, sizeof(buf));
  sleep(10);
  }
  Close(sockfd);
  return 0;
}


4.实例三


基于网络C/S非阻塞模型的epoll ET触发模式

server
/* server.c */
#include <stdio.h>
#include <string.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/wait.h>
#include <sys/types.h>
#include <sys/epoll.h>
#include <unistd.h>
#include <fcntl.h>
#define MAXLINE 10
#define SERV_PORT 8080
int main(void)
{
  struct sockaddr_in servaddr, cliaddr;
  socklen_t cliaddr_len;
  int listenfd, connfd;
  char buf[MAXLINE];
  char str[INET_ADDRSTRLEN];
  int i, efd, flag;
  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; */
  event.events = EPOLLIN | EPOLLET;  /* ET 边沿触发 ,默认是水平触发 */
  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));
  flag = fcntl(connfd, F_GETFL);
  flag |= O_NONBLOCK;
  fcntl(connfd, F_SETFL, flag);
  event.data.fd = connfd;
  epoll_ctl(efd, EPOLL_CTL_ADD, connfd, &event);
  while (1) {
  printf("epoll_wait begin\n");
  res = epoll_wait(efd, resevent, 10, -1);
  printf("epoll_wait end res %d\n", res);
  if (resevent[0].data.fd == connfd) {
    while ((len = read(connfd, buf, MAXLINE/2)) > 0)
    write(STDOUT_FILENO, buf, len);
  }
  }
  return 0;
}


client
/* client.c */
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <netinet/in.h>
#define MAXLINE 10
#define SERV_PORT 8080
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) {
  for (i = 0; i < MAXLINE/2; i++)
    buf[i] = ch;
  buf[i-1] = '\n';
  ch++;
  for (; i < MAXLINE; i++)
    buf[i] = ch;
  buf[i-1] = '\n';
  ch++;
  write(sockfd, buf, sizeof(buf));
  sleep(10);
  }
  Close(sockfd);
  return 0;
}
相关文章
在 Linux 系统中,网络管理是重要任务。本文介绍了常用的网络命令及其适用场景
在 Linux 系统中,网络管理是重要任务。本文介绍了常用的网络命令及其适用场景,包括 ping(测试连通性)、traceroute(跟踪路由路径)、netstat(显示网络连接信息)、nmap(网络扫描)、ifconfig 和 ip(网络接口配置)。掌握这些命令有助于高效诊断和解决网络问题,保障网络稳定运行。
150 2
Linux(openwrt)下iptables+tc工具实现网络流量限速控制(QoS)
通过以上步骤,您可以在Linux(OpenWrt)系统中使用iptables和tc工具实现网络流量限速控制(QoS)。这种方法灵活且功能强大,可以帮助管理员有效管理网络带宽,确保关键业务的网络性能。希望本文能够为您提供有价值的参考。
85 28
深入解析:Linux网络配置工具ifconfig与ip命令的全面对比
虽然 `ifconfig`作为一个经典的网络配置工具,简单易用,但其功能已经不能满足现代网络配置的需求。相比之下,`ip`命令不仅功能全面,而且提供了一致且简洁的语法,适用于各种网络配置场景。因此,在实际使用中,推荐逐步过渡到 `ip`命令,以更好地适应现代网络管理需求。
38 11
Ubuntu20.04搭建嵌入式linux网络加载内核、设备树和根文件系统
使用上述U-Boot命令配置并启动嵌入式设备。如果配置正确,设备将通过TFTP加载内核和设备树,并通过NFS挂载根文件系统。
106 15
|
2月前
|
Linux网络文件系统NFS:配置与管理指南
NFS 是 Linux 系统中常用的网络文件系统协议,通过配置和管理 NFS,可以实现跨网络的文件共享。本文详细介绍了 NFS 的安装、配置、管理和常见问题的解决方法,希望对您的工作有所帮助。通过正确配置和优化 NFS,可以显著提高文件共享的效率和安全性。
262 7
细谈 Linux 中的多路复用epoll
大家好,我是 V 哥。`epoll` 是 Linux 中的一种高效多路复用机制,用于处理大量文件描述符(FD)事件。相比 `select` 和 `poll`,`epoll` 具有更高的性能和可扩展性,特别适用于高并发服务器。`epoll` 通过红黑树管理和就绪队列分离事件,实现高效的事件处理。本文介绍了 `epoll` 的核心数据结构、操作接口、触发模式以及优缺点,并通过 Java NIO 的 `Selector` 类展示了如何在高并发场景中使用多路复用。希望对大家有所帮助,欢迎关注威哥爱编程,一起学习进步。
Linux虚拟机网络配置
【10月更文挑战第25天】在 Linux 虚拟机中,网络配置是实现虚拟机与外部网络通信的关键步骤。本文介绍了四种常见的网络配置方式:桥接模式、NAT 模式、仅主机模式和自定义网络模式,每种模式都详细说明了其原理和配置步骤。通过这些配置,用户可以根据实际需求选择合适的网络模式,确保虚拟机能够顺利地进行网络通信。
192 1
Linux中网络连接问题
【10月更文挑战第3天】
54 1
|
4月前
|
Linux C/C++之IO多路复用(poll,epoll)
这篇文章详细介绍了Linux下C/C++编程中IO多路复用的两种机制:poll和epoll,包括它们的比较、编程模型、函数原型以及如何使用这些机制实现服务器端和客户端之间的多个连接。
102 0
Linux C/C++之IO多路复用(poll,epoll)

热门文章

最新文章