告别手动重启！如何用supervisorphp/supervisor优雅管理PHP后台进程

composer require supervisorphp/supervisor

composer require guzzlehttp/guzzle:^7.0

<?php

require 'vendor/autoload.php'; // 引入 Composer 自动加载

use GuzzleHttp\Client;
use GuzzleHttp\Psr7\HttpFactory;
use fXmlRpc\Client as XmlRpcClient;
use fXmlRpc\Transport\PsrTransport;
use Supervisor\Supervisor;
use Supervisor\Exception\Fault\BadNameException;
use Supervisor\Exception\SupervisorException;

// 假设你的 Supervisor XML-RPC 接口运行在 127.0.0.1:9001
// 并且配置了用户名为 'user'，密码为 '123'
$supervisorUrl = 'http://127.0.0.1:9001/RPC2';

try {
    // 1. 创建 Guzzle HTTP 客户端
    // 如果 Supervisor 配置了认证，可以在这里传入用户名和密码
    $guzzleClient = new Client([
        'auth' => ['user', '123'], // 替换为你的 Supervisor 用户名和密码
        // 如果通过 Unix Domain Socket 连接，可以这样配置：
        // 'curl' => [
        //     CURLOPT_UNIX_SOCKET_PATH => '/var/run/supervisor.sock', // 替换为你的 socket 路径
        // ],
    ]);

    // 2. 创建 fXmlRpc 客户端
    // fXmlRpc 客户端需要一个 PSR-7 HttpFactory 和一个 PSR-18 HTTP 客户端
    $xmlRpcClient = new XmlRpcClient(
        $supervisorUrl,
        new PsrTransport(
            new HttpFactory(), // PSR-7 HttpFactory 实现
            $guzzleClient
        )
    );

    // 3. 实例化 Supervisor 对象
    $supervisor = new Supervisor($xmlRpcClient);

    // 示例操作：

    // 获取所有进程信息
    echo "--- 所有进程信息 ---\n";
    $allProcesses = $supervisor->getAllProcessInfo();
    foreach ($allProcesses as $processInfo) {
        echo "进程名称: {$processInfo['name']}, 状态: {$processInfo['statename']}\n";
    }

    // 假设我们有一个名为 'my_php_worker' 的进程
    $processName = 'my_php_worker';

    // 检查特定进程是否正在运行
    if ($supervisor->getProcessInfo($processName)['state'] === Supervisor::RUNNING) {
        echo "\n进程 '{$processName}' 正在运行。\n";
        // 尝试停止进程
        echo "尝试停止进程 '{$processName}'...\n";
        $supervisor->stopProcess($processName);
        echo "进程 '{$processName}' 已停止。\n";
    } else {
        echo "\n进程 '{$processName}' 未运行。\n";
    }

    // 再次检查状态
    echo "停止后，进程 '{$processName}' 的状态: {$supervisor->getProcessInfo($processName)['statename']}\n";

    // 启动进程
    echo "尝试启动进程 '{$processName}'...\n";
    // 第二个参数为 false 表示不等待进程启动完成，立即返回
    $supervisor->startProcess($processName, false);
    echo "进程 '{$processName}' 已启动（或正在启动中）。\n";

    // 获取进程对象并进行操作
    $process = $supervisor->getProcess($processName);
    if ($process->isRunning()) {
        echo "通过进程对象确认，'{$processName}' 正在运行。\n";
    }

} catch (BadNameException $e) {
    echo "错误：进程名称 '{$processName}' 不存在或不正确。\n";
} catch (SupervisorException $e) {
    echo "Supervisor 错误：{$e->getMessage()}\n";
} catch (\Exception $e) {
    echo "未知错误：{$e->getMessage()}\n";
}

// 注意：如果你使用了 PHP 的 XML-RPC 扩展（通常标记为 EXPERIMENTAL），
// 并且在处理进程日志时遇到问题，可能需要清理日志消息，因为该扩展有时对非标准 XML-RPC 响应不兼容。
// 通常情况下，使用 fXmlRpc 配合 Guzzle 这种方式不会有此问题。