centos7.3 rabbitmq集群

  • 时间:
  • 浏览:4
  • 来源:大发快3官方网址—大发快3APP下载

13

yancongadmin@node2:~$ cat .erlang.cookie

15

 {running_nodes,[rabbit@node1]},

11

Gracefully halting Erlang VM

Cluster status of node rabbit@node3 ...

2

参考:http://idoall.org/blog/post/lion/15

10

node2:

原应着须要负载均衡器,须要安装并配置 HAProxy

Starting node rabbit@node2 ...

mode tcp

Clustering node rabbit@node2 with rabbit@node1 ...

8

yancongadmin@node3:~$ chmod 777 .erlang.cookie

分别在node1、node2、node3将权限恢复过来:

yancongadmin@node1:~$ cat .erlang.cookie

rabbitmqctl set_policy queue-xxx "^queue" \

10.0.0.232  node2

Cluster status of node rabbit@node3 ...

node2:

Stopping node rabbit@node3 ...

8

 {running_nodes,[rabbit@node3]},

10

Cluster status of node rabbit@node1 ...

5

3

yancongadmin@node2:~$ chmod 777 .erlang.cookie

Stopping node rabbit@node2 ...

7

26

原应着要使用内存节点,则须要使用以下命令:

3

20

1

这行命令在vhost名称为hrsystem创建了一三个 多策略,策略名称为ha-allqueue,策略模式为 all 即克隆到所有节点,含有新增节点,策略正则表达式为 “^” 表示所有匹配所有队列名称。

listen rabbitmq_cluster 0.0.0.0:5672

2

yancongadmin@node3:~$ rabbitmqctl join_cluster rabbit@node1

4

[{nodes,[{disc,[rabbit@node1,rabbit@node2,rabbit@node3]}]},

yancongadmin@node2:~$ rabbitmqctl join_cluster rabbit@node1

rabbitmqctl set_policy ha-xxx "^cn\.xxx" \

5

8

原应着rabbitmq-server启动时,会同时启动节点和应用,它预先设置RabbitMQ应用为standalone模式。要将一三个 多节点加入到现有的集群中,你须要停止你这些应用并将节点设置为原始状况,而且就为加入集群准备好了。原应着使用./rabbitmqctl stop,应用和节点都将被关闭。什么都有有有使用rabbitmqctl stop_app仅仅关闭应用。 

12

6

yancongadmin@node2:~$ rabbitmqctl stop_app

VORMVSAAOFOFEQKTNWBB

10

[{nodes,[{disc,[rabbit@node1,rabbit@node2,rabbit@node3]}]},

yancongadmin@node2:~$ rabbitmqctl cluster_status

5

.erlang.cookie                                                                                     60 %   20     0.0KB/s   00:00

最后分别在确认三台机器上的.erlang.cookie的值是一致的

1

修改 /etc/hosts

4

安装 Erlang、RabbitMQ

yancongadmin@node1:~$ chmod 777 .erlang.cookie

[{nodes,[{disc,[rabbit@node1]}]},

4

yancongadmin@node3:~$ cat .erlang.cookie

将所有队列设置为镜像队列,即队列会被克隆到各个节点,各个节点状况保持一三个 多劲。

7

17

使用Rabbit镜像功能,须要基于RabbitMQ策略来实现,策略是用来控制和修改群集范围的某个vhost队列行为和Exchange行为

 {alarms,[{rabbit@node3,[]}]}]

yancongadmin@node2:

18

yancongadmin@node1:~$ rabbitmq-server -detached

10

 {running_nodes,[rabbit@node1]},

此时 node2 与 node3 也会自动建立连接。

yancongadmin@node1's password:

15

yancongadmin@node3:~$ rabbitmqctl stop_app

 {partitions,[]},

21

7

server   node2 10.0.0.232:5672 check inter 60 0 rise 2 fall 3

本文转自 yanconggod 51CTO博客,原文链接:http://blog.51cto.com/yanconggod/1933960

node3:

yancongadmin@node1:~$ rabbitmqctl cluster_status

VORMVSAAOFOFEQKTNWBB

9

使用detached参数,在后台启动Rabbit Node

13

通过rabbitmqctl cluster_status命令,须要查看和个节点的状况,节点的名称是rabbit@shorthostname,

17

4

9

在任意一三个 多节点上执行:

yancongadmin@node3:~$ rabbitmqctl cluster_status

22

Cluster status of node rabbit@node2 ...

16

1

1

yancongadmin@node1's password:

3

   '{"ha-mode":"exactly","ha-params":2,"ha-sync-mode":"automatic","ha-promote-on-shutdown":"always","ha-sync-batch-size":20}'

6

node1:

 {alarms,[{rabbit@node1,[]}]}]

3

3

6

balance roundrobin

7

11

20

2

     通过 Erlang 的分布式行态(通过 magic cookie 认证节点)进行 RabbitMQ 集群,各 RabbitMQ 服务为对等节点,即每个节点都提供服务给客户端连接,进行消息发送与接收。

10.0.0.231  node1

   '{"ha-mode":"exactly","ha-params":2,"ha-sync-mode":"automatic","ha-promote-on-shutdown":"always","ha-sync-batch-size":20}'

6

node3:

4

6

RabbitMQ镜像功能

RabbitMQ集群概述

 {alarms,[{rabbit@node1,[]}]}]

