libevent简介和使用

短命女 2022-08-12 01:21 186阅读 0赞

libevent是一个基于事件触发的网络库，memcached底层也是使用libevent库。  
  
**总体来说，libevent有下面一些特点和优势：**  
\* 事件驱动，高性能；  
\* 轻量级，专注于网络；   
\* 跨平台，支持 Windows、Linux、Mac Os等；   
\* 支持多种 I/O多路复用技术， epoll、poll、dev/poll、select 和kqueue 等；

\* 支持 I/O，定时器和信号等事件；

**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()

[?][Link 1]

编译并执行，编译加 -levent：

[?][Link 1]

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> </td> 
   <td> 
    <div> 
     <div> 
      <code>gapp_devnet_1:/data/home/andyawang/code/2013_11/LibeventTest # mv time.cpp timer.cpp&nbsp; </code> 
     </div> 
     <div> 
      <code>gapp_devnet_1:/data/home/andyawang/code/2013_11/LibeventTest # g++ -o timer timer.cpp -levent&nbsp; </code> 
     </div> 
     <div> 
      <code>gapp_devnet_1:/data/home/andyawang/code/2013_11/LibeventTest # ./timer&nbsp;&nbsp; </code> 
     </div> 
     <div> 
      <code>Game Over!&nbsp; </code> 
     </div> 
     <div> 
      <code>Game Over!&nbsp; </code> 
     </div> 
     <div> 
      <code>Game Over!&nbsp; </code> 
     </div> 
     <div> 
      <code>Game Over!</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

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

event\_base\_new()=>event\_set()=>event\_base\_set()=>event\_add()=>event\_base\_dispatch()

[?][Link 1]

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

来自：http://blog.csdn.net/yyyiran/article/details/12219737

[Link 1]: http://www.open-open.com/lib/view/open1386510630330.html#