轉(zhuǎn)自:http://name5566.com/4190.html
?
參考文獻列表:
http://www.wangafu.net/~nickm/libevent-book/
此文編寫的時候,使用到的 Libevent 為 2.0.21
Libevent 之跨平臺
在處理大量 SOCKET 連接時,使用 select 并不高效。各個系統(tǒng)都提供了處理大量 SOCKET 連接時的解決方案:
- Linux 下的 epoll()
- BSD 下的 kqueue()
- Solaris 下的 evports
- Windows 下的 IOCP
由于各個平臺使用了不同的接口,那么我們需要編寫跨平臺的高性能異步程序時就需要做一層跨平臺封裝。
這個時候 Libevent 就成為一個較好的選擇,其最底層 API(event 和 event_base API)為各個平臺實現(xiàn)高性能異步程序提供了一致的接口。
Libevent 2 提供的 bufferevent 接口,一方面簡化了編程的難度,另一方面保證了在 Windows 和 Unix 上都很高效。
一些基本的概念
- event 會綁定文件描述符、回調(diào)函數(shù)并表示一個或者多個條件(例如,文件描述符可以讀或者寫了、發(fā)生了超時等)。event 表示的條件如果被觸發(fā)了,那么 event 會變?yōu)榛钴S的,它綁定的回調(diào)函數(shù)就會被執(zhí)行
- event_base 用于持有一組 event 并進行事件循環(huán),event_base 會存在一個后端(也叫做方法),常見的后端包括 epoll、kqueue 等
Libevent 的結構
組件:
- evutil 用于抽象不同的平臺的網(wǎng)絡(基礎的)實現(xiàn)
- event、event_base 為 Libevent 的核心,為不同的平臺下基于事件的非阻塞 I/O 提供了一套抽象的接口
- bufferevent 對 Libevent 的基于事件的核心的封裝。應用程序的讀寫請求是基于緩沖區(qū)的
- evbuffer 為 bufferevent 實現(xiàn)的緩沖區(qū)
- evhttp 一個簡單的 HTTP client/server 的實現(xiàn)
- evdns 一個簡單的 DNS client/server 的實現(xiàn)
- evrpc 一個簡單的 RPC 實現(xiàn)
庫:
- libevent_core 包括 util、event_base、evbuffer、bufferevent
- libevent_extra 包括 HTTP、DNS、RPC
- libevent 此庫由于歷史原因而存在,不要使用它
- libevent_pthreads 此庫為基于 pthread 的線程和鎖的實現(xiàn)
- libevent_openssl 此庫通過 openssl 和 bufferevent 提供了加密通訊
頭文件:
所有的公用頭文件位于 event2 目錄中。
編譯 Libevent 庫
Linux 下編譯的方式為(詳細見 README):
- $ ./ configure
- $ make
常用的 configure 標志有:
- -- disable - shared 只編譯靜態(tài)庫
- -- disable - openssl 關閉 OpenSSL 加密支持
Windows 下編譯的方式為:
- nmake / f Makefile . nmake
需要注意的是,雖然官方提供了此 makefile,但是此文件尚未編寫完善(詳見 Makefile.nmake 的注釋)
編譯完成之后,需要將 WIN32-Code 目錄加入到 VS 的 include paths 中去
設置 Libevent 庫
在具體的介紹之前,這里首先需要明確的一點是,我們總是先設置 Libevent,然后才去使用 Libevent。
關于輸出日志的設置
Libevent 的日志信息默認被寫入 stderr(標準錯誤),我們可以提供自己的日志處理函數(shù)給 Libevent:
- // 日志的類型
- #define EVENT_LOG_DEBUG 0
- #define EVENT_LOG_MSG 1
- #define EVENT_LOG_WARN 2
- #define EVENT_LOG_ERR 3
- ?
- // 日志處理函數(shù)原型
- // severity 參數(shù)對應了上面的各種日志類型
- typedef void (* event_log_cb )( int severity , const char * msg );
- ?
- // 設置一個新的日志處理函數(shù)
- void event_set_log_callback ( event_log_cb cb );
設置日志處理函數(shù)的范例:
- #include <event2/event.h>
- #include <stdio.h>
- ?
- static void discard_cb ( int severity , const char * msg )
- {
- // 此函數(shù)不做任何事情
- }
- ?
- static FILE * logfile = NULL ;
- static void write_to_file_cb ( int severity , const char * msg )
- {
- const char * s ;
- if (! logfile )
- return ;
- switch ( severity ) {
- case _EVENT_LOG_DEBUG : s = "debug" ; break ;
- case _EVENT_LOG_MSG : s = "msg" ; break ;
- case _EVENT_LOG_WARN : s = "warn" ; break ;
- case _EVENT_LOG_ERR : s = "error" ; break ;
- default : s = "?" ; break ; /* never reached */
- }
- fprintf ( logfile , "[%s] %s\n" , s , msg );
- }
- ?
- // 關閉 Libevent 的日志信息的輸出
- void suppress_logging ( void )
- {
- event_set_log_callback ( discard_cb );
- }
- ?
- // 設置 Libevent 的日志信息輸出到特定文件
- void set_logfile ( FILE * f )
- {
- logfile = f ;
- event_set_log_callback ( write_to_file_cb );
- }
關于日志的注意事項:
- 日志處理函數(shù)中不要調(diào)用任何的 Libevent 函數(shù)
- Debug 日志信息默認不會被輸出,一般也不需要
Libevent 處理致命錯誤的做法是調(diào)用 exit() 或者 abort() 函數(shù),你可以修改此行為(例如,你希望此時輸出調(diào)用棧信息):
- typedef void (* event_fatal_cb )( int err );
- void event_set_fatal_callback ( event_fatal_cb cb );
注意事項:
- 我們定義的 event_fatal_cb 函數(shù)不要將控制權再返回給 Libevent
- 不要在 event_fatal_cb 函數(shù)中調(diào)用任何的 Libevent 函數(shù)
為 Libevent 定義自己的內(nèi)存管理器
默認的情況下 Libevent 使用 C 庫的內(nèi)存管理函數(shù)從堆上分配內(nèi)存。替換 Libevent 默認內(nèi)存管理函數(shù)主要有以下幾個目的:
- 更加高效的分配內(nèi)存
- 檢測內(nèi)存泄漏
設置自己定義的內(nèi)存管理函數(shù):
- void event_set_mem_functions ( void *(* malloc_fn )( size_t sz ),
- void *(* realloc_fn )( void * ptr , size_t sz ),
- void (* free_fn )( void * ptr ));
替換 Libevent 內(nèi)存管理函數(shù)時需要注意的地方:
- 正如前面說到的,所有設置應該在 Libevent 被使用之前完成,對于內(nèi)存管理的配置來說更加是如此,否則可能引起崩潰
- 你設定的內(nèi)存管理函數(shù)必須是線程安全的
- 你設定的 malloc 和 realloc 返回的內(nèi)存地址的對齊需要和 C 庫一致
- 你設定的 realloc 需要能夠處理 realloc(NULL, sz)
- 你設定的 realloc 需要能夠處理 realloc(ptr, 0)
關閉和清理
我們關閉程序的時候,需要完成一些清理工作:
- void libevent_global_shutdown ( void );
此函數(shù)在 2.1.1-alpha 才被引入。
Libevent 多線程的問題
如果你希望 Libevent 函數(shù)分配的結構能夠被多個線程共享,那么首先需要告知 Libevent 我們使用的鎖定函數(shù)。如果使用 pthreads 庫或者使用 Windows 線程,可以調(diào)用以下函數(shù)來進行設置:
- // 這兩個函數(shù)成功返回 0 失敗返回 -1
- #ifdef WIN32
- int evthread_use_windows_threads ( void );
- #define EVTHREAD_USE_WINDOWS_THREADS_IMPLEMENTED
- #endif
- #ifdef _EVENT_HAVE_PTHREADS
- int evthread_use_pthreads ( void );
- #define EVTHREAD_USE_PTHREADS_IMPLEMENTED
- #endif
void evthread_enable_lock_debuging(void) 函數(shù)可以讓 Libevent 通過 assert 告知我們關于鎖的一些錯誤信息,主要是告知我們解鎖了一個未持有的鎖。我們需要在任意一個鎖被創(chuàng)建或使用之前調(diào)用此函數(shù)。
void event_enable_debug_mode(void) 函數(shù)可以讓 Libevent 檢測 event 使用上的一些錯誤:
- 認為一個未初始化的 event 已經(jīng)初始化了
- 嘗試重新初始化一個 pending event(pending event 為一個術語,之后的文章會談到)
注意的是,開啟 debug 模式(也就是調(diào)用 event_enable_debug_mode)后,會有額外的內(nèi)存和 CPU 開銷,所以應該在真正調(diào)試的時候再開啟。event_enable_debug_mode 函數(shù)需要在任意的 event_base 被創(chuàng)建前調(diào)用。
更多文章、技術交流、商務合作、聯(lián)系博主
微信掃碼或搜索:z360901061

微信掃一掃加我為好友
QQ號聯(lián)系: 360901061
您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。
【本文對您有幫助就好】元
