登录
当前位置： 首页 > 工具软件 > HTTP Parser > 使用案例 >

http-parser用法

公西鸿博
2023-12-01

头文件说明：

解析类型定义：
enum http_parser_type { HTTP_REQUEST, HTTP_RESPONSE, HTTP_BOTH };

解析函数声明：
void http_parser_init(http_parser *parser, enum http_parser_type type);
void http_parser_settings_init(http_parser_settings *settings);
size_t http_parser_execute(http_parser *parser,
const http_parser_settings *settings, const char *data, size_t len);

说明：
http_parser_execute解析请求或应答报文，并返回实际解析的报文长度，此长度只代表解析一个完整报文扫描的长度，并不表示接收完整报文成功，完整报文的判断需要依赖on_message_complete回调。
如果发生错误，可以检查parser->http_errno的数值。

回调函数集合设定：
struct http_parser_settings {
http_cb on_message_begin; // 消息开始回调
http_data_cb on_url; // url回调
http_data_cb on_status; // 状态回调
http_data_cb on_header_field; // 字段名称回调
http_data_cb on_header_value; // 字段值回调
http_cb on_headers_complete; // 头部结束回调
http_data_cb on_body; // 消息体回调
http_cb on_message_complete; // 消息结束回调
http_cb on_chunk_header; // 收到chunk响应回调，已接收的chunk数据长度保存在parser->content_length
http_cb on_chunk_complete; // chunk响应结束回调
};

回调函数定义：
typedef int (http_data_cb) (http_parser, const char at, size_t length);
typedef int (http_cb) (http_parser*);

使用方法：
将源码中的http_parser.h和http_parser.c直接拷贝到工程目录下，随工程一起编译，同时支持windows及linux。

用法举例：

解析请求：

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <stdint.h>

#include <string>
#include <map>
#include "http_parser.h"

// 用于解析的全局变量
bool bParsed = false;
std::map<std::string, std::string> mapHeadField;
std::string strUrl;
std::string strStatus;
std::string strBody;
std::string strFieldTmp;

// 用于解析的回调函数
int onMessageBegin(http_parser* pParser);
int onHeaderComplete(http_parser* pParser);
int onMessageComplete(http_parser* pParser);
int onURL(http_parser* pParser, const char *at, size_t length);
int onStatus(http_parser* pParser, const char *at, size_t length);
int onHeaderField(http_parser* pParser, const char *at, size_t length);
int onHeaderValue(http_parser* pParser, const char *at, size_t length);
int onBody(http_parser* pParser, const char *at, size_t length);


int main(int argc, char* argv[])
{
    // 待解析的请求报文
    std::string strHttpReq = "";
    strHttpReq += "POST /uploaddata HTTP/1.1\r\n";
    strHttpReq += "Host: 127.0.0.1:8080\r\n";
    strHttpReq += "Accept: */*\r\n";
    strHttpReq += "Content-Length: 70\r\n";
    strHttpReq += "Content-Type: application/json\r\n";
    strHttpReq += "\r\n";
    strHttpReq += "{\"DeviceID\":\"12345678\",\"LowPressure\":80,\"HighPressure\":120,\"Pulse\":90}";

    http_parser httpParser;
    http_parser_settings httpSettings;

    // 初使化解析器及回调函数
    http_parser_init(&httpParser, HTTP_REQUEST);
    http_parser_settings_init(&httpSettings);
    httpSettings.on_message_begin = onMessageBegin;
    httpSettings.on_headers_complete = onHeaderComplete;
    httpSettings.on_message_complete = onMessageComplete;
    httpSettings.on_url = onURL;
    httpSettings.on_status = onStatus;
    httpSettings.on_header_field = onHeaderField;
    httpSettings.on_header_value = onHeaderValue;
    httpSettings.on_body = onBody;

    // 解析请求
    int nParseBytes = http_parser_execute(&httpParser, &httpSettings, strHttpReq.data(), strHttpReq.size());
    printf("http_parser_execute => parsebytes:[%d] parseok:[%d] \n", nParseBytes, bParsed);

    // 解析成功，打印解析结果
    if (bParsed)
    {
        printf("url: [%s] \n", strUrl.c_str());
        printf("status: [%s] \n", strStatus.c_str());
        printf("heads: \n");
        for (std::map<std::string, std::string>::iterator iter = mapHeadField.begin(); iter != mapHeadField.end(); ++iter)
        {
            printf("\t %s : %s \n", iter->first.c_str(), iter->second.c_str());
        }
        printf("body: [%s] \n", strBody.c_str());
    }

    return 0;
}


