Boost Beast WebSocket运行数秒后崩溃问题求助

问题根源分析 #

• read: stream truncated 错误并非一定是服务器主动断开，结合AddressSanitizer的堆内存重复使用提示，核心问题是客户端异步回调中的对象生命周期管理不当，导致缓冲区或会话对象在异步操作未完成时被销毁，引发内存非法访问。
• 即使你每次读取后清空缓冲区，若会话对象或缓冲区的生命周期无法覆盖异步async_read的执行周期，就会出现内存重复使用/野指针问题。

关键修复方案 #

1. 用智能指针保证会话对象生命周期 #

官方示例通常依赖std::enable_shared_from_this管理会话，如果你重写on_read时未沿用这个逻辑，会导致this指针失效：

// 会话类必须继承enable_shared_from_this，确保异步回调期间对象存活
class session : public std::enable_shared_from_this<session>
{
    beast::flat_buffer buffer_; // 用可自动扩容的flat_buffer替代固定大小缓冲区
    websocket::stream<tcp::socket> ws_;

public:
    // ... 构造函数等其他代码 ...

    void on_read(beast::error_code ec, std::size_t bytes_transferred)
    {
        boost::ignore_unused(bytes_transferred);

        // 区分正常关闭和异常错误
        if (ec) {
            if (ec != websocket::error::closed) {
                fail(ec, "read");
            }
            return;
        }

        // 处理接收到的消息（示例逻辑）
        std::cout << beast::buffers_to_string(buffer_.data()) << std::endl;
        
        // 清空缓冲区，准备下一次读取
        buffer_.consume(buffer_.size());

        // 用shared_from_this()绑定回调，避免this指针失效
        ws_.async_read(
            buffer_,
            std::bind(
                &session::on_read,
                shared_from_this(), // 替换this，保证对象存活
                std::placeholders::_1,
                std::placeholders::_2
            )
        );
    }
};

2. 修复缓冲区使用逻辑 #

• 必须使用beast::flat_buffer这类可动态扩容的缓冲区，避免固定大小缓冲区导致的读取截断。
• 禁止在异步读取过程中手动销毁或重置缓冲区，确保缓冲区作为会话对象的成员，随会话生命周期同步管理。

3. 正确处理错误码分支 #

• 不要忽略websocket::error::closed错误码，这是服务器正常关闭连接的信号，无需触发崩溃逻辑。
• 其他错误（如stream truncated）需排查是否存在网络波动，或在回调中添加重连逻辑，而非直接让程序崩溃。

额外验证项 #

• 检查是否在多线程环境中直接操作WebSocket对象，Boost Beast的WebSocket流并非线程安全，需保证所有异步操作在同一线程执行。
• 用抓包工具（如Wireshark）验证服务器发送的WebSocket帧是否符合规范，排除隐性的帧格式错误。

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