PHP长运行脚本的动态更新与状态管理：无需物理重启的策略

<?php
// WorkerService.php
// 假设这个文件定义了你的核心业务逻辑
class WorkerService
{
    private $initializedTime;

    public function __construct()
    {
        $this->initializedTime = date('Y-m-d H:i:s');
        echo "WorkerService initialized at " . $this->initializedTime . " (PID: " . getmypid() . ")\n";
    }

    public function processTask(string $taskData)
    {
        // 核心业务逻辑
        echo "WorkerService (Initialized: " . $this->initializedTime . ") processing task: " . $taskData . "\n";
        // 模拟一些耗时操作
        sleep(1);
    }

    public function shutdown()
    {
        echo "WorkerService shutting down. (Initialized: " . $this->initializedTime . ")\n";
        // 清理资源，例如关闭数据库连接
    }
}

// main_script.php (你的长运行脚本)
require_once 'WorkerService.php'; // 确保 WorkerService 类定义被加载一次

$currentWorker = null;
$lastWorkerFileModifiedTime = 0;
$updateSignalFile = 'update_worker_signal.txt'; // 触发更新的信号文件

while (true) {
    $workerFileModifiedTime = filemtime('WorkerService.php');
    $updateRequired = file_exists($updateSignalFile);

    // 检查 WorkerService.php 文件是否被修改，或者是否存在更新信号
    if ($currentWorker === null || $workerFileModifiedTime > $lastWorkerFileModifiedTime || $updateRequired) {
        echo "Detected WorkerService update or signal. Re-instantiating...\n";

        // 如果存在旧的 Worker 实例，先进行清理
        if ($currentWorker !== null) {
            $currentWorker->shutdown();
            unset($currentWorker);
        }

        // 重新创建 WorkerService 实例
        // 注意：这里只是重新实例化了对象，而不是重新加载类定义。
        // 如果 WorkerService.php 中的类定义本身发生了变化，这种方法是无效的。
        // 真正的类定义更新需要进程重启。
        // 此处主要用于重置 WorkerService 实例内部的状态。
        $currentWorker = new WorkerService();
        $lastWorkerFileModifiedTime = $workerFileModifiedTime;

        if ($updateRequired) {
            unlink($updateSignalFile); // 清除信号文件
        }
    }

    if ($currentWorker !== null) {
        $currentWorker->processTask("Some incoming data at " . date('H:i:s'));
    }

    sleep(2); // 模拟主循环间隔
}
?>

<?php
// config.json
// {
//     "feature_enabled": true,
//     "processing_limit": 100,
//     "message": "Hello from config!"
// }

// main_script_config_driven.php
$configFilePath = 'config.json';
$currentConfig = [];
$lastConfigFileModifiedTime = 0;

function loadConfig(string $path): array
{
    if (!file_exists($path)) {
        return [];
    }
    return json_decode(file_get_contents($path), true) ?? [];
}

while (true) {
    $configFileModifiedTime = filemtime($configFilePath);

    if ($configFileModifiedTime > $lastConfigFileModifiedTime) {
        echo "Config file updated. Reloading...\n";
        $currentConfig = loadConfig($configFilePath);
        $lastConfigFileModifiedTime = $configFileModifiedTime;
        print_r($currentConfig);
    }

    // 根据配置执行逻辑
    if (($currentConfig['feature_enabled'] ?? false)) {
        echo "Feature is enabled. Message: " . ($currentConfig['message'] ?? 'N/A') . "\n";
        // 模拟处理一些数据，受 processing_limit 限制
        for ($i = 0; $i < ($currentConfig['processing_limit'] ?? 10); $i++) {
            // ...
        }
    } else {
        echo "Feature is disabled.\n";
    }

    sleep(3);
}
?>