zoukankan      html  css  js  c++  java
  • Libevent笔记

    Libevent简介

    libevent是一个基于事件触发的网络库,适用于windows、linux、bsd等多种平台,内部使用select、epoll、kqueue等系统调用管理事件机制。

    官网:http://libevent.org/

    特点

    • 事件驱动,高性能;

    • 轻量级,专注于网络,不如ACE那么臃肿庞大,只提供了简单的网络API的封装,线程池,内存池,递归锁等均需要自己实现

    • 开放源码,代码相当精炼、易读;

    • 跨平台,支持Windows、Linux、BSD和Mac OS;

    • 支持多种I/O多路复用技术epoll、poll、dev/poll、select和kqueue等),在不同的操作系统下,做了多路复用模型的抽象,可以选择使用不同的模型,通过事件函数提供服务

    • 支持I/O,定时器和信号等事件;

    • 采用Reactor模式;

    源码组织结构

    Libevent的源代码虽然都在一层文件夹下面,但是其代码分类还是相当清晰的,主要可分为头文件、内部使用的头文件、辅助功能函数、日志、libevent框架、对系统I/O多路复用机制的封装、信号管理、定时事件管理、缓冲区管理、基本数据结构和基于libevent的两个实用库等几个部分,有些部分可能就是一个源文件。

    源代码中的test部分就不在我们关注的范畴了。

    1)头文件

    主要就是event.h:事件宏定义、接口函数声明,主要结构体event的声明;

    2)内部头文件

    xxx-internal.h:内部数据结构和函数,对外不可见,以达到信息隐藏的目的;

    3)libevent框架

    event.c:event整体框架的代码实现;

    4)对系统I/O多路复用机制的封装

    epoll.c:对epoll的封装;

    select.c:对select的封装;

    devpoll.c:对dev/poll的封装;

    kqueue.c:对kqueue的封装;

    5)定时事件管理

    min-heap.h:其实就是一个以时间作为key的小根堆结构;

    6)信号管理

    signal.c:对信号事件的处理;

    7)辅助功能函数

    evutil.h 和evutil.c:一些辅助功能函数,包括创建socket pair和一些时间操作函数:加、减和比较等。

    8)日志

    log.h和log.c:log日志函数

    9)缓冲区管理

    evbuffer.c和buffer.c:libevent对缓冲区的封装;

    10)基本数据结构

    compat/sys下的两个源文件:queue.h是libevent基本数据结构的实现,包括链表,双向链表,队列等;_libevent_time.h:一些用于时间操作的结构体定义、函数和宏定义;

    11)实用网络库

    http和evdns:是基于libevent实现的http服务器和异步dns查询库;

    linux下源码安装

    这里以libevent-2.0.19为例,最新版本详见官网(http://libevent.org/)。

    wget https://github.com/downloads/libevent/libevent/libevent-2.0.19-stable.tar.gz
    tar zxvf libevent-2.0.19-stable.tar.gz
    cd libevent-2.0.19-stable
    ./configure && make && make install

    报错:

    error while loading shared libraries: libevent-2.0.so.5: cannot open shared object file: No such file or directory

    解决办法:

    On a 32 bit system:

    ln -s /usr/local/lib/libevent-2.0.so.5 /usr/lib/libevent-2.0.so.5

    On a 64 bit system:

    ln -s /usr/local/lib/libevent-2.0.so.5 /usr/lib64/libevent-2.0.so.5

    示例

    1、获取版本

    View Code
    // gcc getVersion.c -o getVersion -levent
    
    #include <event.h>
    #include <stdio.h>
    
    int main()
    {
        const char *version = event_get_version();
        printf("%s\n",version);
        return 0;
    }


    2、一个timer程序

    View Code
    // gcc timer.c -o timer -levent
    #include <stdio.h>
    #include <stdlib.h>
    #include <string.h>
    #include <time.h>
    #include <event2/event.h>
    #include <event2/event_struct.h>
    
    #define N 300
    #define BUFLEN 256
    
    struct timeval lasttime;
    struct ST_EventWithDescription
    {
        struct event *p_event;
        int time_interval;
        char lable[BUFLEN];
    };
    
    static void timeout_cb(evutil_socket_t fd, short event, void *arg)
    {
        struct timeval newtime, difference;
        struct ST_EventWithDescription *pSTEvent = arg;
        struct event *timeout = pSTEvent->p_event;
        double elapsed;
    
        evutil_gettimeofday(&newtime, NULL);
        evutil_timersub(&newtime, &lasttime, &difference);
        elapsed = difference.tv_sec + (difference.tv_usec / 1.0e6);
    
        printf("%s called at %d: %.3f seconds since my last work.\n",
              (char*)pSTEvent->lable,(int)newtime.tv_sec, elapsed);
        lasttime = newtime;
    
        struct timeval tv;
        evutil_timerclear(&tv);
        tv.tv_sec = pSTEvent->time_interval;
        event_add(timeout, &tv);
    }
    
    void setParam(struct ST_EventWithDescription *stEventDescription,
                  struct event *m_event,int time_interval,char* m_lable)
    {
        stEventDescription->p_event = m_event;
        stEventDescription->time_interval = time_interval;
        memset(stEventDescription->lable,0,sizeof(stEventDescription->lable));
        memcpy(stEventDescription->lable,m_lable,strlen(m_lable)+1);
    }
    
    void setTimeIntervalArr(int *arr,int n)
    {
        int i;
        srand(time(NULL));
        for(i=0; i<n; ++i)
        {
            *(arr+i) = rand()%n + 1;
            //*(arr+i) = i+1;
        }
    }
    
    int main(int argc, char **argv)
    {
        struct event timeout[N];
        struct ST_EventWithDescription stEvent[N];
        int time_interval[N];
        int i=0;
    
        struct timeval tv;
        struct event_base *base;
        int flags = 0;
    
        setTimeIntervalArr(time_interval,N);
    
        base = event_base_new();
        evutil_timerclear(&tv);
    
        for(i=0; i<N; ++i)
        {
            char buf[BUFLEN]= {0};
            sprintf(buf,"task%d",i+1);
            setParam(stEvent+i,timeout+i,time_interval[i],buf);
            event_assign(timeout+i, base, -1, flags, timeout_cb, (void*)(stEvent+i));
            event_add(timeout+i, &tv);
        }
        
        evutil_gettimeofday(&lasttime, NULL);
        event_base_dispatch(base);
    
        return (0);
    }

     demo的完整地址:https://github.com/mike-zhang/testCodes/tree/master/libeventTest

  • E-Mail : Mike_Zhang@live.com
  • 转载请注明出处,谢谢!
查看全文
  • 相关阅读:
    python 安装第三方插件库报错的解决方案
    vue.js helloword
    node.js HelloWord
    十一 —— 迭代器、生成器、装饰器
    十、函数——匿名函数、推导式
    九、函数 —— 参数
    八、数据类型——bytes类型+set类型
    七、数据类型 —— 字典
    六、数据类型 —— 字符串
    五、数据类型 —— 元组
  • 原文地址:https://www.cnblogs.com/MikeZhang/p/libeventNote20121021.html
  • Copyright © 2011-2022 走看看