最近再學習Libevent由于自己使用的是windows系統(tǒng),遺憾的是有關在vs下可以參考的程序少之又少。在參考了許多的博客文章后。自己摸索寫了一個簡單的Libevent Server程序。并且在網(wǎng)上找了一個簡單的客戶端程序,測試該代碼成功。今天在此做一個記錄。
Libevent的確是一個非常好用的東西,還在繼續(xù)學習中,后續(xù)還要在windows下實現(xiàn)Libevent的多線程使用。今天先把自己搞出來的東西貼上來,僅供學習參考。在vs2015上編譯通過。
默認情況下是單線程的(可以配置成多線程,如果有需要的話),每個線程有且只有一event base,對應一個struct event_base結構體(以及附于其上的事件管理器),用來schedule托管給它的一系列event,可以和操作系統(tǒng)的進程管理類比,當然,要更簡單一點。當一個事件發(fā)生后,event_base會在合適的時間(不一定是立即)去調(diào)用綁定在這個事件上的函數(shù)(傳入一些預定義的參數(shù),以及在綁定時指定的一個參數(shù)),直到這個函數(shù)執(zhí)行完,再返回schedule其他事件。
//創(chuàng)建一個event_basestruct event_base *base = event_base_new();assert(base != NULL);
event_base內(nèi)部有一個循環(huán),循環(huán)阻塞在epoll / kqueue等系統(tǒng)調(diào)用上,直到有一個 / 一些事件發(fā)生,然后去處理這些事件。當然,這些事件要被綁定在這個event_base上。每個事件對應一個struct event,可以是監(jiān)聽一個fd或者POSIX信號量之類(這里只講fd了,其他的看manual吧)。struct event使用event_new來創(chuàng)建和綁定,使用event_add來啟用:
//創(chuàng)建并綁定一個eventstruct event *listen_event;//參數(shù):event_base, 監(jiān)聽的fd,事件類型及屬性,綁定的回調(diào)函數(shù),給回調(diào)函數(shù)的參數(shù) listen_event = event_new(base, listener, EV_READ | EV_PERSIST, callback_func, (void*)base);//參數(shù):event,超時時間(struct timeval *類型的,NULL表示無超時設置)event_add(listen_event, NULL);
注:libevent支持的事件及屬性包括(使用bitfield實現(xiàn),所以要用 | 來讓它們合體)
(a) EV_TIMEOUT: 超時
(b) EV_READ : 只要網(wǎng)絡緩沖中還有數(shù)據(jù),回調(diào)函數(shù)就會被觸發(fā)(c) EV_WRITE : 只要塞給網(wǎng)絡緩沖的數(shù)據(jù)被寫完,回調(diào)函數(shù)就會被觸發(fā)(d) EV_SIGNAL : POSIX信號量,參考manual吧(e) EV_PERSIST : 不指定這個屬性的話,回調(diào)函數(shù)被觸發(fā)后事件會被刪除(f) EV_ET : Edge - Trigger邊緣觸發(fā),參考EPOLL_ET然后需要啟動event_base的循環(huán),這樣才能開始處理發(fā)生的事件。循環(huán)的啟動event base dispatch,循環(huán)將一直持續(xù),直到不再有需要關注的事件,或者是遇到event_loopbreak() / event_loopexit()函數(shù)。//啟動事件循環(huán)event_base_dispatch(base);接下來關注下綁定到event的回調(diào)函數(shù)callback_func:傳遞給它的是一個socket fd、一個event類型及屬性bit_field、以及傳遞給event_new的最后一個參數(shù)(去上面幾行回顧一下,把event_base給傳進來了,實際上更多地是分配一個結構體,把相關的數(shù)據(jù)都撂進去,然后丟給event_new,在這里就能取得到了)。其原型是:
typedef void(*event_callback_fn)(evutil_socket_t sockfd, short event_type, void *arg)對于一個服務器而言,上面的流程大概是這樣組合的:
1. listener = socket(),bind(),listen(),設置nonblocking(POSIX系統(tǒng)中可使用fcntl設置,windows不需要設置, 實際上libevent提供了統(tǒng)一的包裝evutil_make_socket_nonblocking)2. 創(chuàng)建一個event_base3. 創(chuàng)建一個event,將該socket托管給event_base,指定要監(jiān)聽的事件類型,并綁定上相應的回調(diào)函數(shù)(及需要給它的參數(shù))新聞熱點
疑難解答
圖片精選