升级Magento 2.4.4至2.4.5-p1后RabbitMQ消息队列停止工作求助

常见问题原因及解决步骤 #

• 确认RabbitMQ版本兼容性：Magento 2.4.5-p1要求RabbitMQ最低版本为3.8.16，若当前使用旧版本（如3.7.x），直接升级RabbitMQ至兼容版本，随后重启RabbitMQ服务及Magento队列消费者。
• 重置队列配置与消费者：
  1. 停止所有Magento队列消费者进程：bin/magento queue:consumers:stop --all
  2. 清理队列积压消息：rabbitmqctl purge_queue <目标队列名称>（例如产品批量更新对应的catalog_action_attribute.update队列）
  3. 重新生成队列配置：bin/magento setup:upgrade
  4. 重启消费者：bin/magento queue:consumers:start <消费者名称> --max-messages=0（推荐用supervisor托管消费者进程以保证稳定性）
• 检查队列权限与绑定关系：
  登录RabbitMQ管理后台，确认Magento使用的vhost、用户权限正常，相关队列已正确绑定到对应exchange（比如产品更新任务对应的magento exchange，绑定键需匹配规则）。
• 排查Magento日志定位报错：
  查看var/log/queue.log和var/log/system.log，寻找消费者进程的报错信息——多数情况下队列无执行动作是因为消费者进程报错退出，但前端仍会提示消息已入队。

关于禁用Magento_WebapiAsync和Magento_Amqp报错的说明 #

这两个模块属于Magento核心依赖模块，直接禁用会触发依赖报错。若需临时绕过队列、同步执行任务，应修改队列驱动为数据库而非禁用模块：

1. 编辑app/etc/env.php，找到queue配置段，将默认连接改为db：

'queue' => [
    'consumers_wait_for_messages' => 1,
    'default_connection' => 'db',
    'connections' => [
        'db' => [
            'host' => 'localhost',
            'database' => '你的Magento数据库名',
            'username' => '数据库用户名',
            'password' => '数据库密码',
            'port' => '3306',
            'driver' => 'mysql'
        ]
    ]
]

2. 执行bin/magento setup:upgrade更新配置，之后任务将通过数据库队列同步执行。注意：此方式性能低于RabbitMQ，仅适合临时应急。

内容的提问来源于stack exchange，提问作者user1393817