libevent简介和使用

libevent是一个基于事件触发的网络库,memcached底层也是使用libevent库,今天学习下。

总体来说,libevent有下面一些特点和优势:
* 统一数据源, 统一I/O事件,信号和定时器这三种事件;

* 可移植,跨平台支持多种I/O多路复用技术, epoll、poll、dev/poll、select 和kqueue 等;

* 对并发编程支持,避免竞态条件;

* 高性能,由事件驱动;

* 轻量级,专注于网络;


libevent有下面几大部分组成:

* 事件管理包括各种IO(socket)、定时器、信号等事件,也是libevent应用最广的模块;

* 缓存管理是指evbuffer功能;

* DNS是libevent提供的一个异步DNS查询功能;

* HTTP是libevent的一个轻量级http实现,包括服务器和客户端


一些资料:
* libevent官网:http://libevent.org/ 
* libevent API:http://www.monkey.org/~provos/libevent/doxygen-2.0.1/index.html
* CSDN上剖析得很赞的文章:http://blog.csdn.net/sparkliang/article/details/4957667


// =============================================================================================


下面写了2个简单的使用例子,一个是定时器,一个是TCP服务器,都只涉及到libevent的事件管理模块。


一、简单定时器:实现程序每秒输出一个“Game Over!”

event_init() => evtimer_set() => event_add() =>event_dispatch()

[cpp] view plaincopy
在CODE上查看代码片派生到我的代码片
  1. #include <stdio.h>  
  2. #include <iostream>  
  3.   
  4. // libevent头文件  
  5. #include <event.h>  
  6. using namespace std;  
  7.   
  8. // 定时事件回调函数  
  9. void onTime(int sock, short event, void *arg)  
  10. {  
  11.     cout << "Game Over!" << endl;  
  12.   
  13.     struct timeval tv;  
  14.     tv.tv_sec = 1;  
  15.     tv.tv_usec = 0;  
  16.     // 重新添加定时事件(定时事件触发后默认自动删除)  
  17.     event_add((struct event*)arg, &tv);  
  18. }  
  19.   
  20. int main()  
  21. {  
  22.     // 初始化  
  23.     event_init();  
  24.   
  25.     struct event evTime;  
  26.     // 设置定时事件  
  27.     evtimer_set(&evTime, onTime, &evTime);  
  28.   
  29.     struct timeval tv;  
  30.     tv.tv_sec = 1;  
  31.     tv.tv_usec = 0;  
  32.     // 添加定时事件  
  33.     event_add(&evTime, &tv);  
  34.   
  35.     // 事件循环  
  36.     event_dispatch();  
  37.   
  38.     return 0;  
  39. }  
编译并执行,编译加 -levent:

[cpp] view plaincopy
在CODE上查看代码片派生到我的代码片
  1. gapp_devnet_1:/data/home/andyawang/code/2013_11/LibeventTest # mv time.cpp timer.cpp  
  2. gapp_devnet_1:/data/home/andyawang/code/2013_11/LibeventTest # g++ -o timer timer.cpp -levent  
  3. gapp_devnet_1:/data/home/andyawang/code/2013_11/LibeventTest # ./timer   
  4. Game Over!  
  5. Game Over!  
  6. Game Over!  
  7. Game Over!  

二、TCP服务器: 实现监听本机8888端口并输出客户端发送过来的信息

event_base_new()=>event_set()=>event_base_set()=>event_add()=>event_base_dispatch()

