libevent簡述

時間 2019-11-11

標籤 libevent 簡述简体版

原文原文鏈接

一。libevent概念

Libevent 是一個用C語言編寫的、輕量級的開源高性能事件通知庫，主要有如下幾個亮點：事件驅動（ event-driven），高性能;輕量級，專一於網絡，不如 ACE 那麼臃腫龐大；源代碼至關精煉、易讀；跨平臺，支持 Windows、 Linux、 *BSD 和 Mac Os；支持多種 I/O 多路複用技術， epoll、 poll、 dev/poll、 select 和 kqueue 等；支持 I/O，定時器和信號等事件；註冊事件優先級。服務器

二。安裝

1.從官網下載安裝包libevent-2.1.8-stable.tar.gz網絡

2.解壓 jar zxvf libevent-2.1.8-stable.tar.gz框架

3.進入解壓目錄 socket

4. ./congifure函數

5. make性能

5.sudo make installthis

6.以上完成後會在/usr/local/lib下生成庫文件，將/usr/local/lib加入到 /etc/ls.so.conf內spa

7.sudo ldconfig -v3d

三。基本函數

1.建立事件處理框架

2.建立事件

what的參數能夠設爲：code

3.將事件加入到事件處理框架中（讓事件處於未決狀態）

4.事件處理框架循環處理事件(事件觸發後執行事件的回調函數)

5.將事件從事件處理框架中卸下（將事件設置爲非未決）

6.釋放事件

7.釋放事件處理框架

8.libevent讀寫管道

 //寫管道
 1 #include<stdio.h>
 2 #include<unistd.h>
 3 #include<stdlib.h>
 4 #include<sys/types.h>
 5 #include<sys/stat.h>
 6 #include<string.h>
 7 #include<fcntl.h>
 8 #include<event2/event.h>
 9 
10 //事件回調函數
11 void write_call_back(evutil_socket_t fd,short what,void *arg)
12 {
13     //寫管道
14     char buf[BUFSIZ];
15     static int num=0;
16     sprintf(buf,"this is the %d data\n",++num);
17     write(fd,buf,sizeof(buf));
18     return ;
19 }
20 //寫管道
21 int main()
22 {
23     //openfile
24     int fd=open("myfifo",O_WRONLY|O_NONBLOCK);
25     if(fd==-1)
26     {
27         perror("open err");
28         exit(1);
29     }
30     //寫管道
31     struct event_base* base=NULL;
32     base=event_base_new();
33     //建立事件
34     struct event* event=NULL;
35 //檢測寫緩衝區是否有空間寫
36         event=event_new(base,fd,EV_WRITE|EV_PERSIST,write_call_back,NULL);
37     //添加事件
38     event_add(event,NULL); //阻塞等待事件發生
39     //事件循環
40     event_base_dispatch(base);
41     //釋放事件
42     event_free(event);
43     //釋放框架
44     event_base_free(base);
45     close(fd);
46     return 0;
47 }

 //讀管道
 1 #include<stdio.h>
 2 #include<unistd.h>
 3 #include<stdlib.h>
 4 #include<sys/types.h>
 5 #include<sys/stat.h>
 6 #include<string.h>
 7 #include<fcntl.h>
 8 #include<event2/event.h>
 9 
10 //事件回調函數
11 void read_call_back(evutil_socket_t fd,short what,void *arg)
12 {
13     //讀管道
14     char buf[BUFSIZ];
15     int len=read(fd,buf,sizeof(buf));
16     printf("buf:%s\n",buf);
17     printf("read event:%s\n",what&EV_READ?"yes":"no");
18     return ;
19 }
20 //讀管道
21 int main()
22 {
23     unlink("myfifo");
24     //建立有名管道
25     mkfifo("myfifo",0664);
26 
27     //openfile
28     int fd=open("myfifo",O_RDONLY|O_NONBLOCK);
29     if(fd==-1)
30     {
31         perror("open err");
32         exit(1);
33     }
34     //讀管道
35     struct event_base* base=NULL;
36     base=event_base_new();
37     //建立事件
38     struct event* event=NULL;
39         event=event_new(base,fd,EV_READ|EV_PERSIST,read_call_back,NULL);
40     //添加事件
41     event_add(event,NULL); //阻塞等待事件發生
42     //事件循環
43     event_base_dispatch(base);
44     //釋放事件
45     event_free(event);
46     //釋放框架
47     event_base_free(base);
48     close(fd);
49     return 0;
50 }

四。bufferevent

1。概念

bufferevent是libevent基於套接字建立的IO緩衝區，分爲讀緩衝區和寫緩衝區。

　　　當讀緩衝區有數據時，會調用相應的讀回調函數。

　　　當有數據寫入寫緩衝區時，會調用相應的寫回調函數

bufferevent至關於服務器與客戶端創建鏈接以後（accept以後），對讀寫事件進行監聽並處理。

2.函數

1.建立帶緩衝區的事件

2.緩衝區連接（客戶端）

3.設置事件回調函數

4.設置緩衝區可讀，可寫

5.釋放緩衝區

五。evconnlistener 鏈接監聽器

1.簡述

evconnlistener在服務端能夠代替socket，bind，listen，accept的操做，而且能夠設置監聽的回調函數，當有客戶端鏈接後執行回調函數。

2.函數

1.建立鏈接監聽器

2.啓用和禁用evconnlistener

服務端實現

 1 #include<stdio.h>
 2 #include<unistd.h>
 3 #include<stdlib.h>
 4 #include<sys/types.h>
 5 #include<sys/stat.h>
 6 #include<string.h>
 7 #include<ctype.h>
 8 #include<event2/event.h>  
 9 #include<event2/bufferevent.h> //帶緩衝區的事件
