之前自己學(xué)過(guò)一些libev編程的基礎(chǔ)，這次寫壓測(cè)剛好用上了，才算真正動(dòng)手寫了些東西，在這里做一些總結(jié)。寫這篇文章是為了用淺顯易懂的語(yǔ)言幫助大家做一個(gè)入門，我自己也是入門程序媛一只，所以有理解錯(cuò)誤的地方歡迎指出。

首先推薦幾個(gè)我認(rèn)為學(xué)習(xí)libev比較好的blog，最后一個(gè)地址是官方文檔，給了我很多幫助:

http://vimersu.win/blog/2014/03/06/libev-study/

http://www.cnblogs.com/dirlt/archive/2011/09/07/2169344.html#sec-1

http://blog.csdn.net/woxiaozhi/article/details/16963641

http://www.cnblogs.com/wunaozai/p/3950249.html

http://wenku.baidu.com/link?url=z021OoHoevOJDNP1IVTmEcWvTKRoNKlfzi96k8gUKvcnvdZxlvW4diCihYlxFYRJVjtHSVtYrN451MIqlyznsmO0wUvjRslNPGOZopSIhP_

一.libev原理

　　之前簡(jiǎn)單寫過(guò)一篇libev的學(xué)習(xí)：http://blog.csdn.net/cxy450019566/article/details/52416349

　　有時(shí)間可以看看，沒(méi)時(shí)間直接看這一篇文章。

　　需要理解的第一句話：Libev的核心是一個(gè)event loop。一個(gè)event loop，通俗講就是一個(gè)不停在循環(huán)運(yùn)行的事件。

　　需要理解的第二句話：Libev通過(guò)分配和注冊(cè)watcher對(duì)不同類型的事件進(jìn)行監(jiān)聽(tīng)，當(dāng)監(jiān)聽(tīng)被觸發(fā)時(shí)，進(jìn)行相應(yīng)的操作。在一個(gè)event　loop中，我們可以設(shè)定對(duì)很多l(xiāng)ibev支持的事件(見(jiàn)上一篇博客)的監(jiān)聽(tīng)watcher，這些事件的監(jiān)聽(tīng)是異步進(jìn)行的，觸發(fā)任意一個(gè)監(jiān)聽(tīng)的事件，都可以根據(jù)我們的設(shè)定進(jìn)行某些操作。

　　理解了這兩句話，你就可以理解libev的作用，以及怎樣來(lái)使用libev。

二.通過(guò)簡(jiǎn)單示例了解libev基本用法

我們從官方示例，來(lái)學(xué)習(xí)libev的基本用法。

[cpp] view plain copy

//?libev需要的頭文件??

#include?<ev.h>??

#include?<stdio.h>??

???

//?建立我們剛剛說(shuō)的需要監(jiān)聽(tīng)的事件，這些事件類型是libev提供的??

//?with?the?name?ev_TYPE??

//ev_io和ev_timer最為常用，ev_io為監(jiān)聽(tīng)控制臺(tái)輸入，ev_timer為時(shí)間事件??

ev_io?stdin_watcher;??

ev_timer?timeout_watcher;??

???

//?以下為自定義的回調(diào)函數(shù)，當(dāng)觸發(fā)監(jiān)聽(tīng)事件時(shí)，調(diào)用執(zhí)行對(duì)應(yīng)的函數(shù)??

???

//?ev_io事件的回調(diào)函數(shù)，當(dāng)有輸入流stdin時(shí)，調(diào)用函數(shù)??

static?void?stdin_cb?(EV_P_?ev_io?*w,?int?revents)??

{??

puts?("stdin?ready");??

//對(duì)ev_io事件的監(jiān)控不會(huì)自動(dòng)停止，需要手動(dòng)在需要的時(shí)候停止??

ev_io_stop?(EV_A_?w);??

???

//整體的loop事件在所有監(jiān)控停止時(shí)停止，也可以手動(dòng)關(guān)閉全部的ev_run??

ev_break?(EV_A_?EVBREAK_ALL);??

}??

???

//?時(shí)間事件的自定義回調(diào)函數(shù)，可定時(shí)觸發(fā)??

