利用WebSockets在PHP中实现浏览器与后端进程的实时交互

<?php

// 定义管道描述符
$descriptors = [
    0 => ["pipe", "r"],  // stdin 是子进程将从中读取的管道
    1 => ["pipe", "w"],  // stdout 是子进程将向其写入的管道
    2 => ["pipe", "w"]   // stderr 是子进程将向其写入的管道
];

// 要执行的命令：编译 test.cpp 并运行 test.o
// 假设 test.cpp 是一个简单的程序，它需要两个数字作为输入并输出它们的和
// 例如：
// #include <iostream>
// int main() {
//     int a, b;
//     std::cin >> a >> b;
//     std::cout << "Sum: " << a + b << std::endl;
//     return 0;
// }
$command = 'g++ test.cpp -o test.o && ./test.o';

// 启动进程
// "/home/ixcoders/Desktop" 是可选的工作目录
$process = proc_open($command, $descriptors, $pipes, "/home/ixcoders/Desktop");

if (is_resource($process)) {
    // 准备输入数据，以换行符分隔，模拟多行输入
    $inputs = "4\n5\n"; // 假设程序需要两个数字

    // 将输入写入子进程的 stdin 管道
    fwrite($pipes[0], $inputs);
    fclose($pipes[0]); // 关闭 stdin 管道，表示输入已结束

    // 从子进程的 stdout 管道读取输出
    echo "Output:\n";
    echo stream_get_contents($pipes[1]);
    fclose($pipes[1]); // 关闭 stdout 管道

    // 从子进程的 stderr 管道读取错误信息
    echo "\nErrors:\n";
    echo stream_get_contents($pipes[2]);
    fclose($pipes[2]); // 关闭 stderr 管道

    // 关闭进程，获取返回码
    $return_value = proc_close($process);
    echo "\n";
    echo "Error Code: " . $return_value . "\n";
} else {
    echo "Failed to open process.\n";
}
?>

// 假设使用一个PHP WebSocket框架（如Ratchet）
// WebSocket服务器启动时
$wsServer->on('open', function ($conn) use ($loop) {
    // 新的WebSocket连接建立
    // 为每个连接创建一个唯一的ID或关联一个用户会话
    $conn->id = uniqid();
    $activeProcesses[$conn->id] = null; // 存储与此连接关联的子进程

    // 假设客户端会发送一个启动命令
});

$wsServer->on('message', function ($from, $msg) use ($activeProcesses, $loop) {
    // 收到来自浏览器的消息
    $data = json_decode($msg, true);

    if ($data['type'] === 'start_binary' && !$activeProcesses[$from->id]) {
        // 启动二进制程序
        $command = $data['command']; // 假设客户端发送要运行的命令
        $descriptors = [
            0 => ["pipe", "r"],
            1 => ["pipe", "w"],
            2 => ["pipe", "w"]
        ];

        $process = proc_open($command, $descriptors, $pipes);
        if (is_resource($process)) {
            $activeProcesses[$from->id] = [
                'process' => $process,
                'pipes' => $pipes
            ];

            // 将 stdout 和 stderr 管道设置为非阻塞模式
            stream_set_blocking($pipes[1], false);
            stream_set_blocking($pipes[2], false);

            // 使用事件循环监听管道的可读事件
            // 当 stdout 有数据时，读取并发送到浏览器
            $loop->addReadStream($pipes[1], function ($stream) use ($from) {
                $output = fread($stream, 8192); // 读取数据
                if ($output) {
                    $from->send(json_encode(['type' => 'output', 'data' => $output]));
                }
            });

            // 当 stderr 有数据时，读取并发送到浏览器
            $loop->addReadStream($pipes[2], function ($stream) use ($from) {
                $error = fread($stream, 8192);
                if ($error) {
                    $from->send(json_encode(['type' => 'error', 'data' => $error]));
                }
            });
        }
    } elseif ($data['type'] === 'input' && $activeProcesses[$from->id]) {
        // 收到来自浏览器的输入，写入子进程的 stdin
        $pipes = $activeProcesses[$from->id]['pipes'];
        fwrite($pipes[0], $data['data'] . "\n"); // 写入输入
    }
});

$wsServer->on('close', function ($conn) use ($activeProcesses) {
    // WebSocket连接关闭
    if ($activeProcesses[$conn->id]) {
        // 关闭相关的子进程和管道
        foreach ($activeProcesses[$conn->id]['pipes'] as $pipe) {
            fclose($pipe);
        }
        proc_close($activeProcesses[$conn->id]['process']);
        unset($activeProcesses[$conn->id]);
    }
});

// 运行事件循环
$loop->run();