基于Libevent的HTTP Server

简单的Http Server

使用Libevent内置的http相关接口，可以很容易的构建一个Http Server，一个简单的Http Server如下：

#include <event2/event.h>
#include <event2/buffer.h>
#include <event2/http.h>
#include <Winsock2.h>
#include <stdlib.h>
#include <stdio.h>

int init_win_socket()
{
    WSADATA wsaData;
    if(WSAStartup(MAKEWORD(2,2) , &wsaData) != 0)
    {
        return -1;
    }
    return 0;
}

void generic_handler(struct evhttp_request *req, void *arg)
{
    struct evbuffer *buf = evbuffer_new();
    if(!buf)
    {
        puts("failed to create response buffer \n");
        return;
    }

    evbuffer_add_printf(buf, "Server Responsed. Requested: %s\n", evhttp_request_get_uri(req));
    evhttp_send_reply(req, HTTP_OK, "OK", buf);
    evbuffer_free(buf);
}

int main(int argc, char* argv[])
{
#ifdef WIN32
    init_win_socket();
#endif

    short          http_port = 8081;
    char          *http_addr = "127.0.0.1";

    struct event_base * base = event_base_new();

    struct evhttp * http_server = evhttp_new(base);
    if(!http_server)
    {
        return -1;
    }

    int ret = evhttp_bind_socket(http_server,http_addr,http_port);
    if(ret!=0)
    {
        return -1;
    }

    evhttp_set_gencb(http_server, generic_handler, NULL);

    printf("http server start OK! \n");

    event_base_dispatch(base);

    evhttp_free(http_server);

    WSACleanup();
    return 0;
}

通过Libevent的接口构建一个Http Server的过程如下：

（1）初始化：在event_base上新建一个evhttp，将这个evhttp绑定到监听的IP和端口号。

（2）设置Http回调函数：使用evhttp_set_gencb设置Http Server的处理请求的回调函数。

（3）启动Http Server：等待请求进入事件循环。

在Http Server中使用定时器提供更新服务

#include <event2/event.h>
#include <event2/buffer.h>
#include <event2/http.h>
#include <sys/stat.h>
#include <Winsock2.h>
#include <assert.h>
#include <string.h>
#include <stdlib.h>
#include <stdio.h>

#define DEFAULT_FILE "F:\\Libevent\\LibeventTest\\Debug\\sample.txt"

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

struct event *loadfile_event;
struct timeval tv;

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

    if(stat(filename,&buf)<0)
    {
        printf("Read file error! \n");
        return;
    }

    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");
            return;
        }

        size = buf.st_size;
        filedata = (char *)malloc(size+1);
        memset(filedata,0,size+1);
        fread(filedata, sizeof(char), size, f);
        fclose(f);

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

void read_file_timer_cb(evutil_socket_t listener, short event, void *arg)
{
    if (!evtimer_pending(loadfile_event, NULL))
    {
        event_del(loadfile_event);
        evtimer_add(loadfile_event, &tv);
    }

    read_file();
}

void load_file(struct event_base * base)
{
    tv.tv_sec = 5;
    tv.tv_usec = 0;

    //loadfile_event = malloc(sizeof(struct event));
    loadfile_event = evtimer_new(base,read_file_timer_cb,NULL);

    //evtimer_set(loadfile_event,load_file,loadfile_event);
    evtimer_add(loadfile_event,&tv);
}

void generic_handler(struct evhttp_request *req, void *arg)
{
    struct evbuffer *buf = evbuffer_new();
    if(!buf)
    {
        puts("failed to create response buffer \n");
        return;
    }
    evbuffer_add_printf(buf,"%s",filedata);
    evhttp_send_reply(req, HTTP_OK, "OK", buf);
    evbuffer_free(buf);
}

int init_win_socket()
{
    WSADATA wsaData;
    if(WSAStartup(MAKEWORD(2,2) , &wsaData) != 0)
    {
        return -1;
    }
    return 0;
}

int main(int argc, char* argv[])
{
#ifdef WIN32
    init_win_socket();
#endif

    short          http_port = 8081;
    char          *http_addr = "127.0.0.1";

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

    struct event_base * base = event_base_new();

    struct evhttp * http_server = evhttp_new(base);
    if(!http_server)
    {
        return -1;
    }

    int ret = evhttp_bind_socket(http_server,http_addr,http_port);
    if(ret!=0)
    {
        return -1;
    }

    evhttp_set_gencb(http_server, generic_handler, NULL);

    read_file();

    load_file(base);

    printf("http server start OK! \n");

    event_base_dispatch(base);

    evhttp_free(http_server);

    WSACleanup();
    return 0;
}

