libevent庫的應用辦法實例。本站提示廣大學習愛好者:(libevent庫的應用辦法實例)文章只能為提供參考,不一定能成為您想要的結果。以下是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)
{
/* 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 履行。