事件库之Libev

一、libev理解

  • libev核心是一个事件循环（ev_loop），一个事件循环就是一个不停在循环运行的事件
  • libev通过分配和注册监控器（watcher）对多个不同类型事件进行监听，任意监听的事件被触发时，进行相应事件回调操作。

二、libev用法

  • 定义一个事件循环事件驱动器（struct ev_loop）和想要监控事件的事件监控器（ev_XXX）;
  • 初始化事件监控器绑定事件回调函数（ev_init）和设置相应事件或参数（ev_XXX_set）;
  • 挂载事件监控器到事件驱动器上（ev_XXX_start）;
  • 事件驱动器带着事件监控器一起Happy（ev_run）。

简单示例

#include <ev.h>
#include <stdio.h>
#include <signal.h>
#include <sys/unistd.h>
 
ev_io io_w;
ev_timer timer_w;
ev_signal signal_w;
 
static void io_action(struct ev_loop *main_loop,ev_io *io_w,int e)
{
   int rst;
   char buf[1024] = {'\0'};
   puts("in io cb\n");
   read(STDIN_FILENO,buf,sizeof(buf));
   buf[1023] = '\0';
   printf("Read in a string %s \n",buf);
   ev_io_stop(main_loop,io_w);
}
 
static void timer_action(struct ev_loop *main_loop,ev_timer *timer_w,int e)
{
   puts("in tiemr cb \n");
   ev_timer_stop(main_loop,timer_w);
}
 
static void signal_action(struct ev_loop *main_loop,ev_signal signal_w,int e)
{
   puts("in signal cb \n");
   ev_signal_stop(main_loop,signal_w);
   ev_break(main_loop,EVBREAK_ALL);
}
 
int main(int argc ,char *argv[])
{
   struct ev_loop *main_loop = ev_default_loop(0);

   ev_init(&io_w,io_action);
   ev_io_set(&io_w,STDIN_FILENO,EV_READ); 

   ev_init(&timer_w,timer_action);
   ev_timer_set(&timer_w,2,0); 

   ev_init(&signal_w,signal_action);
   ev_signal_set(&signal_w,SIGINT);
 
   ev_io_start(main_loop,&io_w);
   ev_timer_start(main_loop,&timer_w);
   ev_signal_start(main_loop,&signal_w);
 
   ev_run(main_loop,0);
 
   return 0;
}

三、常用函数

  • ev_loop构建
    我们默认使用EV_DEFAULT类型的loop，使用一下语句来创建：
struct ev_loop *loop = EV_DEFAULT;

其中EV_DEFAULT宏的定义：ev_default_loop(EVBACKEND_POLL | EVBACKEND_SELECT | EVFLAG_NOENV)
返回一个最基础的ev_loop，并自动完成它的初始化，注意，如果程序中已经执行过该创建，将直接返回之前的创建。除此之外，更多自定义loop，可以使用该函数：struct ev_loop*ev_loop_new (unsigned int flags)

  • 让ev_loop run起来
    使用函数ev_run(loop, int flags)
    flags的作用：用于设置ev_loop的运行方式,通常设置为0，表示该ev_loop在所有watcher结束后停止，也可以手动break，官方鼓励手动break。除了0之外，还有一些选择，如EVRUN_NOWAIT、EVRUN_ONCE（详见官方文档）。

  • ev_loop的停止
    如上所述在flags设置为0的情况下，停止主要靠全部watcher停止或者手动break（ev_break (loop,how)）。
    其中how代表停止方式:
    EVBREAK_ONE：停止最久远的那个ev_run
    EVBREAK_ALL：停止所有的ev_run

  • ev_TYPE对应不同类型的事件监控，
    libev定义了如下类型的watcher：
    ev_io, ev_timer, ev_signal, // 基础事件
    ev_periodic, ev_child, ev_stat, ev_idle, ev_prepare, ev_check, ev_embed, ev_fork, ev_cleanup, ev_async
    共有的标准化函数主要如下：

// 回调函数都是这种类型
typedef void (*)(struct ev_loop *loop, ev_TYPE*watcher, int revents) callback; 
 // 初始化watcher
ev_init (ev_TYPE *watcher, callback);
 // 设置watcher
ev_TYPE_set (ev_TYPE *watcher, [args]);
// 这个函数综合了前两个函数功能
ev_TYPE_init (ev_TYPE *watcher, callback, [args]);
// 在ev_loop中注册watcher
ev_TYPE_start (loop, ev_TYPE *watcher);
// 在ev_loop中注销watcher
ev_TYPE_stop (loop, ev_TYPE *watcher); 
// 设置watcher优先级，值域为[-2,2]，大而优先
ev_set_priority (ev_TYPE *watcher, int priority);
// 这个做跨线程通知非常有用，相当于触发了某个事件
ev_feed_event (loop, ev_TYPE *watcher, int revents);
// watcher是否active
bool ev_is_active (ev_TYPE *watcher);
 // watcher是否pending