在这个Http Server中提供了一个每5秒触发一次的定时器，读取一个文件，如果这个文件被更新过，则读取更新后的内容。

当访问这个Http Server时，提供这个文件中最新的内容。

多线程的Http Server

在上面的Http Server中，处理Http请求的回调函数generic_handler和定时器读取文件的回调函数read_file_timer_cb都在同一个event_base的dispatch中，并且都在同一个进程中，使用多线程可以改善程序的性能，下面是一个来自网络的多线程Http Server：

#include <event.h>
#include <evhttp.h>
#include <pthread.h>
#include <errno.h>
#include <string.h>
#include <fcntl.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>

int httpserver_bindsocket(int port, int backlog);
int httpserver_start(int port, int nthreads, int backlog);
void* httpserver_Dispatch(void *arg);
void httpserver_GenericHandler(struct evhttp_request *req, void *arg);
void httpserver_ProcessRequest(struct evhttp_request *req);

int httpserver_bindsocket(int port, int backlog) {
  int r;
  int nfd;
  nfd = socket(AF_INET, SOCK_STREAM, 0);
  if (nfd < 0) return -1;

  int one = 1;
  r = setsockopt(nfd, SOL_SOCKET, SO_REUSEADDR, (char *)&one, sizeof(int));

  struct sockaddr_in addr;
  memset(&addr, 0, sizeof(addr));
  addr.sin_family = AF_INET;
  addr.sin_addr.s_addr = INADDR_ANY;
  addr.sin_port = htons(port);

  r = bind(nfd, (struct sockaddr*)&addr, sizeof(addr));
  if (r < 0) return -1;
  r = listen(nfd, backlog);
  if (r < 0) return -1;

  int flags;
  if ((flags = fcntl(nfd, F_GETFL, 0)) < 0
      || fcntl(nfd, F_SETFL, flags | O_NONBLOCK) < 0)
    return -1;

  return nfd;
}

int httpserver_start(int port, int nthreads, int backlog) {
  int r, i;
  int nfd = httpserver_bindsocket(port, backlog);
  if (nfd < 0) return -1;
  pthread_t ths[nthreads];
  for (i = 0; i < nthreads; i++) {
    struct event_base *base = event_init();
    if (base == NULL) return -1;
    struct evhttp *httpd = evhttp_new(base);
    if (httpd == NULL) return -1;
    r = evhttp_accept_socket(httpd, nfd);
    if (r != 0) return -1;
    evhttp_set_gencb(httpd, httpserver_GenericHandler, NULL);
    r = pthread_create(&ths[i], NULL, httpserver_Dispatch, base);
    if (r != 0) return -1;
  }
  for (i = 0; i < nthreads; i++) {
    pthread_join(ths[i], NULL);
  }
}

void* httpserver_Dispatch(void *arg) {
  event_base_dispatch((struct event_base*)arg);
  return NULL;
}

void httpserver_GenericHandler(struct evhttp_request *req, void *arg) {
      httpserver_ProcessRequest(req);
}

void httpserver_ProcessRequest(struct evhttp_request *req) {
    struct evbuffer *buf = evbuffer_new();
    if (buf == NULL) return;

    //here comes the magic
}

int main(void) {
    httpserver_start(80, 10, 10240);
}

上面的代码基于Libevent 1.X版本的，不过很容易很看懂：在一个监听socket上创建了多个event_base实例和evhttp实例，在不同的线程中调度不同的event_base，继而可以在不同的线程中处理http请求。

这里还有一个基于Libevent的多线程Http Server：https://sourceforge.net/projects/libevent-thread/，看源代码处理的过程和上面类似，只是每次在监听的socket上accept一个连接请求时，将对应的处理放到一个工作队列里，在队列里由多线程处理相应的回调函数。

 

 

作者：阿凡卢

出处：http://www.cnblogs.com/luxiaoxun/

本文版权归作者和博客园共有，欢迎转载，但未经作者同意必须保留此段声明，且在文章页面明显位置给出原文连接，否则保留追究法律责任的权利。

时间： 2024-12-04 01:56:19

基于Libevent的HTTP Server的相关文章

怎么做求帮助-基于Web的SQL Server数据库实验平台

