使用beast::http::async_read遇问题：异步回调函数未触发

核心问题：未启动IO事件循环 #

Boost.Asio的异步操作完全依赖io_context的事件循环来调度、执行回调逻辑。你的代码仅调用了async_read，但从未触发io_context.run()，导致异步任务根本无法被处理，回调自然不会执行。

修复步骤 #

1. 启动IO事件循环
   调用async_read后，必须运行io_context的事件循环，这是异步操作得以执行的前提。
2. 修正无限循环逻辑
   原代码的while(true)会无限制重复发起async_read，导致大量未完成的异步操作堆积，这是错误逻辑。正确做法是在回调函数内完成后续处理，并按需再次发起异步读取（如需保持长连接）。
3. 规范单个连接的处理流程
   同步accept仅能处理一个客户端连接，若要支持多连接需改用异步accept，先从修复单个连接的异步读取逻辑入手。

修正后的代码示例 #

#include <iostream>
#include <string>
#include <boost/asio.hpp>
#include <boost/beast.hpp>
#include <functional>

namespace asio = boost::asio;
namespace beast = boost::beast;
using tcp = asio::ip::tcp;

// 异步读取回调函数
void on_read(const beast::error_code& ec, std::size_t bytes_transferred,
             tcp::socket& socket, beast::flat_buffer& buffer,
             beast::http::request<beast::http::string_body>& request)
{
    if(ec)
    {
        std::cerr << "读取错误: " << ec.message() << std::endl;
        return;
    }

    // 处理收到的请求
    std::cout << "收到请求: " << request.method_string() << " " << request.target() << std::endl;

    // 构造响应
    beast::http::response<beast::http::string_body> response;
    response.version(request.version());
    response.result(beast::http::status::ok);
    response.set(beast::http::field::server, "Boost.Beast Async Server");
    response.set(beast::http::field::content_type, "text/plain");
    response.body() = "Hello from Async Server!";
    response.prepare_payload();

    // 异步发送响应，完成后关闭连接
    beast::http::async_write(socket, response,
        [&socket](const beast::error_code& ec, std::size_t bytes_sent)
        {
            if(ec)
            {
                std::cerr << "发送错误: " << ec.message() << std::endl;
            }
            socket.shutdown(tcp::socket::shutdown_send, ec);
        });
}

int main()
{
    try
    {
        asio::io_context io_context;
        tcp::acceptor acceptor(io_context, {tcp::v4(), 8080});
        tcp::socket socket(io_context);
        beast::flat_buffer buffer;
        beast::http::request<beast::http::string_body> request;

        // 同步接受一个客户端连接
        acceptor.accept(socket);
        std::cout << "客户端已连接" << std::endl;

        // 发起第一次异步读取
        beast::http::async_read(
            socket, buffer, request,
            std::bind(on_read, std::placeholders::_1, std::placeholders::_2,
                      std::ref(socket), std::ref(buffer), std::ref(request)));

        // 启动IO事件循环，阻塞直到所有异步操作完成
        io_context.run();
    }
    catch(std::exception& e)
    {
        std::cerr << "异常: " << e.what() << std::endl;
    }

    return 0;
}

额外说明 #

• 若要支持多客户端连接，需改用异步accept，并为每个连接创建独立的socket、缓冲区对象（通常用智能指针管理，避免对象生命周期失效问题）。
• 异步回调中必须确保socket、buffer等对象在回调执行期间始终有效，否则会触发未定义行为。

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