boost::asio async_read_some与bytes_readable异常问题求助

问题描述 #

使用boost::asio的async_read_some()函数，通过定时器循环调用receiveAsyncWithTimeout()，预期读取服务器所有消息，但出现以下问题：

• bytesTransferred与bytesReadable数值不一致
• 消息接收异常：先收到一帧数据，约10秒后才收到剩余部分

Boost版本：1.77
输出日志：

readHandle bytesReadable: 0 bytesTransferred: 1112

相关伪代码 #

class TlsSocket 
{
public:
    TlsSocket(boost::asio::io_context &io_context,
              const std::string &endpoint);
private:
    boost::asio::io_context &_iocontext;
    boost::asio::ssl::context _ctx;
    boost::asio::ssl::stream<boost::asio::ip::tcp::socket> _socket;
    std::vector<uint8_t> _recvBuffer;
    std::vector<uint8_t> _sendBuffer;
    size_t _bytesReadable{0};
};

void TlsSocket::readHandle(const boost::system::error_code &ec, std::size_t bytesTransferred)
{
    if(_bytesReadable == 0 && bytesTransferred > 0)
    {
        std::cout << "readHandle ERROR bytesReadable: " << _bytesReadable
                  << " bytesTransferred: " << bytesTransferred << std::endl;
        return;
    }

/// .. 其他处理代码
}

void TlsSocket::receiveAsyncWithTimeout()
{
    boost::asio::socket_base::bytes_readable command(true);
    _socket.lowest_layer().io_control(command);
    _bytesReadable = command.get();
    
     _socket.async_read_some(boost::asio::buffer(_recvBuffer),
                            boost::bind(&TlsSocket::readHandle,
                                        this,
                                        boost::asio::placeholders::error,
                                        boost::asio::placeholders::bytes_transferred));
}

问题原因分析 #

1. 数值不一致的本质：
   bytesReadable是底层TCP套接字的可读字节数，而async_read_some()读取的是SSL层解密后的应用数据。两者之间存在时间窗口和数据缓存差异：

   • 调用io_control获取bytesReadable后，到发起异步读取的间隙，可能有新数据到达SSL缓冲区
   • SSL层会自动缓存解密后的数据，即使底层套接字当前无可读数据，SSL缓冲区仍可能有数据待读取，导致bytesReadable=0但bytesTransferred>0的情况

2. 接收延迟的根源：
   定时器循环轮询的方式破坏了Asio的异步事件驱动模型：

   • 异步读取本应在数据到达时立即触发回调，但定时器轮询会让读取操作只能在定时周期触发，导致后续数据无法及时被读取
   • 重复发起的异步读取可能引发冲突，反而阻塞数据接收流程

修复方案 #

1. 移除手动轮询逻辑 #

Asio的异步模型无需手动检查可读字节数，直接发起异步读取即可，async_read_some()会在数据可用时自动触发回调。

2. 采用链式异步读取 #

在读取回调处理完当前数据后，立即再次发起异步读取，形成持续监听的链式调用，彻底替代定时器轮询：

void TlsSocket::readHandle(const boost::system::error_code &ec, std::size_t bytesTransferred)
{
    if (ec) {
        // 处理错误（如连接断开、SSL错误）
        return;
    }

    // 处理读取到的数据
    processReceivedData(_recvBuffer.data(), bytesTransferred);

    // 再次发起异步读取，保持持续监听
    _socket.async_read_some(boost::asio::buffer(_recvBuffer),
                            boost::bind(&TlsSocket::readHandle,
                                        this,
                                        boost::asio::placeholders::error,
                                        boost::asio::placeholders::bytes_transferred));
}

// 初始化时只需调用一次，启动接收流程
void TlsSocket::startReceiving()
{
    _socket.async_read_some(boost::asio::buffer(_recvBuffer),
                            boost::bind(&TlsSocket::readHandle,
                                        this,
                                        boost::asio::placeholders::error,
                                        boost::asio::placeholders::bytes_transferred));
}

3. 优化缓冲区配置 #

确保_recvBuffer的大小足够容纳单次读取的最大数据量（如设置为16384字节，匹配SSL默认缓冲区大小），避免因缓冲区过小导致数据被多次拆分读取。

4. 处理SSL特定错误 #

在回调中增加SSL错误处理逻辑，比如处理boost::asio::error::ssl_needs_write等SSL握手/重协商相关错误，保证SSL流的正常运行：

if (ec == boost::asio::error::ssl_needs_write) {
    // 触发SSL写操作以完成握手/重协商
    _socket.async_write_some(boost::asio::null_buffers(),
                            boost::bind(&TlsSocket::readHandle,
                                        this,
                                        boost::asio::placeholders::error,
                                        0));
    return;
}

内容的提问来源于stack exchange，提问作者Michał Hanusek