libevent的水平触发与边缘触发

libevent默认是水平触发，也即是如果有数据可读，读回调将被触发。如果数据没有读完，读回调将会持续触发，直至无数据可读。

但是，这里其实也分为两种情况：基于套接字的event和基于套接字的bufferevent。

基于套接字的event：

#include <WinSock2.h>
#include <event2/event.h>
#include <event2/bufferevent.h>
#include <event2/listener.h>
#include <iostream>void socket_read_cb(evutil_socket_t fd, short what, void* arg)
{std::cout << "event_read_fn" << std::endl;
}void listener_cb(evconnlistener *listener, evutil_socket_t fd, struct sockaddr *sock, int socklen, void *arg)
{std::cout << "accept a client : " << fd << std::endl;event_base* pEventBase = (event_base*)arg;event* pEvent = event_new(pEventBase, fd, EV_READ | EV_PERSIST, socket_read_cb, nullptr);event_add(pEvent, nullptr);
}int main(int argc, char* argv[])
{WSADATA wsa_data;WSAStartup(MAKEWORD(2, 2), &wsa_data);struct sockaddr_in sin;memset(&sin, 0, sizeof(struct sockaddr_in));sin.sin_family = AF_INET;sin.sin_port = htons(9999);event_base *base = event_base_new();evconnlistener *listener = evconnlistener_new_bind(base, listener_cb, base,LEV_OPT_REUSEABLE | LEV_OPT_CLOSE_ON_FREE,10, (struct sockaddr*)&sin,sizeof(struct sockaddr_in));event_base_dispatch(base);evconnlistener_free(listener);event_base_free(base);WSACleanup();return 0;
}

这种情形下，套接字中有数据可读，会一直触发读回调函数socket_read_cb。

基于套接字的bufferevent：

#include <WinSock2.h>
#include <event2/event.h>
#include <event2/bufferevent.h>
#include <event2/listener.h>#include <iostream>void socket_event_cb(bufferevent *bev, short events, void *arg)
{bufferevent_free(bev);
}void socket_read_cb(bufferevent *bev, void *arg)
{std::cout << "read cb" << std::endl;
}void listener_cb(evconnlistener *listener, evutil_socket_t fd, struct sockaddr *sock, int socklen, void *arg)
{std::cout << "accept a client : " << fd << std::endl;event_base *base = (event_base*)arg;bufferevent *bev = bufferevent_socket_new(base, fd, BEV_OPT_CLOSE_ON_FREE);bufferevent_setcb(bev, socket_read_cb, NULL, socket_event_cb, NULL);bufferevent_enable(bev, EV_READ | EV_PERSIST | EV_ET);
}int main(int argc, char* argv[])
{WSADATA wsa_data;WSAStartup(MAKEWORD(2, 2), &wsa_data);struct sockaddr_in sin;memset(&sin, 0, sizeof(struct sockaddr_in));sin.sin_family = AF_INET;sin.sin_port = htons(9999);event_base *base = event_base_new();evconnlistener *listener = evconnlistener_new_bind(base, listener_cb, base,LEV_OPT_REUSEABLE | LEV_OPT_CLOSE_ON_FREE,10, (struct sockaddr*)&sin,sizeof(struct sockaddr_in));event_base_dispatch(base);evconnlistener_free(listener);event_base_free(base);WSACleanup();return 0;
}

基于套接字的bufferevent，当有数据可读时，会触发调用读回调函数。回调函数返回后，如果仍有数据可读，将不会触发调用读回调函数。
直到有新的数据被bufferevent接收，才会再次调用读回调函数。

这里实际的情况和理解的水平触发有些出入，可以理解为使用bufferevent时，读取数据的触发方式实际为边缘触发。为了防止数据堆积在bufferevent的输入缓冲区而不能及时处理，应该确保每次触发读回调函数时，读取完所有数据。一个可行的读回调函数如下：

void socket_read_cb(bufferevent *bev, void *arg)
{evbuffer* pInputBuffer = bufferevent_get_input(bev);if (nullptr == pInputBuffer) return;// 为了方便测试，将msgBuf设置较小char msgBuf[2] = { '\0' };while (evbuffer_get_length(pInputBuffer) > 0){size_t len = bufferevent_read(bev, msgBuf, sizeof(msgBuf) - 1);std::cout << "server read the data from client : " << msgBuf << std::endl;}
}

2020.04.27 新增：

bufferevent实际上是对event的封装。
这里为了方便描述，
称通过bufferevent_setcb()设置的回调函数为外层回调函数。
而称通过event_assign()设置的回调函数为内层回调函数。