VORMVSAAOFOFEQKTNWBB

 {cluster_name,<<"rabbit@node2">>},

[{nodes,[{disc,[rabbit@node1,rabbit@node2]}]},{alarms,[{rabbit@node1,[]}]}]

node1:

8

2

1

1

 {cluster_name,<<"rabbit@node1">>},

设置 Erlang Cookie

2

类似:

node2:

5

1

 {alarms,[{rabbit@node2,[]}]}]

node3:

13

 {cluster_name,<<"rabbit@node1">>},

4

 {partitions,[]},

Stopping and halting node rabbit@node1 ...

4

node3:

2

2

集群配置好后,须要在 RabbitMQ 任意节点上执行 rabbitmqctl cluster_status 来查看是是不是集群配置成功。

yancongadmin@node2:~$ rabbitmqctl set_policy -p hrsystem ha-allqueue "^message" '{"ha-mode":"all"}'

yancongadmin@node2:~$ rabbitmqctl cluster_status

5

10.0.0.233  node3

15

yancongadmin@node1:~$ rabbitmqctl stop

19

14

 {running_nodes,[rabbit@node2]},

5

16

12

Setting policy "ha-all" for pattern "^" to "{\"ha-mode\":\"all\"}" with priority "0"

1

11

14

13

 {partitions,[]},

7

2

yancongadmin@node2:~$ scp -r node1:/home/yancongadmin/.erlang.cookie ~/

yancongadmin@node2:~$ rabbitmqctl join_cluster --ram rabbit@node1

1

yancongadmin@node2:~$ rabbitmqctl set_policy -p hrsystem ha-allqueue"^" '{"ha-mode":"all"}'

12

Cluster status of node rabbit@node1 ...

将node1、node2、node3组成集群

19

yancongadmin@node1:~$ rabbitmqctl cluster_status

类似下面的命令,^message 你这些规则要根据买车人修改,你这些是指同步”message”开头的队列名称,亲戚亲戚朋友配置时使用的应用于所有队列,什么都有有有表达式为”^”。

1

14

我使用过的例子,仅供参考:

Starting node rabbit@node3 ...

server   node1 10.0.0.231:5672 check inter 60 0 rise 2 fall 3 

1

yancongadmin@node2:~$ rabbitmqctl start_app

Clustering node rabbit@node3 with rabbit@node1 ...

[{nodes,[{disc,[rabbit@node2]}]},

.erlang.cookie                                                                                     60 %   20     0.0KB/s   00:00

15

27

     那些节点通过 RabbitMQ HA 队列(镜像队列)进行消息队列行态克隆。本方案中搭建 3 个节点,而且都是磁盘节点(所有节点状况保持一致,节点完正对等),而且我有任何一三个 多节点有有助于工作,RabbitMQ 集群对外就能提供服务。

2

9

12

18

 {partitions,[]},

server   node3 10.0.0.233:5672 check inter 60 0 rise 2 fall 3

本文演示的实例是用源码安装,原应着你这些文件权限是 60 ,什么都有有有须要先修改 node2、node3 中的该文件权限为 777:

3

25

node1:

1

8

11

http://yanconggod.blog.51cto.com/1351649/19360 9

node2:

14

 {cluster_name,<<"rabbit@node3">>},

[{nodes,[{disc,[rabbit@node3]}]},

加入集群 3 个节点的对应关系:

1

yancongadmin@node3:~$ rabbitmqctl start_app

  RabbitMQ节点之间和命令行工具 (e.g. rabbitmqctl)是使用Cookie互通的,Cookie是一组随机的数字+字母的字符串。当RabbitMQ服务器启动的之前 ,Erlang VM会自动创建一三个 多随机内容的Cookie文件。原应着是通过yum源安装RabbitMQ得话,Erlang Cookie 文件在/var/lib/rabbitmq/.erlang.cookie。原应着是通过源码安装的RabbitMQ,Erlang Cookie文件$HOME/.erlang.cookie。

16

3

6

5

4

yancongadmin@node3:~$ scp -r node1:/home/yancongadmin/.erlang.cookie ~/

23

9

yancongadmin@node1:~$ chmod 60  .erlang.cookie

 {alarms,[{rabbit@node1,[]}]}]

yancongadmin@node3:~$ rabbitmqctl cluster_status

24

Cluster status of node rabbit@node2 ...

3