Process\Pool->on
最后更新于:2022-04-02 06:35:59
# 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);
}
~~~
';