int onMessageBegin(http_parser* pParser)
{
    printf("@onMessageBegin call \n");
    bParsed = false;
    return 0;
}
int onHeaderComplete(http_parser* pParser)
{
    printf("@onHeaderComplete call \n");
    return 0;
}
int onMessageComplete(http_parser* pParser)
{
    printf("@onMessageComplete call \n");
    bParsed = true;
    return 0;
}
int onURL(http_parser* pParser, const char *at, size_t length)
{
    printf("@onURL call, length:[%d] \n", length);
    strUrl.assign(at, length);
    printf("@onURL url:[%s] \n", strUrl.c_str());
    return 0;
}
int onStatus(http_parser* pParser, const char *at, size_t length)
{
    printf("@onStatus call, length:[%d] \n", length);
    strStatus.assign(at, length);
    printf("@onStatus status:[%s] \n", strStatus.c_str());
    return 0;
}
int onHeaderField(http_parser* pParser, const char *at, size_t length)
{
    printf("@onHeaderField call, length:[%d] \n", length);
    strFieldTmp.assign(at, length);
    printf("@onHeaderField field:[%s] \n", strFieldTmp.c_str());
    return 0;
}
int onHeaderValue(http_parser* pParser, const char *at, size_t length)
{
    printf("@onHeaderValue call, length:[%d] \n", length);
    std::string strValue(at, length);
    printf("@onHeaderValue value:[%s] \n", strValue.c_str());
    mapHeadField.insert( std::make_pair(strFieldTmp, strValue) );
    return 0;
}
int onBody(http_parser* pParser, const char *at, size_t length)
{
    printf("@onBody call, length:[%d] \n", length);
    printf("@onBody recv:[%s] \n", std::string(at, length).c_str());
    strBody.append(at, length);
    return 0;
}

执行输出如下：