static?void?timeout_cb?(EV_P_?ev_timer?*w,?intrevents)??

{??

puts?("timeout");??

//關(guān)閉最早的一個(gè)還在運(yùn)行的ev_run??

ev_break?(EV_A_?EVBREAK_ONE);??

}??

???

int?main?(void)??

{??

//定義默認(rèn)的?event?loop，它就像一個(gè)大容器，可以裝載著很多事件不停運(yùn)行??

struct?ev_loop?*loop?=?EV_DEFAULT;??

???

//?初始化ev_io事件監(jiān)控，設(shè)置它的回調(diào)函數(shù)，和stdin??

ev_io_init?(&stdin_watcher,?stdin_cb,/*STDIN_FILENO*/?0,?EV_READ);??

//將ev_io事件放到event?loop里面運(yùn)行??

ev_io_start?(loop,?&stdin_watcher);??

???

//?初始化ev_timer事件監(jiān)控，設(shè)置它的回調(diào)函數(shù)，間隔時(shí)間，是否重復(fù)??

ev_timer_init?(&timeout_watcher,?timeout_cb,?5.5,0.);??

//將ev_timer事件放到event?loop里面運(yùn)行??

ev_timer_start?(loop,?&timeout_watcher);??

???

//?將我們的大容器event?loop整體運(yùn)行起來(lái)??

ev_run?(loop,?0);??

???

//?ev_run運(yùn)行結(jié)束之后，才會(huì)運(yùn)行到這里??

return?0;??

}??

通過(guò)上面的例子，就可以知道libev使用的思路：

首先，定義一個(gè)eventloop大容器 struct ev_loop，和想要的監(jiān)控事件ev_XXX。

其次，初始化想要監(jiān)控的事件，設(shè)置好回調(diào)函數(shù)和相應(yīng)的參數(shù)ev_XXX_init 。

接下來(lái)，讓想要監(jiān)控的事件都投身到大容器中ev_XXX_start。

最后，讓大容器帶著小容器一起運(yùn)行起來(lái) ev_run 。

?

三.常用函數(shù)詳解

1.event loop 相關(guān)

(1)從創(chuàng)建說(shuō)起：

我們默認(rèn)使用EV_DEFAULT類型的loop，使用一下語(yǔ)句來(lái)創(chuàng)建：struct ev_loop *loop = EV_DEFAULT;

EV_DEFAULT宏是以下指令：

ev_default_loop(EVBACKEND_POLL | EVBACKEND_SELECT | EVFLAG_NOENV);

返回一個(gè)最基礎(chǔ)的ev_loop，并自動(dòng)完成它的初始化，注意，如果程序中已經(jīng)執(zhí)行過(guò)該創(chuàng)建，將直接返回之前的創(chuàng)建。除此之外，更多自定義loop，可以使用該函數(shù)：struct ev_loop*ev_loop_new (unsigned int flags)。

(2)讓ev_loop運(yùn)行起來(lái)

使用函數(shù)ev_run(loop, int flags)。

這里解釋一下flags的作用，用于設(shè)置ev_loop的運(yùn)行方式：

通常設(shè)置為0，表示該ev_loop在所有watcher結(jié)束后停止，也可以手動(dòng)break，官方鼓勵(lì)手動(dòng)break。

除了0之外，還有一些選擇，如EVRUN_NOWAIT、EVRUN_ONCE。具體請(qǐng)看官方文檔。

ev_run函數(shù)的源碼說(shuō)明。推薦博文：http://www.cnblogs.com/xiangshancuizhu/archive/2013/08/10/3250558.html

(3)ev_loop的停止

前面已經(jīng)說(shuō)過(guò)，在flags設(shè)置為0的情況下，停止主要靠全部watcher停止或者手動(dòng)break。

手動(dòng)break用以下函數(shù)：ev_break (loop,how)

其中，how代表停止的方式：

EVBREAK_ONE：停止最久遠(yuǎn)的那個(gè)ev_run

EVBREAK_ALL：停止所有的ev_run

2.ev_TYPE公共基礎(chǔ)

(1)watcher對(duì)應(yīng)的幾種狀態(tài)

