当前位置：首页 > news >正文

RabbitMQ框架及应用场景

news 2026/3/26 20:04:21

简介

RabbitMQ是一个使用Erlang，基于AMQP协议的MQ组件。

AMQP全称为 Advanced Message Queuing Protocol（高级消息队列协议****），是一个面向消息的中间件传输协议，用于在应用程序之间进行异步消息通信。

AMQP协议定义了多种角色和服务，包括生产者、消费者、交换器、队列等。其中生产者负责生成消息，消费者负责接收和处理消息，交换器则负责将消息路由到队列中。

AMQP协议的消息传输基于消息队列，支持消息的确认、持久化、事务等功能，同时支持不同的消息传输模式，如点对点（point-to-point）和发布-订阅（publish-subscribe）模式。

暂时无法在飞书文档外展示此内容

交换机有四种类型，分别是：Direct、Fanout、Topic和Headers

direct： 直接匹配模式，将消息发送到与路由键完全匹配的队列中。按照消息的路由键（routing key）完全匹配来投递消息。direct模式可以使用RabbitMQ自带的默认交换机，所以不需要将交换机进行任何绑定操作
topic： 使用通配符进行模糊匹配，消息会带有一个路由键（routing key），而队列绑定到交换机上时，也可以指定主题，而且还能使用一定的正则形式，只要主题匹配上消息的路由键，该消息就会发送至该队列符号“#”匹配一个或多个词 eg：" log.# "能够匹配到‘ log.info.oa ’ 符号“*” 匹配不多不少一个词 eg：“ log.* ”只能匹配到“log.erro”
headers： 根据消息头的键值对匹配，按照消息头（header）匹配来投递消息。当消息头与某个绑定的headers完全匹配时，才会将消息发送到该队列中。
fanout ： 将接收到的所有消息广播到它知道的所有队列中，如果routing_key 有指定也不会生效

消息被拒绝，并且设置不能重发；或者消息过期还无人消费；或者队列满了，早期的消息；就会成为死信。

如果队列通过dead-letter-exchange 属性指定了一个交换机，那么该队列中的死信就会投递到这个交换机中，

这个交换机就被称为死信交换机（Dead Letter Exchange，简称DLX）

死信交换机

在订单取消方面可以发挥作用。以下是一个使用死信交换机实现订单取消的示例：

定义一个延迟队列，如果这个包含死信的队列配置了dead-letter-exchange属性，指定了一个交换机，那么队列中的死信就会投递到这个交换机中，而这个交换机称为死信交换机（Dead Letter Exchange，检查DLX）。

如果这个死信交换机也绑定了一个队列，则消息最终会进入这个存放死信的队列。然后消费者监听死信队列，取消订单。

另外，队列将死信投递给死信交换机时，必须知道两个信息：

这样才能确保投递的消息能到达死信交换机，并且正确的路由到死信队列。

配置****消息队列：
1. 开启手动ack，以便消费者在处理消息后可以进行应答。
2. 定义一个延迟队列，例如order.delay.queue，用于存放超时的订单信息。
3. 创建一个死信交换机，例如order.delay.exchange，用于接收来自延迟队列的消息。
4. 配置延迟队列与死信交换机之间的绑定，使用x-dead-letter-exchange和x-dead-letter-routing-key参数来指定死信消息的转发规则。
生产者：
1. 在订单生成后，将订单信息发送到延迟队列，并设置消息的TTL（生存时间），例如10分钟。
2. 如果需要，可以设置消息的优先级，以便于区分不同紧急程度的订单。
消费者：
1. 监听死信队列，并从中获取超时的订单信息。
2. 对订单信息进行处理，例如取消订单、更新订单状态等。
3. 手动ack消息，告知消息服务器消息已被处理。
测试：
1. 发送延迟消息进行测试，并检查订单状态的变化。