基于libevent库实现的http server示例

雨点打透心脏的1/2处 2022-10-09 15:20 29阅读 0赞

最近在工作当中接触到libevent库，用于http server端功能还是比较强大，特在此记录一笔，以备后面查漏补缺。首先是下载安装，直接去官网下载对应版本的安装包，解压安装即可，这里就不啰嗦了。  
　　 \#tar  
　　 \#./configure  
　　\#make  
　　\#make install  
　　完成安装之后，就可以开始编写自己的示例程序了，先上代码：

\#include  
\#include  
\#include  
\#include  
\#include  
\#include "event2/http.h"  
\#include "event2/event.h"  
\#include "event2/buffer.h"  
\#include "event2/bufferevent.h"  
\#include "event2/bufferevent\_compat.h"  
\#include "event2/http\_struct.h"  
\#include "event2/http\_compat.h"  
\#include "event2/util.h"  
\#include "event2/listener.h"

\#define BUF\_MAX 1024\*16

//解析post请求数据  
void get\_post\_message(char \*buf, struct evhttp\_request \*req)  
\{  
    size\_t post\_size = 0;

**//获取数据长度**  
    post\_size = **evbuffer\_get\_length**(req->input\_buffer);

printf("====line:%d,post len:%d\\n",\_\_LINE\_\_,post\_size);  
    if (post\_size <= 0)  
    \{  
        printf("====line:%d,post msg is empty!\\n",\_\_LINE\_\_);  
        return;  
    \}  
    else  
    \{  
        size\_t copy\_len = post\_size > BUF\_MAX ? BUF\_MAX : post\_size;  
        printf("====line:%d,post len:%d, copy\_len:%d\\n",\_\_LINE\_\_,post\_size,copy\_len);  
        memcpy(buf, evbuffer\_pullup(req->input\_buffer,-1), copy\_len);  
        buf\[post\_size\] = '\\0';  
        printf("====line:%d,post msg:%s\\n",\_\_LINE\_\_,buf);  
    \}  
\}

//解析http头，主要用于get请求时解析uri和请求参数  
char \*find\_http\_header(struct evhttp\_request \*req, **struct evkeyvalq \*params**, const char \*query\_char)  
\{  
    if(req == NULL || params == NULL || query\_char == NULL)  
    \{  
        printf("====line:%d,%s\\n",\_\_LINE\_\_,"input params is null.");  
        return NULL;  
    \}  
      
    struct evhttp\_uri \*decoded = NULL;  
    char \*query = NULL;      
    char \*query\_result = NULL;  
    const char \*path;  
    **const char \*uri = evhttp\_request\_get\_uri(req);//获取请求uri**  
      
    if(uri == NULL)  
    \{  
        printf("====line:%d,evhttp\_request\_get\_uri return null\\n",\_\_LINE\_\_);  
        return NULL;  
    \}  
    else  
    \{  
        printf("====line:%d,Got a GET request for <%s>\\n",\_\_LINE\_\_,uri);  
    \}  
      
    //解码uri  
   ** decoded = evhttp\_uri\_parse(uri);**  
    if (!decoded)   
    \{  
        printf("====line:%d,It's not a good URI. Sending BADREQUEST\\n",\_\_LINE\_\_);  
        evhttp\_send\_error(req, HTTP\_BADREQUEST, 0);  
        return;  
    \}  
      
    //获取uri中的path部分  
   ** path = evhttp\_uri\_get\_path(decoded);**  
    if (path == NULL)   
    \{  
        path = "/";  
    \}  
    else  
    \{  
        printf("====line:%d,path is:%s\\n",\_\_LINE\_\_,path);  
    \}  
      
    //获取uri中的参数部分  
   ** query = (char\*)evhttp\_uri\_get\_query(decoded);**  
    if(query == NULL)  
    \{  
        printf("====line:%d,evhttp\_uri\_get\_query return null\\n",\_\_LINE\_\_);  
        return NULL;  
    \}  
      
    //查询指定参数的值  
   ** evhttp\_parse\_query\_str(query, params);  **            
    query\_result = (char\*)evhttp\_find\_header(params, query\_char);  
      
    return query\_result;  
\}

