Fork me on GitHub

RabbitMQ集群部署

字数统计: 1.4k字   |   阅读时长≈ 5分

RabbitMQ集群部署

  • 环境
1
2
3
4
5
6
7
8
9
主机名如下：
10.0.10.21    rabbitmq1
10.0.10.22    rabbitmq2
10.0.10.23    rabbitmq3

vim /etc/hosts
10.0.10.21    rabbitmq1
10.0.10.22    rabbitmq2
10.0.10.23    rabbitmq3
  • 在这三台机器上部署RabbitMQ

参考：RabbitMQ原理与单机部署

  • 首先启动rabbitmq1上启动服务
1
2
用来生成.erlang.cookie文件
[root@rabbitmq1 ~]# rabbitmq-server -detached
  • 读取其中一个节点的cookie,并复制到其他节点
1
2
3
4
5
6
7
8
erlang.cookie是erlang实现分布式的必要文件，erlang分布式的每个节点上要保持相同的.erlang.cookie文件，同时保证文件的权限是400。
cookie存放在/var/lib/rabbitmq/.erlang.cookie或者$HOME/.erlang.cookie中。

我文件位置在$HOME/.erlang.cookie
[root@rabbitmq1 ~]# scp .erlang.cookie root@10.0.10.22:/root
[root@rabbitmq1 ~]# scp .erlang.cookie root@10.0.10.23:/root

注：cookie相当于令牌，集群中的RabbitMQ节点需要通过交换密钥令牌获得相互认证
  • 逐个启动节点
1
rabbitmq-server -detached  #以守护方式运行rabbitmq-server
  • 服务开机启动
1
略
  • 验证各节点状态
1
2
rabbitmqctl status  #验证单个服务
rabbitmqctl cluster_status  #验证集群,可以看到目前仍是单节点集群状态。

使用rabbitmqctl方式配置集群

以rabbitmq1为主节点

1
2
3
4
5
6
7
8
rabbitmq2上操作如下：

rabbitmqctl stop_app 
rabbitmqctl reset 
rabbitmqctl join_cluster rabbit@rabbitmq1 
rabbitmqctl start_app 

注：rabbit为RabbitMQ具有管理权限的管理用户
1
2
3
4
5
6
rabbitmq3上操作如下：

rabbitmqctl stop_app 
rabbitmqctl reset 
rabbitmqctl join_cluster rabbit@rabbitmq1 
rabbitmqctl start_app

验证RabbitMQ集群

1
2
3
4
5
6
7
8
9
rabbitmqctl cluster_status   查看集群的状态信息

出现类似以下信息说明成功：
Cluster status of node rabbit@rabbitmq1 ...
[{nodes,[{disc,[rabbit@rabbitmq1,rabbit@rabbitmq2,rabbit@rabbitmq3]}]},
 {running_nodes,[rabbit@rabbitmq3,rabbit@rabbitmq2,rabbit@rabbitmq1]},
 {cluster_name,<<"rabbit@rabbitmq1">>},
 {partitions,[]},
 {alarms,[{rabbit@rabbitmq3,[]},{rabbit@rabbitmq2,[]},{rabbit@rabbitmq1,[]}]}]

注：如果关闭了集群中的所有节点，则需要确保在启动的时候最后关闭的那个节点是第一个启动的。

RabbitMQ集群节点类型

1
2
3
4
5
6
7
8
9
10
共分为2种：磁盘节点和内存节点。内存节点将所有的队列、交换器、绑定关系、用户、权限等元数据信息存储在内存中（提高性能,重启丢失），而磁盘节点则将这些信息存储在硬盘中。rabbitmq默认创建的是硬盘节点，而且它要求集群中至少有一个磁盘节点，所有其他节点都可以是内存节点，但为了可靠性可以配置为至少2个磁盘节点或都为磁盘节点。
rabbitmqctl cluster_status命令结果中，disc表示磁盘节点，ram表示内存节点。

- 节点加入集群时指定为内存节点
  rabbitmqctl join_cluster rabbit@rabbitmq1  --ram