　　 initialiased：調(diào)用init函數(shù)初始化

　　 active：調(diào)用start進(jìn)行注冊(cè)

　　 pending：已經(jīng)觸發(fā)事件但是沒(méi)有處理

　　 inactive：調(diào)用stop注銷。這個(gè)狀態(tài)等同于initialised這個(gè)狀態(tài)。

(2)ev_TYPE對(duì)應(yīng)不同類型的時(shí)間監(jiān)控，共有的標(biāo)準(zhǔn)化函數(shù)主要如下：

[cpp] view plain copy

typedef?void?(*)(struct?ev_loop?*loop,?ev_TYPE*watcher,?int?revents)?callback;?//?回調(diào)函數(shù)都是這種類型??

ev_init?(ev_TYPE?*watcher,?callback);?//?初始化watcher??

ev_TYPE_set?(ev_TYPE?*watcher,?[args]);?//?設(shè)置watcher??

ev_TYPE_init?(ev_TYPE?*watcher,?callback,?[args]);?//?這個(gè)函數(shù)綜合了前兩個(gè)函數(shù)功能??

ev_TYPE_start?(loop,?ev_TYPE?*watcher);?//?在ev_loop中注冊(cè)watcher??

ev_TYPE_stop?(loop,?ev_TYPE?*watcher);?//?在ev_loop中注銷watcher??

ev_set_priority?(ev_TYPE?*watcher,?int?priority);?//?設(shè)置watcher優(yōu)先級(jí)，值域?yàn)閇-2,2]，大而優(yōu)先??

ev_feed_event?(loop,?ev_TYPE?*watcher,?int?revents);//?這個(gè)做跨線程通知非常有用，相當(dāng)于觸發(fā)了某個(gè)事件。??

bool?ev_is_active?(ev_TYPE?*watcher);?//?watcher是否active.??

bool?ev_is_pending?(ev_TYPE?*watcher);?//?watcher是否pending.??

int?ev_clear_pending?(loop,?ev_TYPE?*watcher);?//?清除watcher?pending狀態(tài)并且返回事件??

3.ev_io相關(guān)

(1)ev_io結(jié)構(gòu)

ev_io用來(lái)監(jiān)聽(tīng)io事件，當(dāng)有標(biāo)準(zhǔn)輸入或輸出時(shí)，則會(huì)觸發(fā)事件，執(zhí)行回調(diào)函數(shù)。

[cpp] view plain copy

typedef?structev_io??

{??

EV_WATCHER_LIST?(ev_io)??

int?fd;?/*?所監(jiān)聽(tīng)io事件的文件描述符（file?descriptor，非負(fù)數(shù)）?*/??

int?events;?/*所監(jiān)聽(tīng)的事件，包括EV_READ,?EV_WRITE?或?EV_READ?|?EV_WRITE?*/??

}?ev_io;??

(2)初始化

兩種方式：

方式一：ev_init(ev_TYPE *watcher, callback) ，ev_io_set(ev_io *ev, intfd, int events)

方式二：ev_io_init(ev_io*ev, callback,int fd, int events)

即需要設(shè)置監(jiān)聽(tīng)watcher，回調(diào)函數(shù)callback，文件描述符fd，監(jiān)聽(tīng)的事件events。

(3)運(yùn)行和停止

ev_io_start(EV_P_ev_io * w)：綁定到ev_loop上

ev_io_stop(EV_P_ev_io * w)：從ev_loop上撤離

4.ev_timer相關(guān)

(1)ev_timer結(jié)構(gòu)

ev_timer是一個(gè)相對(duì)時(shí)間的定時(shí)器，會(huì)在給定的時(shí)間點(diǎn)觸發(fā)事件，還可以在固定的時(shí)間間隔之后再次觸發(fā)超時(shí)事件。

[cpp] view plain copy

typedef?structev_timer??

{??

int?active;??

int?pending;??

int?priority;?/*優(yōu)先級(jí)?*/??

void?*data;?/*?參數(shù)*/??

void?(*cb)(struct?ev_loop?*loop,?struct?ev_timer?*w,int?revents);?/*回調(diào)函數(shù)?*/??

ev_tstamp?at;?/*?定時(shí)器時(shí)間，單位為s*/??

ev_tstamp?repeat;?/*是否重復(fù)?*/??

}?ev_timer;??