[cpp] view plaincopy
在CODE上查看代码片派生到我的代码片
  1. #include <stdio.h>  
  2. #include <string.h>  
  3. #include <iostream>  
  4. #include <sys/socket.h>      
  5. #include <netinet/in.h>      
  6. #include <arpa/inet.h>      
  7. #include <netdb.h>  
  8.   
  9. #include <event.h>  
  10. using namespace std;  
  11.   
  12. // 事件base  
  13. struct event_base* base;  
  14.   
  15. // 读事件回调函数  
  16. void onRead(int iCliFd, short iEvent, void *arg)  
  17. {  
  18.     int iLen;  
  19.     char buf[1500];  
  20.   
  21.     iLen = recv(iCliFd, buf, 1500, 0);  
  22.   
  23.     if (iLen <= 0) {  
  24.         cout << "Client Close" << endl;  
  25.   
  26.         // 连接结束(=0)或连接错误(<0),将事件删除并释放内存空间  
  27.         struct event *pEvRead = (struct event*)arg;  
  28.         event_del(pEvRead);  
  29.         delete pEvRead;  
  30.   
  31.         close(iCliFd);  
  32.         return;  
  33.     }  
  34.   
  35.     buf[iLen] = 0;  
  36.     cout << "Client Info:" << buf << endl;  
  37. }  
  38.   
  39. // 连接请求事件回调函数  
  40. void onAccept(int iSvrFd, short iEvent, void *arg)  
  41. {  
  42.     int iCliFd;  
  43.     struct sockaddr_in sCliAddr;  
  44.   
  45.     socklen_t iSinSize = sizeof(sCliAddr);  
  46.     iCliFd = accept(iSvrFd, (struct sockaddr*)&sCliAddr, &iSinSize);  
  47.   
  48.     // 连接注册为新事件 (EV_PERSIST为事件触发后不默认删除)  
  49.     struct event *pEvRead = new event;  
  50.     event_set(pEvRead, iCliFd, EV_READ|EV_PERSIST, onRead, pEvRead);  
  51.     event_base_set(base, pEvRead);  
  52.     event_add(pEvRead, NULL);  
  53. }  
  54.   
  55. int main()  
  56. {  
  57.   
  58.     int iSvrFd;    
  59.     struct sockaddr_in sSvrAddr;  
  60.                 
  61.     memset(&sSvrAddr, 0, sizeof(sSvrAddr));    
  62.     sSvrAddr.sin_family = AF_INET;    
  63.     sSvrAddr.sin_addr.s_addr = inet_addr("127.0.0.1");      
  64.     sSvrAddr.sin_port = htons(8888);     
  65.                               
  66.     // 创建tcpSocket(iSvrFd),监听本机8888端口    
  67.     iSvrFd = socket(AF_INET, SOCK_STREAM, 0);    
  68.     bind(iSvrFd, (struct sockaddr*)&sSvrAddr, sizeof(sSvrAddr));    
  69.     listen(iSvrFd, 10);  
  70.   
  71.     // 初始化base  
  72.     base = event_base_new();  
  73.       
  74.     struct event evListen;  
  75.     // 设置事件  
  76.     event_set(&evListen, iSvrFd, EV_READ|EV_PERSIST, onAccept, NULL);  
  77.     // 设置为base事件  
  78.     event_base_set(base, &evListen);  
  79.     // 添加事件  
  80.     event_add(&evListen, NULL);  
  81.       
  82.     // 事件循环  
  83.     event_base_dispatch(base);  
  84.   
  85.     return 0;  
  86. }  

三. HTTP服务器

   