问题描述 基于Web的SQL Server数据库实验平台 传统数据库课程实验教学存在课时安排不足.学生在课外实验又缺乏有效的指导和教师无法进行有效监督等问题.该题目要求实现一个基于Web的SQL Server数据库实验平台,使得学生能够在任何地点.时间通过 Internet 进行数据库相关的增. 删.改.查等数据库实验,同时教师可以布置数据库实验,监控和指导学生的实验等. 想知道用什么工具 怎么做呀 如何在internet上用sql语句进行相关的增删除改啊

基于 aLi Lua Web Server 的一个简单例子_Lua

复制代码 代码如下: file = 'index.lua' if headers.uri ~= '/' then file = headers.uri end   local fexists = file_exists(file)   if not fexists then     -- try stat file.lua     fexists = file_exists(file .. '.lua')     if fexists then         file = file .. '.

惠普推出基于Windows的家庭服务器MediaSmart Server

  惠普本周一宣布推出了新一代基于Windows的家庭服务器,其内存是上一代产品的四倍之多,存储容量也有所提高. 新推出的HP MediaSmart Server有ex485和ex487两个型号,区别就在于存储容量的不同.ex485的容量为750GB,采用了7200 RPM.SATA硬盘:ex487采用了两个和ex485相同的硬盘,总存储容量为1.5TB.惠普在2007年底发布的第一代服务器基本容量为500GB.另外,新系统可支持9TB的扩展容量. MediaSmart Server的设计理念是

【原创】libevent功能简介

  @section intro Introduction   介绍    libevent is an event notification library for developing scalable network   servers.  The libevent API provides a mechanism to execute a callback   function when a specific event occurs on a file descriptor or af

使用 libevent 和 libev 提高网络应用性能的方法_Linux

有许多解决方案,但是 libevent 库和 libev 库能够大大提高性能和事件处理能力.在本文中,我们要讨论在 UNIX 应用程序中使用和部署这些解决方案所用的基本结构和方法.libev 和 libevent 都可以在高性能应用程序中使用,包括部署在 IBM Cloud 或 Amazon EC2 环境中的应用程序,这些应用程序需要支持大量并发客户端或操作. 简介 许多服务器部署(尤其是 web 服务器部署)面对的最大问题之一是必须能够处理大量连接.无论是通过构建基于云的服务来处理网络通信流,

基于JSP技术的数据库连接

js|数据|数据库|数据库连接     相对于基于传统的Client/Server模式的数据库系统,Web数据库系统采用三层浏览器/服务器结构(即网络浏览器/Web服务器/数据库服务器结构),具有极大的优势.Web数据库系统充分发挥了DBMS高效的数据存储与管理能力,以B/S模式为平台,将客户端统一为Web浏览器,为用户提供使用简便.内容丰富的数据库服务,已经成为Internet和Intranet提供的核心服务,为Internet上的电子商务提供技术支持.Web数据库系统的关键技术是Web与数据

SQL Server 2005报表设计:最佳实践和指导

本文包含了Microsoft SQL Server报表服务报表设计的技巧和最佳实践.本文提供一些基本的设计问题和一些报表服务的功能. 关于这篇文档 从使用数据控件,到使用什么格式,到如何分发报表,报表制作者面对着很多种选择.Microsoft SQL Server 报表服务提供了丰富的报表设计和格式的支持,从基于纸介质表格报表到带有图片和钻取功能的交互式报表 这篇文档包括了报表制作和设计中的指导.建议和技巧.本文档的目的在于解释一般性的问题并对初学者提供指导建议.报表服务联机丛书提供了报表的制作

SQL Server 2005可伸缩性和性能的计划（1）

本白皮书提供了关于不同报表服务实现架构中可伸缩性的相关内容.也提供了一些基于使用Microsoft SQL Server Reporting Services完成您自己的性能测试的指导方针.建议和提示. 简介 Microsoft SQL Server Reporting Services是一个报表平台,包括可扩展和可管理的中央管理报表服务器和可扩展的基于Web.桌面的报表交付.报表服务是微软综合商业智能平台的重要组成部分.对于许多组织,通过报表来交付信息是一个非常重要的日常商务环节.因此,报表性

用 SQL Server 2000 索引视图提高性能

server|视图|索引|性能 什么是索引视图? 许多年来,Microsoft SQL Server 一直都提供创建虚拟表(称为视图)的功能.在过去,这些视图主要有两种用途: 提供安全机制,将用户限制在一个或多个基表中的数据的某个子集. 提供一种机制,允许开发人员定制用户如何才能以逻辑方式查看存储在基表中的数据. SQL Server 2000 已经扩展了 SQL Server 视图的功能,以提高系统性能.它可以在一个视图上创建唯一的群集索引和非群集索引,可以改进最复杂查询的数据访问性能.在 S