libevent庫的使用方法

接寫一個很簡單的 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)  

{  

    fprintf(stderr, "%s(): fd = %d, event = %d.\n", __func__, fd, event);  

    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;  

    }  

    struct event *ev = malloc(sizeof(struct event));  

    event_set(ev, ns, EV_WRITE, (void *) connection_time, ev);  

    event_add(ev, NULL);  

}  

int main(void)  

{  

    int s = socket(PF_INET, SOCK_STREAM, 0);  

    if (s < 0) {  

        perror("socket");  

        exit(1);  

    }  

    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);  

    }  

    if (listen(s, 5) < 0) {  

        perror("listen");  

        exit(1);  

    }  

    event_init();  

    struct event ev;  

    event_set(&ev, s, EV_READ | EV_PERSIST, connection_accept, &ev);  

    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);  

    }  

    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 執行。