RabbitMQ

RabbitMQ(一)安装篇

1. RabbitMQ 的介绍

➢ 什么是 MQ？

MQ 全称为 Message Queue, 消息队列（MQ）是一种应用程序对应用程序的通信方法。

➢ 要解决什么样的问题？

在项目中，将一些无需即时返回且耗时的 *** 作提取出来，进行了异步处理，而这种异步处理的方式大大的节省了服务器的请求响应时间，从而提高了系统的吞吐量。

2. RabbitMQ 安装与使用

安装 RabbitMQ

1. 安装 Linux 以及必要的依赖包（Centos7）

1.准备

Linux系统的一些基本工具（安装简洁版Linux需要安装这些工具）

yum install lrzsz wget vim unzip net-tools -y

安装RabbitMQ所需要的依赖包

yum install gcc glibc-devel make ncurses-devel openssl-devel xmlto

2.下载安装包

wget https://github.com/rabbitmq/rabbitmq-server/releases/download/v3.7.2/rabbitmq-server-3.7.2-1.el7.noarch.rpm

wget http://erlang.org/download/otp_src_19.3.tar.gz

2. 下载 RabbitMQ 的安装包

3.安装RabbitMQ

解压erlang 源码包

tar -zxvf otp_src_19.2.tar.gz（应该用这个tar -xvf otp_src_19.3.tar.tar 最终测应使用tar -vxf memcached-1.4.34.tar.gz）

手动创建erlang 的安装目录

mkdir /usr/local/erlang

进入erlang的解压目录

cd otp_src_19.3

配置erlang的安装信息

 ./configure --prefix=/usr/local/erlang --without-javac

 编译并安装

make && make install

配置环境变量

vim /etc/profile

将这些配置填写到profile文件的最后

ERL_HOME=/usr/local/erlang

PATH=$ERL_HOME/bin:$PATH

export ERL_HOME PATH

启动环境变量配置文件

source /etc/profile

安装RabbitMQ

rpm -ivh --nodeps rabbitmq-server-3.7.2-1.el7.noarch.rpm

4.服务启动 rabbitmq-server start

这里可能会出现错误，错误原因是/var/lib/rabbitmq/.erlang.cookie文件不够

解决方案

chown rabbitmq:rabbitmq /var/lib/rabbitmq/.erlang.cookie

chmod 400 /var/lib/rabbitmq/.erlang.cookie

启动之后界面:

3. 安装，修改相关配置

查看启动进程:

ps -ef | grep rabbit

5.使用浏览器登录RabbitMQ的管理平台：http://RabbitMQ服务器IP:15672

RabbitMQ默认情况无法直接访问管理平台

解决方案

添加管理台的插件（用于Web浏览器管理RabbitMQ）

rabbitmq-plugins enable rabbitmq_management

使用默认用户名guest登录

账号：guest

密码：guest

注意：这里guest只允许本机登录访问需要创建用户并授权远程访问命令如下

rabbitmqctl add_user root root

rabbitmqctl set_user_tags root administrator

rabbitmqctl set_permissions -p / root '.*' '.*' '.*'

打开浏览器，输入http://RabbitMQ服务器IP:15672

如果你能正常启动，却打不开RabbitMQ的管理平台，请检查防火墙是否关闭，centos7关防火墙:

centos从7开始默认用的是firewalld，这个是基于iptables的，虽然有iptables的核心，但是iptables的服务是没安装的。

所以你只要停止firewalld服务即可：

sudo systemctl stop firewalld.service && sudo systemctl disable firewalld.service

1-4 RabbitMQ 核心概念

RabbitMQ 结构图

AMQP 核心概念

➢Server：又称 Broker 接收客户端的连接，实现 AMQP 实体服务

➢ Connection：链接，用于应用程序链接到 Broker

➢ Channel：网络通道，Channel 是进行消息读写的一个通道每一个 Channel 都表示一个会话，有点类似我们之前的Session 概念

➢Message：消息，消息就是我们真正用来进行传输的数据，Message 由两部分组成，Properties 和 Body，Properties用于对消息就行修饰，比如优先级或是否持久等，Body则是消息数据的主体

➢ Virtual host：虚拟地址，用于进行逻辑隔离，一个 Server拥有过多个 Vitual hsot，一个 Virual hsot 会拥有多个Exchange（交换机）和 Queue（队列）

➢ Exchange：交换机，用于具体接收消息并将消息根据绑定路由 key 存入到指定的队列中

➢ Binding：绑定，就是将 Exchange 和 Queue 链接在一起，通过一个 Routing key 进行绑定

➢ Routing key：路由规则，消息发送到 Exchang 后会根据这个规则将消息存入对应的 Queue

➢ Queue：队列也称 Message Queue 简称 MQ，用于存放消息，并使用队列的结构先进先出、后进后出

RabbiMQ 执行流程