bool ev_is_pending (ev_TYPE *watcher);
// 清除watcher pending状态并且返回事件
int ev_clear_pending (loop, ev_TYPE *watcher);

四、libev实现非阻塞网络通信实例

  • server端
#include <stdio.h>
#include <stdlib.h>
#include <malloc.h>
#include <ev.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <string.h>

#define PORT 9999
#define BUFFER_SIZE 1024

static int total_clients=0;

static void accept_cb(struct ev_loop *loop,struct ev_io *watcher,int revents)
{
        int client_sd;
        struct ev_io *w_client = (struct ev_io*)malloc(sizeof(struct ev_io));
        if(EV_ERROR & revents){
                printf("error event in accept");
                return ;
        }

        client_sd = accept(watcher->fd,NULL,NULL);

        if(client_sd < 0){
                printf("accept error");
                return;
        }
        total_clients++;
        printf("successfully connected with client.\n");
        printf("%d client connected .\n",total_clients);
        ev_io_init(w_client,read_cb,client_sd,EV_READ);
        ev_io_start(loop,w_client);
}

static void read_cb(struct ev_loop *loop,struct ev_io *watcher,int revents)
{
        int read;
        char buffer[BUFFER_SIZE];
        if(EV_ERROR & revents){
                printf("error event in read");
                return;
        }
        read = recv(watcher->fd,buffer,BUFFER_SIZE,0);
        if(read == 0){
                ev_io_stop(loop,watcher);
                free(watcher);
                perror("peer might closing");
                total_clients--;
                printf("%d client connected .\n",total_clients);
                return;
        }
        else{
                buffer[read] = '\0';
                printf("get the message: %s\n",buffer);
        }

        send(watcher->fd,buffer,read,0);
        bzero(buffer,read);
}

int main(void)
{
        int sd;
        struct sockaddr_in addr;
        struct ev_io socket_accept;
        struct ev_loop *loop=ev_default_loop(0);

        if((sd = socket(AF_INET,SOCK_STREAM,0))<0){
                printf("socket error");
                return -1;
        }
        bzero(&addr,sizeof(addr));
        addr.sin_family = AF_INET;
        addr.sin_port = htons(PORT);
        addr.sin_addr.s_addr = INADDR_ANY;
        if(bind(sd,(struct sockaddr*)&addr,sizeof(addr))!=0){
                printf("bind error");
        }
        if(listen(sd,0)<0){
                printf("listen error");
                return -1;
        }
        ev_io_init(&socket_accept,accept_cb,sd,EV_READ);
        ev_io_start(loop,&socket_accept);
        while(1){
                ev_loop(loop,0);
        }
        return 0;
}
  • client端
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <arpa/inet.h>
#include <sys/socket.h>
#include <netinet/in.h>

#define PORT 9999
#define BUFFER_SIZE 1024

int main()
{
        int sd;
        struct sockaddr_in addr;
        char buffer[BUFFER_SIZE];

        if((sd=socket(AF_INET,SOCK_STREAM,0))<0)
        {
                perror("socket error");
                return -1;
        }
        bzero(&addr,sizeof(addr));

        addr.sin_family = AF_INET;
        addr.sin_port = htons(PORT);
        addr.sin_addr.s_addr = htonl(INADDR_ANY);

        if(connect(sd,(struct sockaddr *)&addr,sizeof(addr))<0)
        {
                perror("connect error");
                return -1;
        }
        while(strcmp(buffer,"q")!=0)
        {
                scanf("%s",buffer);
                send(sd,buffer,strlen(buffer),0);
                recv(sd,buffer,BUFFER_SIZE,0);
                printf("message:%s\n",buffer);
        }
        return 0;
}
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 206,126评论 6赞 481
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 88,254评论 2赞 382
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 152,445评论 0赞 341
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 55,185评论 1赞 278
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 64,178评论 5赞 371
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 48,970评论 1赞 284
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 38,276评论 3赞 399
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 36,927评论 0赞 259
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 43,400评论 1赞 300
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,883评论 2赞 323
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,997评论 1赞 333
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 33,646评论 4赞 322
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 39,213评论 3赞 307
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,204评论 0赞 19
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,423评论 1赞 260
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 45,423评论 2赞 352
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 42,722评论 2赞 345