带你从头进行RabbitMQ安装、集群搭建、镜像队列配置和代码验证（上）

前言

不知道说什么好，直接开始吧。本来想采用最新版本的，一想到生产和测试必须版本保持一致，不能随便升级，就只好去下载指定版本的rabbitmq的rpm。

RabbitMQ概念

Broker ：消息中间件的服务节点，RabbitMQ的一个服务实例，也可以看做是RabbitMQ的一台服务器

Queue 队列：用于存储消息。kafka不一样，它的消息存在在topic逻辑层面，而队列存储的只是topic中实际存储文件中的编译标识。多个消费者可以同时订阅一个队列，平均分摊(Round-robin轮询)处理消息

Exchange 交换器：生产者将消息发送到交换器，由交换器路由到一个或者多个队列中

• directexchange和queue进行bingding时会设置相应的routingkey。生产者发送消息到交换器时会设定相应的routingkey，如果这两个routingkey相同，消息都会投放到绑定的队列上。
  
• topic 和direct一样，但是支持routingkey的通配符模式，可以有通配符：* , #。 其中 * 表示匹配一个单词， #则表示匹配没有或者多个单词
  
• fanout 直接将发送到该交换器的消息路由到它绑定的一个或者多个队列
  
• header 根据添加的header来判断
  

• x-match == all，匹配所有header
  
• x-match == any, 只需要匹配其中的一个header的值

Routingkey 路由键： 生产者将消息发给交换器的时候， 一般会指定一个 RoutingKey ，用 来指定这个消息的路由规则，而这个 RoutingKey 需要与交换器类型和绑定键 (BindingKey) 合起来使用才能最终生效。在交换器类型和绑定键 (BindingKey) 固定的情况下，生产者可以在发送消息给交换器时， 通过指定 RoutingKey 来决定消息流向哪里

Bindingkey 绑定：通过绑定将交换器与队列关联起来，在绑定的时候一般会指定一绑定键 BindingKey ，这样 RabbitMQ 就知何正确将消息路由到队列了。BindingKey只针对特定交换器才有效。

Producer：消息生产者

Consumer：消息消费者

安装条件

环境

Centos 7.4 3台虚机8c16g

用户权限

需要有sudo权限

安装文件

下载的文件统一在/home/lazasha/download目录下， rabbitmq和erlang对应的版本关系可以参考：

https://www.rabbitmq.com/which-erlang.html

epel: epel-release-7-12.noarch.rpm

下载地址：https://mirrors.tuna.tsinghua.edu.cn/epel/7/x86_64/Packages/e/epel-release-7-12.noarch.rpm

erlang:erlang-22.1.8-1.el7.x86_64.rpm

下载地址：https://github.com/rabbitmq/erlang-rpm/releases

rabbitmq: rabbitmq-server-3.8.2-1.el7.noarch.rpm

下载地址：https://dl.bintray.com/rabbitmq/all/rabbitmq-server/3.8.2/

key: rabbitmq-release-signing-key.asc (我好像后面没有用到)

下载地址：https://github.com/rabbitmq/signing-keys/releases

步骤

epel安装

sudo yum -y install epel-release-7-12.noarch.rpm

erlang安装

sudo yum -y install erlang-22.1.8-1.el7.x86_64.rpm

检查是否安装成功：

rabbitmq安装

在他两台机器上同样操作. 服务缺省端口是5672.

集群搭建

在3台机器上/etc/hosts文件中添加IP和节点名称的对应

10.156.13.92 lchod1392
10.156.13.93 lchod1393
10.156.13.94 lchod1394

把lchod1392上的 cookie文件，赋值到lchod1393、lchod1394节点上，集群环境下各个

节点的cookie必须一致。rpm安装的cookie 文件默认路 径为

/var/lib/rabbitmq/.erlang.cookie

注意：.erlang.cookie可能有权限问题，可以使用下面的操作：

sudo chmod -R 600 /var/lib/rabbitmq/.erlang.cookie

注意： 拷贝到另外两台机器上后，不管怎么样执行一下下面的命令，改一下.erlang.cookie的owner:

sudo chown -R rabbitmq:rabbitmq /var/lib/rabbitmq/.erlang.cookie

通过Rabbitmqctl来配置集群，集群内部通讯端口是25672

1.首先启动3个节点上的RabbitMQ服务

sudo systemctl start rabbitmq-server

可以使用rabbitmqctl cluster_status 查看各个节点的集群状态

2.以lchod1392为基准，将lchod1393、lchod1394加入到集群中，把3个节点都设置为

硬盘节点了。

lchod1393：

sudo rabbitmqctl stop_app                    //只关闭rabbitmq服务，不关闭erlang服务
    sudo rabbitmqctl reset                       //这个命令我在加集群时没有执行
    sudo rabbitmqctl join_cluster rabbit@lchod1392   //--ram这个参数是内存节点模式，不是就是硬盘节点
    sudo rabbitmqctl start_app

lchod1394：

sudo rabbitmqctl stop_app                    //只关闭rabbitmq服务，不关闭erlang服务
    sudo rabbitmqctl reset                       //这个命令我在加集群时没有执行
    sudo rabbitmqctl join_cluster rabbit@lchod1392   //--ram这个参数是内存节点模式，不是就是硬盘节点
    sudo rabbitmqctl start_app

3.检查集群状态

sudo rabbitmqctl cluster_status

注意点： 如果关闭了集群中的所有节点，确保启动时最后一个关闭的节点第一个启动，否则会有问题。