Контроль выполнения PHP кода в реальном времени

Дополнительные расширенные примеры

Пример 1. Обработка сигналов для корректного снятия блокировки

При использовании файловой блокировки важно освобождать ресурс даже при получении сигнала завершения. В PHP можно задать обработчики для SIGTERM и SIGINT.

$lockFile = '/tmp/my_daemon.lock';
$fp = fopen($lockFile, 'c');
if (!flock($fp, LOCK_EX | LOCK_NB)) {
    exit("Процесс уже запущен\n");
}

declare(ticks = 1);
pcntl_signal(SIGTERM, function() use ($fp, $lockFile) {
    flock($fp, LOCK_UN);
    fclose($fp);
    @unlink($lockFile);
    exit("Принудительное завершение\n");
});
pcntl_signal(SIGINT, function() use ($fp, $lockFile) {
    flock($fp, LOCK_UN);
    fclose($fp);
    @unlink($lockFile);
    exit("Завершение по Ctrl+C\n");
});

echo "Работа запущена, PID=" . getmypid() . "\n";
sleep(300); // имитация долгой работы

flock($fp, LOCK_UN);
fclose($fp);
@unlink($lockFile);
echo "Работа завершена\n";

Результат выполнения (при преждевременном завершении сигналом SIGTERM):

Работа запущена, PID=12345
Принудительное завершение

При этом файл .lock удаляется. Без обработчиков скрипт оставит файл, и следующий запуск будет невозможен.

Пример 2. Использование shared memory (shmop) для уведомления о статусе

Для межпроцессного взаимодействия без файлов можно использовать разделяемую память. В PHP функции shmop позволяют записывать и читать данные, которые видны всем процессам.

$shmKey = ftok(__FILE__, 't');
$shmId = shmop_open($shmKey, 'c', 0644, 1);
if (!$shmId) {
    exit("Не удалось создать сегмент памяти\n");
}

// Пытаемся установить значение 1 (занято) с помощью атомарной операции
$current = shmop_read($shmId, 0, 1);
if ($current === "1") {
    shmop_close($shmId);
    exit("Скрипт уже выполняется\n");
} else {
    shmop_write($shmId, "1", 0);
    shmop_close($shmId);
}

register_shutdown_function(function() use ($shmKey) {
    $shmId = shmop_open($shmKey, 'w', 0, 0);
    if ($shmId) {
        shmop_write($shmId, "0", 0);
        shmop_close($shmId);
    }
});

echo "Запуск процесса\n";
sleep(20); // работа

echo "Завершение\n";
// очистка уже выполнена в shutdown

Результат при повторном запуске:

Скрипт уже выполняется

Метод быстр и не создаёт файлов, но требует конфигурации shmop в PHP.

Пример 3. Запуск дочернего скрипта через proc_open и мониторинг его состояния

Иногда нужно запустить PHP скрипт как подпроцесс и отслеживать его жизнедеятельность. Функция proc_open возвращает ресурс, по которому можно проверять статус.

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

$process = proc_open('php child_worker.php', $descriptorspec, $pipes);

if (is_resource($process)) {
    fclose($pipes[0]);
    $status = proc_get_status($process);
    echo "PID: " . $status['running'] ? $status['pid'] : 'unknown' . "\n";

    // Имитация ожидания
    sleep(2);

    $status = proc_get_status($process);
    if ($status['running']) {
        echo "Дочерний процесс ещё выполняется\n";
    } else {
        echo "Дочерний процесс завершён\n";
    }

    proc_close($process);
}

Содержимое child_worker.php:

<?php
sleep(5);
echo "Работа завершена";

Результат:

PID: 23456
Дочерний процесс ещё выполняется

Метод позволяет управлять временем жизни дочернего процесса и перехватывать его вывод.

Пример 4. Комбинированный подход с использованием MySQL и блокировкой строк

Для критических сценариев можно использовать SELECT ... FOR UPDATE в InnoDB, чтобы заблокировать строку статуса на уровне базы данных. Это гарантирует атомарность проверки и обновления.

try {
    $db = new PDO('mysql:host=localhost;dbname=test', 'user', 'pass');
    $db->beginTransaction();

    // Выбираем запись о статусе скрипта с блокировкой строки
    $stmt = $db->prepare('SELECT status FROM script_status WHERE script_id = ? FOR UPDATE');
    $stmt->execute(['my_script']);
    $row = $stmt->fetch();

    if ($row && $row['status'] === 'running') {
        $db->rollBack();
        exit('Скрипт уже выполняется');
    }

    // Устанавливаем статус 'running'
    $update = $db->prepare('INSERT INTO script_status (script_id, status) VALUES (?, \'running\') ON DUPLICATE KEY UPDATE status = \'running\'');
    $update->execute(['my_script']);

    $db->commit();

    // Основная работа
    echo "Начало выполнения\n";
    sleep(30);

    // После завершения сбрасываем статус
    $db->exec("UPDATE script_status SET status = 'finished' WHERE script_id = 'my_script'");

} catch (Exception $e) {
    $db->rollBack();
    exit('Ошибка: ' . $e->getMessage());
}

Результат при одновременном запуске двух экземпляров:

Cкрипт уже выполняется

Этот способ подходит для распределённых систем с поддержкой транзакций.