RabbitMQ简介及安装类

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版本

erl

Erlang/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的概述和安装卸载过程了！