Windows平台下用C++实现C# Process.OutputDataReceived功能

核心问题分析 #

你当前用async_read仅读取一次固定缓冲区的数据，既不会自动循环读取，也没有按行分割输出，所以没法实现C#里逐行触发回调的效果。要解决问题，得结合异步按行读取和循环发起异步操作，同时监控子进程的退出状态。

解决方案步骤 #

1. 用boost::process::async_read_until替代async_read，它会自动读取到换行符（或自定义分隔符），实现逐行触发回调。
2. 在回调函数处理完当前行数据后，再次发起async_read_until操作，形成持续读取的循环。
3. 监控子进程退出状态，进程结束时停止异步读取。

完整代码示例 #

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

namespace bp = boost::process;
namespace asio = boost::asio;

int main() {
    asio::io_context io;
    // 启动子进程并绑定异步管道到stdout
    bp::child child("your_child_process.exe", bp::std_out > bp::async_pipe(io));
    bp::async_pipe& ap = child.get_stdout();

    std::string line_buffer;

    // 异步读取回调函数
    auto read_handler = [&](const boost::system::error_code& ec, std::size_t bytes_transferred) {
        if (!ec) {
            // 提取当前行（去掉末尾的换行符）
            std::string line(line_buffer.data(), bytes_transferred - 1);
            line_buffer.erase(0, bytes_transferred); // 清空已处理的缓冲区内容

            // 这里就是模拟OutputDataReceived的触发点，处理当前行数据
            std::cout << "Received line: " << line << std::endl;

            // 再次发起异步读取，持续监控子进程输出
            bp::async_read_until(ap, asio::dynamic_buffer(line_buffer), '\n', read_handler);
        } else if (ec == asio::error::eof) {
            // 子进程stdout关闭，说明进程可能已退出
            std::cout << "Process stdout closed." << std::endl;
        } else {
            // 读取出错时输出错误信息
            std::cerr << "Read error: " << ec.message() << std::endl;
        }
    };

    // 首次发起异步按行读取
    bp::async_read_until(ap, asio::dynamic_buffer(line_buffer), '\n', read_handler);

    // 运行IO上下文，阻塞处理所有异步操作
    io.run();

    // 等待子进程完全退出并获取退出码
    child.wait();
    std::cout << "Process exited with code: " << child.exit_code() << std::endl;

    return 0;
}

关键细节说明 #

• asio::dynamic_buffer：替代固定大小缓冲区，自动扩容，避免缓冲区不足导致的截断问题。
• async_read_until：确保每次回调对应子进程输出的一行内容，无需手动处理缓冲区拼接。
• 循环回调逻辑：处理完当前行后重新发起异步读取，实现持续监控直到子进程退出。
• 错误处理：捕获eof信号（子进程关闭输出流）和其他读取错误，保证程序稳定退出。

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