@onMessageBegin call 
@onURL call, length:[11] 
@onURL url:[/uploaddata] 
@onHeaderField call, length:[4] 
@onHeaderField field:[Host] 
@onHeaderValue call, length:[14] 
@onHeaderValue value:[127.0.0.1:8080] 
@onHeaderField call, length:[6] 
@onHeaderField field:[Accept] 
@onHeaderValue call, length:[3] 
@onHeaderValue value:[*/*] 
@onHeaderField call, length:[14] 
@onHeaderField field:[Content-Length] 
@onHeaderValue call, length:[2] 
@onHeaderValue value:[70] 
@onHeaderField call, length:[12] 
@onHeaderField field:[Content-Type] 
@onHeaderValue call, length:[16] 
@onHeaderValue value:[application/json] 
@onHeaderComplete call 
@onBody call, length:[70] 
@onBody recv:[{"DeviceID":"12345678","LowPressure":80,"HighPressure":120,"Pulse":90}] 
@onMessageComplete call 
http_parser_execute => parsebytes:[186] parseok:[1] 
url: [/uploaddata] 
status: [] 
heads: 
         Accept : */* 
         Content-Length : 70 
         Content-Type : application/json 
         Host : 127.0.0.1:8080 
body: [{"DeviceID":"12345678","LowPressure":80,"HighPressure":120,"Pulse":90}]

解析响应：

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <stdint.h>

#include <string>
#include <map>
#include "http_parser.h"

// 用于解析的全局变量
bool bParsed = false;
std::map<std::string, std::string> mapHeadField;
std::string strUrl;
std::string strStatus;
std::string strBody;
std::string strFieldTmp;

// 用于解析的回调函数
int onMessageBegin(http_parser* pParser);
int onHeaderComplete(http_parser* pParser);
int onMessageComplete(http_parser* pParser);
int onURL(http_parser* pParser, const char *at, size_t length);
int onStatus(http_parser* pParser, const char *at, size_t length);
int onHeaderField(http_parser* pParser, const char *at, size_t length);
int onHeaderValue(http_parser* pParser, const char *at, size_t length);
int onBody(http_parser* pParser, const char *at, size_t length);


int main(int argc, char* argv[])
{
    // 待解析的响应报文
    std::string strHttpRes = "";
    strHttpRes += "HTTP/1.1 200 OK\r\n";
    strHttpRes += "Cache-Control: private\r\n";
    strHttpRes += "Content-Type: application/json; charset=utf-8\r\n";
    strHttpRes += "Server: Microsoft-IIS/8.0\r\n";
    strHttpRes += "X-AspNetMvc-Version: 5.2\r\n";
    strHttpRes += "X-AspNet-Version: 4.0.30319\r\n";
    strHttpRes += "X-Powered-By: ASP.NET\r\n";
    strHttpRes += "Date: Sat, 24 Oct 2020 02:45:29 GMT\r\n";
    strHttpRes += "Content-Length: 30\r\n";
    strHttpRes += "\r\n";
    strHttpRes += "{\"State\":\"Success\",\"Msg\":\"OK\"}";

    http_parser httpParser;
    http_parser_settings httpSettings;

    // 初使化解析器及回调函数
    http_parser_init(&httpParser, HTTP_RESPONSE);
    http_parser_settings_init(&httpSettings);
    httpSettings.on_message_begin = onMessageBegin;
    httpSettings.on_headers_complete = onHeaderComplete;
    httpSettings.on_message_complete = onMessageComplete;
    httpSettings.on_url = onURL;
    httpSettings.on_status = onStatus;
    httpSettings.on_header_field = onHeaderField;
    httpSettings.on_header_value = onHeaderValue;
    httpSettings.on_body = onBody;

    // 解析响应
    int nParseBytes = http_parser_execute(&httpParser, &httpSettings, strHttpRes.data(), strHttpRes.size());
    printf("http_parser_execute => parsebytes:[%d] parseok:[%d] \n", nParseBytes, bParsed);

    // 解析成功，打印解析结果
    if (bParsed)
    {
        printf("url: [%s] \n", strUrl.c_str());
        printf("status: [%s] \n", strStatus.c_str());
        printf("heads: \n");
        for (std::map<std::string, std::string>::iterator iter = mapHeadField.begin(); iter != mapHeadField.end(); ++iter)
        {
            printf("\t %s : %s \n", iter->first.c_str(), iter->second.c_str());
        }
        printf("body: [%s] \n", strBody.c_str());
    }

    return 0;
}


int onMessageBegin(http_parser* pParser)
{
    printf("@onMessageBegin call \n");
    bParsed = false;
    return 0;
}
int onHeaderComplete(http_parser* pParser)
{
    printf("@onHeaderComplete call \n");
    return 0;
}
int onMessageComplete(http_parser* pParser)
{
    printf("@onMessageComplete call \n");
    bParsed = true;
    return 0;
}
int onURL(http_parser* pParser, const char *at, size_t length)
{
    printf("@onURL call, length:[%d] \n", length);
    strUrl.assign(at, length);
    printf("@onURL url:[%s] \n", strUrl.c_str());
    return 0;
}
int onStatus(http_parser* pParser, const char *at, size_t length)
{
    printf("@onStatus call, length:[%d] \n", length);
    strStatus.assign(at, length);
    printf("@onStatus status:[%s] \n", strStatus.c_str());
    return 0;
}
int onHeaderField(http_parser* pParser, const char *at, size_t length)
{
    printf("@onHeaderField call, length:[%d] \n", length);
    strFieldTmp.assign(at, length);
    printf("@onHeaderField field:[%s] \n", strFieldTmp.c_str());
    return 0;
}
int onHeaderValue(http_parser* pParser, const char *at, size_t length)
{
    printf("@onHeaderValue call, length:[%d] \n", length);
    std::string strValue(at, length);
    printf("@onHeaderValue value:[%s] \n", strValue.c_str());
    mapHeadField.insert( std::make_pair(strFieldTmp, strValue) );
    return 0;
}
int onBody(http_parser* pParser, const char *at, size_t length)
{
    printf("@onBody call, length:[%d] \n", length);
    printf("@onBody recv:[%s] \n", std::string(at, length).c_str());
    strBody.append(at, length);
    return 0;
}

执行输出如下：

@onMessageBegin call 
@onStatus call, length:[2] 
@onStatus status:[OK] 
@onHeaderField call, length:[13] 
@onHeaderField field:[Cache-Control] 
@onHeaderValue call, length:[7] 
@onHeaderValue value:[private] 
@onHeaderField call, length:[12] 
@onHeaderField field:[Content-Type] 
@onHeaderValue call, length:[31] 
@onHeaderValue value:[application/json; charset=utf-8] 
@onHeaderField call, length:[6] 
@onHeaderField field:[Server] 
@onHeaderValue call, length:[17] 
@onHeaderValue value:[Microsoft-IIS/8.0] 
@onHeaderField call, length:[19] 
@onHeaderField field:[X-AspNetMvc-Version] 
@onHeaderValue call, length:[3] 
@onHeaderValue value:[5.2] 
@onHeaderField call, length:[16] 
@onHeaderField field:[X-AspNet-Version] 
@onHeaderValue call, length:[9] 
@onHeaderValue value:[4.0.30319] 
@onHeaderField call, length:[12] 
@onHeaderField field:[X-Powered-By] 
@onHeaderValue call, length:[7] 
@onHeaderValue value:[ASP.NET] 
@onHeaderField call, length:[4] 
@onHeaderField field:[Date] 
@onHeaderValue call, length:[29] 
@onHeaderValue value:[Sat, 24 Oct 2020 02:45:29 GMT] 
@onHeaderField call, length:[14] 
@onHeaderField field:[Content-Length] 
@onHeaderValue call, length:[2] 
@onHeaderValue value:[30] 
@onHeaderComplete call 
@onBody call, length:[30] 
@onBody recv:[{"State":"Success","Msg":"OK"}] 
@onMessageComplete call 
http_parser_execute => parsebytes:[282] parseok:[1] 
url: [] 
status: [OK] 
heads: 
         Cache-Control : private 
         Content-Length : 30 
         Content-Type : application/json; charset=utf-8 
         Date : Sat, 24 Oct 2020 02:45:29 GMT 
         Server : Microsoft-IIS/8.0 
         X-AspNet-Version : 4.0.30319 
         X-AspNetMvc-Version : 5.2 
         X-Powered-By : ASP.NET 
body: [{"State":"Success","Msg":"OK"}]

 

 类似资料：

相关阅读

OPTIONS Http方法禁用Spring Securitygolang http连接复用方法反应：找不到模块：无法解析“ react-html-parser”如何使用dom parser java解析xml中的同名标签？使用Angular.js的HTTP POST

相关文章

HTTP-请求方法Dubbo 服务调用-之远程调用（HTTP）CouchDB HTTP APIHTTP 消息HTTP-响应

相关问答

使用. htaccess将HTTP重定向到HTTPStanford Tagger、Parser和CoreNLP有什么区别？http=>akka流=>httphttp：//http：//http：//http：//http：//EOF中的SSL版本违反了协议GitHub使用智能HTTP

相关文档

图解 HTTPHTTP 协议教程HTTP 权威指南HTTP 入门教程HTTP 中文开发手册
快捷导航： 新手教程 算法原理 架构设计 Java进阶 数据库进阶 大厂专栏 面试经验 编程笔记 编程问答 所有专题 文档资料 工具软件 电子书籍 小牛导航
在线工具： 房贷计算器 个税计算器 Linux命令查询 Json格式化 正则表达式 颜色转换 AES加解密 SHA1加密 MD5加密 毒鸡汤 字数统计 随机密码生成 进制转换 Base64编解码 励志句子
Copyright © 2019-2024 小牛知识库@xnip.cn. All Rights Reserved.