PHP与后台进程控制：实现动态可调任务的策略

<?php
// web_controller.php
// 这是一个Web可访问的PHP脚本，用于接收并设置后台进程的定时参数

// 确保只接受GET请求，并检查'req'参数是否存在
if ($_SERVER['REQUEST_METHOD'] === 'GET' && isset($_GET['req'])) {
    $timing_ms = (int)$_GET['req']; // 将参数转换为整数

    // 验证参数有效性
    if ($timing_ms >= 0) {
        // 将参数写入一个配置文件
        // 在生产环境中，推荐使用数据库、Redis或其他消息队列来存储配置
        $config_file = 'timing_config.txt';
        if (file_put_contents($config_file, $timing_ms) !== false) {
            echo "Timing set to {$timing_ms} ms. Background process will adjust.\n";
        } else {
            http_response_code(500);
            echo "Error: Could not write configuration file.\n";
        }
    } else {
        http_response_code(400);
        echo "Error: Invalid 'req' parameter. Must be a non-negative integer.\n";
    }
} else {
    http_response_code(400);
    echo "Usage: web_controller.php?req=VALUE (VALUE is timing in milliseconds)\n";
}
?>

<?php
// background_worker.php (这是一个命令行脚本，由Cron Job管理)

// 确保脚本在CLI环境下运行
if (php_sapi_name() !== 'cli') {
    die("This script can only be run from the command line.\n");
}

echo "Background worker started.\n";

$counter = 0;
$config_file = 'timing_config.txt';

// 函数：从配置文件中获取当前定时参数
function getTimingConfig($file) {
    if (file_exists($file)) {
        $value = (int)file_get_contents($file);
        return ($value >= 0) ? $value : 1000; // 确保返回非负值，否则默认1秒
    }
    return 1000; // 默认1秒
}

while (true) {
    $current_timing_ms = getTimingConfig($config_file);

    // 如果配置为0，则作为退出信号
    if ($current_timing_ms === 0) {
        echo "Timing set to 0. Exiting worker.\n";
        break;
    }

    // 执行核心任务
    // 这里可以是你需要执行的任何后台逻辑
    echo "[" . date('Y-m-d H:i:s.v') . "] Counter: " . (++$counter) . " - Working with timing: {$current_timing_ms} ms\n";

    // 使用 usleep 实现微秒级等待，以达到指定的毫秒精度
    // usleep 参数是微秒 (1ms = 1000us)
    usleep($current_timing_ms * 1000);

    // 为了避免在极短的循环中频繁读取文件造成的I/O开销，
    // 可以在这里加入一个条件判断，例如每隔N次循环或N秒才重新读取配置。
    // 但为了演示“实时调整”，我们每次循环都读取。
    // 对于非常高的频率（如10ms），文件I/O可能会成为瓶颈，
    // 此时更推荐使用共享内存、Redis或更