libevent庫的使用--定時器的使用實例

更新時間：2013年12月21日 15:29:09 作者：

這篇文章主要介紹了libevent庫的使用--定時器的使用實例，有需要的朋友可以參考一下

#include <sys/types.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/stat.h>
#include <event.h>
#include <evhttp.h>

#define RELOAD_TIMEOUT 5
#define DEFAULT_FILE "sample.html"

char *filedata;
time_t lasttime = 0;
char filename[80];
int counter = 0;

void read_file()
{
int size = 0;
char *data;
struct stat buf;

stat(filename,&buf);

if (buf.st_mtime > lasttime)
    {
      if (counter++)
        fprintf(stderr,"Reloading file: %s",filename);
      else
        fprintf(stderr,"Loading file: %s",filename);

      FILE *f = fopen(filename, "rb");
      if (f == NULL)
        {
          fprintf(stderr,"Couldn't open file\n");
          exit(1);
        }

      fseek(f, 0, SEEK_END);
      size = ftell(f);
      fseek(f, 0, SEEK_SET);
      data = (char *)malloc(size+1);
      fread(data, sizeof(char), size, f);
      filedata = (char *)malloc(size+1);
      strcpy(filedata,data);
      fclose(f);

      fprintf(stderr," (%d bytes)\n",size);
      lasttime = buf.st_mtime;
    }
}

void load_file()
{
struct event *loadfile_event;
struct timeval tv;

read_file();

tv.tv_sec = RELOAD_TIMEOUT;
tv.tv_usec = 0;

loadfile_event = malloc(sizeof(struct event));

evtimer_set(loadfile_event,
load_file,
loadfile_event);

evtimer_add(loadfile_event,
&tv);
}

void generic_request_handler(struct evhttp_request *req, void *arg)
{
struct evbuffer *evb = evbuffer_new();

evbuffer_add_printf(evb, "%s",filedata);
evhttp_send_reply(req, HTTP_OK, "Client", evb);
evbuffer_free(evb);
}

int main(int argc, char *argv[])
{
short http_port = 8081;
char *http_addr = "192.168.0.22";
struct evhttp *http_server = NULL;

if (argc > 1)
    {
      strcpy(filename,argv[1]);
      printf("Using %s\n",filename);
    }
else
    {
      strcpy(filename,DEFAULT_FILE);
    }

event_init();

load_file();

http_server = evhttp_start(http_addr, http_port);
evhttp_set_gencb(http_server, generic_request_handler, NULL);

fprintf(stderr, "Server started on port %d\n", http_port);
event_dispatch();
}

這個服務器的基本原理與前面的示例相同。首先，腳本設置一個 HTTP 服務器，它只響應對基本 URL 主機/端口組合的請求（不處理請求 URI）。第一步是裝載文件 (read_file())。在裝載最初的文件時和在計時器觸發(fā)回調時都使用此函數(shù)。
read_file() 函數(shù)使用 stat() 函數(shù)調用檢查文件的修改時間，只有在上一次裝載之后修改了文件的情況下，它才重新讀取文件的內容。此函數(shù)通過調用 fread() 裝載文件數(shù)據，把數(shù)據復制到另一個結構中，然后使用 strcpy() 把數(shù)據從裝載的字符串轉移到全局字符串中。
load_file() 函數(shù)是觸發(fā)計時器時調用的函數(shù)。它通過調用 read_file() 裝載內容，然后使用 RELOAD_TIMEOUT 值設置計時器，作為嘗試裝載文件之前的秒數(shù)。libevent 計時器使用 timeval 結構，允許按秒和毫秒指定計時器。計時器不是周期性的；當觸發(fā)計時器事件時設置它，然后從事件隊列中刪除事件。
使用與前面的示例相同的格式編譯代碼：$ gcc -o basichttpfile basichttpfile.c -levent。
現(xiàn)在，創(chuàng)建作為數(shù)據使用的靜態(tài)文件；默認文件是 sample.html，但是可以通過命令行上的第一個參數(shù)指定任何文件（見清單 6）。
清單 6. 創(chuàng)建作為數(shù)據使用的靜態(tài)文件

復制代碼代碼如下:

$ ./basichttpfile
Loading file: sample.html (8046 bytes)
Server started on port 8081

現(xiàn)在，程序可以接受請求了，重新裝載計時器也啟動了。如果修改 sample.html 的內容，應該會重新裝載此文件并在日志中記錄一個消息。例如，清單 7 中的輸出顯示初始裝載和兩次重新裝載：
清單 7. 輸出顯示初始裝載和兩次重新裝載

復制代碼代碼如下:

$ ./basichttpfile
Loading file: sample.html (8046 bytes)
Server started on port 8081
Reloading file: sample.html (8047 bytes)
Reloading file: sample.html (8048 bytes)

注意，要想獲得最大的收益，必須確保環(huán)境沒有限制打開的文件描述符數(shù)量?？梢允褂?ulimit 命令修改限制（需要適當?shù)臋嘞藁蚋L問）。具體的設置取決與您的 OS，但是在 Linux® 上可以用 -n 選項設置打開的文件描述符（和網絡套接字）的數(shù)量

您可能感興趣的文章: