RabbitMQ概述-MQ介绍

RabbitMQ是一个开源的消息代理和队列服务器，它支持多种消息协议，并且可以轻松地与多种编程语言和框架集成。RabbitMQ是使用Erlang语言编写的，因此它具有高并发和高可用性的特点。以下是RabbitMQ的一些关键特性和概念

• 消息代理（Message Broker） RabbitMQ充当消息代理，它接收来自生产者的消息，并将这些消息传递给消费者。
• 消息队列（Message Queue） 消息队列是一种数据结构，用于存储等待处理的消息。
• 生产者（Producer） 生产者是发送消息到RabbitMQ的应用程序。
• 消费者（Consumer）消费者是从RabbitMQ接收消息的应用程序。
• 交换器（Exchange） 交换器是RabbitMQ中消息的路由点。它接收来自生产者的消息，并根据路由规则将消息路由到一个或多个队列
• 绑定（Binding） 绑定是交换器和队列之间的关系。它定义了消息如何从交换器路由到队列
• 路由键（Routing Key） 路由键是消息的一部分，用于消息的路由。生产者发送消息时指定路由键，交换器根据绑定规则和路由键将消息路由到相应的队列
• 队列（Queue） 队列是存储消息的实体。消费者从队列中获取消息进行处理
• 确认（Acknowledgement） 当消费者成功处理完一条消息后，它会发送一个确认信号给RabbitMQ，表示消息已被处理
• 持久化（Persistence） RabbitMQ支持消息和队列的持久化，确保在服务器重启后消息不会丢失
• 集群（Clustering） 多个RabbitMQ节点可以组成一个集群，以提高消息处理的吞吐量和系统的可用性
• 高可用性（High Availability） RabbitMQ支持镜像队列，可以实现队列的高可用性
• 消息的可靠性 通过消息确认和持久化机制，RabbitMQ确保消息的可靠传递
• 多种消息协议支持 RabbitMQ支持多种消息协议，如AMQP（高级消息队列协议）、MQTT、STOMP等
• 插件系统 RabbitMQ有一个丰富的插件系统，可以通过插件扩展其功能。

RabbitMQ广泛应用于分布式系统中，用于解耦服务、异步处理任务、消息传递和事件通知等场景。

MQ从字面意思上看本质上是个队列，FIFO先进先出，只不过队列中存放的内容是消息（message）而已，消息可以非常简单，比如只包含文本字符串，JSON等，也可以很复杂，比如内嵌对象

MQ多用于分布式系统之间进行通信

系统之间的调用通常有两种方式：

同步通信

直接调用对方的服务，数据从一端发出后立即就可以达到另一端

异步通信

数据从一端发出后，先进入一个容器进行临时存储，当达到某种条件后，再由这个容器发送给另一端，容器的一个具体实现就是MQ（Message Queue）

RabbitMQ就是MQ的一种实现

MQ作用

MQ主要⼯作是接收并转发消息, 在不同的应⽤场景下可以展现不同的作⽤

可以把MQ想象成⼀个仓库. 采购部⻔进货之后, 把零件放进仓库⾥, ⽣产部⻔从仓库中取出零件, 并加 ⼯成产品. MQ和仓库的区别是, 仓库⾥放的是物品, MQ⾥放的是消息, 仓库负责存储物品,并转发物品, MQ负责存储和转发消息

• 异步解耦: 在业务流程中, ⼀些操作可能⾮常耗时, 但并不需要即时返回结果. 可以借助MQ把这些操 作异步化, ⽐如 ⽤⼾注册后发送注册短信或邮件通知, 可以作为异步任务处理, ⽽不必等待这些操作 完成后才告知⽤⼾注册成功
• 流量削峰: 在访问量剧增的情况下, 应⽤仍然需要继续发挥作⽤, 但是这样的突发流量并不常⻅. 如果 以能处理这类峰值为标准⽽投⼊资源,⽆疑是巨⼤的浪费. 使⽤MQ能够使关键组件⽀撑突发访问压 ⼒, 不会因为突发流量⽽崩溃. ⽐如秒杀或者促销活动, 可以使⽤MQ来控制流量, 将请求排队, 然后系 统根据⾃⼰的处理能⼒逐步处理这些请求
• 消息分发: 当多个系统需要对同⼀数据做出响应时, 可以使⽤MQ进⾏消息分发. ⽐如⽀付成功后, ⽀ 付系统可以向MQ发送消息, 其他系统订阅该消息, ⽽⽆需轮询数据库
• 延迟通知: 在需要在特定时间后发送通知的场景中, 可以使⽤MQ的延迟消息功能, ⽐如在电⼦商务平 台中，如果⽤⼾下单后⼀定时间内未⽀付，可以使⽤延迟队列在超时后⾃动取消订单