C代码  收藏代码
  1. #include <stdio.h>  
  2. #include <stdlib.h>  
  3. #include <unistd.h>  
  4. #include <event.h>  
  5. #include <evhttp.h>  
  6.   
  7. void reqHandler(struct evhttp_request *req,void *arg)  
  8. {  
  9.     struct evbuffer *buf = evbuffer_new();  
  10.       
  11.     // 发送响应  
  12.     evbuffer_add_printf(buf, "Thanks for the request");  
  13.     evhttp_send_reply(req,HTTP_OK,"Client",buf);  
  14.       
  15.     evbuffer_free(buf);  
  16.       
  17.     return;  

  1. void http_handle(struct evhttp_request* req, void* arg)
    {
        struct evbuffer* buffer = evbuffer_new();

        // 获取客户端请求的URL
        const char* url;
        url = evhttp_request_uri(req);
        evbuffer_add_printf(buffer, "url = %s\n", url);

        // 解析url的参数(即GET方法的参数)
        struct evkeyvalq params;
        evhttp_parse_query(url, &params);
        evbuffer_add_printf(buffer, "a = %s\n", evhttp_find_header(&params, "a"));
        evbuffer_add_printf(buffer, "b = %s\n", evhttp_find_header(&params, "b"));

        // 设置HTTP表头
        evhttp_add_header(req->output_headers, "Server", "mytest http server 0.1");
        evhttp_add_header(req->output_headers, "Content-Type", "text/plain;charset=UTF-8");
        evhttp_add_header(req->output_headers, "Connection", "close");

        // 返回数据
        evhttp_send_reply(req, HTTP_OK, "OK", buffer);
        evbuffer_free(buffer);
    }

  2. int main(int argc,char **argv)  
  3. {  
  4.     short port = 8000;  
  5.     const char *addr = "192.168.1.11";  
  6.     struct evhttp *httpserv = NULL;  
  7.   
  8.     event_init();  
  9.         // 启动http服务  
  10.     httpserv = evhttp_start(addr,port);  
  11.   
  12.     // 设置回调  
  13.     evhttp_set_gencb(httpserv, reqHandler,NULL);  
  14.     printf("Server started on port %d\n",port);  
  15.   
  16.     event_dispatch();  
  17.   
  18.     return 0;  
  19. }  

    浏览器访问: http://192.168.1.11:8000 会显示 Thanks for the request




  1. #include <stdio.h>  
  2. #include <stdlib.h>  
  3. #include <unistd.h>  
  4. #include <event.h>  
  5. #include <evhttp.h>  
  6.   
  7. void reqHandler(struct evhttp_request *req,void *arg)  
  8. {  
  9.     struct evbuffer *buf = evbuffer_new();  
  10.       
  11.     // 发送响应  
  12.     evbuffer_add_printf(buf, "Thanks for the request");  
  13.     evhttp_send_reply(req,HTTP_OK,"Client",buf);  
  14.       
  15.     evbuffer_free(buf);  
  16.       
  17.     return;  


  1. void http_handle(struct evhttp_request* req, void* arg)
    {
        struct evbuffer* buffer = evbuffer_new();

        // 获取客户端请求的URL
        const char* url;
        url = evhttp_request_uri(req);
        evbuffer_add_printf(buffer, "url = %s\n", url);

        // 解析url的参数(即GET方法的参数)
        struct evkeyvalq params;
        evhttp_parse_query(url, &params);
        evbuffer_add_printf(buffer, "a = %s\n", evhttp_find_header(&params, "a"));
        evbuffer_add_printf(buffer, "b = %s\n", evhttp_find_header(&params, "b"));

        // 设置HTTP表头
        evhttp_add_header(req->output_headers, "Server", "mytest http server 0.1");
        evhttp_add_header(req->output_headers, "Content-Type", "text/plain;charset=UTF-8");
        evhttp_add_header(req->output_headers, "Connection", "close");

        // 返回数据
        evhttp_send_reply(req, HTTP_OK, "OK", buffer);
        evbuffer_free(buffer);
    }

  2. int main(int argc,char **argv)  
  3. {  
  4.     short port = 8000;  
  5.     const char *addr = "192.168.1.11";  
  6.     struct evhttp *httpserv = NULL;  
  7.   
  8.     event_init();  
  9.         // 启动http服务  
  10.     httpserv = evhttp_start(addr,port);  
  11.   
  12.     // 设置回调  
  13.     evhttp_set_gencb(httpserv, reqHandler,NULL);  
  14.     printf("Server started on port %d\n",port);  
  15.   
  16.     event_dispatch();  
  17.   
  18.     return 0;  


本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/351921.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

qr码生成_从Java程序生成QR码图像

qr码生成如果您精通技术和小工具&#xff0c;则必须了解QR码。 这些天&#xff0c;到处都可以找到它-在博客&#xff0c;网站&#xff0c;甚至在某些公共场所。 这在移动应用程序中非常流行&#xff0c;在移动应用程序中&#xff0c;您可以使用QR Code扫描仪应用程序扫描QR Cod…

jracdrive变频器说明书580_jracdrive变频器err02

A&#xff1a;高性能密封型变频器-防粉尘、防水、防油污、防腐蚀此款高性能变频器&#xff0c;因为其具有防粉尘、防水、防油污、防腐蚀性能&#xff0c;适用于化工厂、印染厂、化纤厂、纺织厂、输送带、机床、水泥厂、制*厂、食品厂等环境恶劣的场合。变频器硬件特点&#xff…

Harris角点检测+sift描述匹配

最近用到&#xff1a;Harris检测图像中边缘处的特征点&#xff0c;并且需要两张图特征点匹配起来。Harris只是一个角点检测的算法&#xff0c;最终只得到特征点坐标&#xff0c;想要匹配需要描述&#xff0c;而Harris是单尺度的&#xff0c;自己写描述函数又有些麻烦。找到MATL…

python辅助脚本教程_微信跳一跳python辅助脚本实例分享

本文主要为大家整理了关于微信跳一跳的辅助脚本内容&#xff0c;这次我们给大家整理的是关于python的脚本内容&#xff0c;一起来学习下。这段时间微信跳一跳这个游戏非常火爆&#xff0c;但是上分又非常的难&#xff0c;对于程序员来说第一个念头就是通过写一个辅助脚本外挂让…

Bug解决方案

一&#xff1a;百度错误代码或者关键字搜索 二&#xff1a;在博客论坛招贴问人 三&#xff1a;向同事或者公司老人请教 四&#xff1a;程序的每个字母逻辑浏览一遍 五&#xff1a;重启电脑 六&#xff1a;环境软件重装 七&#xff1a;回去睡一觉&#xff0c;等待明天早上再看 八…

非Java专家的APM:什么泄漏?

通过AppDynamics解决应用程序问题的速度提高了10倍–以最小的开销在代码级深度监视生产应用程序。 开始免费试用&#xff01; 内存&#xff0c;内存&#xff0c;内存... 内存是Java的关键部分&#xff0c;尤其是内存管理。 作为开发人员&#xff0c;内存管理不是您要定期执行…

总结libevent安装方法

1.先用&#xff1a;ls -al /usr/lib | grep libevent 查看是否已安装&#xff0c;如果已安装且版本低于1.3&#xff0c;则先通过&#xff1a;rpm -e libevent —nodeps 进行卸载。 2.下载libevent安装包&#xff1a;libevent-1.4.13-stable.tar.gz&#xff0c;然后解压。 3.切…

opencv中匹配点对的坐标提取

在opencv中&#xff0c;特征检测、描述、匹配都有集成的函数。vector<DMatch> bestMatches;用来存储得到的匹配点对。那么如何提取出其中的坐标呢&#xff1f; int index1, index2;for (int i 0; i < bestMatches.size(); i)//将匹配的特征点坐标赋给point{index1 b…

echarts 弹出放大_Echarts图标增加全屏/放大功能

需求描述&#xff1a;客户爸爸在看某个echarts图表时&#xff0c;图标的数据很多&#xff0c;字看着很小&#xff0c;客户爸爸希望能双击放大某个图表。如下面这个图表字太小&#xff0c;太密。image.png解决方式&#xff1a;网上有不少方式是用Echarts的tool工具先上自定义工具…

Hdoj 1847.Good Luck in CET-4 Everybody! 题解

Problem Description 大学英语四级考试就要来临了&#xff0c;你是不是在紧张的复习&#xff1f;也许紧张得连短学期的ACM都没工夫练习了&#xff0c;反正我知道的Kiki和Cici都是如此。当然&#xff0c;作为在考场浸润了十几载的当代大学生&#xff0c;Kiki和Cici更懂得考前的放…

mexw32与mexw64

关于mex文件 MATLAB的mex文件是一种特征的函数封装形式&#xff0c;这类函数一般由C/C语言编写的&#xff0c;经过MATLAB编译器处理而生成的二进制文件。它可以被MATLAB解释器自动装载并执行的动态链接程序&#xff0c;类似于windows下的dll文件。在使用的时候也可以像普通的.m…

对外汉语语料库有哪些_国内语料库建设一览表

英语学习者语料库(书面语及口语)中国学习者语料库 CLEC(100万)广外、上海交大大学英语学习者口语语料库 COLSEC (5万) 上海交大香港科技大学学习者语料库 HKUST Learner Corpus 香港科技大学中国英语专业语料库 CEME (148万) 南京大学中国英语学习者口语语料库 SECCL (100万) 南…

数据库设计(一对一、一对多、多对多)

关联映射&#xff1a;一对多/多对一 存在最普遍的映射关系&#xff0c;简单来讲就如球员与球队的关系&#xff1b; 一对多&#xff1a;从球队角度来说一个球队拥有多个球员 即为一对多 多对一&#xff1a;从球员角度来说多个球员属于一个球队 即为多对一数据表间一对多关系如下…

oozie与hue整合 执行WC案例报错: 连接10020端口被拒绝

Call From hdp-05/192.168.230.15 to hdp-01:10020 failed on connection exception: java.net.ConnectException: 拒绝连接; For more details see: http://wiki.apache.org/hadoop/ConnectionRefused错误原因没有启动hadoop的history程序JobHistoryServer进程监听端口就是10…

matlab无法读取xls

我首先从C中导出了xls格式的excel表格&#xff0c;又用MATLAB读取时&#xff0c;遇到下面的问题&#xff1a; Error using xlsread (line 251) File E:\matlab_pagram\myGMS\right.xls not in Microsoft Excel Format. 我的读取函数是&#xff1a;labels_right xlsread(righ…

Valhalla项目的价值

我对Valhalla项目的进度一直很感兴趣&#xff0c;但是Brian Goetz最近的信息“ Valhalla项目&#xff1a;目标 ”提高了我的兴趣。 我经常喜欢Goetz的作品&#xff0c;因为他结合了我最想成为技术作者的两个特征&#xff1a;他比他所写的内容更了解他所写的主题&#xff0c;而且…

python里clear和copy_python之字典

通过名字引用值得数据结构.这种结构类型称为映射.字典是python中唯一内建的映射类型.字典中的值并没有特殊的顺序,但是都存储在一个特定的键里.键可以是数字,字符串甚至是元组.某些情况下,字典比列表更加适用:1.表征游戏棋盘的状态,每个键都是由坐标值组成的元组;2.存储文件修改…

实用类-会员信息

录入会员生日&#xff0c;形式必须是“月/日”&#xff0c;如“09/12”&#xff1b;录入的密码必须在6-10位之间&#xff1b;允许用户重复输入&#xff0c;直到输入正确为止。 1 package demo3;2 3 import java.util.Scanner;4 5 public class Test8 {6 public static void…

GDAL学习总结

GDAL介绍 GDAL(Geospatial Data Abstraction Library)是一个在X/MIT许可协议下的开源栅格空间数据转换库。它利用抽象数据模型来表达所支持的各种文件格式。它还有一系列命令行工具来进行数据转换和处理。OGR是GDAL项目的一个分支&#xff0c;功能与GDAL类似&#xff0c;只不过…

matlab能用矩阵操作就不要用for循环

1.MATLAB尽量少用for循环来操作矩阵&#xff0c;多用本身的矩阵操作函数 比如&#xff0c;想将矩阵的第三列通过第二列计算得到&#xff0c;以下两种方式得到的结果一致&#xff0c;但不用for更简洁。 a 6; feature_labelnum(:,3) a * sqrt(feature_labelnum(:,2));%第三列…