🔥码云GVP开源项目 12k star Uniapp+ElementUI 功能强大 支持多语言、二开方便! 广告
# Process\\Pool->on [TOC] 设置进程池回调函数。 ~~~ function Process\Pool::on(string $event, callable $function); ~~~ ## 子进程启动 `onWorkerStart`回调函数,接受`2`个参数: 1. `Pool`对象 2. `WorkerId`当前工作进程的编号,底层会对子进程进行标号,范围是`[0-$worker_num)` ~~~ function onWorkerStart(Swoole\Process\Pool $pool, int $workerId) { echo "Worker#{$workerId} is started\n"; } ~~~ ## 子进程结束 `onWorkerStop`回调函数,与`onWorkerStart`参数一致。 ## 消息接收 `onMessage`回调函数,收到外部投递的消息。 一次连接只能投递一次消息, 类似于php-fpm的短连接机制. 1. `Pool`对象 2. 消息数据内容 ~~~ function onMessage(Swoole\Process\Pool $pool, string $data) { var_dump($data); } ~~~