一文读懂运维消息中间件之RabbitMQ

虚拟主机，表示一批交换器、消息队列和相关对象。虚拟主机是共享相同的身份认证和加密环境的独立服务器域。每个 vhost 本质上就是一个 mini 版的 RabbitMQ 服务器，拥有自己的队列、交换器、绑定和权限机制。vhost 是 AMQP 概念的基础，必须在连接时指定，RabbitMQ 默认的 vhost 是 / 。

(10)、Broker

表示消息队列服务器实体。

3、AMQP中的消息路由

AMQP 中消息的路由过程和 Java 开发者熟悉的 JMS 存在一些差别，AMQP 中增加了 Exchange 和 Binding 的角色。生产者把消息发布到 Exchange 上，消息最终到达队列并被消费者接收，而 Binding 决定交换器的消息应该发送到那个队列。

Exchange分发消息时根据类型的不同分发策略有区别，目前共三种常见类型：direct、fanout、topic 。

(1)、direct

消息中的路由键（routing key）如果和 Binding 中的 binding key 一致，交换器就将消息发到对应的队列中。路由键与队列名完全匹配，如果一个队列绑定到交换机要求路由键为“dog”，则只转发 routing key 标记为“dog”的消息，不会转发“dog.puppy”，也不会转发“dog.guard”等等。它是完全匹配、单播的模式。

(2)、fanout

每个发到 fanout 类型交换器的消息都会分到所有绑定的队列上去。fanout 交换器不处理路由键，只是简单的将队列绑定到交换器上，每个发送到交换器的消息都会被转发到与该交换器绑定的所有队列上。很像子网广播，每台子网内的主机都获得了一份复制的消息。fanout 类型转发消息是最快的。

(3)、topic

topic 交换器通过模式匹配分配消息的路由键属性，将路由键和某个模式进行匹配，此时队列需要绑定到一个模式上。它将路由键和绑定键的字符串切分成单词，这些单词之间用点隔开。它同样也会识别两个通配符：符号“#”和符号“”。#匹配0个或多个单词，匹配不多不少一个单词。

(二)、RabbitMQ搭建模式

端口号	作用
5672	消息中间内部通讯的端口号
15672	rabbitmq管理平台端口号
25672	rabbitmq集群的端口号
4369	epmd进程，是Erlang Port Mapper Daemon的缩写，在Erlang集群中相当于dns的作用。

单机搭建部署过程

(1）安装Erlang环境

步骤一：安装相关依赖

[root@localhost ~]# yum -y install gcc glibc-devel make ncurses-devel openssl-devel xmlto perl wget gtk2-devel binutils-devel xz

步骤二：下载Erlang压缩包(官网下，很慢)

[root@localhost ~]# cd /usr/local/src/

[root@localhost src]# wget http://erlang.org/download/otpsrc22.0.tar.gz

步骤三：创建Erlang安装目录

[root@localhost src]# mkdir -p /usr/local/erlang

步骤四：解压、编译、安装Erlang

解压：

[root@localhost src]# tar -zxvf otpsrc22.0.tar.gz

[root@localhost src]# cd otpsrc22.0

编译：

[root@localhost otpsrc22.0]# ./configure --prefix=/usr/local/erlang

[root@localhost otpsrc22.0]# make install

步骤五：测试是否安装成功

[root@localhost otpsrc22.0]# ll /usr/local/erlang/bin/

步骤六：添加至环境变量

[root@localhost otpsrc22.0]# echo "export PATH=$PATH:/usr/local/erlang/bin" >> /etc/profile

[root@localhost otpsrc22.0]# source /etc/profile

[root@localhost otpsrc22.0]# erl

Erlang安装成功！

(2）安装RabbitMQ

步骤一：下载RabbitMQ

[root@localhost src]# wget https://github.com/rabbitmq/rabbitmq-server/releases/download/v3.7.15/rabbitmq-server-generic-unix-3.7.15.tar.xz

步骤二：解压rabbitmq-server-generic-unix-3.7.15.tar.xz

[root@localhost src]# xz -d rabbitmq-server-generic-unix-3.7.15.tar.xz

[root@localhost src]# tar -xvf rabbitmq-server-generic-unix-3.7.15.tar

步骤三：将解压后的路径移至/usr/local路径下，命名为rabbitmq

[root@localhost src]# mv rabbitmq_server-3.7.15/ /usr/local/rabbitmq

步骤四：配置环境变量

[root@localhost sbin]# echo "export PATH=$PATH:/usr/local/rabbitmq/sbin" >> /etc/profile

[root@localhost sbin]# source /etc/profile

步骤五：启动RabbitMQ

[root@localhost rabbitmq]# rabbitmq-server -detached

步骤六：开启web插件

[root@localhost rabbitmq]# rabbitmq-plugins enable rabbitmq_management

打开浏览器：http://192.168.31.116:15672

步骤七：添加用户

添加：

用户名：lbj

密码：111111

[root@localhost rabbitmq]# rabbitmqctl adduser lbj 111111

查看用户列表

[root@localhost rabbitmq]# rabbitmqctl listusers

配置用户lbj的权限

[root@localhost rabbitmq]# rabbitmqctl setpermissions -p "/" lbj "." "." ".*"

查看用户lbj的权限

[root@localhost rabbitmq]# rabbitmqctl listuser_permissions lbj

配置用户lbj为administrator标签

[root@localhost rabbitmq]# rabbitmqctl setusertags lbj administrator

删除默认用户guest

[root@localhost rabbitmq]# rabbitmqctl delete_user guest

步骤八：使用新创建的用户登录web

打开浏览器：http://192.168.31.116:15672

至此，RabbitMQ安装配置完成！

(三)、常用命令

1、服务管理命令

(1)、后台方式启动RabbitMQ

[root@localhost rabbitmq]# rabbitmq-server -detached

(2)、查询RabbitMQ服务器状态

[root@localhost rabbitmq]# rabbitmqctl status

(3)、关闭RabbitMQ节点

我们知道 RabbitMQ 是用 Erlang 语言写的，在Erlang 中有两个概念：节点和应用程序。节点就是 Erlang 虚拟机的每个实例，而多个 Erlang 应用程序可以运行在同一个节点之上。节点之间可以进行本地通信（不管他们是不是运行在同一台服务器之上）。比如一个运行在节点A上的应用程序可以调用节点B上应用程序的方法，就好像调用本地函数一样。如果应用程序由于某些原因奔溃，Erlang 节点会自动尝试重启应用程序。

如果要关闭整个 RabbitMQ 节点可以用参数 stop

1）关闭本机节点

[root@localhost rabbitmq]# rabbitmqctl stop