Libevent学习-----Reactor的事件处理机制

xiaoxiao2021-02-27  166

1.      普通函数的调用机制:

       主程序调用某函数à函数执行,保存入参和返回寄存器地址,主程序等待à 函数处理完将结果和控制权返回给主程序 à主程序继续执行

void func () { return; } int main(int argc, char *argv[]) { int a,b; func(); -------主程序调用func函数时,必须等待func执行完以后才能继续执行后续的代码 a = 1; b = 2; }

2.      Reactor, 中文的意思是“反应堆”, 是一种事件驱动机制。

应用程序不是主动调用某个函数完成处理,而是将函数以回调函数的方式注册到Reactor上,如果相应的事件发生了,Reactor将主动调用注册的函数。

3.      Reactor模式整体框架

1) Reactor----反应堆

Reactor是事件管理的接口,将事件注册到事件多路分发器上,然后在事件多路分发器上等待事件的发生,当有事件发生时,调用注册的事件回调函数处理事件。

 

2) eventdemultiplexer   ----事件多路分发器

是一个函数,用来等待一个或多个事件的发生。调用者会被阻塞,直到分发器上有事件发生。一般是I/O多路复用机制,比如select,poll和epoll等。

3) Handle------(事件源)

用于识别每一个事件,如socket描述符、文件描述符、信号等

4) EventHandler-----事件处理程序

事件处理程序提供了一组接口,每一个接口对应一种类型的事件

5) ConcreteEvent Handler-----具体的事件处理器

这个是Event Handler接口的具体实现。每一个具体的事件处理器通常和一个描述符相关。

Libevent对应的实现

 

1) Reactor反应堆

Libevent里面的反应堆,对应的是Struct event_base 结构

2)eventdemultiplexer   ----事件多路分发器

struct event_base { const struct eventop *evsel; ---------对应io的事件多路分发器—epoll …… const struct eventop *evsigsel; --------对应信号的事件多路分发器 evsigops …… };

 3)Handle------(事件源)

struct event { …… evutil_socket_t ev_fd; ------------------对应的事件 …… };

4)  Event Handler-----事件处理程序

struct event { …… void (*ev_callback)(evutil_socket_t, short, void *arg);----- 事件处理程序 …… }

4) ConcreteEvent Handler-----具体的事件处理器

event_new(struct event_base *base,evutil_socket_t fd, short events, void (*cb)(evutil_socket_t, short, void *),void *arg)

调用event_new时候添加的回调函数cb

 Event_new函数完成了

 1、event结构的内存分配;

2、设置可所属的event_base;

 3、初始化了event结构;

4、设置了fd,events,cb和arg等参数

 

 Libevent整体处理流程:

1)首先调用struct event_base *base = event_base_new(); 创建一个反应堆

2) 调用event_new产生event结构,并将handler(fd)和具体事件处理器cb放入event结构中,完成Handler和事件处理器的赋值,并且将event与event_base相关联

3)调用event_add将event注册到事件多路分发器eventdemultiplexer  

4)调用event_base_dispatch,等待事件多路分发器返回激活事件,然后调用对应事件的事件处理函数

转载请注明原文地址: https://www.6miu.com/read-14378.html

最新回复(0)