RabbitMQ教程_2 RabbitMQ 安装

淡淡的烟草味﹌ 2023-01-03 14:07 150阅读 0赞

https://gitee.com/fakerlove/rabbitmq

### 文章目录 ###

*  2.RabbitMQ 的安装
 *   *  2.1 RabbitMQ
     *   *  简介
         *  应用场景
         *  AMQP协议
         *  常用交换器
     *  2.2 RabbitMQ 的安装
     *   *  2.2.1 下载
         *  2.2.2 下载的安装包
         *  2.2.3 安装步骤
         *   *  1.将rabbitmq安装包上传到linux系统中
             *  2.安装依赖包
             *   *  rpm安装方式
                 *  yum 安装方式
             *  3.安装RabbitMQ安装包(需要联网)
             *  4.复制配置文件
             *  5.查看配置文件位置
             *  6.修改配置文件(参见下图:)
             *  7.执行如下命令,启动rabbitmq中的插件管理
             *  8.启动RabbitMQ的服务
             *  9.查看服务状态(见下图:)
             *  10.关闭防火墙服务
             *  11.访问web管理界面
             *  12.登录管理界面
     *  2.3 docker 安装 rabbitmq
 *

# 2.RabbitMQ 的安装 #

## 2.1 RabbitMQ ##

### 简介 ###

> 基于`AMQP`协议，erlang语言开发，是部署最广泛的开源消息中间件,是最受欢迎的开源消息中间件之一。

![image-20190925215603036][]

`官网`: https://www.rabbitmq.com/

`官方教程`: https://www.rabbitmq.com/\#getstarted

