Shopware 6集成RabbitMQ：低优先级/失败消息未处理及DSN错误

你的问题核心是RabbitMQ传输的DSN格式不符合Symfony Messenger要求，导致低优先级和失败队列无法被正确识别，消息只能 fallback 到数据库存储，同时执行messenger:setup-transports时触发DSN不支持的错误。以下是具体修复步骤：

1. 修正.env.local中的DSN格式 #

Symfony AMQP传输的标准DSN格式为：amqp://[用户名]:[密码]@[主机]:[端口]/[虚拟主机编码]?queue_name=[队列名]，其中虚拟主机/需要编码为%2f。你之前的DSN错误地将队列名放在了虚拟主机的路径后，导致Symfony无法识别传输类型。

修正后的.env.local配置：

MESSENGER_TRANSPORT_DSN=amqp://admin:12345@rabbitmq.example.org:14021/%2f?queue_name=messages
MESSENGER_TRANSPORT_LOW_PRIORITY_DSN=amqp://admin:12345@rabbitmq.example.org:14021/%2f?queue_name=low_priority
MESSENGER_TRANSPORT_FAILURE_DSN=amqp://admin:12345@rabbitmq.example.org:14021/%2f?queue_name=failed

2. 调整messenger.yaml配置 #

避免DSN中的queue_name参数与yaml配置里的queue_name选项重复定义，选择其中一种方式即可。这里推荐去掉yaml中的queue_name选项（因为已经在DSN中指定）：

修正后的config/packages/messenger.yaml：

framework:
    messenger:
        transports:
            messages:
                dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
            low_prio:
                dsn: '%env(MESSENGER_TRANSPORT_LOW_PRIORITY_DSN)%'
            failed:
                dsn: '%env(MESSENGER_TRANSPORT_FAILURE_DSN)%'

如果更倾向于在yaml中定义队列名，也可以将DSN简化为仅包含连接信息，保留yaml中的queue_name：

# 简化后的.env.local DSN
MESSENGER_TRANSPORT_DSN=amqp://admin:12345@rabbitmq.example.org:14021/%2f
MESSENGER_TRANSPORT_LOW_PRIORITY_DSN=amqp://admin:12345@rabbitmq.example.org:14021/%2f
MESSENGER_TRANSPORT_FAILURE_DSN=amqp://admin:12345@rabbitmq.example.org:14021/%2f

# 保留queue_name的messenger.yaml
framework:
    messenger:
        transports:
            messages:
                dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
                options:
                    queue_name: messages
            low_prio:
                dsn: '%env(MESSENGER_TRANSPORT_LOW_PRIORITY_DSN)%'
                options:
                    queue_name: low_priority
            failed:
                dsn: '%env(MESSENGER_TRANSPORT_FAILURE_DSN)%'
                options:
                    queue_name: failed

3. 验证修复效果 #

1. 清除Shopware缓存：

   bin/console cache:clear
   

2. 重新设置传输队列：

   bin/console messenger:setup-transports
   

   此时应该不会再出现No transport supports the given Messenger DSN的错误。
3. 启动消费者监听所有队列：

   bin/console messenger:consume messages low_prio failed
   

   验证低优先级和失败消息是否能被RabbitMQ正常处理，不再留存于数据库。

额外注意事项 #

• 确保RabbitMQ的admin用户拥有队列创建、交换器绑定的权限，否则即使DSN正确，也无法完成传输设置。
• 检查RabbitMQ控制台，确认messages、low_priority、failed队列已被正确创建。

内容的提问来源于stack exchange，提问作者ᗩᕬᕭΐ