基于Boost.Asio的C++命名管道服务器编译问题求助

我已通过Windows API实现了一个可用的命名管道服务器，代码如下：

#include <iostream>
#include <windows.h>

int main() {
    // 定义命名管道名称
    const wchar_t* pipeName = L"\\\\.\\pipe\\MyNamedPipe";

    // 创建命名管道
    HANDLE hPipe = CreateNamedPipe(
        pipeName,                  // 管道名称
        PIPE_ACCESS_DUPLEX,        // 管道打开模式
        PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT, // 管道模式
        PIPE_UNLIMITED_INSTANCES,  // 实例数量
        512,                       // 输出缓冲区大小
        512,                       // 输入缓冲区大小
        NMPWAIT_USE_DEFAULT_WAIT,  // 客户端连接超时时间
        nullptr                    // 安全属性
    );

    if (hPipe == INVALID_HANDLE_VALUE) {
        std::cerr << "创建命名管道失败，错误码: " << GetLastError() << std::endl;
        return 1;
    }

    // 等待客户端连接
    if (ConnectNamedPipe(hPipe, nullptr)) {
        std::cout << "客户端已连接，等待数据...\n";

        // 读取客户端数据
        char buffer[512];
        DWORD bytesRead;
        if (ReadFile(hPipe, buffer, sizeof(buffer), &bytesRead, nullptr)) {
            std::cout << "收到客户端数据: " << buffer << std::endl;
        } else {
            std::cerr << "读取管道数据失败，错误码: " << GetLastError() << std::endl;
        }

        // 断开管道连接
        DisconnectNamedPipe(hPipe);
    } else {
        std::cerr << "等待客户端连接失败，错误码: " << GetLastError() << std::endl;
    }

    // 关闭管道句柄
    CloseHandle(hPipe);

    return 0;
}

但我希望改用Boost.Asio这类现代C++方案，网上找到的代码要么不符合需求，要么无法编译，报错代码如下：

#include <iostream>
#include <boost/asio.hpp>

using namespace boost::asio;

int main() {
    io_service ioService;

    // 定义命名管道名称
    const char* pipeName = "\\\\.\\pipe\\MyNamedPipe";

    // 创建本地端点
    local::stream_protocol::endpoint endpoint(pipeName);

    // 创建并打开接收器
    local::stream_protocol::acceptor acceptor(ioService, endpoint);

    std::cout << "等待客户端连接...\n";

    // 等待客户端连接
    local::stream_protocol::socket socket(ioService);
    acceptor.accept(socket);

    std::cout << "客户端已连接，等待数据...\n";

    // 读取客户端数据
    char buffer[512];
    size_t bytesRead = socket.read_some(buffer, ioService); // 错误：找不到匹配的重载函数

    std::cout << "收到客户端数据: " << std::string(buffer, bytesRead) << std::endl;

    // 关闭套接字（自动断开客户端连接）
    socket.close();

    return 0;
}

我的Boost版本是通过vcpkg安装的1.82.0#1，需要修正这段代码使其正常编译运行。

修正后的代码 #

#include <iostream>
#include <boost/asio.hpp>
#include <boost/system/error_code.hpp>

using namespace boost::asio;

int main() {
    // 使用Boost 1.70+推荐的io_context替代io_service
    io_context ioCtx;

    // Windows命名管道标准格式
    const char* pipeName = "\\\\.\\pipe\\MyNamedPipe";

    try {
        local::stream_protocol::endpoint endpoint(pipeName);
        local::stream_protocol::acceptor acceptor(ioCtx);

        // 提前清理残留管道（避免之前进程未正常关闭导致绑定失败）
        boost::system::error_code ec;
        local::stream_protocol::socket tempSocket(ioCtx);
        tempSocket.connect(endpoint, ec);
        if (!ec) {
            std::cerr << "检测到残留管道，自动清理..." << std::endl;
            remove(endpoint, ec);
        }

        // 初始化接收器并监听
        acceptor.open(endpoint.protocol());
        acceptor.bind(endpoint);
        acceptor.listen();

        std::cout << "等待客户端连接...\n";

        // 接受客户端连接
        local::stream_protocol::socket socket(ioCtx);
        acceptor.accept(socket);

        std::cout << "客户端已连接，等待数据...\n";

        // 读取数据：read_some无需传入io_context，正确传入缓冲区和错误码
        char buffer[512];
        boost::system::error_code readEc;
        size_t bytesRead = socket.read_some(buffer(buffer, sizeof(buffer)), readEc);

        if (!readEc) {
            std::cout << "收到客户端数据: " << std::string(buffer, bytesRead) << std::endl;
        } else {
            std::cerr << "读取数据失败: " << readEc.message() << std::endl;
        }

        socket.close();
    } catch (const std::exception& e) {
        std::cerr << "程序异常: " << e.what() << std::endl;
        return 1;
    }

    return 0;
}

关键修正说明 #

• 替换io_service为io_context：Boost.Asio 1.70+版本开始推荐使用io_context作为核心执行上下文，io_service仅为兼容别名。
• 修正read_some调用：该方法无需传入io_context，正确参数为缓冲区（可通过buffer()函数包装）和可选的错误码对象，原代码错误地传递了执行上下文。
• 添加管道清理逻辑：Windows命名管道若未正常关闭会残留，导致新进程绑定失败，因此在绑定前检测并清理残留管道。
• 完善错误处理：通过try-catch捕获Asio异常，同时用error_code处理非致命错误，提升代码健壮性。
• 拆分接收器初始化流程：将open/bind/listen步骤拆分，便于中间错误的捕获与处理，比构造函数直接初始化更灵活。

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