libevent库的使用方法实例

所属分类: 软件编程 / C 语言 阅读数: 118
收藏 0 赞 0 分享

接写一个很简单的 Time Server 来当作例子:当你连上去以后 Server 端直接提供时间,然后结束连线。event_init() 表示初始化 libevent 所使用到的变数。event_set(&ev, s, EV_READ | EV_PERSIST, connection_accept, &ev) 把 s 这个 File Description 放入 ev (第一个参数与第二个参数),并且告知当事件 (第三个参数的 EV_READ) 发生时要呼叫 connection_accept() (第四个参数),呼叫时要把 ev 当作参数丢进去 (第五个参数)。其中的 EV_PERSIST 表示当呼叫进去的时候不要把这个 event 拿掉 (继续保留在 Event Queue 里面),这点可以跟 connection_accept() 内在注册 connection_time() 的代码做比较。而 event_add(&ev, NULL) 就是把 ev 注册到 event queue 里面,第二个参数指定的是 Timeout 时间,设定成 NULL 表示忽略这项设定。
注:这段代码来自于网络,虽然很粗糙,但是对libevent的使用方法已经说明的很清楚了.
附源码:

复制代码 代码如下:

#include <netinet/in.h>  
#include <sys/socket.h>  
#include <sys/types.h>  
#include <event.h>  
#include <stdio.h>  
#include <time.h>  

void connection_time(int fd, short event, struct event *arg)  
{  
    char buf[32];  
    struct tm t;  
    time_t now;  

    time(&now);  
    localtime_r(&now, &t);  
    asctime_r(&t, buf);  

    write(fd, buf, strlen(buf));  
    shutdown(fd, SHUT_RDWR);  

    free(arg);  
}  

void connection_accept(int fd, short event, void *arg)  
{  
    /* for debugging */
    fprintf(stderr, "%s(): fd = %d, event = %d.\n", __func__, fd, event);  

    /* Accept a new connection. */
    struct sockaddr_in s_in;  
    socklen_t len = sizeof(s_in);  
    int ns = accept(fd, (struct sockaddr *) &s_in, &len);  
    if (ns < 0) {  
        perror("accept");  
        return;  
    }  

    /* Install time server. */
    struct event *ev = malloc(sizeof(struct event));  
    event_set(ev, ns, EV_WRITE, (void *) connection_time, ev);  
    event_add(ev, NULL);  
}  

int main(void)  
{  
    /* Request socket. */
    int s = socket(PF_INET, SOCK_STREAM, 0);  
    if (s < 0) {  
        perror("socket");  
        exit(1);  
    }  

    /* bind() */
    struct sockaddr_in s_in;  
    bzero(&s_in, sizeof(s_in));  
    s_in.sin_family = AF_INET;  
    s_in.sin_port = htons(7000);  
    s_in.sin_addr.s_addr = INADDR_ANY;  
    if (bind(s, (struct sockaddr *) &s_in, sizeof(s_in)) < 0) {  
        perror("bind");  
        exit(1);  
    }  

    /* listen() */
    if (listen(s, 5) < 0) {  
        perror("listen");  
        exit(1);  
    }  

    /* Initial libevent. */
    event_init();  

    /* Create event. */
    struct event ev;  
    event_set(&ev, s, EV_READ | EV_PERSIST, connection_accept, &ev);  

    /* Add event. */
    event_add(&ev, NULL);  

    event_dispatch();  

    return 0;  
}

在写 Nonblocking Network Program 通常要处理 Buffering 的问题,但并不好写,主要是因为 read() 或 recv() 不保证可以一次读到一行的份量进来。
在 libevent 里面提供相当不错的 Buffer Library 可以用,完整的说明在 man event 的时候可以看到,最常用的应该就是以 evbuffer_add()、evbuffer_readline() 这两个 Function,其他的知道存在就可以了,需要的时候再去看详细的用法。
下面直接提供 libevent-buff.c 当作范例,编译后看执行结果,再回头来看 source code 应该就有感觉了:

复制代码 代码如下:

#include <sys/time.h>  
#include <event.h>  
#include <stdio.h>  

