基于Boost Beast实现握手后发送HTTP请求的正确方式

核心问题：避免空请求维持长连接 #

你遇到的"end of stream"错误，本质是Boost Beast的SSL流在握手完成后，如果没有立即启动异步读操作，对方可能因连接空闲超时关闭，或者本地流状态未正确初始化。根本不需要发空请求，正确做法是在握手完成后立即启动一个异步读操作（哪怕暂时不处理响应），保持流处于活跃监听状态：

void REST_on_handshake(beast::error_code ec, ssl::stream<beast::tcp_stream>& stream) {
    if(ec) {
        // 处理握手错误
        return;
    }
    // 握手完成后启动异步读，维持连接活跃状态
    beast::flat_buffer buffer;
    http::request<http::empty_body> dummy_req;
    http::async_read(stream, buffer, dummy_req,
        [&](beast::error_code ec, std::size_t bytes_transferred) {
            if(ec && ec != beast::errc::not_connected) {
                // 处理读错误（如连接断开）
            }
            // 若需继续维持连接，可再次启动异步读
        });
}

HTTP Keep-Alive要求连接两端至少有一端保持读写活跃，启动异步读相当于告诉Boost Beast：该连接仍在使用，不要关闭。

处理响应缓存累积问题 #

响应缓存累积多因多次读操作后未正确清空缓冲区，或响应解析不完整导致残留数据。解决方法：

• 每次发送请求后使用独立缓冲区处理响应，避免复用同一个buffer对象；
• 响应解析完成后，调用buffer.consume(bytes_transferred)清空已处理的数据；
• 持久连接模式下，每次响应处理完成后重新启动异步读，避免残留数据干扰下一次请求解析：

void handle_response(beast::error_code ec, std::size_t bytes_transferred,
                     beast::flat_buffer& buffer, http::response<http::string_body>& res) {
    if(ec) {
        // 处理错误
        return;
    }
    // 处理响应数据
    process_response(res.body());
    // 清空缓冲区已处理部分
    buffer.consume(bytes_transferred);
    // 重新启动异步读，维持连接并准备接收下一个响应
    http::async_read(stream, buffer, res, std::bind(&handle_response, std::placeholders::_1, std::placeholders::_2, std::ref(buffer), std::ref(res)));
}

按需触发请求最小化延迟 #

要实现长连接建立后按需发请求，需将SSL流对象保存为全局或类成员变量，确保握手完成后可从外部访问，同时提供线程安全的请求触发接口：

1. 类中保存流对象与I/O上下文示例：

class DbQueryClient {
public:
    DbQueryClient(boost::asio::io_context& ioc, ssl::context& ctx)
        : ioc_(ioc), stream_(ioc, ctx) {}

    // 启动握手
    void start_handshake(const std::string& host, const std::string& port) {
        host_ = host;
        // 连接服务器逻辑（略）
        ssl::async_handshake(stream_, ssl::stream_base::client,
            std::bind(&DbQueryClient::on_handshake, this, std::placeholders::_1));
    }

    // 外部调用的按需请求接口
    void send_query(const std::string& query) {
        // 用post确保操作在I/O线程执行，避免线程安全问题
        boost::asio::post(ioc_, [this, query]() {
            http::request<http::string_body> req(http::verb::post, "/query", 11);
            req.set(http::field::host, host_);
            req.set(http::field::content_type, "application/json");
            req.body() = R"({"query":")" + query + R"("})";
            req.prepare_payload();

            // 异步发送请求
            http::async_write(stream_, req,
                std::bind(&DbQueryClient::on_write, this, std::placeholders::_1, std::placeholders::_2, query));
        });
    }

private:
    boost::asio::io_context& ioc_;
    ssl::stream<beast::tcp_stream> stream_;
    std::string host_;
    // 响应处理等私有方法（略）
};

2. 关键要点：

• 所有异步操作必须在I/O上下文线程中执行，通过boost::asio::post将外部请求转发到I/O线程；
• 握手完成后不要关闭流，保持其活跃状态；
• 每次请求发送后，响应处理函数需重新启动异步读以维持连接。

内容的提问来源于stack exchange，提问作者Henry