RabbitMQ --- 安装及基本概念

喜欢ヅ旅行 2022-11-25 11:49 329阅读 0赞

> RabbitMQ是实现了高级消息队列协议（AMQP）的开源消息代理软件（亦称面向消息的中间件）。RabbitMQ服务器是用Erlang语言编写的，而集群和故障转移是构建在开放电信平台框架上的。所有主要的编程语言均有与代理接口通讯的客户端库。

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70_pic_center]

### 文章目录 ###

*  一、RabbitMQ安装
 *   *  1.1 离线安装
     *  1.2 Yum在线安装
     *  1.3 启动rabbitmq服务器
     *  1.4 rabbitmq管理界面
     *   *  1.4.1 启用管理界面
         *  1.4.2 重启RabbitMQ服务
     *  1.5 访问
     *  1.6 添加用户
     *   *  1.6.1 添加用户
         *  1.6.2 设置访问权限
     *  1.7 开放客户端连接端口
 *  二、RabbitMQ 使用场景
 *   *  2.1 服务解耦
     *  2.2 流量削峰
     *  2.3 异步调用
 *  三、rabbitmq 基本概念
 *   *  3.1 Exchange
     *  3.2 Message Queue
     *  3.3 Binding Key
     *  3.4 Routing Key

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70_pic_center 1]

# 一、RabbitMQ安装 #

## 1.1 离线安装 ##

**下载离线安装包文件**

*  [https://download.csdn.net/download/weixin\_38305440/12265906][https_download.csdn.net_download_weixin_38305440_12265906]

**上传离线安装包**  
`rabbitmq-install` 目录上传到 `/root`

**切换到rabbitmq-install目录**

cd rabbitmq-install

**安装**

rpm -ivh *.rpm

> 推荐使用工具:MobaXterm，免费版的功能就相当强大了，个人感觉可以代替xshell，winscp等
> 
> 下载地址[https://mobaxterm.mobatek.net/download-home-edition.html][https_mobaxterm.mobatek.net_download-home-edition.html]  
> ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70]

## 1.2 Yum在线安装 ##

以下内容来自 RabbitMQ 官方手册 (选择其中一个复制就可以，centos6/7)

命令行逐条复制运行

rpm --import https://github.com/rabbitmq/signing-keys/releases/download/2.0/rabbitmq-release-signing-key.asc
    
    
    # centos7 用这个
    cat <<EOF > /etc/yum.repos.d/rabbitmq.repo
    [bintray-rabbitmq-server]
    name=bintray-rabbitmq-rpm
    baseurl=https://dl.bintray.com/rabbitmq/rpm/rabbitmq-server/v3.8.x/el/7/
    gpgcheck=0
    repo_gpgcheck=0
    enabled=1
    EOF
    
    
    # centos6 用这个
    cat <<EOF > /etc/yum.repos.d/rabbitmq.repo
    [bintray-rabbitmq-server]
    name=bintray-rabbitmq-rpm
    baseurl=https://dl.bintray.com/rabbitmq/rpm/rabbitmq-server/v3.8.x/el/6/
    gpgcheck=0
    repo_gpgcheck=0
    enabled=1
    EOF
    
    
    yum makecache
    
    yum install socat
    
    wget https://github.com/rabbitmq/erlang-rpm/releases/download/v21.3.8.12/erlang-21.3.8.12-1.el7.x86_64.rpm
    rpm -ivh erlang-21.3.8.12-1.el7.x86_64.rpm --force --nodeps
    
    yum install rabbitmq-server

## 1.3 启动rabbitmq服务器 ##

# 设置服务,开机自动启动
    systemctl enable rabbitmq-server
    
    # 启动服务
    systemctl start rabbitmq-server

## 1.4 rabbitmq管理界面 ##

### 1.4.1 启用管理界面 ###

# 开启管理界面插件
    rabbitmq-plugins enable rabbitmq_management
    
    # 防火墙打开 15672 管理端口
    firewall-cmd --zone=public --add-port=15672/tcp --permanent
    firewall-cmd --reload

### 1.4.2 重启RabbitMQ服务 ###

systemctl restart rabbitmq-server

## 1.5 访问 ##

访问服务器的15672端口,例如：[http://192.168.126.129:15672][http_192.168.126.129_15672]

## 1.6 添加用户 ##

### 1.6.1 添加用户 ###

# 添加用户
    rabbitmqctl add_user admin admin
    
    # 新用户设置用户为超级管理员
    rabbitmqctl set_user_tags admin administrator

### 1.6.2 设置访问权限 ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 1]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 2]  
正确修改之后!!!  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 3]

> 用户管理参考：[https://www.cnblogs.com/AloneSword/p/4200051.html][https_www.cnblogs.com_AloneSword_p_4200051.html]

## 1.7 开放客户端连接端口 ##

# 打开客户端连接端口
    firewall-cmd --zone=public --add-port=5672/tcp --permanent
    firewall-cmd --reload

主要端口介绍

*  4369 – erlang发现口
 *  5672 – client端通信口
 *  15672 – 管理界面ui端口
 *  25672 – server间内部通信口

# 二、RabbitMQ 使用场景 #

## 2.1 服务解耦 ##

假设有这样一个场景, 服务A产生数据, 而服务B,C,D需要这些数据, 那么我们可以在A服务中直接调用B,C,D服务,把数据传递到下游服务即可

但是,随着我们的应用规模不断扩大,会有更多的服务需要A的数据,如果有几十甚至几百个下游服务,而且会不断变更,再加上还要考虑下游服务出错的情况,那么A服务中调用代码的维护会极为困难

这是由于服务之间耦合度过于紧密  
![在这里插入图片描述][2020080819003654.png]  
再来考虑用RabbitMQ解耦的情况

A服务只需要向消息服务器发送消息,而不用考虑谁需要这些数据;下游服务如果需要数据,自行从消息服务器订阅消息,不再需要数据时则取消订阅即可  
![解耦][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 4]

## 2.2 流量削峰 ##

假设我们有一个应用,平时访问量是每秒300请求,我们用一台服务器即可轻松应对  
![低流量][20200808190134548.png]  
而在高峰期,访问量瞬间翻了十倍,达到每秒3000次请求,那么单台服务器肯定无法应对,这时我们可以考虑增加到10台服务器,来分散访问压力

但如果这种瞬时高峰的情况每天只出现一次,每次只有半小时,那么我们10台服务器在多数时间都只分担每秒几十次请求,这样就有点浪费资源了  
![在这里插入图片描述][2020080819015631.png]  
这种情况,我们就可以使用RabbitMQ来进行流量削峰,高峰情况下,瞬间出现的大量请求数据,先发送到消息队列服务器,排队等待被处理,而我们的应用,可以慢慢的从消息队列接收请求数据进行处理,这样把数据处理时间拉长,以减轻瞬时压力

这是消息队列服务器非常典型的应用场景  
![在这里插入图片描述][20200808190216400.png]

## 2.3 异步调用 ##

考虑定外卖支付成功的情况

支付后要发送支付成功的通知,再寻找外卖小哥来进行配送,而寻找外卖小哥的过程非常耗时,尤其是高峰期,可能要等待几十秒甚至更长

这样就造成整条调用链路响应非常缓慢  
![在这里插入图片描述][20200808190247377.png]  
而如果我们引入RabbitMQ消息队列,订单数据可以发送到消息队列服务器,那么调用链路也就可以到此结束,订单系统则可以立即得到响应,整条链路的响应时间只有200毫秒左右

寻找外卖小哥的应用可以以异步的方式从消息队列接收订单消息,再执行耗时的寻找操作  
![在这里插入图片描述][20200808190300914.png]

# 三、rabbitmq 基本概念 #

RabbitMQ是一种消息中间件，用于处理来自客户端的异步消息。服务端将要发送的消息放入到队列池中。接收端可以根据RabbitMQ配置的转发机制接收服务端发来的消息。RabbitMQ依据指定的转发规则进行消息的转发、缓冲和持久化操作，主要用在多服务器间或单服务器的子系统间进行通信，是分布式系统标准的配置。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 5]

## 3.1 Exchange ##

接受生产者发送的消息，并根据Binding规则将消息路由给服务器中的队列。ExchangeType决定了Exchange路由消息的行为。在RabbitMQ中，ExchangeType常用的有direct、Fanout和Topic三种。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 6]

