如何正确使用Swoole进程管理功能

在 Swoole 中有效管理进程，核心目标是避免三大典型问题：僵尸进程堆积、子进程意外退出无人接管，以及主服务停止时子进程残留。要彻底解决这些问题，必须根据具体使用场景区别处理——单进程、自定义进程、进程池和 Task 模块这四类的生命周期管理方式各不相同，混用会引发混乱。

详解单个 Swoole Process 的创建与回收

当直接实例化 SwooleProcess 时，子进程与父进程完全解耦，若不手动回收，子进程会立刻变为僵尸进程。这一点是初学者最容易忽略的陷阱。

操作流程分为以下三个关键步骤：

• 第一步：使用匿名函数定义子进程的执行逻辑。注意：禁止在回调内直接调用 exit() 或 die()，必须使用 $worker->exit() 正确退出。
• 第二步：调用 $process->start() 获取子进程 PID。此时子进程已启动，但若父进程不等待或监听，会立即退出并遗弃子进程，导致僵尸进程产生。
• 第三步：在父进程中调用 swoole_process::wait() 进行阻塞等待——该方法只能回收一个子进程。若需要非阻塞回收，必须配合 pcntl_signal(SIGCHLD, ...) 和 swoole_process::wait(false) 组合使用，实现异步回收。

这步操作看似简单，但若遗漏 signal 注册或 wait 调用，5 秒后即可在 ps aux | grep defunct 中看到僵尸进程，实践经验表明这一点极易被忽视。

将自定义进程接入 Swoole Server 生命周期的方法

当 SwooleHttpServer 或 SwooleWebSocketServer 已存在时，所有后台任务进程必须通过 addProcess() 注入，否则 server->shutdown() 时子进程不会被终止。这是最容易混淆的概念——许多人误以为启动了 Server 就能自动管理所有子进程，实则不然。

方法一：直接传入 SwooleProcess 对象实例

$http = new SwooleHttpServer("0.0.0.0", 9501);
$taskProc = new SwooleProcess(function($proc) {
    while(true) { // 消费消息
        sleep(3);
    }
});
$http->addProcess($taskProc); // 关键：必须走这一步

方法二：使用闭包快捷注册（需要 Swoole ≥ 4.8.0）

$http->addProcess(new SwooleProcess(function($proc) {
    while(true) {
        $proc->write("tick\n");
        sleep(1);
    }
}));

注意：addProcess() 必须在 $http->start() 之前调用，否则进程不会被纳入管理，SIGTERM 信号也无法触达。这个顺序问题在调试时极易被忽略，务必牢记。

使用进程池管理器统一调度多个工作进程

当需要固定数量的常驻子进程，并希望支持自动拉起、信号重启和任务投递时，进程池是更省心的解决方案。典型应用场景包括日志归档、定时清理和消息广播等。

使用流程非常清晰，包含以下步骤：

1. 创建一个 PoolsManager 实例，并指定 worker 数量。
2. 调用 addProcess() 注册每个子进程类，传入完整的命名空间路径。
3. 在子进程类的 run() 方法中编写死循环逻辑——注意禁止使用 sleep(0) 或空耗 CPU，避免资源浪费。
4. 启动后，发送 kill -USR2 $MASTER_PID 命令可触发全部 worker 逐个重启，实现平滑更新。

需要特别警惕的是：进程池与 Swoole Server 的 addProcess() 不兼容，二者不可嵌套使用。如果已经在 HTTP Server 中运行，应改用 TaskWorker 机制替代进程池，以避免冲突。

使用 TaskWorker 实现 I/O 密集型任务异步卸载

当任务本身不消耗 CPU，但需要等待数据库、Redis 或 HTTP 响应时，应优先选择 TaskWorker 而非 Process。原因很简单：协程与 Task 组合更轻量，且具备自动回收机制——你无需关心 PID、管道、信号、wait 等细节，这些全部由 Swoole 底层封装处理。

启用 TaskWorker 的步骤如下：

• 设置 task_worker_num 参数以启用 Task 机制。
• 在 onReceive 或 onMessage 回调中，调用 $server->task($data) 投递任务。
• 在 onTask 回调中执行实际业务逻辑，任务完成后调用 $server->finish($result) 返回结果。

整个过程类似于“把任务扔给后台，有人帮你收尾”，代码编写最为简洁清爽。