Muduo网络库实现 [十三] - HttpRequest模块

目录

设计思路 

成员设计

模块实现

设计思路 

首先我们要先知道HTTP的请求的流程是什么样子的，不然我们会学的很迷糊。对于HTTP请求如何到来以及去往哪里，我们应该很清楚的知道

HTTP请求在服务器系统中的传递流程是一个多层次的过程:

1. 客户端发起请求 - 用户在浏览器或应用中发起HTTP请求
2. 网络传输 - 请求通过网络传输到服务器
3. 服务器接收 - 服务器的TCP/IP协议栈接收数据包并将其传递给操作系统
4. 网络库接收 - 在muduo这样的网络库中，数据通过以下路径流动:
   • 操作系统的socket接口接收原始数据
   • 网络库的EventLoop检测到socket可读事件
   • TcpConnection将数据读入其内部Buffer
5. HTTP解析 - 数据进入HTTP解析层:
   • TcpServer将连接和数据传递给HttpServer
   • HttpServer创建HttpContext对象处理每个连接
   • HttpContext从Buffer中读取数据并进行解析
   • 解析结果存储在HttpRequest对象中
6. 应用处理 - 最终HttpRequest被传递给用户注册的回调函数进行业务逻辑处理

HttpRequest通常由HttpContext创建和填充，然后传递给处理HTTP请求的回调函数或处理器。它本质上是HTTP请求信息的容器，使服务器能够方便地访问和处理客户端的请求内容。

在整个HTTP处理流程中，HttpRequest的角色是保存从网络层解析出的HTTP请求信息，供应用层使用。

HTTP请求格式

成员设计

HTTP请求中的主要要素包括：

1. 请求行:
   • 请求方法（GET、POST、PUT、DELETE等）
   • URL，包含:
     • 资源路径
     • 查询参数（键值对形式）
   • 协议版本（如HTTP/1.1）
2. 请求头部:
   • 多个键值对格式的头部字段
   • 常见的如Content-Type、User-Agent、Host等
3. 请求正文:
   • 根据Content-Length或Transfer-Encoding确定长度
   • 内容格式由Content-Type决定

首先请求行中，有请求方法，url ，协议版本，而url中又分为资源路径和参数，参数是kv的形式，所以我们需要使用一个map来保存

而请求头部中，都是一些kv格式的属性，我们也是使用一个map来保存

最后就是正文部分，正文部分是交给上层业务逻辑去处理的，我们只需要按照请求头部中的Content-Length提取出来就行了。

那么我们需要保存的就是 ： 请求方法，资源路径，参数，协议版本，头部字段，正文 ，当然，由于可能会存在中间的处理过程，比如对请求行的解析，我们会使用正则表达式来进行，我们可以再存储一个 std::smatch 来保存正则提取出来的结果。

由于HttpRequest后续我们是交给 上下文模块来进行设置的，为了方便，我们就直接将成员设置为公有的了，便于直接访问。

同时，对于参数和请求头部，我们可以提供结构，用来插入kv形式的参数和请求头部，以及查询是否有某个参数或者请求头部。

再HttpRequest的头部字段中，有一个很重要的信息就是正文长度，我们可以提供一个接口用来获取正文长度。

最后再提供一个接口用于判断长短连接，长短连接后续我们会用到。

然后如果是短连接的话，我们每次接收完也需要把数据给清除了。所以也需要个接口

模块实现

代码挺简单的，跟着思路走就很容易写出来的

class HttpRequest
{
public:
    string _method;  //存储请求方法
    string _path;    //存储资源路径
    string _version;  //存储协议版本
    string _body;    //存储正文
    unordered_map<string, string> _headers;   //存储请求头部
    unordered_map<string, string> _params;  //存储查询字符串
    smatch _matches; //资源路径正则提取
private:
    bool HasHeader(const sting &key) const  //给获取报文长度函数提供的
    {
        auto it = _headers.find(key);
        if(it == _headers.end())
        {
            return false;
        }
        return it->second;
    }
    string GetHeader(const sting &key) const //给获取报文长度函数提供的
    {
        auto it = _headers.find(key);
        if(it == _headers.end())
        {
            return "";
        }
        return it->second;
    }

public:
    HttpRequest()
    :_version("HTTP/1.1")
    {}

    void clear()//清空类数据
    {
        _method.clear();
        _path.clear();
        _version("HTTP/1.1");
        _body.clear();
        _headers.clear();
        _params.clear();
        smatch matches;
        _matches.swap(matches);
    }
    void SetHeader(const string &key, const string &val)//添加请求头部
    {
        _headers.insert(key, val);
    }
    void SetParam(const string &key, const string &val)//添加查询字符串
    {
        _params.insert(key, val);
    }
    size_t GetLength()//获取正文长度
    {
        bool ret = HasHeader("Content-Length");
        if(ret == false)
        {
            return 0;
        }
        string len = GetHeader("Content-Length");
        return stol(len);
    }
    //是否是短链接
    bool Close() const
    {
        if(HasHeader("Connection") == true && GetHeader("Connection") == "keep-alive");
        {
            return false;
        }
        return true;
    }
};