10 #include<event2/listener.h> //鏈接監聽器
11 #define PORT 8888 
12 
13 //讀回調
14 void readcb(struct bufferevent* bev,void* arg)
15 {
16     char buf[1024]={0};
17     //讀緩衝區的數據
18     bufferevent_read(bev,buf,sizeof(buf));
19     int i=0;
20     while(buf[i]!='\0')
21     {
22         buf[i]=toupper(buf[i]);
23         i++;
24     }
25     //往緩衝區發送數據
26     bufferevent_write(bev,buf,sizeof(buf));
27 
28 }
29 
30 //寫回調
31 void writecb(struct bufferevent* bev,void* arg)
32 {
33     printf("數據已發送\n");
34 }
35 
36 //事件回調
37 void eventcb(struct bufferevent* bev,short events,void *arg)
38 {
39     if(events&BEV_EVENT_EOF)
40     {
41         printf("connection cloased");
42     }else if(events&BEV_EVENT_ERROR)
43     {
44         printf("err\n");
45     }
46     //釋放bufferevent資源
47     bufferevent_free(bev);
48 }
49 
50 //鏈接完成以後對應的通訊操做
51 void listen_call_back(struct evconnlistener* listener,evutil_socket_t fd,struct sockaddr* addr,int len,void *ptr)
52 {
53     //接收base
54     struct event_base *base=(struct event_base*)ptr;
55     //接收數據 - 發送數據
56     //將fd封裝成帶緩衝區的事件
57     struct bufferevent* bev=bufferevent_socket_new(base,fd,BEV_OPT_CLOSE_ON_FREE);
58     //給bufferevent對應的讀寫緩衝區設置回調函數
59     bufferevent_setcb(bev,readcb,writecb,eventcb,NULL);
60     //設置獨緩衝區的回調可用
61     bufferevent_enable(bev,EV_READ);
62 }
63 int main()
64 {
65     //建立事件處理框架
66     struct event_base* base=event_base_new();
67     //設置服務器地址信息
68     struct sockaddr_in serv;
69     memset(&serv,0,sizeof(serv));
70     serv.sin_family=AF_INET;
71     serv.sin_port=htons(PORT);
72     serv.sin_addr.s_addr=htonl(INADDR_ANY);
73     //建立監聽的套接字
74     //綁定
75     //監聽
76     //等待並接收鏈接
77     //有鏈接時listen_call_back被調用
78     struct evconnlistener* listen=evconnlistener_new_bind(base,listen_call_back,base,LEV_OPT_CLOSE_ON_FREE|LEV_OPT_REUSEABLE,-1,(struct sockaddr*)&serv,sizeof(serv));
79     //開始事件循環
80     event_base_dispatch(base);
81     //釋放資源
82     evconnlistener_free(listen);
83     event_base_free(base);    
84     return 0;
85 }

客戶端

 1 #include <stdio.h>
 2 #include <unistd.h>
 3 #include <stdlib.h>
 4 #include <sys/types.h>
 5 #include <sys/stat.h>
 6 #include <string.h>
 7 #include <event2/event.h>
 8 #include <event2/bufferevent.h>
 9 
10 
11 void read_cb(struct bufferevent *bev, void *arg)
12 {
13     char buf[1024] = {0}; 
14     bufferevent_read(bev, buf, sizeof(buf));
15     printf("Server say: %s\n", buf);
16 }
17 
18 void write_cb(struct bufferevent *bev, void *arg)
19 {
20     printf("I am Write_cb function....\n");
21 }
22 
23 void event_cb(struct bufferevent *bev, short events, void *arg)
24 {
25     if (events & BEV_EVENT_EOF)
26     {
27         printf("connection closed\n");  
28     }
29     else if(events & BEV_EVENT_ERROR)   
30     {
31         printf("some other error\n");
32     }
33     else if(events & BEV_EVENT_CONNECTED)
34     {
35         printf("成功鏈接到服務器, O(∩_∩)O哈哈~\n");
36         return;
37     }
38     
39     bufferevent_free(bev);
40     printf("free bufferevent...\n");
41 }
42 
43 void send_cb(evutil_socket_t fd, short what, void *arg)
44 {
45     char buf[1024] = {0}; 
46     struct bufferevent* bev = (struct bufferevent*)arg;
47     printf("請輸入要發送的數據: \n");
48     read(fd, buf, sizeof(buf));
49     bufferevent_write(bev, buf, strlen(buf)+1);
50 }
51 
52 
53 int main(int argc, const char* argv[])
54 {
55     struct event_base* base;
56     base = event_base_new();
57 
58 
59     struct bufferevent* bev;
60     bev = bufferevent_socket_new(base, -1, BEV_OPT_CLOSE_ON_FREE);
61 
62     // 鏈接服務器
63     struct sockaddr_in serv;
64     memset(&serv, 0, sizeof(serv));
65     serv.sin_family = AF_INET;
66     serv.sin_port = htons(9876);
67     evutil_inet_pton(AF_INET, "127.0.0.1", &serv.sin_addr.s_addr);
68     bufferevent_socket_connect(bev, (struct sockaddr*)&serv, sizeof(serv));
69 
70     // 設置回調
71     bufferevent_setcb(bev, read_cb, write_cb, event_cb, NULL);
72     bufferevent_enable(bev, EV_READ | EV_PERSIST);
73 
74     // 建立一個事件
75     struct event* ev = event_new(base, STDIN_FILENO, 
76                                  EV_READ | EV_PERSIST, 
77                                  send_cb, bev);
78     event_add(ev, NULL);
79     
80     event_base_dispatch(base);
81 
82     event_base_free(base);
83 
84     return 0;
85 }