使用Boost::asio::windows::stream_handle时客户端无法接收数据的问题

问题现象 #

服务器端async_write回调未触发，客户端始终输出“Empty buf”，无法接收数据。

核心问题与修复方案 #

1. 服务器端ConnectNamedPipe错误处理逻辑完全错误 #

当使用FILE_FLAG_OVERLAPPED创建管道时，ConnectNamedPipe返回FALSE且GetLastError()为ERROR_IO_PENDING是正常异步等待状态，当前代码只要返回非0就断言退出，直接阻断了连接建立流程。

修正代码：

if (ConnectNamedPipe(m_WindowsPipeHandle, &m_OverlapWin) == 0)
{
    DWORD err = GetLastError();
    // 仅在非预期错误时终止进程
    if (err != ERROR_IO_PENDING && err != ERROR_PIPE_CONNECTED)
    {
        assert(false && "Connect Pipe");
        exit(EXIT_FAILURE);
    }
}

2. 管道缓冲区大小设置过小 #

创建管道时指定的输入/输出缓冲区均为1字节，远小于实际传输的字符串长度，会导致写入操作阻塞或直接失败。

修正代码：

m_WindowsPipeHandle = CreateNamedPipe(
    pipe_name.c_str(),
    PIPE_ACCESS_OUTBOUND | FILE_FLAG_FIRST_PIPE_INSTANCE | FILE_FLAG_OVERLAPPED,
    PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT,
    PIPE_UNLIMITED_INSTANCES,
    4096,  // 输出缓冲区大小，设置合理值
    4096,  // 输入缓冲区大小，与输出保持一致
    INFINITE,
    NULL);

3. 客户端异步读缓冲区为空 #

客户端的read_buf是默认构造的空字符串，boost::asio::buffer(read_buf)大小为0，异步读操作会立即完成但不会读取任何数据，因此始终输出“Empty buf”。

修正代码：

// 提前预分配足够的缓冲区空间
std::string read_buf(4096, '\0');

void Run()
{
    fs << "Run launch" << std::endl;
    // 使用async_read_some读取可用数据，适配消息管道特性
    boost::asio::async_read_some(
        *pipe,
        boost::asio::buffer(read_buf),
        [this](const boost::system::error_code& error, size_t bytes)
        {
            if (error)
            {
                fs << error.message() << std::endl;
                return;
            }
            if (bytes > 0)
            {
                // 仅读取实际传输的字节数
                fs << "Readed str: " << std::string(read_buf.data(), bytes) << std::endl;
                read_buf.assign(4096, '\0'); // 重置缓冲区
            }
            else
            {
                fs << "Empty buf!" << std::endl;
            }

            boost::asio::post(ctx, boost::bind(&Pipe::Run, this));
        });
}

4. 服务器端未正确处理异步连接完成 #

原代码用sleep_for等待连接，属于低效且不可靠的方式，同时未将管道句柄正确关联到Boost Asio的完成端口，导致异步写入无法触发回调。

修正代码：

// 在MessageProcessor类中添加成员
std::unique_ptr<boost::asio::windows::object_handle> m_connect_handle;

// 构造函数中修改连接等待逻辑
m_OverlapWin.hEvent = CreateEvent(NULL, TRUE, FALSE, NULL);
m_connect_handle = std::make_unique<boost::asio::windows::object_handle>(asio_ctx, m_OverlapWin.hEvent);

// 异步等待连接完成
m_connect_handle->async_wait(
    [this](const boost::system::error_code& error)
    {
        if (!error)
        {
            // 连接建立后再初始化stream_handle
            m_Pipe = std::make_unique<boost::asio::windows::stream_handle>(asio_ctx, m_WindowsPipeHandle);
        }
        else
        {
            log("Connect pipe error", error);
        }
    });

// 移除原有的sleep和提前初始化m_Pipe的代码

额外注意事项 #

• 确保管道名称格式正确，Windows命名管道标准格式为\\.\pipe\PipeName
• 服务器和客户端的io_context必须调用run()方法，否则所有异步操作无法执行
• 服务器端AsyncWrite需在连接完成后调用，避免句柄未初始化时执行写入

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