void printbuf(struct evbuffer *evbuf)  
{  
    for (;;) {  
        char *buf = evbuffer_readline(evbuf);  
        printf("* buf = %p, the string = \"\e[1;33m%s\e[m\"\n", buf, buf);  
        if (buf == NULL)  
            break;  
        free(buf);  
    }  
}  

int main(void)  
{  
    struct evbuffer *evbuf;  

    evbuf = evbuffer_new();  
    if (evbuf == NULL) {  
        fprintf(stderr, "%s(): evbuffer_new() failed.\n", __func__);  
        exit(1);  
    }  

    /* Add "gslin" into buffer. */
    u_char *buf1 = "gslin";  
    printf("* Add \"\e[1;33m%s\e[m\".\n", buf1);  
    evbuffer_add(evbuf, buf1, strlen(buf1));  
    printbuf(evbuf);  

    u_char *buf2 = " is reading.\nAnd he is at home.\nLast.";  
    printf("* Add \"\e[1;33m%s\e[m\".\n", buf2);  
    evbuffer_add(evbuf, buf2, strlen(buf2));  
    printbuf(evbuf);  

    evbuffer_free(evbuf);  
}  


最后的 event_dispatch() 表示进入 event loop,当 Queue 里面的任何一个 File Description 发生事件的时候就会进入 callback function 执行。

更多精彩内容其他人还在看

用标准c++实现string与各种类型之间的转换

这个类在头文件中定义, < sstream>库定义了三种类:istringstream、ostringstream和stringstream,分别用来进行流的输入、输出和输入输出操作。另外,每个类都有一个对应的宽字符集版本
收藏 0 赞 0 分享

C++如何通过ostringstream实现任意类型转string

再使用整型转string的时候感觉有点棘手,因为itoa不是标准C里面的,而且即便是有itoa,其他类型转string不是很方便。后来去网上找了一下,发现有一个好方法
收藏 0 赞 0 分享

C/C++指针小结

要搞清一个指针需要搞清指针的四方面的内容:指针的类型,指针所指向的类型,指针的值或者叫指针所指向的内存区,还有指针本身所占据的内存区
收藏 0 赞 0 分享

C++ 类的静态成员深入解析

在C++中类的静态成员变量和静态成员函数是个容易出错的地方,本文先通过几个例子来总结静态成员变量和成员函数使用规则,再给出一个实例来加深印象
收藏 0 赞 0 分享

C++类的静态成员初始化详细讲解

通常静态数据成员在类声明中声明,在包含类方法的文件中初始化.初始化时使用作用域操作符来指出静态成员所属的类.但如果静态成员是整型或是枚举型const,则可以在类声明中初始化
收藏 0 赞 0 分享

C++类静态成员与类静态成员函数详解

静态成员不可在类体内进行赋值,因为它是被所有该类的对象所共享的。你在一个对象里给它赋值,其他对象里的该成员也会发生变化。为了避免混乱,所以不可在类体内进行赋值
收藏 0 赞 0 分享

C++中的friend友元函数详细解析

友元可以是一个函数,该函数被称为友元函数;友元也可以是一个类,该类被称为友元类。友元函数的特点是能够访问类中的私有成员的非成员函数。友元函数从语法上看,它与普通函数一样,即在定义上和调用上与普通函数一样
收藏 0 赞 0 分享

static全局变量与普通的全局变量的区别详细解析

以下是对static全局变量与普通的全局变量的区别进行了详细的分析介绍,需要的朋友可以过来参考下,希望对大家有所帮助
收藏 0 赞 0 分享

C++ explicit关键字的应用方法详细讲解

C++ explicit关键字用来修饰类的构造函数,表明该构造函数是显式的,既然有"显式"那么必然就有"隐式",那么什么是显示而什么又是隐式的呢?下面就让我们一起来看看这方面的知识吧
收藏 0 赞 0 分享

教你5分钟轻松搞定内存字节对齐

随便google一下,人家就可以跟你解释的,一大堆的道理,我们没怎么多时间,讨论为何要对齐.直入主题,怎么判断内存对齐规则,sizeof的结果怎么来的,请牢记以下3条原则
收藏 0 赞 0 分享
查看更多