# AMQP 协议
     		AMQP（advanced message queuing protocol）`在2003年时被提出，最早用于解决金融领不同平台之间的消息传递交互问题。顾名思义，AMQP是一种协议，更准确的说是一种binary wire-level protocol（链接协议）。这是其和JMS的本质差别，AMQP不从API层进行限定，而是直接定义网络交换的数据格式。这使得实现了AMQP的provider天然性就是跨平台的。以下是AMQP协议模型:

![image-20200311182438041][]

### 应用场景 ###

RabbitMQ除了像兔子一样跑的很快以外，还有这些特点：

*  开源、性能优秀，稳定性保障
 *  提供可靠性消息投递模式、返回模式
 *  与Spring AMQP完美整合，API丰富
 *  集群模式丰富，表达式配置，HA模式，镜像队列模型
 *  保证数据不丢失的前提做到高可靠性、可用性

MQ典型应用场景：

*  异步处理。把消息放入消息中间件中，等到需要的时候再去处理。
 *  流量削峰。例如秒杀活动，在短时间内访问量急剧增加，使用消息队列，当消息队列满了就拒绝响应，跳转到错误页面，这样就可以使得系统不会因为超负载而崩溃。
 *  日志处理
 *  应用解耦。假设某个服务A需要给许多个服务（B、C、D）发送消息，当某个服务（例如B）不需要发送消息了，服务A需要改代码再次部署；当新加入一个服务（服务E）需要服务A的消息的时候，也需要改代码重新部署；另外服务A也要考虑其他服务挂掉，没有收到消息怎么办？要不要重新发送呢？是不是很麻烦，使用MQ发布订阅模式，服务A只生产消息发送到MQ，B、C、D从MQ中读取消息，需要A的消息就订阅，不需要了就取消订阅，服务A不再操心其他的事情，使用这种方式可以降低服务或者系统之间的耦合。

### AMQP协议 ###

提到RabbitMQ，就不得不提AMQP协议。AMQP协议是具有现代特征的二进制协议。是一个提供统一消息服务的应用层标准高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。

先了解一下AMQP协议中间的几个重要概念：

*  Server：接收客户端的连接，实现AMQP实体服务。
 *  Connection：连接，应用程序与Server的网络连接，TCP连接。
 *  Channel：信道，消息读写等操作在信道中进行。客户端可以建立多个信道，每个信道代表一个会话任务。
 *  Message：消息，应用程序和服务器之间传送的数据，消息可以非常简单，也可以很复杂。有Properties和Body组成。Properties为外包装，可以对消息进行修饰，比如消息的优先级、延迟等高级特性；Body就是消息体内容。
 *  Virtual Host：虚拟主机，用于逻辑隔离。一个虚拟主机里面可以有若干个Exchange和Queue，同一个虚拟主机里面不能有相同名称的Exchange或Queue。
 *  Exchange：交换器，接收消息，按照路由规则将消息路由到一个或者多个队列。如果路由不到，或者返回给生产者，或者直接丢弃。RabbitMQ常用的交换器常用类型有direct、topic、fanout、headers四种，后面详细介绍。
 *  Binding：绑定，交换器和消息队列之间的虚拟连接，绑定中可以包含一个或者多个RoutingKey。
 *  RoutingKey：路由键，生产者将消息发送给交换器的时候，会发送一个RoutingKey，用来指定路由规则，这样交换器就知道把消息发送到哪个队列。路由键通常为一个“.”分割的字符串，例如“com.rabbitmq”。
 *  Queue：消息队列，用来保存消息，供消费者消费。

> 我们完全可以直接使用 Connection 就能完成信道的工作，为什么还要引入信道呢?

> 试想这样一个场景， 一个应用程序中有很多个线程需要从 RabbitMQ 中消费消息，或者生产消息，那么必然需要建立很多个 Connection，也就是许多个 TCP 连接。然而对于操作系统而言，建立和销毁 TCP 连接是非常昂贵的开销，如果遇到使用高峰，性能瓶颈也随之显现。 RabbitMQ 采用 TCP 连接复用的方式，不仅可以减少性能开销，同时也便于管理 。

下图是AMQP的协议模型：

![img][]

正如图中所看到的，AMQP协议模型有三部分组成：生产者、消费者和服务端。

生产者是投递消息的一方，首先连接到Server，建立一个连接，开启一个信道；然后生产者声明交换器和队列，设置相关属性，并通过路由键将交换器和队列进行绑定。同理，消费者也需要进行建立连接，开启信道等操作，便于接收消息。

接着生产者就可以发送消息，发送到服务端中的虚拟主机，虚拟主机中的交换器根据路由键选择路由规则，然后发送到不同的消息队列中，这样订阅了消息队列的消费者就可以获取到消息，进行消费。

最后还要关闭信道和连接。

RabbitMQ是基于AMQP协议实现的，其结构如下图所示，和AMQP协议简直就是一模一样。

![img][img 1]

### 常用交换器 ###

RabbitMQ常用的交换器类型有direct、topic、fanout、headers四种。

Direct Exchange

该类型的交换器将所有发送到该交换器的消息被转发到RoutingKey指定的队列中，也就是说路由到BindingKey和RoutingKey完全匹配的队列中。

![img][img 2]

Topic Exchange

该类型的交换器将所有发送到Topic Exchange的消息被转发到所有RoutingKey中指定的Topic的队列上面。

Exchange将RoutingKey和某Topic进行模糊匹配，其中“*”用来匹配一个词，“\#”用于匹配一个或者多个词。例如“com.\#”能匹配到“com.rabbitmq.oa”和“com.rabbitmq”；而"login.*"只能匹配到“com.rabbitmq”。

![img][img 3]

Fanout Exchange

该类型不处理路由键，会把所有发送到交换器的消息路由到所有绑定的队列中。优点是转发消息最快，性能最好。

![img][img 4]

Headers Exchange

该类型的交换器不依赖路由规则来路由消息，而是根据消息内容中的headers属性进行匹配。headers类型交换器性能差，在实际中并不常用。

## 2.2 RabbitMQ 的安装 ##

### 2.2.1 下载 ###

rabbitmq 是基于 erlang 编程语言的，所以需要环境的

首先注意系统版本，自己的服务器是linux 还是windows

下面的网址是下载erlang 的

https://www.erlang-solutions.com/resources/download.html

下面的比较慢

https://www.erlang.org/downloads

下面是下载rabbitmq 的

https://www.rabbitmq.com/download.html

![image-20190925220115235][]

> `最新版本`: 3.7.18

### 2.2.2 下载的安装包 ###

rabbit 如果能够运行，需要两个东西 erlang 和socket 的包

![image-20190925220343521][]

> `注意`:这里的安装包是centos7安装的包

### 2.2.3 安装步骤 ###

#### 1.将rabbitmq安装包上传到linux系统中 ####

erlang-22.0.7-1.el7.x86_64.rpm
    rabbitmq-server-3.7.18-1.el7.noarch.rpm

#### 2.安装依赖包 ####

##### rpm安装方式 #####

就需要三个rpm 格式的东西

rpm -ivh erlang-22.0.7-1.el7.x86_64.rpm
    rpm -ivh socat-1.7.3.2-2.el7.x86_64.rpm
    rpm -ivh rabbitmq-server-3.7.18-1.el7.noarch.rpm

##### yum 安装方式 #####

*  安装erlang需要的依赖环境

# 添加仓库
    curl -s https://packagecloud.io/install/repositories/rabbitmq/erlang/script.rpm.sh | sudo bash
    Detected operating system as centos/8.
    # 安装erlang
    dnf install erlang

*  安装socat

wget http://www.dest-unreach.org/socat/download/socat-1.7.0.1.tar.gz
    tar -zxvf socat-1.7.0.1.tar.gz
    cd socat-1.7.0.1 
    ./configure --disable-fips 
    make && make install

# 如果是centos 8 
    http://www.dest-unreach.org/socat/download/socat-1.7.4.0.tar.gz

*  安装 logrotate

yum -y install logrotate

*  问题
    
    centos 7 的socat.rpm
    
        wget http://repo.iotti.biz/CentOS/7/x86_64/socat-1.7.3.2-5.el7.lux.x86_64.rpm

二、导入密钥

rpm --import https://github.com/rabbitmq/signing-keys/releases/download/2.0/rabbitmq-release-signing-key.asc

三、在/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/8/
    gpgcheck=0
    repo_gpgcheck=0
    enabled=1

centos7 的配置

[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

#### 3.安装RabbitMQ安装包(需要联网) ####

yum install -y rabbitmq-server-3.7.18-1.el7.noarch.rpm

#### 4.复制配置文件 ####

cp /usr/share/doc/rabbitmq-server-3.7.18/rabbitmq.config.example /etc/rabbitmq/rabbitmq.config

> 注意:默认安装完成后配置文件模板在:/usr/share/doc/rabbitmq-server-3.7.18/rabbitmq.config.example目录中,需要  
> 将配置文件复制到/etc/rabbitmq/目录中,并修改名称为rabbitmq.config

#### 5.查看配置文件位置 ####

ls /etc/rabbitmq/rabbitmq.config

#### 6.修改配置文件(参见下图:) ####

vim /etc/rabbitmq/rabbitmq.config

\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-3yUMGKco-1610088624249)(picture/image-20190925222230260-3836271.png)\]

将上图中配置文件中红色部分去掉`%%`,以及最后的`,`逗号 修改为下图:

\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-gxvd9y5b-1610088624250)(picture/image-20190925222329200-3836312.png)\]

#### 7.执行如下命令,启动rabbitmq中的插件管理 ####

rabbitmq-plugins enable rabbitmq_management

> 出现如下说明:  
> Enabling plugins on node rabbit@localhost:  
> rabbitmq\_management  
> The following plugins have been configured:  
> rabbitmq\_management  
> rabbitmq\_management\_agent  
> rabbitmq\_web\_dispatch  
> Applying plugin configuration to rabbit@localhost…  
> The following plugins have been enabled:  
> rabbitmq\_management  
> rabbitmq\_management\_agent  
> rabbitmq\_web\_dispatch
> 
> set 3 plugins.  
> Offline change; changes will take effect at broker restart.

#### 8.启动RabbitMQ的服务 ####

systemctl start rabbitmq-server
    systemctl restart rabbitmq-server
    systemctl stop rabbitmq-server

#### 9.查看服务状态(见下图:) ####

systemctl status rabbitmq-server

● rabbitmq-server.service - RabbitMQ broker
         Loaded: loaded (/usr/lib/systemd/system/rabbitmq-server.service; disabled; vendor preset: disabled)
         Active: active (running) since 三 2019-09-25 22:26:35 CST; 7s ago
       Main PID: 2904 (beam.smp)
         Status: "Initialized"
         CGroup: /system.slice/rabbitmq-server.service
                 ├─2904 /usr/lib64/erlang/erts-10.4.4/bin/beam.smp -W w -A 64 -MBas ageffcbf -MHas ageffcbf -
                 MBlmbcs...
                 ├─3220 erl_child_setup 32768
                 ├─3243 inet_gethost 4
                 └─3244 inet_gethost 4
          .........

![image-20190925222743776][]

#### 10.关闭防火墙服务 ####

systemctl disable firewalld
    Removed symlink /etc/systemd/system/multi-user.target.wants/firewalld.service.
    Removed symlink /etc/systemd/system/dbus-org.fedoraproject.FirewallD1.service.
    systemctl stop firewalld

#### 11.访问web管理界面 ####

http://10.15.0.8:15672/

![image-20190926194738708][]

#### 12.登录管理界面 ####

username:  guest
    password:  guest

![image-20190926194954822][]

## 2.3 docker 安装 rabbitmq ##

下载镜像，并且运行

docker run -d -p 5672:5672 -p 15672:15672 --name rabbitmq rabbitmq:management