赞
踩
Libevent是开源社区的一款高性能的I/O框架库,使用Libevent的著名案例有:高性能的分布式内存对象缓存软件memcached,Googlo浏览器Chromium的Linux版本。作为一个I/O框架库,Libevent具有如下特点:
libevent主框架提供注册方法,通过事件循环去检测事件就绪并通知libevent框架去调用回调函数
#include<stdio.h> #include<stdlib.h> #include<unistd.h> #include<string.h> #include<signal.h> #include<event.h> #include<assert.h> void signal_cb(int fd,short event,void* arg) { //fd与事件类型 系统传入,其他参数在arg printf("sig = %d\n",fd); } void timeout_cb(int fd,short event,void* arg) { printf("Time out\n"); } int main() { //实例初始化 struct event_base* base = event_init(); assert(base != NULL); //定义信号事件 //参数: //哪个实例 //信号是谁 //如何处理信号,回调函数 //传入参数 struct event* sig_ev = evsignal_new(base,SIGINT,signal_cb,NULL); assert(sig_ev != NULL); //注册 //参数: //添加事件 //事件超时事件 event_add(sig_ev,NULL); //定义定时事件 struct event* timeout_ev = evtimer_new(base,timeout_cb,NULL); struct timeval tv = {3,0};//指3秒0微秒 event_add(timeout_ev,&tv); //启动事件循环 event_base_dispatch(base); //阻塞在这里 内部进行循环 并且libevent会根据情况去选择使用select,poll,或eopll //释放事件与实例 event_free(sig_ev); event_free(timeout_ev); event_base_free(base); }
编译代码
直接编译会显示错误,需要链接libevent库
运行查看
设置事件,将事件添加至libevent,其中有三个队列(数据结构为链表)分别存放读写时间、定时器、与信号事件,通过底层I\O复用方法检测,若事件产生就将事件挪至就绪队列中,然后将就绪队列中对应的回调函数一一执行,来相应事件
永久事件需要配合其他事件进行辅助,当我们将事件添加至队列中,当事件产生挪至就绪队列,响应后队列中该事件将不复存在,只相应一次,而永久事件在处理完后,还会再将该事件放回队列,可以将该事件继续检测而不是只检测一次
启动事件循环后,I\O函数会循环检测三个队列上有没有事件产生,若三个队列都为空则会直接退出;或者三个队列不为空,我们调用了退出事件循环的方法退出
在上面的示例中,我们并没有主动去使用事件类型,这是因为我们使用evsignal_new方法以及evtimer_new方法来实现,这两种方法实际上是对event_new方法的封装
在这里我们并没有看到我们的事件类型,现在我们将它展开,将创建信号与定时器的事件表现出来
修改后的完整代码如下,编译运行查看
#include<stdio.h> #include<stdlib.h> #include<unistd.h> #include<string.h> #include<signal.h> #include<event.h> #include<assert.h> void signal_cb(int fd,short event,void* arg) { if(event & EV_SIGNAL) { //fd与事件类型 系统传入,其他参数在arg printf("sig = %d\n",fd); } } void timeout_cb(int fd,short event,void* arg) { if(event & EV_TIMEOUT) { printf("Time out\n"); } } int main() { //实例初始化 struct event_base* base = event_init(); assert(base != NULL); //定义信号事件 //参数: //哪个实例 //信号是谁 //如何处理信号,回调函数 //传入参数 //struct event* sig_ev = evsignal_new(base,SIGINT,signal_cb,NULL); struct event* sig_ev = event_new(base,SIGINT,EV_SIGNAL|EV_PERSIST,signal_cb,NULL); assert(sig_ev != NULL); //注册 //参数: //添加事件 //事件超时事件 event_add(sig_ev,NULL); //定义定时事件 //struct event* timeout_ev = evtimer_new(base,timeout_cb,NULL); struct event* timeout_ev = event_new(base,-1,EV_TIMEOUT,timeout_cb,NULL); struct timeval tv = {3,0};//指3秒0微秒 event_add(timeout_ev,&tv); //启动事件循环 event_base_dispatch(base); //阻塞在这里 内部进行循环 并且libevent会根据情况去选择使用select,poll,或eopll //释放事件与实例 event_free(sig_ev); event_free(timeout_ev); event_base_free(base); }
定时器不是永久事件,触发一次后就会被移除,而信号事件是永久时间则会一直触发
如果我们删除在添加信号时间时,加入的永久事件
struct event* sig_ev = event_new(base,SIGINT,EV_SIGNAL|EV_PERSIST,signal_cb,NULL);
struct event* sig_ev = event_new(base,SIGINT,EV_SIGNAL,signal_cb,NULL);
这时当程序启动,当libevent内部读写事件,定时事件以及信号事件的队列都为空时,事件循环结束,程序结束,而不像上面会不断循环去检测信号事件
客户端代码
首先创建监听队列去监听读事件来自客户端的连接,然后继续监听读事件来自客户段发送来的消息
#include<stdio.h> #include<stdlib.h> #include<unistd.h> #include<string.h> #include<assert.h> #include<sys/socket.h> #include<arpa/inet.h> #include<netinet/in.h> #include<event.h> void recv_cb(int fd, short ev, void* arg) { if(ev & EV_READ) { char buff[128] = {0}; int n = recv(fd,buff,127,0); if(n<=0) { close(fd); printf("client close\n"); return; } printf("buff=%s\n",buff); send(fd,"ok",2,0); } } void accept_cb(int fd, short ev, void* arg) { struct event_base * base = (struct event_base*)arg; if(ev & EV_READ) { struct sockaddr_in caddr; int len = sizeof(caddr); int c = accept(fd,(struct sockaddr*)&caddr,&len); if(c < 0) { return; } printf("accept c = %d\n",c); struct event* c_ev = event_new(base,c,EV_READ|EV_PERSIST,recv_cb,NULL); //无法将c_ev指针传入进函数,函数返回才会产生c_ev if(c_ev == NULL) { close(c); return; } event_add(c_ev,NULL); } } int create_socket(); int main() { int sockfd = create_socket(); assert(sockfd != -1); struct event_base * base = event_init(); assert(base != NULL); //监听读事件 struct event * sock_ev = event_new(base,sockfd,EV_READ|EV_PERSIST,accept_cb,base); assert(sock_ev != NULL); event_add(sock_ev,NULL); event_base_dispatch(base); event_free(sock_ev); event_base_free(base); exit(0); } int create_socket() { int sockfd = socket(AF_INET,SOCK_STREAM,0); if(sockfd == -1) { return -1; } struct sockaddr_in saddr; memset(&saddr,0,sizeof(saddr)); saddr.sin_family = AF_INET; saddr.sin_port = htons(6000); saddr.sin_addr.s_addr = inet_addr("127.0.0.1"); int res = bind(sockfd,(struct sockaddr*)&saddr,sizeof(saddr)); if(res == -1) { return -1; } res = listen(sockfd,5); if(res == -1) { return -1; } return sockfd; }
客户端代码
#include<stdio.h> #include<stdlib.h> #include<unistd.h> #include<string.h> #include<assert.h> #include<sys/socket.h> #include<arpa/inet.h> #include<netinet/in.h> int main() { int sockfd = socket(AF_INET,SOCK_STREAM,0); assert(sockfd!=-1); assert(sockfd != -1); struct sockaddr_in saddr; memset(&saddr,0,sizeof(saddr)); saddr.sin_family = AF_INET; saddr.sin_port = htons(6000); saddr.sin_addr.s_addr = inet_addr("127.0.0.1"); int res = connect(sockfd,(struct sockaddr*)&saddr,sizeof(saddr)); assert(res != -1); while(1) { printf("input:\n"); char buff[128] = {0}; fgets(buff,128,stdin); if(strncmp(buff,"end", 3) == 0) { break; } send(sockfd,buff,strlen(buff),0); memset(buff,0,128); recv(sockfd,buff,127,0); printf("buff = %s\n",buff); } close(sockfd); }
运行结果查看
以上代码存在一个问题
其中event_free(sock_ev)
在释放过程中,不仅释放了空间同时会在libevent中移除,而在监听来自客户端发送消息的读事件,无法将其释放,因为我们并没有创建该监听事件的指针(c_ev),想要解决这个问题需要我们间接的将c_ev的指针传入进去(malloc),或者定义一个数组,根据描述符做下标,c_ev来做值实现映射关系。
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。