信息发布→ 登录 注册 退出

Swoole的onPipeMessage事件是做什么的

发布时间:2025-10-05

点击量:
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(); 配合管道读取也可实现,但需手动管理
注意:只有在work_mode为SWOOLE_PROCESS时,进程间通信才会走管道机制,onPipeMessage才有效。 基本上就这些。onPipeMessage是Swoole进程间通信的重要组成部分,适合用于解耦任务处理、状态同步等场景。
标签:# 回调函数  # swoole  # 字符串  # 对象  # 事件  # 回调  # 发送消息  # 就会  # 什么时候  # 模式下  # 才会  # 也可  # 自定义  # 组成部分  # 与其他  
在线客服
服务热线

服务热线

4008888355

微信咨询
二维码
返回顶部
×二维码

截屏,微信识别二维码

打开微信

微信号已复制,请打开微信添加咨询详情!