PHP通过WebSockets实现交互式二进制程序Web界面

<?php

$descriptors = [
    0 => ["pipe", "r"],  // stdin 是子进程读取的管道
    1 => ["pipe", "w"],  // stdout 是子进程写入的管道
    2 => ["pipe", "w"]   // stderr 是子进程写入的管道
];

// 假设 /home/ixcoders/Desktop 目录下有 test.cpp
// test.cpp 内容可能如下：
// #include <iostream>
// int main() {
//     int a, b;
//     std::cout << "Enter first number: ";
//     std::cin >> a;
//     std::cout << "Enter second number: ";
//     std::cin >> b;
//     std::cout << "Sum: " << a + b << std::endl;
//     return 0;
// }

// 编译并执行二进制文件
$process = proc_open('g++ test.cpp -o test.o && ./test.o', $descriptors, $pipes, "/home/ixcoders/Desktop");

if (is_resource($process)) {
    // 预设输入
    $inputs = "4\n5\n"; // 模拟用户输入4和5，每个输入后跟换行符

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

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

    // 读取子进程的stderr错误输出
    $error_output = stream_get_contents($pipes[2]);
    if (!empty($error_output)) {
        echo "Errors:\n" . $error_output;
    }
    fclose($pipes[2]);

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

<?php
// 这段代码是概念性的，它描述了在一个已建立的WebSocket连接上下文中，
// PHP如何与二进制进程进行交互。实际的WebSocket服务器逻辑（如连接管理、事件循环）
// 将由 Ratchet、Swoole 或 WebSocketD 等工具提供。

// 假设我们已经为每个WebSocket连接启动了一个独立的PHP进程，
// 并且这个进程可以访问到唯一的二进制程序实例。

// 1. 启动二进制程序
$descriptors = [
    0 => ["pipe", "r"],  // stdin
    1 => ["pipe", "w"],  // stdout
    2 => ["pipe", "w"]   // stderr
];
$process = proc_open('./interactive_binary', $descriptors, $pipes, '/path/to/binary/directory');

if (!is_resource($process)) {
    // 错误处理：无法启动进程
    // 通过WebSocket发送错误信息到浏览器
    // $websocket_connection->send("Error: Could not start interactive binary.");
    exit();
}

// 设置管道为非阻塞模式，以便可以异步读取和写入
stream_set_blocking($pipes[1], false);
stream_set_blocking($pipes[2], false);

// 2. 循环处理WebSocket消息和二进制输出
while (true) {
    // 假设这里是WebSocket服务器的事件循环，等待消息或进程输出

    // A. 从WebSocket接收用户输入
    // 伪代码：$user_input = $websocket_connection->receive_message();
    if (/* $user_input 存在 */) {
        fwrite($pipes[0], $user_input . "\n"); // 将用户输入写入二进制进程的stdin
        fflush($pipes[0]); // 确保数据立即发送
    }

    // B. 从二进制进程读取输出
    $stdout_output = stream_get_contents($pipes[1]);
    if (!empty($stdout_output)) {
        // 通过WebSocket将输出发送回浏览器
        // $websocket_connection->send($stdout_output);
        echo "Binary Output: " . $stdout_output; // 仅为演示，实际应通过WebSocket发送
    }

    $stderr_output = stream_get_contents($pipes[2]);
    if (!empty($stderr_output)) {
        // 通过WebSocket发送错误输出
        // $websocket_connection->send("Error: " . $stderr_output);
        echo "Binary Error: " . $stderr_output; // 仅为演示
    }

    // C. 检查进程是否已结束
    $status = proc_get_status($process);
    if (!$status['running']) {
        // 进程已结束，发送最终状态并清理
        // $websocket_connection->send("Binary process exited with code: " . $status['exitcode']);
        echo "Binary process exited with code: " . $status['exitcode'] . "\n";
        break;
    }

    // 短暂休眠以避免CPU空转，或等待事件（在实际的异步框架中由框架处理）
    usleep(10000); // 10毫秒
}

// 清理：关闭所有管道和进程
fclose($pipes[0]);
fclose($pipes[1]);
fclose($pipes[2]);
proc_close($process);

?>