消息 dispatch 后未异步执行,大概率是 routing 键错误:必须严格匹配消息类全名(如 App\Message\SendEmailNotification),大小写、命名空间、反斜杠均需一致,且不能用处理器类名或目录结构推测。

消息 dispatch 后没走异步,大概率是 routing 键写错了——它必须是你 new 出来的那个消息类全名,不是处理器类名,也不是命名空间前缀。
routing 配置必须用消息类名,不是处理器类名
常见错误是把 'App\MessageHandler\SendEmailNotificationHandler': async 这种写进 messenger.yaml。Messenger 路由匹配只看 dispatch 的对象类型,和 handler 完全无关。
-
routing的 key 必须和你传给$this->messenger->send()的实例类完全一致,比如App\Message\SendEmailNotification - 类名大小写、命名空间、反斜杠方向都要严格匹配(PHP 是大小写敏感的)
- 如果类在
src/Message/下但命名空间是App\Messages,那路由也得写App\Messages\...,不能靠目录结构猜 - 运行
php bin/console debug:messenger,检查输出里transport列是否明确显示async;如果是空或sync,说明没命中任何路由规则
消息对象里别塞 Doctrine 实体、闭包或 resource
序列化失败是消费者崩溃最隐蔽的原因之一。Messenger 会把消息对象序列化后存进 Redis/DB,再反序列化交给 handler。任何不可序列化的值都会导致失败且无明显报错。
- 只允许传原始类型:字符串、数字、布尔、数组、
DateTimeInterface实例 - 禁止直接传
$user实体对象,应改为传$user->getId(),handler 内再查库:$this->userRepository->find($message->getUserId()) -
stdClass、Closure、resource、未定义的私有属性(没 getter/setter)、__sleep()返回非法字段——全部会触发SerializationException - 用
php bin/console messenger:consume async --limit=1 --verbose测试单条,能快速暴露序列化问题
transport DSN 和消费者命令要对得上
配置了 async: redis://...,但运行 messenger:consume 时没指定 transport 名,就会默认消费 default 或 fallback 到 sync。
立即学习“PHP免费学习笔记(深入)”;
-
messenger.yaml里定义的 transport 名(如async)必须和 consume 命令参数一致:php bin/console messenger:consume async - DSN 中的路径部分(如
redis://localhost:6379/messages)会影响队列名,多个项目共用 Redis 时容易串队,建议加项目前缀:redis://localhost:6379/myapp_messages - AMQP 场景下,
amqp://DSN 的 vhost(如%2f)和 queue name 必须和 RabbitMQ 服务端实际创建的一致,否则 consumer 启动就报ChannelException - 本地开发用
doctrine://default时,确保doctrine.dbal已配好,且表messenger_messages已通过php bin/console doctrine:schema:update --force创建
别在 handler 构造函数里做重操作或依赖未初始化服务
Handler 实例是每次消费消息时 new 出来的,构造函数执行频率极高。这里卡住,整个 consumer 就会假死。
- 避免在
__construct()里调用外部 API、查大表、加载大文件 - 不要在构造函数里调用
$this->entityManager->clear()或其他可能触发 flush 的操作 - 依赖注入的服务本身没问题,但若该服务在构造时做了 heavy 初始化(比如预热缓存),就要重构——把初始化逻辑移到
__invoke()或单独方法里 - Consumer 进程长驻内存,所有静态变量、全局状态、未关闭的 PDO 连接都可能累积泄漏,handler 内尽量保持无状态
最常被跳过的一步:没确认 transport 是否真被启用。哪怕 routing 写对了,transport DSN 语法错一个字符(比如漏了 redis:// 的双斜杠),debug:messenger 仍会显示 transport 存在,但实际投递时静默 fallback 到 sync。务必用 --verbose 模式跑一次 consume 看真实日志。



















