一、Apache RabbitMQ定义
Apache RabbitMQ 是一个开源消息队列系统，基于 Erlang 语言开发，实现了高级消息队列协议（AMQP）。RabbitMQ 提供了多种消息传递机制，包括点对点（direct）、发布/订阅（fanout）、路由（route）和事务（transactional）等。
组件
-
交换器（Exchanges）：
- 交换器是消息发送者和接收者之间的中介。
- 它根据路由键（routing key）来决定将消息发送到哪些队列。
- 类型包括直连（direct）、扇形（fanout）、主题（topic）和头头（headers）。
-
队列（Queues）：
- 队列是存储消息的地方，生产者将消息发送到队列，消费者从队列中取出消息进行处理。
- 消息会在队列中保留，直到被消费者完全处理。
-
绑定（Binding）：
- 绑定是队列和交换器之间的关系，它将队列与交换器的路由键进行关联。
- 这允许交换器将消息路由到与之绑定的队列。
-
消息（Messages）：
- 消息是传递的信息，由生产者发送，由消费者接收。
- 消息可以包含正文、属性（headers）和元数据。
-
通道（Channels）：
- 通道是发送和接收消息的轻量级连接，它们在客户端和 RabbitMQ 服务器之间建立。
- 使用通道可以提高性能，并允许发送多个消息。
-
确认（Acknowledgments）：
- 消费者在处理完消息后需要向 RabbitMQ 发送确认，表示消息已经被正确接收。
- 如果消费者在处理消息前失效，RabbitMQ 会将消息重新入队，等待其他消费者处理。
-
持久化（Persistence）：
- RabbitMQ 可以将队列和消息持久化到磁盘，以确保在服务器重启后数据不会丢失。
-
集群（Clustering）：
- RabbitMQ 支持集群，可以将多个 RabbitMQ 服务器组成一个集群，提供高可用性和扩展性。
-
插件（Plugins）：
- RabbitMQ 具有丰富的插件生态系统，可以扩展其功能，例如用于消息优先级、死信队列、消息过滤等
-
RabbitMQ支持的语言有Python（
pika）、Java（amqp-client）、JavaScript（amqp.js）等
二、RabbitMQ 怎么保证顺序的消费消息
-
有序队列（Ordered Queues）： RabbitMQ 支持有序队列，这种队列确保所有消息按照发送顺序进行处理。为了使用有序队列，你需要将消息发布到具有
x-ordered属性的队列中。在 RabbitMQ 的管理界面中，你可以为队列设置x-orderered属性，或者在创建队列时使用rabbitmqctl命令行工具。 -
例如，使用
rabbitmqctl设置队列有序：shell
rabbitmqctl set_queue_arg -p /myvhost myqueue x-ordered true或者在代码中，使用 RabbitMQ 的客户端 API 设置：
python
channel.queue_declare(queue='myqueue', arguments={'x-ordered': True}) -
消息持久化（Message Persistence）： 即使消息队列重启，持久化的消息也不会丢失。通过设置消息或队列的持久化属性，可以保证消息顺序在服务器重启后依然得到维护。
-
单独的交换器（Exchange）和队列绑定： 如果你想要严格控制消息的顺序，可以使用一个交换器将多个队列绑定到同一个交换器上，并保证所有消息都按照发送顺序到达队列。
-
消费者端的处理： 在消费者端，可以通过业务逻辑来保证消息处理的顺序。例如，你可以使用数据库的事务来处理消息，确保消息的处理顺序与到达顺序一致。
-
顺序消息的确认机制（Message Acknowledgment）： 消费者在处理消息后需要发送一个确认（acknowledgment）给 RabbitMQ，表明消息已经被处理。在处理顺序消息时，确保按照消息的接收顺序来发送确认。
-
监控和日志记录： 在生产环境中，监控和记录是保证消息顺序的重要手段。通过监控可以及时发现问题，日志记录可以帮助追踪问题和进行故障排查。
三、如何单独的交换器（Exchange）和队列绑定，从而保证顺序消费
-
创建交换机： 首先，需要创建一个交换机。交换机可以有多种类型，包括直连（direct）、扇形（fanout）、主题（topic）和头头（headers）。交换机的类型决定了消息如何被路由到队列。
shell
# 创建一个名为 my_exchange 的直连交换机 rabbitmqctl declare exchange my_exchange type direct -
创建队列： 接下来，创建一个队列，这将是我们用来存储消息的地方。
shell
# 创建一个名为 my_queue 的队列 rabbitmqctl declare queue my_queue durable exclusive auto_delete arguments -
绑定队列和交换机： 然后，将队列绑定到交换机上。在绑定时，你需要指定一个路由键（routing key），它决定了哪些队列会接收到发送到交换机的消息。
shell
# 将 my_queue 队列绑定到 my_exchange 交换机，路由键为 my_routing_key rabbitmqctl declare binding queue my_queue exchange my_exchange binding_key my_routing_key
在这个例子中，任何发送到 my_exchange 且路由键为 my_routing_key 的消息都会被路由到 my_queue 队列。
如果你使用的是扇形交换机，那么绑定时不需要指定路由键，因为扇形交换机会将消息发送到所有与交换机绑定的队列。
如果你使用的是主题交换机，你可以使用模式匹配来绑定队列。例如，如果你想要将包含特定关键词的消息路由到特定的队列，你可以这样做：
shell
复制
# 将 my_queue 队列绑定到 my_exchange 交换机，使用通配符模式匹配路由键
rabbitmqctl declare binding queue my_queue exchange my_exchange binding_key "#.my_keyword"
在这个例子中，任何包含 my_keyword 的路由键的消息都会被路由到 my_queue 队列。从而保证消息被顺序消费
![[Spring Cloud] (6)gateway整体加解密](https://img-blog.csdnimg.cn/img_convert/47146091a3714383065d266768a64041.png)
