onPipeMessage在Swoole的SWOOLE_PROCESS模式下,当工作进程调用sendMessage或通过管道向其他进程发送数据时触发,接收进程执行回调处理消息,用于Worker间通信、Task传递结果等场景。

Swoole的onPipeMessage事件用于处理工作进程向其他进程发送消息时触发的回调。它主要在多进程模式下使用,当一个工作进程通过管道(pipe)向另一个进程发送数据时,接收进程会收到该消息并触发onPipeMessage事件。
什么时候会触发onPipeMessage?
当一个Swoole进程调用$worker->sendMessage()或通过管道主动写入数据到其他进程时,目标进程如果设置了onPipeMessage回调,就会执行这个函数。
常见于以下场景:
- Worker进程之间需要通信
- Task进程向Worker进程传递任务结果
- 自定义进程与其他进程交换数据
onPipeMessage的参数说明
回调函数接收两个参数:- $worker:接收消息的Worker对象,可以获取该进程的信息,如$worker->id
- $message:发送过来的数据内容,可以是字符串或序列化后的数据
$server->on('PipeMessage', function($worker, $message) {
echo "来自进程 {$worker->id} 的消息:{$message}\n";
});
如何发送消息触发该事件?
使用Swoole提供的进程方法发送消息:-
$worker->sendMessage('hello');—— 发送消息给特定worker -
$process->write();配合管道读取也可实现,但需手动管理