## 3.2 Message Queue ##

消息队列。我们发送给RabbitMQ的消息最后都会到达各种queue，并且存储在其中(如果路由找不到相应的queue则数据会丢失)，等待消费者来取。

## 3.3 Binding Key ##

它表示的是Exchange与Message Queue是通过binding key进行联系的，这个关系是固定。

## 3.4 Routing Key ##

生产者在将消息发送给Exchange的时候，一般会指定一个routing key，来指定这个消息的路由规则。这个routing key需要与Exchange Type及binding key联合使用才能生，我们的生产者只需要通过指定routing key来决定消息流向哪里。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70_pic_center]: /images/20221124/515786af27f547b2ac5f70cb5ae22731.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221124/1e6bb21914c747ac9d2515201fb7f3e4.png
[https_download.csdn.net_download_weixin_38305440_12265906]: https://download.csdn.net/download/weixin_38305440/12265906
[https_mobaxterm.mobatek.net_download-home-edition.html]: https://mobaxterm.mobatek.net/download-home-edition.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70]: /images/20221124/abf48201751c49eb8ebfb215d7380faf.png
[http_192.168.126.129_15672]: http://192.168.126.129:15672
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 1]: /images/20221124/a3800056534645aab12787f2d56a2089.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 2]: /images/20221124/eb80d91591884e93bd51e93a9411c8e5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 3]: /images/20221124/4a913a69e3cb433ea60ae0c6cf39e730.png
[https_www.cnblogs.com_AloneSword_p_4200051.html]: https://www.cnblogs.com/AloneSword/p/4200051.html
[2020080819003654.png]: /images/20221124/8457bf7a83544da382b93e028ba0677f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 4]: /images/20221124/b0add46c6e8e4637b8115fb3ad9491f4.png
[20200808190134548.png]: /images/20221124/679cb93a0bdb4b34bde9e52e6db70be1.png
[2020080819015631.png]: /images/20221124/f1f101fc8eda4aa2b06338ca805a0752.png
[20200808190216400.png]: /images/20221124/a359029d7424458384bb2006c16c3b9c.png
[20200808190247377.png]: /images/20221124/a2261db0723a4b9d919f65e1549ff721.png
[20200808190300914.png]: /images/20221124/4210e85647644c0aaac21b870463f72e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 5]: /images/20221124/ab90a88ca90c44ccaa590b258084845c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70 6]: /images/20221124/f2bf192667fb49a2a929dd0ae907210d.png