RabbitMQ：1.概述及安装

news2025/1/11 16:59:31

概述

AMQP协议

MQ

Message Queue（消息队列）是在消息的传输过程中保存消息的容器，多用于系统之间的异步通信

AMQP

Advanced Message Queuing Protocol(高级消息队列协议)是一个网络协议，2006年AMQP规范发布【类比HTTP】

专门为消息中间件设计，基于此协议的客户端与消息中间件可传递消息，并不受不同中间件产品，不同开发语言等条件的限制

AMQP工作过程

生产者将消息发布到交换机，交换机根据规则将消息分发给交换机绑定的队列，队列再将消息投递给订阅了此队列的消费者

RabbitMQ

简介

RabbitMQ是使用Erlang语言编写的

RabbitMQ为什么使用信道而不直接使用TCP连接通信？

1.TCP连接的创建和销毁开销特别大。创建需要3次握手，销毁需要4次分手，高峰时每秒成千上万条TCP连接的创建会造成资源巨大的浪费

2.操作系统每秒处理TCP连接数也是有限制的，会造成性能瓶颈

3.如果一条线程使用一条信道，一条TCP链接可以容纳无限的信道，即使每秒成千上万的请求也不会成为性能的瓶颈

RabbitMQ核心概念

Producer【生产者】
消息的生产者，也是一个向交换机发布消息的客户端应用程序

Connection【连接】
生产者/消费者和RabbitMQ服务器之间建立的TCP连接

Channel【信道】
信道，是TCP里面的虚拟连接，一条TCP连接中可以创建多条信道，增加连接效率
无论是发布消息、接收消息、订阅队列都是通过信道完成的

Broker【RabbitMQ服务器】
消息队列服务器实体，即RabbitMQ服务器

Virtual host【虚拟主机】
出于多租户和安全因素设计的，把AMQP的基本组件划分到一个虚拟的分组中
每个vhost本质上就是一个mini版的RabbitMQ服务器，拥有自己的队列、交换机、绑定和权限机制
当多个不同的用户使用同一个RabbitMQ服务器时，可以划分出多个虚拟主机
RabbitMQ默认的虚拟主机路径是/

Exchange【交换机】
用来接收生产者发送的消息，并根据分发规则，将这些消息分发给服务器中的队列中，不同的交换机有不同的分发规则

Queue【消息队列】
用来保存消息直到发送给消费者，它是消息的容器，也是消息的终点
消息一直在队列里面，等待消费者链接到这个队列将其取走

Binding【虚拟连接】
消息队列和交换机之间的虚拟连接，绑定中包含路由规则，绑定信息保存到交换机的路由表中，作为消息的分发依据

Consumer【消费者】
消息的消费者，表示一个从消息队列中取得消息的客户端应用程序

RabbitMQ场景

1.抢红包、秒杀活动、抢火车票等
这些业务场景都是短时间内需要处理大量请求，如果直接连接系统处理业务，会耗费大量资源，有可能造成系统瘫痪
而使用MQ后，可以先让用户将请求发送到MQ中，MQ会先保存请求消息，不会占用系统资源，且MQ会进行消息排序，先请求的秒杀成功，后请求的秒杀失败。

2.消息分发
如电商网站要推送促销信息，该业务耗费时间较多，但对时效性要求不高，可以使用MQ做消息分发

3.数据同步
假如我们需要将数据保存到数据库之外，还需要一段时间将数据同步到缓存（如Redis）、搜索引擎（如Elasticsearch）中。
此时可以将数据库的数据作为消息发送到MQ中，并同步到缓存、搜索引擎中。

4.异步处理
在电商系统中，订单完成后，需要及时的通知子系统（进销存系统发货，用户服务积分，发送短信）进行下一步操作。
为了保证订单系统的高性能，应该直接返回订单结果，之后让MQ通知子系统做其他非实时的业务操作。这样能保证核心业务的高效及时。

5.离线处理
在银行系统中，如果要查询近十年的历史账单，这是非常耗时的操作。如果发送同步请求，则会花费大量时间等待响应
此时使用MQ发送异步请求，等到查询出结果后获取结果即可

docker安装

拉取镜像

docker pull docker.io/macintoshplus/rabbitmq-management

创建容器

docker run -d  --name rabbitmq -e RABBITMQ_DEFAULT_USER=guest -e RABBITMQ_DEFAULT_PASS=guest -p 8042:15672 -p 8041:5672 docker.io/macintoshplus/rabbitmq-management