- 已加入集群的节点更改节点类型为内存节点
  rabbitmqctl stop_app
  rabbitmqctl change_cluster_node_type ram
  rabbitmqctl start_app
  rabbitmqctl cluster_status

从集群中剔除单个节点

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
- 正常方式剔除单个节点
  rabbitmqctl stop_app
  rabbitmqctl reset 
  rabbitmqctl start_app
  注：rabbitmqctl reset命令将清空节点状态,并将其恢复到空白状态。

- 如果集群所有节点非正常关闭，最后一个关闭的节点因某些异常而导致无法启动，则可以通过以下命令将此节点剔除当前集群。
  举例：集群中节点按照node3、node2、node1的顺序关闭,此时如果要启动集群，需要先启动node1
  [node3]# rabbitmqctl stop
  [node2]# rabbitmqctl stop
  [node1]# rabbitmqctl stop
  此时在node2节点中把node1节点剔除当前集群
  [node2]# rabbitmqctl forget_cluster_node rabbit@node1 --offline
  [node2]# rabbitmq-server -detached
  [node2]# rabbitmqctl cluster_status

查看服务日志

1
RabbitMQd 日志默认存放在 $RABBITMQ_HOME/var/log/rabbitmq目录内,一般会出现两个log文件

RabbitMQ镜像队列

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
配置所有节点镜像队列
rabbitmqctl set_policy ha-all "^" '{"ha-mode":"all"}'
配置完成后，通过访问Web页面的Exchanges查看


-----------------------------------参考------------------------------------------
配置镜像队列
rabbitmqctl set_policy --priority 0 --apply-to queues mirror_queue \
"^queue_" '{"ha-mode":"exactly","ha-params":2,"ha-sync-mode":"automatic"}'

参数解释：
ha-mode: 指明镜像队列的模式,有效值为all,exactly,nodes,默认为all
         all表示在集群所有节点上进行镜像; exactly表示在指定个数的节点上进行镜像,节点个数由ha-params指
         定；nodes表示在指定的节点上进行镜像，节点名称通过ha-params指定，节点名称通常类似于
         rabbit@hostname,可通过rabbitmqctl cluster_status命令获取节点名称。
ha-params：配合ha-mode镜像模式进行赋值
ha-sync-mode: 队列中消息的同步方式,有效值为automatic和manual。当ha-sync-mode设置为automatic时，新加入的slave会默认同步已知的镜像队列。

启用RabbitMQ插件

rabbitmq1启用网页插件

1
2
3
4
mkdir -p /etc/rabbitmq   #防报错
rabbitmq-plugins enable rabbitmq_management   #启用网页管理插件,网页管理端口:15672

访问http://10.0.10.21:15672即可, 默认用户guest 密码guest

rabbitmq1添加远程访问用户,这里创建一个openstack用户

1
2
3
4
5
6
7
8
9
10
11
12
默认网页是不允许访问的，需要增加一个用户修改一下权限，代码如下：

添加用户openstack
rabbitmqctl add_user openstack password

添加权限
rabbitmqctl set_permissions -p "/" openstack ".*" ".*" ".*"

修改用户角色
rabbitmqctl set_user_tags openstack administrator

然后就可以远程访问了，然后可直接配置用户权限等信息。

Web访问查看rabbitmq集群

1
2
3
4
使用openstack用户再次访问http://10.0.10.21:15672

注: 如果在Web Overview中的Nodes部分看到“Node statistics not available”的信息，说明在该节点上web管理插件还未启用。在rabbitmq2和rabbitmq3节点上面，分别运行命令即可：
rabbitmq-plugins enable rabbitmq_management

扫一扫，分享到微信

tag:

    缺失模块。
    1、请确保node版本大于6.2
    2、在博客根目录（注意不是yilia-plus根目录）执行以下命令：
    npm i hexo-generator-json-content --save

    3、在根目录_config.yml里添加配置： 

      jsonContent:
    meta: false
    pages: false
    posts:
      title: true
      date: true
      path: true
      text: false
      raw: false
      content: false
      slug: false
      updated: false
      comments: false
      link: false
      permalink: false
      excerpt: false
      categories: false
      tags: true


不论我写了什么...
其实都是错的......