基于Boost Asio的Windows命名管道服务器：handler未触发及ready_异常

尝试基于Boost Asio实现Windows命名管道服务器，流程为：创建带重叠IO的命名管道对象，分配给windows::stream_handle；创建windows::overlapped_ptr绑定处理函数，调用::ConnectNamedPipe等待异步连接。但处理函数handle_accept从未被调用，调试发现win_iocp_io_context::do_one中::GetQueuedCompletionStatus在客户端连接后立即返回，但win_iocp_operation的ready_属性始终为0，处理函数未触发。

疑问：什么操作会将ready_属性设为true？

代码示例：

class NamedPipeServer {
public:
    NamedPipeServer(boost::asio::io_context& io_context)
        : io_context_(io_context)
        , pipe_(io_context) 
    {
        start_accept();
    }

private:
    void start_accept() {
        HANDLE pipe_handle = ::CreateNamedPipe(
            "\\\\.\\pipe\\mypipe",
            PIPE_ACCESS_DUPLEX | FILE_FLAG_OVERLAPPED,
            PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT,
            PIPE_UNLIMITED_INSTANCES,
            512, 512, 0, nullptr);

        pipe_.assign(pipe_handle);

        // Copying overlapped to the closure will make sure it isn't released
        // after I exit the function, but when I exit the closure
        auto overlapped = std::make_shared<boost::asio::windows::overlapped_ptr>();
        overlapped->reset(io_context_, [this, overlapped](const boost::system::error_code& ec, std::size_t bytes_transferred) {
            handle_accept(ec);
        });
        ::ConnectNamedPipe(pipe_handle, overlapped->get());
    }

    void handle_accept(const boost::system::error_code& error) {
        // Here I should start read/write/etc.
        // the problem is: THIS FUNCTION IS NEVER CALLED
    }


    boost::asio::io_context& io_context_;
    std::string pipe_name_;
    boost::asio::windows::stream_handle pipe_;
};


int main() {
    boost::asio::io_context io_context;
    NamedPipeServer server(io_context);
    io_context.run();
    return 0;
}

核心逻辑说明 #

win_iocp_operation的ready_属性由Boost Asio在以下两种场景下设置为true：

1. 异步操作进入ERROR_IO_PENDING状态，后续IOCP完成端口收到操作完成通知时，Boost Asio内部会标记对应win_iocp_operation的ready_为true，并调度绑定的处理函数执行。
2. 当异步操作同步完成（即::ConnectNamedPipe直接返回成功，或返回失败但GetLastError()为ERROR_PIPE_CONNECTED），需要手动调用overlapped_ptr::complete()，触发Boost Asio标记ready_并执行处理函数。

你的代码未处理同步完成的场景，导致即使连接成功，overlapped_ptr也未被正确触发，ready_始终为0。

修复步骤 #

1. 检查::ConnectNamedPipe的返回值，覆盖同步完成的情况：
   • 若::ConnectNamedPipe返回TRUE，说明连接已同步完成。
   • 若::ConnectNamedPipe返回FALSE且GetLastError()为ERROR_PIPE_CONNECTED，说明客户端已完成连接，无需等待异步通知。
   • 以上两种情况都需手动调用overlapped->complete()触发处理函数。
2. 确保CreateNamedPipe参数兼容：FILE_FLAG_OVERLAPPED与PIPE_WAIT可以共存，但需严格按照异步逻辑处理返回值。

修改后的start_accept函数 #

void start_accept() {
    HANDLE pipe_handle = ::CreateNamedPipe(
        "\\\\.\\pipe\\mypipe",
        PIPE_ACCESS_DUPLEX | FILE_FLAG_OVERLAPPED,
        PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT,
        PIPE_UNLIMITED_INSTANCES,
        512, 512, 0, nullptr);

    if (pipe_handle == INVALID_HANDLE_VALUE) {
        // 处理管道创建失败逻辑
        return;
    }

    pipe_.assign(pipe_handle);

    auto overlapped = std::make_shared<boost::asio::windows::overlapped_ptr>();
    overlapped->reset(io_context_, [this, overlapped](const boost::system::error_code& ec, std::size_t bytes_transferred) {
        handle_accept(ec);
        // 递归调用以支持多客户端连接
        start_accept();
    });

    BOOL result = ::ConnectNamedPipe(pipe_handle, overlapped->get());
    if (!result) {
        DWORD err = ::GetLastError();
        if (err != ERROR_IO_PENDING) {
            if (err == ERROR_PIPE_CONNECTED) {
                // 同步连接完成，手动触发处理函数
                overlapped->complete(boost::system::error_code(), 0);
            } else {
                // 处理其他错误
                overlapped->complete(boost::system::error_code(err, boost::asio::error::get_system_category()), 0);
            }
        }
        // 若err为ERROR_IO_PENDING，等待IOCP通知即可
    } else {
        // ConnectNamedPipe直接返回成功，同步完成
        overlapped->complete(boost::system::error_code(), 0);
    }
}

补充说明 #

• overlapped_ptr的核心作用是将Windows重叠IO与Boost Asio的io_context绑定，无论是异步pending还是同步完成，都必须确保complete()被调用（要么IOCP触发，要么手动调用），否则绑定的处理函数永远不会执行。
• 在handle_accept中递归调用start_accept()，可以实现多客户端连接的支持。

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