bufferevent的外层回调函数由用户调用bufferevent_setcb()设置。
而其内层回调函数由libevent自己设置。实际上是由用户调用bufferevent_socket_new()该函数内部自己设置。

bufferevent中，如果其套接字可读，其内层读回调函数将会被调用，读取数据，然后存放在读取缓冲区中。如果该缓冲区中的数据大于等于读低水位，就将调用外层读调用函数，此时数据已经在读取缓冲区中，无需再从套接字中读取，bufferevent封装了读取细节，外层读回调函数实际上是直接从读取缓冲区中读取数据。

这里问题出现：
如果读取缓冲区中有100字节数据，但是外层读回调函数却只取回了10字节。那因为还剩下90字节，外层读回调函数会立刻再次被调用吗？

答案是否定。因为一次内层读回调函数只会调用一次外层读回调函数，即使调用完外层读回调函数之后读取缓冲区中仍有数据，也不会立刻再次调用外层读回调函数。只有等到下次内层读回调函数(即套接字可读)被调用之后才可能继续读取剩余数据。之所以是可能，是因为外层读回调函数是在调用内层读回调函数之后读取缓冲区evbuffer中的数据量大于等于读低水位后才会被调用。

因此，设置触发方式只会涉及到event对象的读写回调，即直接面对套接字时。
而对于bufferevent对象的读写回调毫无影响，bufferevent的读写回调根本与触发方式毫无相干。

对于外层读回调函数，最好每次都将读取缓冲区的数据全部读取(evbuffer_get_length() == 0)，以免剩余的数据无法得到及时处理。

libevent的水平触发与边缘触发相关推荐

实例浅析epoll的水平触发和边缘触发，以及边缘触发为什么要使用非阻塞IO
一.基本概念我们通俗一点讲: Level_triggered(水平触发):当被监控的文件描述符上有可读写事件发生时,epoll_wait()会通知处理程序去读写.如果这次没有把数据一次性全部读写完( ...
epoll哪些触发模式_5.epoll的水平触发和边缘触发
本篇是多路复用的第五篇,主要来讲解epoll的水平触发和边缘触发是怎么回事. 一.概念介绍 EPOLL事件有两种模型,水平出发和边缘触发,如下所示: 1. Level Triggered (LT) 水 ...
epoll边缘触发_4.2.3、epoll:水平触发与边缘触发
select和poll都只提供了一个函数:select或者poll函数. 而epoll提供了三个函数,epoll_create,epoll_ctl和epoll_wait,epoll_create是创建 ...
五种高级IO | select poll epoll 水平触发模式边缘触发模式惊群问题
一.高级IO 在介绍多路复用IO之前,先介绍一下其它四种高级IO: 阻塞IO: 在内核将数据准备好之前,系统调用会一直等待.所以的套集字默认是阻塞方式. 非阻塞IO: 在内核还未将数据准备好,则系统调 ...
移除类名没有触发transition_epoll边缘触发模式
epoll(kqueue),支持两种事件触发模式.水平触发以及边缘触发. epoll实际可以监听多种描述符,下文主要以套接字介绍,并且假设同时注册了读/写. 水平触发:只要套接字可读/可写epollw ...
Linux网络编程 | 多路复用I/O ：select、poll、epoll、水平触发与边缘触发、惊群问题
文章目录多路复用IO 多路复用IO的概念多路复用IO与多线程/多进程的并发多路复用IO模型进行服务器并发处理多线程/多进程进行服务器并发处理 select 工作原理接口优缺点 select ...
什么是epoll的水平触发与边缘触发？两段代码彻底理解
Edge trigger and level trigger of epoll 水平触发对于读操作:只要缓冲内容不为空,LT模式返回读就绪. 对于写操作:只要缓冲区还不满,LT模式会返回写就绪. # ...
条件触发和边缘触发及 epoll 的长处
条件触发: 仅仅要输入缓冲有数据就会一直通知该事件边缘触发: 输入缓冲收到数据时仅注冊1次该事件.即使输入缓冲中还留有数据,也不会再进行注冊水平触发(level-triggered.也被称为条件触 ...
操作文件操作符的工作模式:LT(电平触发)ET(边缘触发)实验对比
文章目录什么是LT和ET? LT(Level Trigger)模式: ET(Edge Trigger)模式: 得出结论,ET模式的工作效率要比LT高,因为ET模式降低了同一事件被重复触发的次数实验 ...
水平触发LT、边缘触发ET
Level_triggered(水平触发 LT):当被监控的文件描述符上有可读写事件发生时,epoll_wait()会通知处理程序去读写.如果这次没有把数据一次性全部读写完(如读写缓冲区太小),那么下 ...

libevent的水平触发与边缘触发

libevent的水平触发与边缘触发相关推荐

最新文章

热门文章