PHP如何通过观察者模式解耦异步任务分发至Worker进程？

本文共计1056个文字，预计阅读时间需要5分钟。

PHP 本身没有原生的跨进程观察者模式，直接使用 `SplObserver` 和 `SplSubject` 在 Web 请求中通知后台 Worker 是行不通的——这些只在当前进程内存中有效，Worker 进程根本收不到通知。

为什么不能在 PHP Web 层直接 notify() Worker？

Web 请求结束，整个 PHP 进程就销毁了，所有对象、观察者列表、回调函数全部消失。Worker 是另一个独立运行的 CLI 进程（比如通过 supervisord 启动的 php worker.php），它和 Web 进程之间没有共享内存或自动通信通道。

• 常见错误：在控制器里写 $event->notify()，以为 Worker 会响应——实际什么都不会发生
• SplObserver 的通知机制是同步、内存级的，不涉及序列化、网络或持久化
• 即使你把 Observer 实例传给 pcntl_fork() 子进程，子进程也无法继承父进程的事件循环或监听状态

真正可行的解耦路径：用队列代替“通知”

所谓“观察者分发到 Worker”，本质是把「事件触发」和「事件响应」物理分离。可靠做法是：Web 层把事件写入持久化中间件，Worker 主动轮询或阻塞等待消费。

• 推荐首选 Redis 的 LPUSH + BRPOP：轻量、低延迟、支持阻塞读取
• 避免用数据库轮询（如每分钟查 task_queue 表）：实时性差，且高并发下容易产生间隙或重复消费
• 别在 Web 层调用 exec("php worker.php &")：进程难管理，失败无记录，易失控
• 事件数据必须可序列化，建议用 json_encode()，不要传闭包、资源句柄或未定义类实例

如何模拟“观察者语义”但保持跨进程可靠？

你可以保留观察者的设计意图（松耦合、关注点分离），但底层改用队列驱动。例如：

立即学习“PHP免费学习笔记（深入）”；

// Web 层：像发布事件一样“触发”，但实际是入队 $event = new UserRegisteredEvent($userId); EventDispatcher::dispatch($event); // 内部调用 $redis->lPush('events', json_encode([...])) // Worker 层：像监听事件一样“响应”，但实际是消费 while (true) { $packed = $redis->brPop('events', 30); if ($packed) { $data = json_decode($packed[1], true); $handler = new UserRegisteredHandler(); $handler->handle($data); } }

• UserRegisteredEvent 和 UserRegisteredHandler 是纯业务逻辑类，不依赖进程上下文
• EventDispatcher::dispatch() 是个薄封装，屏蔽了 Redis 细节，对外保持“发布”语义
• Worker 必须用 BRPOP 而非 LPOP：避免空轮询浪费 CPU，也防止多个 Worker 竞争时漏消息
• 每个 Handler 应有明确失败策略：比如失败后 LPUSH 回重试队列，或写入 failed_events 表供人工干预

容易被忽略的边界问题

真正上线时，最常出问题的不是“怎么发”，而是“发完之后怎么兜底”。几个硬伤点：

• Redis 连接中断时，dispatch() 失败不能静默吞掉——要 fallback 到本地日志 + 告警，否则事件彻底丢失
• Worker 进程意外退出（如 OOM、未捕获异常），supervisord 虽能拉起，但断连期间的队列消息可能已超时丢弃（尤其用了 BRPOP timeout）
• 同一个事件被多个 Worker 消费（如网络分区导致 Redis 返回重复响应）：Handler 必须幂等，不能假设“只来一次”
• Web 层事务未提交就发事件（比如刚 INSERT 订单还没 COMMIT），Worker 查数据库会查不到数据——必须确保事件发布在事务 提交后 触发（Laravel 可用 DB::transaction() 包裹 + afterCommit 回调）