Boost.Asio TCP服务端无法正常接收末尾带\0的字符串消息

带\0的消息触发异常不是TCP协议本身的行为，是你的代码存在3个确定性的bug，不带\0时能正常运行完全是未定义行为下的巧合：

• 异步写操作存在野指针问题，会随机踩内存
• 空应答场景下的递归调用会导致栈溢出
• 全局队列导致多连接数据串扰
  \0本身不影响TCP数据传输，只是改变了栈内存布局，提前触发了上述bug。

具体Bug说明 #

1. 异步写的野指针与并发写违规 #

你的do_write逻辑存在严重的生命周期错误：

// 原错误代码片段
std::string stdstrAnswer = stdqueAnswers.front();
boost::asio::async_write(socket_, boost::asio::buffer(stdstrAnswer.c_str(), stdstrAnswer.length() ),
    [this, self](boost::system::error_code ec, std::size_t /*length*/)
{
    if (!ec) { do_read(); }
});
stdqueAnswers.pop();

• stdstrAnswer是do_write栈上的局部变量，async_write是异步操作，调用后立即返回，do_write函数退出时stdstrAnswer就会被析构，后续异步写持有的buffer指针是已经释放的野指针，会随机破坏栈/堆内存。
• 你在发起异步写后立刻pop队列，没有等写操作完成，如果此时有新的应答入队再次触发do_write，会在同一个socket上同时发起两个async_write操作，这是Boost.Asio明确禁止的未定义行为，会直接触发内部断言或内存错误。
• 不带\0时消息长度短、发送频率刚好匹配栈内存复用节奏，野指针暂时没有访问到非法内存，所以看起来运行正常；带\0时消息长度多1字节，栈内存布局变化，野指针访问触发异常，连接直接中断，自然只能收到少量消息。

2. 递归读导致栈溢出 #

当应答队列stdqueAnswers为空时，你直接在当前读回调的栈帧里同步调用do_read()：

else {
    auto self(shared_from_this());
    do_read(); // 同步递归调用
}

如果客户端持续发送数据，这个调用会形成无限递归：读完成→调do_write→空队列→调do_read→读完成→...，每次调用都会在栈上新增栈帧，很快就会打满线程栈导致程序崩溃。如果你的业务逻辑在处理带\0的消息时没有生成应答（比如字符串匹配逻辑因为\0的存在匹配失败），就会直接进入这个递归分支快速崩溃。

3. 全局队列导致跨连接串扰 #

代码中commandsQueue和stdqueAnswers是全局变量，所有客户端连接的session都会读写这两个队列，会出现A连接发的消息生成的应答发给B连接的问题，高并发下会直接导致内存结构混乱。

1. 将队列和写缓冲改为session成员变量，每个连接独立持有自己的收发队列，避免跨连接串扰，同时保证写缓冲的生命周期覆盖整个异步写过程。
2. 修正异步写时序：等写缓冲的内容拷贝到持久化成员变量后再pop队列，写操作完成回调触发后再启动下一次读，禁止并发写。
3. 消除递归调用：空队列场景下用boost::asio::post将下一次读操作投递到事件循环，避免栈嵌套。
4. 不要依赖\0作为消息分隔符，TCP是字节流协议，需要自己实现应用层消息边界逻辑（比如长度前缀、固定分隔符\r\n），否则一定会出现粘包/拆包问题。

修复后的核心代码参考：

class session : public std::enable_shared_from_this<session>
{
public:
    session(tcp::socket socket)
        : socket_(std::move(socket))
    {}

    void start()
    {
        do_read();
    }

private:
    void do_read()
    {
        auto self(shared_from_this());
        socket_.async_read_some(boost::asio::buffer(data_, max_length),
            [this, self](boost::system::error_code ec, std::size_t length)
        {
            if (!ec && length > 0) {
                std::string strData(data_, length);
                std::cout << strData;
                // 过滤空消息时需要把\0也纳入判断范围
                if (strData.find_first_not_of(" \0") != std::string::npos)
                {
                    commandsQueue.push(strData);
                    // 此处补充业务处理逻辑，生成应答推入stdqueAnswers
                }
                do_write();
            }
        });
    }

    void do_write()
    {
        if (stdqueAnswers.empty()) {
            // 投递到事件循环，避免递归栈溢出
            auto self(shared_from_this());
            boost::asio::post(socket_.get_executor(), [this, self]() {
                do_read();
            });
            return;
        }

        auto self(shared_from_this());
        // 把待发内容拷贝到成员变量，保证buffer生命周期
        current_write_buf_ = stdqueAnswers.front();
        stdqueAnswers.pop();
        boost::asio::async_write(socket_, boost::asio::buffer(current_write_buf_),
            [this, self](boost::system::error_code ec, std::size_t)
        {
            if (!ec) {
                do_read();
            }
        });
    }

    tcp::socket socket_;
    enum { max_length = 8096 };
    char data_[max_length];
    // 原全局队列改为session成员变量，每个连接独立持有
    std::queue<std::string> commandsQueue;
    std::queue<std::string> stdqueAnswers;
    std::string current_write_buf_; // 持久化写缓冲，避免野指针
};

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