如何为多用户运行PHP脚本？PHP7.2批量执行用户脚本方案咨询

针对你的情况——单用户脚本耗时30-60秒、需要每5分钟为所有用户执行一次、不想让总运行时间过长且不想折腾复杂扩展，我推荐几个实用的方案：

方案1：Cron + 后台进程分发（最简单易实现） #

这个方案不需要额外安装服务，完全基于现有环境就能搞定：

1. 先修改你的example.php，让它可以通过命令行参数接收用户ID，比如：

// example.php
// 从命令行获取用户ID（注意：要做好参数校验，避免安全问题）
$userId = isset($argv[1]) ? (int)$argv[1] : die("缺少用户ID参数");
// 原来的单用户逻辑，用$userId代替硬编码的用户ID即可

2. 写一个分发脚本dispatch_users.php，负责遍历用户表，为每个用户启动后台进程：

// dispatch_users.php
// 连接数据库，获取所有需要处理的用户ID列表
$db = new PDO('mysql:host=localhost;dbname=your_db', 'user', 'password');
$users = $db->query("SELECT id FROM users")->fetchAll(PDO::FETCH_COLUMN);

foreach ($users as $userId) {
    // 后台启动单个用户的脚本，避免阻塞当前进程
    // > /dev/null 2>&1 & 表示把输出扔到黑洞，且后台运行
    exec("php /path/to/example.php {$userId} > /dev/null 2>&1 &");
}

3. 设置Cron，每5分钟调用这个分发脚本：

*/5 * * * * php /path/to/dispatch_users.php

优点：实现简单，不需要额外依赖；分发脚本瞬间完成，不会超时；每个用户的进程独立运行。
注意点：如果用户数量特别多（比如几百上千），建议限制并发数，比如每启动10个进程就sleep几秒，避免服务器负载过高。

方案2：消息队列 + 消费者进程（更可控、适合大用户量） #

如果你的用户数量较多，或者希望更可控地处理任务（比如失败重试、并发数限制），可以用消息队列：

1. 安装轻量的Redis消息队列（大部分服务器都支持，安装配置简单）。
2. 写一个enqueue_users.php脚本，负责把所有用户ID推送到Redis队列：

// enqueue_users.php
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

$db = new PDO('mysql:host=localhost;dbname=your_db', 'user', 'password');
$users = $db->query("SELECT id FROM users")->fetchAll(PDO::FETCH_COLUMN);
foreach ($users as $userId) {
    $redis->lPush('user_process_tasks', $userId);
}

3. 写一个消费者脚本consumer.php，负责从队列里取任务并执行：

// consumer.php
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

while (true) {
    // 阻塞式获取队列任务，没有任务时会等待，不会空循环浪费资源
    $task = $redis->brPop('user_process_tasks', 0);
    $userId = $task[1];
    // 执行单用户脚本逻辑，或者直接调用example.php
    exec("php /path/to/example.php {$userId}");
}

4. 设置Cron每5分钟调用enqueue_users.php，然后用Supervisor管理consumer.php进程（确保它一直运行，即使崩溃也会自动重启）。

优点：可以灵活控制并发消费者数量（比如启动3-5个consumer进程）；任务失败可以重新入队；不会一下子启动大量进程导致服务器负载过高。
注意点：需要安装Redis和Supervisor，但配置步骤都比较简单，网上有很多现成的教程。

方案3：PCNTL扩展创建子进程（适合CLI模式，需注意进程管理） #

如果你的服务器允许使用PCNTL扩展（PHP CLI模式下支持），可以用它创建子进程来处理用户任务：

1. 修改分发脚本，用pcntl_fork创建子进程：

// dispatch_fork.php
$db = new PDO('mysql:host=localhost;dbname=your_db', 'user', 'password');
$users = $db->query("SELECT id FROM users")->fetchAll(PDO::FETCH_COLUMN);
$maxChildren = 5; // 限制最大并发子进程数
$children = [];

foreach ($users as $userId) {
    // 如果子进程数量达到上限，等待任意子进程结束
    while (count($children) >= $maxChildren) {
        $pid = pcntl_wait($status);
        unset($children[array_search($pid, $children)]);
    }

    $pid = pcntl_fork();
    if ($pid == -1) {
        die("无法创建子进程");
    } elseif ($pid == 0) {
        // 子进程：执行单用户逻辑
        include '/path/to/example.php'; // 直接包含脚本执行，或者调用外部命令
        exit(0);
    } else {
        // 父进程：记录子进程ID
        $children[] = $pid;
    }
}

// 等待所有子进程结束
foreach ($children as $pid) {
    pcntl_waitpid($pid, $status);
}

2. 设置Cron每5分钟调用这个脚本即可。

优点：不需要额外依赖，进程管理更精细；可以控制并发数。
注意点：必须在CLI模式下运行，Web环境不支持PCNTL；需要注意进程资源的释放，避免内存泄漏。

综合来看，方案1是最适合你的初始选择，因为它不需要额外安装任何东西，实现成本最低，完全适配你现有的PHP7.2环境和Cron配置。如果后续用户量增大，再考虑切换到方案2。

内容的提问来源于stack exchange，提问作者Fabian Ortner