为什么选择RabbitMQ？

⽬前业界有很多的MQ产品, 例如RabbitMQ, RocketMQ, ActiveMQ, Kafka, ZeroMQ等, 也有直接使⽤ Redis充当消息队列的案例, 这些消息队列, 各有侧重, 也没有好坏, 只有适合不适合, 在实际选型时, 需要 结合⾃⾝需求以及MQ产品特征, 综合考虑

以下我们介绍⼀下当前最主流的3种MQ产品

• Kafka Kafka⼀开始的⽬的就是⽤于⽇志收集和传输，追求⾼吞吐量, 性能卓越, 单机吞吐达到⼗万级, 在⽇ 志领域⽐较成熟, 功能较为简单，主要⽀持简单的 MQ 功能, 如果有⽇志采集需求,肯定是⾸选kafka 了
• RocketMQ RocketMQ采⽤Java语⾔开发, 由阿⾥巴巴开源, 后捐赠给了Apache. 它在设计时借鉴了Kafka，并做出了⼀些⾃⼰的改进, ⻘出于蓝⽽胜于蓝, 经过多年双⼗⼀的洗礼, 在 可⽤性、可靠性以及稳定性等⽅⾯都有出⾊的表现. 适合对于可靠性⽐较⾼,且并发⽐较⼤的场景, ⽐ 如互联⽹⾦融. 但⽀持的客⼾端语⾔不多, 且社区活跃度⼀般
• RabbitMQ 采⽤Erlang语⾔开发, MQ 功能⽐较完备, 且⼏乎⽀持所有主流语⾔，开源提供的界⾯也⾮常友好, 性 能较好, 吞吐量能达到万级, 社区活跃度也⽐较⾼，⽐较适合中⼩型公司, 数据量没那么⼤, 且并发没 那么⾼的场景

综合: 由于RabbitMQ的综合能⼒较强, 咱们这边的项⽬没有那么⼤的⾼并发, 且RabbitMQ社区⽐较成 熟, 管理界⾯友好, 所以咱们接下来主要学习RabbitMQ的使⽤

RabbitMQ介绍

RabbitMQ 官⽹: RabbitMQ: One broker to queue them all | RabbitMQ

RabbitMQ是采⽤Erlang语⾔实现AMQP(Advanced Message Queuing Protocol,⾼级消息队列协议)的 消息中间件,它最初起源于⾦融系统领域, 为了在分布式系统中存储和转发消息⽽设计的

在此之前,有⼀些消息中间件的商业实现,⽐如微软的MSMQ(MicroSoft Message Queue), IBM的 WebSphere等. 但是他们价格太贵了,⼀般只应⽤于⼤型组织机构

• RabbitMQ开发始于2006年, 是由Rabbit Technologies开发并且提供商业⽀持的. 之所以取名为 Rabbit, 是因为兔⼦⾏动⾮常迅速且繁殖起来⾮常疯狂, RabbitMQ的开创者认为这个名字再合适不过 了
• 2010年4⽉, Rabbit Technologies被 VMware 旗下的 SpringSource 收购, 在 2013 年 5 ⽉被并⼊ Pivotal
• 其实 VMware, Pivotal 本质上是⼀家的. 不同的是，VMware 是独⽴上市⼦公司, ⽽ Pivotal 是整合了 EMC的某些资源, 其中我们现在使⽤的 Spring 系列框架, 就是 Pivotal 公司热⻔的产品之⼀
• 直到后来 Pivotal 将其开源, RabbitMQ 才逐渐⾛向⼤众！
• RabbitMQ 发展到今天, 已经被越来越多的⼈认可, 尤其是互联⽹公司, 已经有着⼤规模的场景应⽤, 这和 它在易⽤性, 扩展性, 可靠性和⾼可⽤性等⽅⾯的卓越表现是分不开的. 接下来我们就⼀起来深⼊了解⼀ 下 RabbitMQ

RabbitMQ快速上手-Ubuntu安装

RabbitMQ已经包含在标准的Ubuntu仓库中, 然⽽，包含的版本通常⽐最新的RabbitMQ发⾏版落后很 多，可能提供的RabbitMQ版本已经不⽀持. RabbitMQ团队制作了⾃⼰的软件包，并使⽤Cloudsmith 进⾏分发

具体操作可以参考: Installing on Debian and Ubuntu | RabbitMQ

由于该种⽅法安装⽐较复杂, 学习阶段, 咱们使⽤Ubuntu仓库中的版本来安装

安装Erlang

