libevent簡(jiǎn)單非阻塞異步程序示例

1、Libevent簡(jiǎn)介 Libevent是一個(gè)輕量級(jí)的開(kāi)源高性能網(wǎng)絡(luò)庫(kù) libevent支持用戶使用三種類型的事件，分別是網(wǎng)絡(luò)IO、定時(shí)器、信號(hào)三種 事件驅(qū)動(dòng)機(jī)制 輕量級(jí)、專注于網(wǎng)絡(luò)、跨平臺(tái) Libevent默認(rèn)情況下是單線程，每個(gè)線程有且僅有一個(gè)event_base，對(duì)應(yīng)一個(gè)struct event_base結(jié)構(gòu)體，以及一個(gè)事件管理器，用來(lái)安排托管給event_base結(jié)構(gòu)體的一系列事件使用Libevent的基本流程 (1)創(chuàng)建socket，bind，listen，設(shè)置為非阻塞模式 (2)首先創(chuàng)建一個(gè)event_base 對(duì)象 (3)創(chuàng)建一個(gè)event對(duì)象，并且將其監(jiān)聽(tīng)的socket托管給ev

2、ent_base,指定要監(jiān)聽(tīng)的事件類型，并綁上相應(yīng)的回調(diào)函數(shù) (4)通過(guò)event_add方法啟動(dòng)監(jiān)聽(tīng)事件 (5)進(jìn)入事件循環(huán)Libevent對(duì)事件的處理流程Libevent buffer實(shí)現(xiàn)異步傳輸 在Linux下有epoll，BSDS有kqueue，Solaris有evport和/dev/poll等等可以實(shí)現(xiàn)異步傳輸，但是沒(méi)有哪一個(gè)操作系統(tǒng)擁有他們?nèi)?，而libevent就是把這些接口都封裝起來(lái)，并且無(wú)論哪一個(gè)系統(tǒng)使用它都是最高效的 Socket的read操作的數(shù)據(jù)先全部存儲(chǔ)到input buffer當(dāng)中，然后再存儲(chǔ)到內(nèi)存當(dāng)中 Socket的write操作的數(shù)據(jù)全部從內(nèi)存輸出到output

3、 buffer當(dāng)中 以下兩個(gè)示例程序是皆出自csdn博客，本人讀懂之后添加注釋的代碼，適合簡(jiǎn)單入門(mén)。 若要深入一步的了解相關(guān)的API，官網(wǎng)有l(wèi)ibevent的英文版的學(xué)習(xí)手冊(cè)，不過(guò)csdn也有博主翻譯了，可自行搜索示例程序一：#include #include #include #include #include #define PORT 25341#define BACKLOG 5#define MEM_SIZE 1024struct event_base* base;/封裝一個(gè)結(jié)構(gòu)體來(lái)保護(hù)讀、寫(xiě)的事件以及數(shù)據(jù)緩沖區(qū)。便于釋放緩存，以免造成內(nèi)存泄露 struct sock_ev struct

