消息队列与RabbitMQ
消息队列简介
消息队列（Message Queue，简称MQ）是一种用于在分布式系统中传递消息的中间件技术。它通过异步通信的方式，将消息的生产者和消费者解耦，使得系统之间的交互更加灵活和高效。消息队列的核心思想是：生产者将消息发送到队列中，消费者从队列中获取并处理消息，而无需直接与对方进行实时交互。
消息队列的特点
- 异步通信：生产者和消费者不需要同时在线，消息可以被暂时存储。
- 解耦：生产者和消费者之间没有直接依赖关系，降低了系统的耦合性。
- 削峰填谷：在高并发场景下，消息队列可以缓冲请求，避免系统过载。
- 可靠性：支持消息持久化、重试机制等，确保消息不会丢失。
- 扩展性：可以通过增加消费者来提高系统的处理能力。
消息队列的应用场景
- 异步处理
例如用户注册后发送欢迎邮件或短信，这些操作不需要实时完成，可以通过消息队列异步处理。 - 应用解耦
不同服务之间通过消息队列进行通信，减少直接调用的依赖。 - 流量削峰
在秒杀、抢购等高并发场景中，消息队列可以平滑处理瞬间涌入的大量请求。 - 日志处理
收集系统日志并发送到消息队列，后续由消费者进行分析和存储。 - 分布式事务
在分布式系统中，通过消息队列实现最终一致性。
RabbitMQ关键概念
RabbitMQ是开源消息队列中间件，遵循AMQP协议。它功能强大,支持多种消息模式，如点对点、发布-订阅等。具备高可用、可扩展特性，在分布式系统中实现高效异步通信，广泛用于Web应用、微服务等场景。
https://www.rabbitmq.com/
RabbitMQ的关键概念
RabbitMQ 是一个开源的消息代理（Message Broker），它实现了高级消息队列协议（AMQP）。以下是 RabbitMQ 的关键概念：
- Producer（生产者）
生产者是发送消息的应用程序。它将消息发送到 RabbitMQ 的交换器（Exchange）。 - Consumer（消费者）
消费者是接收消息的应用程序。它从队列中获取消息并进行处理。 - Queue（队列）
队列是存储消息的缓冲区。消息被生产者发送到交换器后，最终会被路由到一个或多个队列中。 - Exchange（交换器）
交换器负责接收生产者发送的消息，并根据绑定规则将消息路由到一个或多个队列。常见的交换器类型包括：
○ Direct Exchange：根据路由键（Routing Key）精确匹配。
○ Fanout Exchange：广播消息到所有绑定的队列。
○ Topic Exchange：根据模式匹配路由键。
○ Headers Exchange：根据消息头属性进行匹配。 - Binding（绑定）
绑定是交换器和队列之间的连接规则。它定义了消息如何从交换器路由到队列。 - Routing Key（路由键）
路由键是生产者发送消息时附带的一个键值，交换器根据路由键和绑定规则决定消息的去向。 - Message（消息）
消息是生产者发送的数据单元，包含有效载荷（Payload）和可选的元数据（如路由键、消息头等）。 - Broker（代理）
RabbitMQ 本身就是一个消息代理，负责接收、存储和分发消息。 - Virtual Host（虚拟主机）
虚拟主机是对 RabbitMQ 的逻辑隔离，允许在同一物理实例上运行多个独立的消息环境。
执行流程图
流程说明
- Producer 发送消息
生产者将消息发送到 RabbitMQ 的交换器（Exchange），并附带一个路由键（Routing Key）。 - Exchange 路由消息
交换器根据路由键和绑定规则（Binding Rules）决定消息的去向。 - 消息进入 Queue
消息被路由到一个或多个队列（Queue）中。 - Consumer 消费消息
消费者从队列中获取消息并进行处理。 - RabbitMQ Broker 的作用
RabbitMQ 作为消息代理，负责管理交换器、队列和绑定规则，并确保消息的可靠传递。