然而，目前高效率的 Server 都偏好採用 Event-based，一方面是沒有 Create Process/Thread 所造成的 Overhead，另外一方面是不需要透過 Shared Memory 或是 Mutex 在不同的 Process/Thread 之間交換資料。
使用的是 3-clause BSD license 而非 GPL，所以在不想公開程式碼 (像是商業(yè)用途) 的情況下會比其他的 Library 適合。
接下來要談的是
libevent 要如何使用，不過為了方便起見，我們直接寫一個很簡單的 Time Server 來當(dāng)作例子：當(dāng)你連上去以後 Server 端直接提供時間，然後結(jié)束連線。
在這些例子裡面我以
FreeBSD 6.0 當(dāng)作測試的平臺，另外使用
libevent 1.1a 當(dāng)作 Event-based Library，Compile 時請使用
gcc -I/usr/local/include -o timeserver timeserver.c -L/usr/local/lib -levent (如果
libevent 的 Header 與 Library 放在
/usr/include 與
/usr/lib 下的話可以省略這兩個參數(shù))。
原始程式碼在文章的最後頭。
event_init() 表示初始化
libevent 所使用到的變數(shù)。
event_set(&ev, s, EV_READ | EV_PERSIST, connection_accept, &ev) 把
s 這個 File Description 放入
ev (第一個參數(shù)與第二個參數(shù))，並且告知當(dāng)事件 (第三個參數(shù)的
EV_READ) 發(fā)生時要呼叫
connection_accept() (第四個參數(shù))，呼叫時要把
ev 當(dāng)作參數(shù)丟進去 (第五個參數(shù))。
其中的
EV_PERSIST 表示當(dāng)呼叫進去的時候不要把這個 event 拿掉 (繼續(xù)保留在 Event Queue 裡面)，這點可以跟
connection_accept() 內(nèi)在註冊
connection_time() 的程式碼做比較。
而
event_add(&ev, NULL) 就是把
ev 註冊到 event queue 裡面，第二個參數(shù)指定的是 Timeout 時間，設(shè)定成
NULL 表示忽略這項設(shè)定。
最後的
event_dispatch() 表示進入 event loop，當(dāng) Queue 裡面的任何一個 File Description 發(fā)生事件的時候就會進入 callback function 執(zhí)行。
這隻程式非常粗糙，有很多地方?jīng)]有注意到 Blocking 的問題，這點我們就先不管了。當(dāng)跑起來以後你就可以連到 port 7000，就會出現(xiàn)類似下面的結(jié)果：gslin@netnews [~] [3:14/W5] t 0 7000
gslin@netnews [~/work/C] [3:15/W3] t 0 7000
Trying 0.0.0.0...
Connected to 0.
Escape character is '^]'.
Fri Nov 25 03:15:10 2005
Connection closed by foreign host.
最基本的使用就是這樣了，你可以
man event 看到完整的說明。
這是
timeserver.c：
#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;
}
這次要談的跟 Network Programming 沒有直接的關(guān)係。
在寫 Nonblocking Network Program 通常要處理 Buffering 的問題，但並不好寫，主要是因為
read() 或
recv() 不保證可以一次讀到一行的份量進來。
在
libevent 裡面提供相當(dāng)不錯的 Buffer Library 可以用，完整的說明在
man event 的時候可以看到，最常用的應(yīng)該就是以
evbuffer_add()、
evbuffer_readline() 這兩個 Function，其他的知道存在就可以了，需要的時候再去看詳細(xì)的用法。
下面直接提供
libevent-buff.c 當(dāng)作範(fàn)例，編譯後看執(zhí)行結(jié)果，再回頭來看 source code 應(yīng)該就有感覺了：
#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);
}