实时调整workerman协程池大小需启用swoole/swow/fiber驱动并保留pool实例引用;可通过http端点、负载自动调节或sigusr2信号三种方式动态resize,不重启、不断连、不丢任务。

要在运行中的 Workerman 服务里实时调整协程池大小,不重启、不中断连接、不丢任务,关键不是改 $worker->count,而是通过事件循环驱动层的动态 resize 机制触发 worker 进程内协程调度器的扩缩容动作——这要求你已启用 Swoole/Swow/Fiber 任一协程驱动,并在进程启动后保留对 Pool 实例的引用。
确认协程驱动已激活并获取 Pool 实例
检查 config/process.php 中目标进程的 eventLoop 是否明确设为 Workerman\Events\Swoole::class(或 Swow/Fiber),空字符串或 Select 表示未开启协程;【未开启协程驱动时调用 resize 将静默失败】。
在 Worker 启动回调中保存协程池引用,例如使用 workerman/pool 组件或自定义 Pool 类:
$pool = new \Workerman\Utils\Pool(function () { return new \Redis(); }, ['maxSize' => 10]);
将 $pool 存入全局变量、静态属性或 DI 容器,确保后续 resize 调用能访问到同一实例。
方法一:通过 HTTP 管理端点触发 resize
在控制器中新增一个管理路由,例如 /admin/pool/resize?size=16:
解析 URL 参数 size 并转为整数,若小于 1 则强制设为 1;
调用 $pool->resize((int)$size) —— 此方法会立即生效,新任务按新大小分配,已有连接不受影响;
返回 JSON:{ "status": "ok", "current_size": 16 }。
方法二:基于 CPU 或队列积压自动调节
第一步:启动一个独立协程,每 5 秒采集一次指标:
Coroutine::create(function () use ($pool) { while (true) { Timer::sleep(5); $load = sys_getloadavg()[0]; $pending = $pool->getPendingCount(); if ($load > 3.0 && $pool->getSize() resize($pool->getSize() + 4); } else if ($load getSize() > 8 && $pending === 0) { $pool->resize($pool->getSize() - 2); } } });
第二步:确保该协程只在主 Worker 进程中运行(加 if (Worker::$pid === Worker::$masterPid) 判断);
注意:resize 是幂等操作,多次调用相同 size 不会重复创建或销毁资源。
方法三:监听信号实现热重载式调整
在 Worker 启动后注册 SIGUSR2 信号处理器:
pcntl_signal(SIGUSR2, function ($sig) use ($pool) { $newSize = (int)file_get_contents('/tmp/workerman_pool_size'); $pool->resize(max(2, $newSize)); });
向主进程发送信号:kill -USR2 $(cat /var/run/workerman.pid);
提前写好目标大小到文件:echo 24 > /tmp/workerman_pool_size。











