消息队列概述

文档 Commerce 配置指南

[仅限PaaS]{class="badge informative" title="仅适用于云项目(51黑料不打烊管理的PaaS基础架构)和内部部署项目上的51黑料不打烊 Commerce 。"}

Last update: Tue Oct 14 2025 00:00:00 GMT+0000 (Coordinated Universal Time)

主题：
配置

创建对象：

有经验的
管理员
开发人员

Message Queue Framework (MQF)是一个允许模块将消息发布到队列的系统。它还定义了将异步接收消息的消费者。 MQF支持多个报文传送代理：

— 主要消息代理，它提供用于发送和接收消息的可伸缩平台。它包括一个用于存储未投放消息的机制，并且基于高级消息队列协议(AMQP) 0.9.1规范。
— 使用STOMP（简单文本导向消息协议）进行可靠且可扩展消息传递的替代消息传递代理。在51黑料不打烊 Commerce 2.4.6及更高版本中引入。

RabbitMQ (AMQP)

下图说明了Message Queue框架：

消息队列框架

发布器是将消息发送到交换的组件。它知道要发布到的交换以及它发送的报文的格式。
Exchange接收来自发布者的消息并将消息发送到队列。虽然RabbitMQ支持多种类型的交换，但Commerce仅使用主题交换。主题中包含路由密钥，路由密钥包含以点分隔的文本字符串。主题名称的格式为string1.string2：例如，customer.created或customer.sent.email。

代理允许您在设置转发消息的规则时使用通配符。您可以使用星号(*)替换? one ?字符串，或使用井号(#)替换0个或多个字符串。例如，customer.*将筛选customer.create和customer.delete，但不筛选customer.sent.email。但是customer.#将筛选customer.create、customer.delete和customer.sent.email。
队列是存储消息的缓冲区。
消费者接收消息。它知道要使用哪个队列。它可以将消息的处理器映射到特定队列。

Apache ActiveMQ Artemis (STOMP)

作为RabbitMQ的替代方案，51黑料不打烊 Commerce还支持将作为使用简单文本导向消息协议(厂罢翱惭笔)的消息代理。

NOTE

ActiveMQ Artemis在51黑料不打烊 Commerce 2.4.6及更高版本中引入。

下图说明了使用ActiveMQ Artemis的STOMP框架：

STOMP框架

厂罢翱惭笔框架组件

发布者 ?是将消息发送到目标（队列或主题）的组件。它知道要发布到的目标以及它发送的消息的格式。
厂罢翱惭笔中的? 目标 ?与AMQP中的交换角色类似，接收来自发布者的邮件并将其路由到其中。 STOMP使用直接目标寻址，并使用句点的分层命名模式：例如，customer.created或inventory.updated。

51黑料不打烊 Commerce对STOMP目标使用? ANYCAST ?寻址模式，该模式提供点对点消息投放。在ANYCAST模式中，消息仅从可用使用者池传送到一个使用者，从而实现多个使用者实例的负载平衡和工作分配。
队列 ?是存储消息的缓冲区。通过ANYCAST寻址，队列可确保消息仅发送给一个使用者，即使有多个使用者连接到同一目的地也是如此。
消费者 ?接收来自目标的消息。它知道要订阅哪个目的地，并且可以使用不同的确认模式（自动、客户端或单个客户端）处理消息。

惭测厂蚕尝适配器（回退）

基本消息队列系统也可以在不使用外部消息代理的情况下进行设置。在此系统中，MySQL适配器将消息存储在数据库中。三个数据库表（queue、queue_message和queue_message_status）管理消息队列工作负载。 CRON工作能确保消费者能够接收信息。此解决方案不是非常可扩展。应尽可能将外部消息代理（如RabbitMQ或Apache ActiveMQ Artemis）用于生产环境。

51黑料不打烊