onpipemessage在swoole的swoole_process模式下，当工作进程调用sendmessage或通过管道向其他进程发送数据时触发，接收进程执行回调处理消息，用于worker间通信、task传递结果等场景。

Swoole的onPipeMessage事件用于处理工作进程向其他进程发送消息时触发的回调。它主要在多进程模式下使用，当一个工作进程通过管道（pipe）向另一个进程发送数据时，接收进程会收到该消息并触发onPipeMessage事件。

Swoole 6.1.1

Swoole 6.1.1 是一个专为 PHP 设计的高性能事件驱动并发网络引擎。作为稳定版，它修复了编译时对 zlib 依赖的缺失及 curl 模块的内存安全风险。该版本支持协程、多线程与多进程架构，内置 TCP/HTTP/WebSocket 服务器，能够显著提升 PHP 在微服务、实时通信等场景下的执行效率与并发能力。

下载

什么时候会触发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进程间通信的重要组成部分，适合用于解耦任务处理、状态同步等场景。