4、 event* read_ev; struct event* write_ev; char* buffer;/釋放緩存 void release_sock_event(struct sock_ev* ev) event_del(ev-read_ev); free(ev-read_ev); free(ev-write_ev); free(ev-buffer); free(ev);/on_write函數(shù)中向客戶端回寫(xiě)數(shù)據(jù)void on_write(int sock, short event, void* arg) char* buffer = (char*)arg; send(sock, buff

5、er, strlen(buffer), 0); free(buffer);/讀事件 void on_read(int sock, short event, void* arg) struct event* write_ev; int size; struct sock_ev* ev = (struct sock_ev*)arg; ev-buffer = (char*)malloc(MEM_SIZE); bzero(ev-buffer, MEM_SIZE); size = recv(sock, ev-buffer, MEM_SIZE, 0); printf(receive data:%s, si

6、ze:%dn, ev-buffer, size); /當(dāng)從socket讀返回0標(biāo)志對(duì)方已經(jīng)關(guān)閉了連接，因此這個(gè)時(shí)候就沒(méi)必要繼續(xù)監(jiān)聽(tīng)該套接口上的事件 if (size = 0) release_sock_event(ev); close(sock); return; /傳參給on_write 準(zhǔn)備寫(xiě)時(shí)間 event_set(ev-write_ev, sock, EV_WRITE, on_write, ev-buffer); event_base_set(base, ev-write_ev); event_add(ev-write_ev, NULL);void on_accept(int sock

7、, short event, void* arg) struct sockaddr_in cli_addr; int newfd, sin_size; struct sock_ev* ev = (struct sock_ev*)malloc(sizeof(struct sock_ev); /之所以是在堆申請(qǐng)內(nèi)存，是防止在棧分配而導(dǎo)致的訪問(wèn)未知內(nèi)存而使得程序崩潰 ev-read_ev = (struct event*)malloc(sizeof(struct event); ev-write_ev = (struct event*)malloc(sizeof(struct event); sin

8、_size = sizeof(struct sockaddr_in); /創(chuàng)建新的套接字進(jìn)行連接,sock是正在監(jiān)聽(tīng)連接的套接字，而中間參數(shù)則是客戶端的地址信息 newfd = accept(sock, (struct sockaddr*)&cli_addr, &sin_size); /在newfd文件描述符上監(jiān)聽(tīng)可讀事件，如果有數(shù)據(jù)到達(dá)則調(diào)用on_read函數(shù) event_set(ev-read_ev, newfd, EV_READ|EV_PERSIST, on_read, ev); event_base_set(base, ev-read_ev); event_add(ev

9、-read_ev, NULL);int main(int argc, char* argv) /創(chuàng)建一個(gè)套接字地址對(duì)象 struct sockaddr_in my_addr; int sock; /創(chuàng)建套接字描述符，實(shí)質(zhì)是一個(gè)文件描述符 /AF_INET表示使用IP地址，SOCK_STREAM表示使用流式套接字 sock = socket(AF_INET, SOCK_STREAM, 0); int yes = 1; setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(int); memset(&my_addr, 0,

10、sizeof(my_addr); /實(shí)例化對(duì)象的屬性 my_addr.sin_family = AF_INET;/主機(jī)字節(jié)順序 my_addr.sin_port = htons(PORT);/網(wǎng)絡(luò)字節(jié)順序，短整形 my_addr.sin_addr.s_addr = INADDR_ANY;/因特網(wǎng)的網(wǎng)絡(luò)地址設(shè)為使用自己的地址 /將套接字地址和套接字描述符綁定起來(lái) bind(sock, (struct sockaddr*)&my_addr, sizeof(struct sockaddr); /監(jiān)聽(tīng)該套接字，連接的客戶端數(shù)量最多為BACKLOG listen(sock, BACKLOG);

11、/聲明事件 struct event listen_ev; /創(chuàng)建基事件 base = event_base_new(); /設(shè)置回調(diào)函數(shù) event_set(&listen_ev, sock, EV_READ|EV_PERSIST, on_accept, NULL); /使從屬于基事件 event_base_set(base, &listen_ev); /添加到事件隊(duì)列當(dāng)中 event_add(&listen_ev, NULL); /開(kāi)始循環(huán) event_base_dispatch(base); return 0;示例程序二#include #include #inc

12、lude #include #include #include #define LISTEN_PORT 9999 #define LISTEN_BACKLOG 32void do_accept(evutil_socket_t listener, short event, void *arg);void read_cb(struct bufferevent *bev, void *arg);void error_cb(struct bufferevent *bev, short event, void *arg);void write_cb(struct bufferevent *bev, vo

13、id *arg);int main(int argc, char *argv) int ret; evutil_socket_t listener; /創(chuàng)建一個(gè)流式套接字描述符 listener = socket(AF_INET, SOCK_STREAM, 0); assert(listener 0); /是的該描述符在當(dāng)前的套接字關(guān)閉之后還可以使用在另外的一個(gè)套接字當(dāng)中 evutil_make_listen_socket_reuseable(listener); /創(chuàng)建一個(gè)套接字地址對(duì)象 struct sockaddr_in sin; /實(shí)例化這個(gè)對(duì)象的屬性 sin.sin_family =

14、 AF_INET; sin.sin_addr.s_addr = 0; sin.sin_port = htons(LISTEN_PORT); /將套接字地址和套接字描述符關(guān)聯(lián)起來(lái) if (bind(listener, (struct sockaddr *)&sin, sizeof(sin) 0) perror(bind); return 1; /監(jiān)聽(tīng)該套接字，連接的客戶端最多為L(zhǎng)ISTEN_BACKLOG if (listen(listener, LISTEN_BACKLOG) 0) perror(listen); return 1; printf (Listening.n); /設(shè)置該

15、套接字為非阻塞 evutil_make_socket_nonblocking(listener); struct event_base *base = event_base_new(); assert(base != NULL); /創(chuàng)建并且綁定一個(gè)event struct event *listen_event; /參數(shù)： event_base ,監(jiān)聽(tīng)的fd，事件類型及屬性，綁定的回調(diào)函數(shù)，傳給回調(diào)函數(shù)的參數(shù) listen_event = event_new(base, listener, EV_READ|EV_PERSIST, do_accept, (void*)base); /啟動(dòng)對(duì)事件

16、的監(jiān)聽(tīng) event_add(listen_event, NULL); /啟動(dòng)事件循環(huán) event_base_dispatch(base); printf(The End.); return 0; void do_accept(evutil_socket_t listener, short event, void *arg) struct event_base *base = (struct event_base *)arg; /libevent2為了兼容windows而重定義的文件描述符類型 evutil_socket_t fd; struct sockaddr_in sin; socklen

17、_t slen; /創(chuàng)建新的套接字進(jìn)行連接客戶端 fd = accept(listener, (struct sockaddr *)&sin, &slen); if (fd FD_SETSIZE) perror(fd FD_SETSIZEn); return; printf(ACCEPT: fd = %un, fd); /創(chuàng)建一個(gè)bufferevent，關(guān)聯(lián)該sockfd，托管給event_base ，而且fd是非阻塞的 struct bufferevent *bev = bufferevent_socket_new(base, fd, BEV_OPT_CLOSE_ON_FRE

18、E); /設(shè)置讀寫(xiě)和出錯(cuò)對(duì)應(yīng)的回調(diào)函數(shù)，主要是把后面的參數(shù)賦值給函數(shù)的第一個(gè)參數(shù) bufferevent_setcb(bev, read_cb, NULL, error_cb, arg); /啟動(dòng)讀寫(xiě)事件，加入到事件的監(jiān)聽(tīng)隊(duì)列當(dāng)中 bufferevent_enable(bev, EV_READ|EV_WRITE|EV_PERSIST); void read_cb(struct bufferevent *bev, void *arg) #define MAX_LINE 256 char lineMAX_LINE+1; int n; evutil_socket_t fd = bufferevent_getfd(bev); /該函數(shù)的作用是把bev這個(gè)input buffer中的數(shù)據(jù)最多移除MAX_LINE的數(shù)據(jù)到line中 while (n = bufferevent_read(bev, line,