消息队列之RabbitMQ的安装配置

一，前言

RabbitMQ是由erlang语言开发，基于AMQP（Advanced Message Queue 高级消息队列协议）协议实现的消息队列，它是一种应用程序之间的通信方法，消息队列在分布式系统开发中应用非常广泛。点击跳转RabbitMQ官方地址

RabbitMQ提供了6种模式：

简单模式，work模式，Publish/Subscribe发布与订阅模式，Routing路由模式，Topics主题模式，RPC远程调用模式（远程调用，不太算MQ；暂不作介绍）
点击跳转官网对应模式介绍
在这里插入图片描述
2007年，Rabbit 技术公司基于 AMQP 标准开发的 RabbitMQ 1.0 发布。RabbitMQ 采用 Erlang 语言开发。Erlang 语言由 Ericson 设计，专门为开发高并发和分布式系统的一种语言，在电信领域使用广泛。

RabbitMQ 基础架构如下图：

在这里插入图片描述

RabbitMQ 中的相关概念

Broker：接收和分发消息的应用，RabbitMQ Server就是 Message Broker
Virtual host:出于多租户和安全因素设计的，把 AMQP 的基本组件划分到一个虚拟的分组中，类似于网络中的 namespace 概念。当多个不同的用户使用同一个 RabbitMQ server 提供的服务时，可以划分出多个vhost，每个用户在自己的 vhost 创建exchange／queue 等。
Connection：publisher／consumer 和 broker 之间的 TCP 连接。
Channel：如果每一次访问 RabbitMQ 都建立一个 Connection，在消息量大的时候建立 TCP Connection的开销将是巨大的，效率也较低。Channel 是在 connection 内部建立的逻辑连接，如果应用程序支持多线程，通常每个thread创建单独的 channel 进行通讯，AMQP method 包含了channel id 帮助客户端和message broker 识别 channel，所以 channel 之间是完全隔离的。Channel 作为轻量级的 Connection 极大减少了操作系统建立 TCP connection 的开销。
Exchange：message 到达 broker 的第一站，根据分发规则，匹配查询表中的 routing key，分发消息到queue 中去。常用的类型有：direct (point-to-point)，topic (publish-subscribe) and fanout (multicast)。
Queue：存储消息的容器，消息最终被送到这里，等待 consumer 取走。
Binding：exchange 和 queue 之间的虚拟连接，binding 中可以包含 routing key。Binding 信息被保存到 exchange 中的查询表中，用于 message 的分发依据。

二，下载安装和配置RabbitMQ

下载

下载Erlang的rpm包
RabbitMQ是Erlang语言编写，所以Erlang环境必须要有，注：Erlang环境一定要与RabbitMQ版本匹配：点击查看版本匹配关系
下载socat的rpm包
rabbitmq安装依赖于socat，所以需要下载socat。
点击下载：socat下载地址
下载RabbitMQ的rpm包
RabbitMQ下载地址：下载（根据自身需求及匹配关系，下载对应rpm包）例如：rabbitmq-server-3.8.1-1.el7.noarch.rpm
也可从github等网站下载。

安装配置

安装Erlang、Socat、RabbitMQ
①rpm -ivh erlang-21.3.8.9-1.el7.x86_64.rpm
②rpm -ivh socat-1.7.3.2-1.el6.lux.x86_64.rpm
在安装rabbitmq之前需要先安装socat，否则，报错。
可以采用yum安装方式：yum install socat，我们这里采用rpm安装方式
③rpm -ivh rabbitmq-server-3.8.1-1.el7.noarch.rpm
启用管理插件
/usr/lib/rabbitmq/bin/
rabbitmq-plugins enable rabbitmq_management
修改主机名
（1）vim /etc/hostname

（2）vim /etc/hosts
启动RabbitMQ
启动：systemctl start rabbitmq-server.service
查看状态systemctl status rabbitmq-server.service
重启：systemctl restart rabbitmq-server.service
关闭：systemctl stop rabbitmq-server.service
查看进程
ps -ef | grep rabbitmq

测试

关闭防火墙：systemctl stop firewalld.service
在web浏览器中输入地址：http://虚拟机ip:15672/
输入默认账号密码： guest ： guest，guest用户默认不允许远程连接。

增加自定义账号
l 添加管理员账号密码：rabbitmqctl add_user admin admin
l 分配账号角色：rabbitmqctl set_user_tags admin administrator
l 修改密码：rabbitmqctl change_password admin 123456
l 查看用户列表：rabbitmqctl list_users
使用新账号登录，成功界面
在这里插入图片描述

管理界面标签页介绍
l overview：概览
l connections：无论生产者还是消费者，都需要与RabbitMQ建立连接后才可以完成消息的生产和消费，在这里可以查看连接情况
l channels：通道，建立连接后，会形成通道，消息的投递获取依赖通道。
l Exchanges：交换机，用来实现消息的路由
l Queues：队列，即消息队列，消息存放在队列中，等待消费，消费后被移除队列。
端口：
l 5672：rabbitMq的编程语言客户端连接端口
l 15672：rabbitMq管理界面端口
l 25672：rabbitMq集群的端口