//处理get请求  
void **http\_handler\_testget\_msg**(struct evhttp\_request \*req,void \*arg)  
\{  
    if(req == NULL)  
    \{  
        printf("====line:%d,%s\\n",\_\_LINE\_\_,"input param req is null.");  
        return;  
    \}  
      
    char \*sign = NULL;  
    char \*data = NULL;  
    struct evkeyvalq sign\_params = \{0\};  
    sign = find\_http\_header(req,&sign\_params,"sign");//获取get请求uri中的sign参数  
    if(sign == NULL)  
    \{  
        printf("====line:%d,%s\\n",\_\_LINE\_\_,"request uri no param sign.");  
    \}  
    else  
    \{  
        printf("====line:%d,get request param: sign=\[%s\]\\n",\_\_LINE\_\_,sign);  
    \}  
      
    data = find\_http\_header(req,&sign\_params,"data");//获取get请求uri中的data参数  
    if(data == NULL)  
    \{  
        printf("====line:%d,%s\\n",\_\_LINE\_\_,"request uri no param data.");  
    \}  
    else  
    \{  
        printf("====line:%d,get request param: data=\[%s\]\\n",\_\_LINE\_\_,data);  
    \}  
    printf("\\n");

/\*\*\*\*\*\*\*\*\*\*\*\*\*\*回响应\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*

\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*/  
    struct evbuffer \*retbuff = NULL;  
    retbuff = evbuffer\_new();  
    if(retbuff == NULL)  
    \{  
        printf("====line:%d,%s\\n",\_\_LINE\_\_,"retbuff is null.");  
        return;  
    \}  
   ** evbuffer\_add\_printf**(retbuff, "Receive get request,Thamks for the request!");  
    **evhttp\_send\_reply**(req, HTTP\_OK, "Client", retbuff);  
    evbuffer\_free(retbuff);  
\}

//处理post请求  
void **http\_handler\_testpost\_msg**(struct evhttp\_request \*req, void \*arg)  
\{  
    if(req == NULL)  
    \{  
        printf("====line:%d,%s\\n",\_\_LINE\_\_,"input param req is null.");  
        return;  
    \}  
      
    char buf\[BUF\_MAX\] = \{0\};  
    get\_post\_message(buf, req);//获取请求数据，一般是json格式的数据  
    if(buf == NULL)  
    \{  
        printf("====line:%d,%s\\n",\_\_LINE\_\_,"get\_post\_message return null.");  
        return;  
    \}  
    else  
    \{  
        //可以使用json库解析需要的数据  
        printf("====line:%d,request data:%s",\_\_LINE\_\_,buf);  
    \}

/\*\*\*\*\*\*\*\*\*\*\*\*\*\*回响应\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*

\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*/  
    struct evbuffer \*retbuff = NULL;  
    retbuff = evbuffer\_new();  
    if(retbuff == NULL)  
    \{  
        printf("====line:%d,%s\\n",\_\_LINE\_\_,"retbuff is null.");  
        return;  
    \}  
    evbuffer\_add\_printf(retbuff,"Receive post request,Thamks for the request!");  
   ** evhttp\_send\_reply**(req, HTTP\_OK, "Client", retbuff);  
    evbuffer\_free(retbuff);  
\}

**int main()**  
\{  
    struct evhttp \*http\_server = NULL;  
    short http\_port = 8081;  
    char \*http\_addr = "0.0.0.0";  
      
    //初始化  
    event\_init();  
    //启动http服务端  
 **   http\_server = evhttp\_start(http\_addr,http\_port);**  
    if(http\_server == NULL)  
    \{  
        printf("====line:%d,%s\\n",\_\_LINE\_\_,"http server start failed.");  
        return -1;  
    \}  
      
**    //设置请求超时时间(s)  
    evhttp\_set\_timeout(http\_server,5);  
    //设置事件处理函数，evhttp\_set\_cb针对每一个事件(请求)注册一个处理函数，  
    //区别于evhttp\_set\_gencb函数，是对所有请求设置一个统一的处理函数  
    evhttp\_set\_cb(http\_server,  "/me/testpost", http\_handler\_testpost\_msg, NULL);  
    evhttp\_set\_cb(http\_server, "/me/testget", http\_handler\_testget\_msg, NULL);**  
      
    //循环监听  
    event\_dispatch();  
    //实际上不会释放，代码不会运行到这一步  
    evhttp\_free(http\_server);  
          
    return 0;  
\}  
  
关于代码，相应的注释已经很清楚了，这里主要说明一下编译有关的问题，编译的时候需要引入libevent库相关的头文件目录，动态库路径和名称。  
编译命令：gcc -o http\_server http\_server.c -I/usr/local/include/ -L/usr/local/lib/ -levent  
\-I/usr/local/include/ ：头文件路径  
\-L/usr/local/lib/ ：动态库路径  
\-levent ：动态库名称（libevent.so）

附get请求和post请求及处理结果，使用postman工具模拟发送http命令，

客户端get请求及响应：

![客户端get请求及响应][get]

客户端post请求及响应：

![客户端post请求及响应][post]

服务端处理get请求：

![服务端处理get请求][get 1]

服务端处理post请求：

![服务端处理post请求][post 1]

————————————————  
版权声明：本文为CSDN博主「阿彡」的原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接及本声明。  
原文链接：https://blog.csdn.net/li\_qinging/article/details/82254633

[get]: /images/20221005/0983d7794cd743d5a761f75d425df86c.png
[post]: /images/20221005/6c212fa9384f42c09cdcaeb044adc1f1.png
[get 1]: /images/20221005/6166235d5d0b42a9b7b753455de797b4.png
[post 1]: /images/20221005/c620256270f74d0f9e65fabfeb79deb2.png