(2)初始化

同樣兩種方式：

方式一：ev_init(ev_TYPE *watcher, callback) ，ev_timer_set (ev_timer *,ev_tstamp after, ev_tstamp repeat)

方式二：ev_timer_init(ev_timer *, callback, ev_tstamp after, ev_tstamp repeat)

即需要設(shè)置監(jiān)聽(tīng)watcher，回調(diào)函數(shù)callback，定時(shí)器時(shí)間after,是否重復(fù)repeat。

其中，repeat設(shè)置為0表示定時(shí)器只觸發(fā)一次，設(shè)置為正整數(shù)則間隔after秒一直不斷觸發(fā)。

(3)運(yùn)行和停止

ev_timer_start(EV_P_ev_io * w)：綁定到ev_loop上

ev_timer_stop(EV_P_ev_io * w)：從ev_loop上撤離

(4)其它函數(shù)

ev_timer_again(loop, ev_timer *) :重啟，對(duì)于不同狀態(tài)的timer效果不同。

ev_tstampev_timer_remaining (loop, ev_timer *)：返回現(xiàn)在到下一次觸發(fā)定時(shí)器之間的時(shí)間。

四.在Socket編程的應(yīng)用實(shí)例

libev用在Socket編程上有幾個(gè)好處，用ev_timer可以控制發(fā)送頻率，用ev_io可以方便地異步進(jìn)行包的接收。下面的實(shí)例就實(shí)現(xiàn)的這個(gè)流程，直接用代碼解釋了：

[cpp] view plain copy

double?time_span?=?1.0;?//發(fā)送消息的時(shí)間間隔??

int?test_num?=?5;?//發(fā)送消息的次數(shù)??

int?send_num?=?0;?//已發(fā)送消息的次數(shù)??

int?rev_num?=?0;?//已收到回復(fù)的次數(shù)??

int?fd?=?-1;?//文件描述符??

???

struct?ev_loop?*loop?=?EV_DEFAULT;??

ev_io?io_watcher;??

ev_timer?timer_watcher;??

???

//ev_io的回調(diào)函數(shù)，用于異步接受回復(fù)??

void?io_action(struct?ev_loop?*main_loop,ev_io*io_w,int?e)??

{??

char?buf[4096];??

char?*ptr?=?(char?*)buf;??

int?ret?=?0;??

//接收消息??

ret?=?::recv(fd,?ptr,?4096,?0);??

???

std::cout?<<?buf?<<?"\n";??

???

//接收到所有消息，停止ev_io事件??

if(rev_num?>=?test_num){??

ev_io_stop(main_loop,io_w);??

}??

}??

???

//ev_timer的回調(diào)函數(shù)，用于定時(shí)發(fā)送消息??

void?timer_action(struct?ev_loop?*main_loop,ev_timer*time_w,int?e)??

{??

int?ret;??

std::string?msg_send?=?"send?msg";??

//發(fā)送消息??

ret?=?::send(fd,?msg_send.c_str(),strlen(msg_send.c_str()),?0);??

std::cout?<<?msg_send?<<?"\n";??

???

//發(fā)送足夠數(shù)量的消息后，停止事件??

if(send_num?>=?test_num){??

ev_timer_stop(main_loop,time_w);??

}??

}??

???

int?main(int?argc,?char?*argv[])??

{??

fd?=?socket(AF_INET,?SOCK_STREAM,?0);??

ret?=?::connect(fd,?(struct?sockaddr?*)&addr,sizeof(addr));??

???

ev_init(&io_watcher,io_action);??

ev_io_set(&io_watcher,fd,EV_READ);??

???

ev_init(&timer_watcher,timer_action);??

ev_timer_set(&timer_watcher,time_span,1);??

???

ev_io_start(loop,&io_watcher);??

ev_timer_start(loop,&timer_watcher);??

???

ev_run(loop,0);??

return?0;??

}??

總結(jié)

以上是生活随笔為你收集整理的libev的使用——结合Socket编程的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。