Работа с внешними процессами через proc_open в PHP

Запуск нескольких процессов параллельно и сбор результатов

Иногда требуется запустить несколько команд одновременно, например, для параллельной обработки файлов. Используем массив процессов.

$commands = [
    'echo "Процесс 1"',
    'echo "Процесс 2"',
    'sleep 1; echo "Процесс 3"'
];

$processes = [];
$pipes = [];

foreach ($commands as $index => $cmd) {
    $descriptorspec = [
        0 => ['pipe', 'r'],
        1 => ['pipe', 'w'],
        2 => ['pipe', 'w']
    ];
    $process = proc_open($cmd, $descriptorspec, $pipes[$index]);
    $processes[$index] = $process;
    // сразу закрываем stdin, так как писать не собираемся
    fclose($pipes[$index][0]);
}

// Читаем результаты после запуска всех
$outputs = [];
foreach ($processes as $index => $process) {
    $stdout = stream_get_contents($pipes[$index][1]);
    fclose($pipes[$index][1]);
    $stderr = stream_get_contents($pipes[$index][2]);
    fclose($pipes[$index][2]);
    $exitcode = proc_close($process);
    $outputs[$index] = [
        'stdout' => $stdout,
        'stderr' => $stderr,
        'exitcode' => $exitcode
    ];
}

print_r($outputs);

Array
(
    [0] => Array
        (
            [stdout] => Процесс 1
            [stderr] => 
            [exitcode] => 0
        )
    [1] => Array
        (
            [stdout] => Процесс 2
            [stderr] => 
            [exitcode] => 0
        )
    [2] => Array
        (
            [stdout] => Процесс 3
            [stderr] => 
            [exitcode] => 0
        )
)

Пояснение: Запускаем все процессы сразу, затем последовательно читаем вывод. Это позволяет экономить время на ожидании каждого процесса по очереди.

Взаимодействие с интерактивной программой (например, bash)

Можно организовать диалог с оболочкой: отправлять команды и получать ответы.

$descriptorspec = [
    0 => ['pipe', 'r'],
    1 => ['pipe', 'w'],
    2 => ['pipe', 'w']
];

$process = proc_open('/bin/bash', $descriptorspec, $pipes);

if (is_resource($process)) {
    fwrite($pipes[0], "echo 'Привет, мир!'\n");
    fwrite($pipes[0], "ls -d /home/*\n");
    fwrite($pipes[0], "exit\n");
    fclose($pipes[0]);

    $output = stream_get_contents($pipes[1]);
    fclose($pipes[1]);
    $errors = stream_get_contents($pipes[2]);
    fclose($pipes[2]);
    proc_close($process);

    echo "Вывод bash:\n$output";
    if ($errors) echo "Ошибки:\n$errors";
}

Вывод bash:
Привет, мир!
/home/user  /home/guest

Важно: при работе с интерактивными программами нужно учитывать, что они могут ждать ввода после каждой команды. В примере команды отправлены одной пачкой, затем закрыт stdin, и bash завершится после exit.

Использование псевдотерминала (pty) для программ, требующих tty

Некоторые программы (например, ssh, sudo) требуют наличия терминала. Используем дескриптор 'pty'.

$descriptorspec = [
    0 => ['pty'],
    1 => ['pty'],
    2 => ['pty']
];

$process = proc_open('ssh user@localhost', $descriptorspec, $pipes);
if (is_resource($process)) {
    // ждём приглашение
    sleep(1);
    fwrite($pipes[0], "password\n");
    fwrite($pipes[0], "whoami\n");
    fwrite($pipes[0], "exit\n");
    fclose($pipes[0]);
    $output = stream_get_contents($pipes[1]);
    fclose($pipes[1]);
    proc_close($process);
    echo $output;
}

Обратите внимание: при использовании pty все потоки (stdin, stdout, stderr) объединяются в один терминальный поток, поэтому читать надо только из pipes[1] (или pipes[0] в зависимости от реализации).

Обработка таймаута и принудительное завершение процесса

Если команда выполняется слишком долго, нужно остановить её принудительно.

$descriptorspec = [
    0 => ['pipe', 'r'],
    1 => ['pipe', 'w'],
    2 => ['pipe', 'w']
];
$process = proc_open('ping -c 100 google.com', $descriptorspec, $pipes);

$timeout = 5;
$start = time();
$output = '';

while (true) {
    $r = [$pipes[1]];
    $w = null;
    $e = null;
    $tv_sec = 0;
    $tv_usec = 500000; // 0.5 сек
    if (@stream_select($r, $w, $e, $tv_sec, $tv_usec) === false) {
        break;
    }
    if ($r) {
        $output .= fread($pipes[1], 8192);
    }
    if (feof($pipes[1])) break;
    if (time() - $start > $timeout) {
        proc_terminate($process, 9); // SIGKILL
        echo "Процесс прерван по таймауту.\n";
        break;
    }
}
fclose($pipes[1]);
fclose($pipes[2]);
proc_close($process);
echo $output;

Использование proc_open с временными файлами для больших объёмов данных

Если нужно передать много данных, лучше использовать файлы вместо pipe, чтобы избежать переполнения буфера.

$tempFile = tempnam(sys_get_temp_dir(), 'proc');
file_put_contents($tempFile, "много данных...");

$descriptorspec = [
    0 => ['file', $tempFile, 'r'],
    1 => ['pipe', 'w'],
    2 => ['pipe', 'w']
];
$process = proc_open('wc -l', $descriptorspec, $pipes);
if (is_resource($process)) {
    $stdout = stream_get_contents($pipes[1]);
    fclose($pipes[1]);
    fclose($pipes[2]);
    proc_close($process);
    echo "Количество строк в переданных данных: $stdout";
}
unlink($tempFile);

Получение статуса процесса с помощью proc_get_status в цикле

Для отслеживания длительного процесса можно опрашивать его статус.

$process = proc_open('sleep 3', $descriptorspec, $pipes);
fclose($pipes[0]);
$running = true;
while ($running) {
    $status = proc_get_status($process);
    $running = $status['running'];
    if ($running) {
        echo "Процесс ещё работает...\n";
        sleep(1);
    }
}
echo "Завершён с кодом: " . $status['exitcode'];
proc_close($process);

Процесс ещё работает...
Процесс ещё работает...
Процесс ещё работает...
Завершён с кодом: 0