PHP实现常驻进程平滑关闭与重启的PCNTL信号处理方案

慢慢来

发布时间：2026-10-15| 6人浏览过

原创

在使用 PHP 编写 CLI 常驻进程时，直接终止进程可能导致正在进行的业务逻辑中断或资源未正常释放。本文介绍基于 pcntl 扩展的信号处理机制，通过阻塞信号、注册处理器及适时分发的方法，实现进程的业务级平滑关闭与重启。

原理解析：从强制中断到优雅退出

实现平滑关闭的核心在于控制操作系统发送给进程的信号处理方式。默认情况下，当收到 SIGTERM（kill命令默认发送）或 SIGINT（Ctrl+C）等信号时，进程会立即停止执行。对于需要保证原子性的操作（如数据库事务），这种中断是危险的。

第一步：阻塞信号以保护临界区

使用 pcntl_sigprocmask() 可以暂时将特定信号加入阻塞队列，使其不会打断当前代码的执行，直到显式解除阻塞。这确保了即使外部发出终止指令，当前耗时任务也能完整执行完毕。

<?php
// 定义需要阻塞的信号集合
$sig_set = array(SIGINT, SIGTERM);

// 阻塞信号：在事务执行期间忽略终止请求
pcntl_sigprocmask(SIG_BLOCK, $sig_set);

echo date("[Y-m-d H:i:s]") . " 开始执行核心任务" . PHP_EOL;

// 模拟耗时操作
$finish_time = time() + 5;
while (time() < $finish_time) {
    // 此处执行真实业务逻辑，不受信号影响
}

echo date("[Y-m-d H:i:s]") . " 任务执行完毕" . PHP_EOL;

// 解除阻塞：允许排队中的信号生效
pcntl_sigprocmask(SIG_UNBLOCK, $sig_set);
?>

执行上述代码时，若在运行过程中按下 Ctrl+C 或执行 kill，程序仍会继续运行直至结束，体现了阻塞机制的保护作用。

第二步：注册信号处理器以响应退出

仅仅阻塞信号会导致进程无法正常退出。我们需要使用 pcntl_signal() 注册回调函数，并配合 pcntl_signal_dispatch() 来实际触发这些回调。关键点在于：pcntl_signal_dispatch() 必须在信号发生后调用才会有效，且通常在任务间隙（解除阻塞后）调用。

注意：如果业务逻辑存在无限死循环，信号分发机制可能无法及时介入，导致进程无法退出。

<?php
$sig_handler = function ($signo) {
    echo "收到信号 {$signo}，准备退出..." . PHP_EOL;
};

// 为多个信号注册处理器
foreach (array(SIGINT, SIGTERM) as $sig) {
    pcntl_signal($sig, $sig_handler);
}

// 模拟一段耗时工作
$finish_time = time() + 5;
while(true) {
    if (time() > $finish_time) {
        echo "事务执行完毕" . PHP_EOL;
        break;
    }
}

// 手动分发等待中的信号
// 若此处不调用，注册的 sig_handler 不会被执行
pcntl_signal_dispatch(); 
?>

整合框架：构建平滑关闭的常驻进程

将上述概念结合，即可构建一个支持平滑关闭的标准框架。其核心模式是：在循环内执行任务前阻塞信号 → 执行业务逻辑 → 解除阻塞 → 分发信号。

初始化状态变量：设置 $running 标志位，供信号处理器修改。
注册信号处理器：统一处理多种退出信号，将 $running 设为 false。
主循环控制：基于 $running 判断是否继续运行。

<?php
$running = true;

// 1. 定义信号处理器
$sig_handler = function ($signo) use (&$running) {
    echo "[Signal] 收到 {$signo}，标记退出状态" . PHP_EOL;
    // 不再做复杂清理，仅标记状态
    $running = false;
};

// 2. 注册信号 (包括常用的 USR2)
$sig_set = array(SIGINT, SIGTERM, SIGUSR2);
foreach ($sig_set as $sig) {
    pcntl_signal($sig, $sig_handler);
}

// 3. 主循环
while ($running) {
    // 3-1. 阻塞信号，确保接下来的任务不被强行中断
    pcntl_sigprocmask(SIG_BLOCK, $sig_set);

    try {
        // --- 插入业务逻辑 ---
        sleep(1); // 示例：模拟一次任务处理
        // -------------------
    } catch (Exception $e) {
        echo "Error: " . $e->getMessage() . PHP_EOL;
    }

    // 3-2. 解除阻塞
    pcntl_sigprocmask(SIG_UNBLOCK, $sig_set);
    
    // 3-3. 分发信号
    // 此时如果之前收到了 SIGTERM，处理器会被调用，将 $running 设为 false
    pcntl_signal_dispatch();
}

echo "进程已安全退出" . PHP_EOL;
?>