PHP长运行脚本状态管理与“软重启”策略

{
  "processing_speed": "normal",
  "log_level": "info",
  "trigger_reset": false
}

<?php
// LogicProcessor.php
class LogicProcessor
{
    private array $config;
    private int $processedCount = 0;

    public function __construct(array $config)
    {
        $this->config = $config;
        echo "LogicProcessor initialized with config: " . json_encode($config) . "\n";
    }

    public function processData(string $data): string
    {
        $this->processedCount++;
        $speed = $this->config['processing_speed'] ?? 'normal';
        $logLevel = $this->config['log_level'] ?? 'info';

        echo sprintf(
            "[%s] Processing data '%s' (Speed: %s, Log: %s). Total processed: %d\n",
            date('H:i:s'), $data, $speed, $logLevel, $this->processedCount
        );

        // Simulate some work based on config
        if ($speed === 'slow') {
            sleep(2);
        } else {
            sleep(1);
        }

        return "Processed: " . $data;
    }

    public function getProcessedCount(): int
    {
        return $this->processedCount;
    }
}

<?php
// main_loop.php
require_once 'LogicProcessor.php'; // 确保LogicProcessor类只被定义一次

function loadConfiguration(string $filePath): array
{
    if (file_exists($filePath)) {
        $content = file_get_contents($filePath);
        $config = json_decode($content, true);
        if (json_last_error() === JSON_ERROR_NONE) {
            return $config;
        } else {
            echo "[WARNING] Failed to decode config file '$filePath'. JSON error: " . json_last_error_msg() . "\n";
        }
    } else {
        echo "[WARNING] Config file '$filePath' not found.\n";
    }
    // Return default configuration if file not found or invalid
    return [
        'processing_speed' => 'normal',
        'log_level' => 'info',
        'trigger_reset' => false
    ];
}

$logicProcessor = null; // 声明在循环外部，以便后续重赋值

echo "PHP Long-Running Script Started.\n";

while (true) {
    echo "\n--- Outer Loop: Starting new 'session' ---\n";

    // 1. 重新加载配置
    $currentConfig = loadConfiguration('my_config.json');
    echo "Loaded Configuration: " . json_encode($currentConfig) . "\n";

    // 2. (重新)实例化核心逻辑处理器
    // 这会创建一个新的对象，其内部状态基于最新的配置重新初始化
    $logicProcessor = new LogicProcessor($currentConfig);

    $innerLoopCounter = 0;
    $shouldReset = false;

    while (true) {
        // 核心业务逻辑处理
        $dataToProcess = "data_item_" . $innerLoopCounter;
        $logicProcessor->processData($dataToProcess);

        // 检查是否需要“软重启”
        // 这里可以根据业务逻辑、外部信号或配置变化来判断
        // 例如，如果配置文件中的 'trigger_reset' 变为 true，则触发重置
        if ($currentConfig['trigger_reset'] === true && $innerLoopCounter >= 2) {
            echo "[INFO] 'trigger_reset' flag is true and condition met. Initiating soft reset...\n";
            $shouldReset = true;
        }

        if ($shouldReset) {
            break; // 跳出内层循环，进入外层循环进行“软重启”
        }

        $innerLoopCounter++;
        // 模拟外部事件或定期检查
        // sleep(1); // 已经在 LogicProcessor::processData() 中模拟了
    }

    // --- 内层循环结束后，执行“软重启”清理操作 ---
    echo "--- Outer Loop: Performing 'soft reset' actions ---\n";

    // 3. 清理不再需要的变量
    // $logicProcessor 会在外层循环的下一次迭代中被新的实例覆盖，旧实例会被垃圾回收
    unset($innerLoopCounter);
    unset($shouldReset);
    // 如果有其他全局变量或静态变量需要清理，在这里进行

    echo "Soft reset complete. Pausing before next full cycle...\n";
    sleep(3); // 暂停一段时间，避免CPU空转，并允许外部修改配置
}