RabbitMq需要Erlang语⾔的⽀持，在安装rabbitMq之前需要安装erlang

#更新软件包
sudo apt-get update
#安装erlang
sudo apt-get install erlang

查看erlang版本

erlErlang/OTP 22 [erts-10.6.4] [source] [64-bit] [smp:2:2] [ds:2:2:10] [asyncthreads:1]
Eshell V10.6.4 (abort with ^G)

退出命令:

halt().

安装RabbitMQ

#更新软件包
sudo apt-get update
#安装rabbitmq
sudo apt-get install rabbitmq-server
#确认安装结果
systemctl status rabbitmq-server

确认安装结果

systemctl status rabbitmq-server

安装RabbitMQ管理界⾯

• 默认是不安装管理界⾯的

rabbitmq-plugins enable rabbitmq_management

启动服务并访问

启动服务

若服务已经启动了, 此步省略

#启动rabbitmq
sudo service rabbitmq-server start

查看服务状态

systemctl status rabbitmq-server

通过 IP:port 访问界⾯

http:123.249.46.177:15672

默认⽤⼾名和密码都是: guest

rabbitmq从3.3.0开始禁⽌使⽤guest/guest权限通过除localhost外的访问, 解除⽅法也有, 此处不多说

添加管理员⽤⼾

添加⽤⼾admin, 密码:admin

rabbitmqctl add_user ${账号} ${密码}
rabbitmqctl add_user admin admin

给⽤⼾添加权限

#rabbitmqctl set_user_tags ${账号} ${⻆⾊名称}
rabbitmqctl set_user_tags admin administrator

以下⻆⾊可选 RabbitMQ⽤⼾⻆⾊分为Administrator、Monitoring、Policymaker、Management、 Impersonator、None共六种⻆⾊

• Administrator 超级管理员，可登陆管理控制台(启⽤management plugin的情况下)，可查看所 有的信息，并且可以对⽤⼾，策略(policy)进⾏操作
• Monitoring 监控者，可登陆管理控制台(启⽤management plugin的情况下)，同时可以查看 rabbitmq节点的相关信息(进程数，内存使⽤情况，磁盘使⽤情况等)
• Policymaker 策略制定者，可登陆管理控制台(启⽤management plugin的情况下)，同时可以对 policy进⾏管理。但⽆法查看节点的相关信息
• Management 普通管理者，仅可登陆管理控制台(启⽤management plugin的情况下)，⽆法看到 节点信息，也⽆法对策略进⾏管理
• Impersonator 模拟者，⽆法登录管理控制台
• None 其他⽤⼾，⽆法登陆管理控制台，通常就是普通的⽣产者和消费者

rabbitmqctl set_user_tags admin administrator

通过IP:port访问, 并使⽤刚才设置的⽤⼾名和密码登录 

 

其他操作

• 修改端⼝号
• 查找rabbitmq位置

whereis rabbitmq
rabbitmq: /usr/lib/rabbitmq /etc/rabbitmq

• 新增配置⽂件rabbitmq.conf
• (在/etc/rabbitmq路径下创建rabbitmq.conf⽂件, 并添加以下内容)

#修改client端⼝为8942(默认为5672)
listeners.tcp.default=8942
#修改管理界⾯端⼝为8943(默认为15672)
management.tcp.port=8943

• 修改rabbitmq-defaults⽂件，添加配置⽂件路径
• ⽂件路径: /usr/lib/rabbitmq/lib/rabbitmq_server-3.8.30/sbin/rabbitmq-defaults
• 编辑rabbitmq-defaults, 在⽂本最后添加如下代码

#添加配置路径到⽂件中，保存退出
CONFIG_FILE=/etc/rabbitmq/rabbitmq.conf

重启RabbitMQ

sudo systemctl restart rabbitmq-server

服务相关

#启动服务
sudo systemctl start rabbitmq-server
#停⽌服务
sudo systemctl stop rabbitmq-server
#重启服务
sudo systemctl restart rabbitmq-server
#添加开机启动服务
sudo systemctl enable rabbitmq-server
#检查服务状态
sudo systemctl status rabbitmq-server

卸载RabbitMQ

• 停⽌RabbitMQ服务

sudo systemctl stop rabbitmq-serve

• 查找RabbitMQ安装情况

dpkg -l | grep rabbitmq

• 卸载rabbitmq已安装的相关内容

sudo apt-get purge --auto-remove rabbitmq-server

• 卸载Erlang
• 查看erlang安装的相关列表

dpkg -l | grep erlang

• 卸载erlang已安装的相关内容

sudo apt-get purge --auto-remove erlang

以上就是RabbitMQ的概述和安装卸载过程了！