快捷導(dǎo)航

libevent庫(kù)的使用方法實(shí)例

更新時(shí)間：2013年12月21日 15:32:01 作者：

這篇文章主要介紹了libevent庫(kù)的使用方法實(shí)例，有需要的朋友可以參考一下

接寫(xiě)一個(gè)很簡(jiǎn)單的 Time Server 來(lái)當(dāng)作例子：當(dāng)你連上去以后 Server 端直接提供時(shí)間，然后結(jié)束連線。event_init() 表示初始化 libevent 所使用到的變數(shù)。event_set(&ev, s, EV_READ | EV_PERSIST, connection_accept, &ev) 把 s 這個(gè) File Description 放入 ev (第一個(gè)參數(shù)與第二個(gè)參數(shù))，并且告知當(dāng)事件 (第三個(gè)參數(shù)的 EV_READ) 發(fā)生時(shí)要呼叫 connection_accept() (第四個(gè)參數(shù))，呼叫時(shí)要把 ev 當(dāng)作參數(shù)丟進(jìn)去 (第五個(gè)參數(shù))。其中的 EV_PERSIST 表示當(dāng)呼叫進(jìn)去的時(shí)候不要把這個(gè) event 拿掉 (繼續(xù)保留在 Event Queue 里面)，這點(diǎn)可以跟 connection_accept() 內(nèi)在注冊(cè) connection_time() 的代碼做比較。而 event_add(&ev, NULL) 就是把 ev 注冊(cè)到 event queue 里面，第二個(gè)參數(shù)指定的是 Timeout 時(shí)間，設(shè)定成 NULL 表示忽略這項(xiàng)設(shè)定。
注:這段代碼來(lái)自于網(wǎng)絡(luò),雖然很粗糙,但是對(duì)libevent的使用方法已經(jīng)說(shuō)明的很清楚了.
附源碼:

復(fù)制代碼代碼如下:

#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;
}

在寫(xiě) Nonblocking Network Program 通常要處理 Buffering 的問(wèn)題，但并不好寫(xiě)，主要是因?yàn)?read() 或 recv() 不保證可以一次讀到一行的份量進(jìn)來(lái)。
在 libevent 里面提供相當(dāng)不錯(cuò)的 Buffer Library 可以用，完整的說(shuō)明在 man event 的時(shí)候可以看到，最常用的應(yīng)該就是以 evbuffer_add()、evbuffer_readline() 這兩個(gè) Function，其他的知道存在就可以了，需要的時(shí)候再去看詳細(xì)的用法。
下面直接提供 libevent-buff.c 當(dāng)作范例，編譯后看執(zhí)行結(jié)果，再回頭來(lái)看 source code 應(yīng)該就有感覺(jué)了：

復(fù)制代碼代碼如下:

#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() 表示進(jìn)入 event loop，當(dāng) Queue 里面的任何一個(gè) File Description 發(fā)生事件的時(shí)候就會(huì)進(jìn)入 callback function 執(zhí)行。

您可能感興趣的文章: