一、前言
1.1 什么是消息队列
消息队列是一种在应用程序之间传递数据的通信机制，它基于 发布-订阅 模式，将消息发送者（发布者）和消息接收者（订阅者）解耦，使得它们可以独立地进行消息的发送和接收。
在消息队列中，消息发送者将消息发送到队列中，而消息接收者则从队列中获取消息进行处理。消息队列提供了一种异步的通信方式，即发送者发送消息后不需要等待接收者的回复，而可以立即继续执行其他操作。同时，消息队列还可以实现消息的持久化存储，确保消息在发送和接收过程中的可靠性。
消息队列的应用场景非常广泛，例如：
- 在分布式系统中，可以用消息队列来实现不同模块之间的解耦；
- 在高并发系统中，可以利用消息队列来缓解系统压力；
- 在实时数据处理中，可以将数据存储在消息队列中，再由数据处理模块进行处理。
1.2 RabbitMQ 是什么
RabbitMQ是一个开源的消息队列中间件，它实现了高级消息队列协议），并提供了可靠的消息传递机制。
RabbitMQ使用Erlang语言编写，具有高度可靠、可扩展、灵活和可插拔的特性，被广泛应用于分布式系统、微服务架构、异步任务处理等场景。
RabbitMQ基于生产者和消费者模型工作。生产者将消息发送到RabbitMQ的交换机，然后交换机将消息路由到一个或多个队列，消费者从队列中获取消息并进行处理。
RabbitMQ 支持多种消息传递模式，同时还提供了消息的持久化、消息优先级、消息确认机制等特性，确保消息的可靠性和可靠传输。
RabbitMQ是一个成熟、可靠的消息队列中间件，提供了强大的消息传递机制和丰富的特性，被广泛应用于分布式系统和异步消息处理中。
1.3 为什么需要用到 RabbitMQ
- 解耦：RabbitMQ通过消息队列实现了生产者和消费者的解耦。生产者将消息发送到队列中，而消费者从队列中获取消息并进行处理。这种解耦使得系统中的不同模块能够独立进行开发和部署，提高了系统的灵活性和可维护性。
- 异步通信：RabbitMQ提供了一种异步通信机制。生产者发送消息到队列后，不需要等待消费者立即处理，而可以继续执行其他操作。这种异步通信能够提升系统的并发性能和响应速度。
- 缓冲和削峰：RabbitMQ可以作为一个缓冲区，用于存储来自生产者的消息。这样可以避免生产者和消费者之间的直接耦合，同时也能够应对瞬时的高并发请求，减轻系统压力。
- 可靠性和可恢复性：RabbitMQ提供了持久化消息的功能，即使在消息队列或消费者故障的情况下，消息也可以得到保留和恢复。这种可靠性保证了消息的不丢失和可靠传递。
- 扩展性：RabbitMQ是一个可扩展的消息队列中间件，可以在需要的时候增加更多的消息队列和消费者节点，以应对不断增长的业务需求。
- 多语言支持：RabbitMQ提供了多种编程语言的客户端，如Java、Python、C#等，使得开发者可以选择合适自己的编程语言与RabbitMQ进行交互。
1.4 RabbitMQ 相比 Kafka 的优势
RabbitMQ 提供了简单易用的 API 和管理界面,使得开发者可以快速上手并进行配置和管理，相比之下，Kafka 的配置和管理相对复杂一些。
RabbitMQ 支持多种消息传递模式和消息的路由选择机制，可以根据需求进行灵活的消息处理，而Kafka更适用于大规模的高吞吐量流式处理,通常使用发布-订阅模式。
RabbitMQ 具备持久化消息、消息确认机制等特性,可以确保消息的可靠传输，而 Kafka 通过多副本机制和消息日志的方式，提供了高度可靠性的消息传递。
RabbitMQ 可以通过设置队列的限流策略和消费者的消费速率来进行流量控制和削峰处理，能够保护消费者免受过多的消息推送，而Kafka则将消费者的消费速率控制交给消费者自身，在高并发场景下可能需要额外处理。
RabbitMQ 提供了多种编程语言的客户端，开发者可以根据自己的编程需求选择合适的客户端进行交互，而Kafka的客户端主要集中在Java语言上，对其他语言的支持相对较少。
RabbitMQ 拥有庞大的开源社区和丰富的生态系统,提供了丰富的插件和集成工具，方便开发者进行扩展和集成，Kafka的生态系统相对较小,但在大数据领域有广泛的应用和支持。
二、搭建 RabbitMQ 环境
2.1 安装 Erlang
Erlang 是 RabbitMQ 消息服务的基础环境，就像 Java 的 JDK 一样，是必须安装的。
2.1.1 下载
Erlang 官网下载地址：下载地址。
因为我们要把 RabbitMQ 服务装在服务器上，所以同学们可以在服务器上下载 Erlang 安装包，或者下载后手动上传至服务器。
2.1.2 安装
下载完成后双击安装包，按照提示流程正常安装即可，截图如下所示。
