centos7.3 rabbitmq集群

  • 时间:
  • 浏览:0

19

14

2

VORMVSAAOFOFEQKTNWBB

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

4

8

6

yancongadmin@node2:~$ cat .erlang.cookie

完后 需要负载均衡器,需要安装并配置 HAProxy

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

3

13

5

4

yancongadmin@node1's password:

node3:

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

listen rabbitmq_cluster 0.0.0.0:5672

node3:

http://yanconggod.blog.51cto.com/1351649/193509

4

 {partitions,[]},

10

15

6

18

21

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

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

例如下面的命令,^message 你这一规则要根据当时人修改,你这一是指同步”message”开头的队列名称,亲戚亲戚让让让我们配置时使用的应用于所有队列,全都表达式为”^”。

5

yancongadmin@node1:~$ rabbitmq-server -detached

10.0.0.232  node2

     那些节点通过 RabbitMQ HA 队列(镜像队列)进行消息队列行态克隆qq好友好友。本方案中搭建 3 个节点,但是都不 磁盘节点(所有节点状况保持一致,节点完整版对等),但是有任何有有一一两个节点不需要 工作,RabbitMQ 集群对外就能提供服务。

RabbitMQ镜像功能

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

1

1

26

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

13

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

4

20

node2:

balance roundrobin

yancongadmin@node1's password:

yancongadmin@node1:~$ rabbitmqctl cluster_status

node1:

 {running_nodes,[rabbit@node2]},

10

VORMVSAAOFOFEQKTNWBB

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

 {partitions,[]},

mode tcp

Cluster status of node rabbit@node3 ...

7

9

node3:

15

Starting node rabbit@node2 ...

yancongadmin@node3:~$ rabbitmqctl cluster_status

12

完后 要使用内存节点,则可不里能 使用以下命令:

将所有队列设置为镜像队列,即队列会被克隆qq好友好友到各个节点,各个节点状况保持总是。

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

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

1

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

7

完后 rabbitmq-server启动时,会共同启动节点和应用,它预先设置RabbitMQ应用为standalone模式。要将有有一一两个节点加入到现有的集群中,你需要停止你这一应用并将节点设置为原始状况,但是就为加入集群准备好了。完后 使用./rabbitmqctl stop,应用和节点都将被关闭。全都使用rabbitmqctl stop_app仅仅关闭应用。 

rabbitmqctl set_policy queue-xxx "^queue" \

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

27

1

8

4

3

node2:

17

5

将node1、node2、node3组成集群

yancongadmin@node2:~$ rabbitmqctl stop_app

2

 {partitions,[]},

1

25

2

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

12

14

Stopping node rabbit@node2 ...

11

Starting node rabbit@node3 ...

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

 {running_nodes,[rabbit@node3]},

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

1

Cluster status of node rabbit@node2 ...

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

修改 /etc/hosts

3

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

VORMVSAAOFOFEQKTNWBB

15

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

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

1

  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。

例如:

1

6

yancongadmin@node3:~$ rabbitmqctl cluster_status

10

Stopping and halting node rabbit@node1 ...

15

5

2

16

Cluster status of node rabbit@node3 ...

yancongadmin@node2:~$ rabbitmqctl join_cluster rabbit@node1

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

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

 {running_nodes,[rabbit@node1]},

8

yancongadmin@node3:~$ cat .erlang.cookie

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

11

3

 {running_nodes,[rabbit@node1]},

16

7

3

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

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

6

14

yancongadmin@node1:~$ rabbitmqctl cluster_status

5

3

19

10

11

yancongadmin@node1:~$ rabbitmqctl stop

node2:

1

本文演示的实例是用源码安装,完后 你这一文件权限是 50,全都需要先修改 node2、node3 中的该文件权限为 777:

7

14

yancongadmin@node1:~$ cat .erlang.cookie

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

 {partitions,[]},

22

3

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

server   node2 10.0.0.232:5672 check inter 50 rise 2 fall 3

8

1

11

4

yancongadmin@node3:~$ rabbitmqctl stop_app

node2:

1

RabbitMQ集群概述

Cluster status of node rabbit@node1 ...

yancongadmin@node3:~$ rabbitmqctl join_cluster rabbit@node1

18

server   node1 10.0.0.231:5672 check inter 50 rise 2 fall 3 

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

yancongadmin@node2:~$ rabbitmqctl cluster_status

12

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

Stopping node rabbit@node3 ...

通过rabbitmqctl cluster_status命令,可不里能 查看和个节点的状况,节点的名称是rabbit@shorthostname,

2

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

Cluster status of node rabbit@node1 ...

16

4

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

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

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

9

6

20

10.0.0.231  node1

9

安装 Erlang、RabbitMQ

4

Cluster status of node rabbit@node2 ...

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

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

5

8

1

1

10.0.0.233  node3

3

集群配置好后,可不里能 在 RabbitMQ 任意节点上执行 rabbitmqctl cluster_status 来查看与非 集群配置成功。

13

2

12

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

5

13

2

yancongadmin@node2:

node3:

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

server   node3 10.0.0.233:5672 check inter 50 rise 2 fall 3

node1:

17

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

yancongadmin@node2:~$ rabbitmqctl start_app

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

在任意有有一一两个节点上执行:

2

7

yancongadmin@node2:~$ rabbitmqctl cluster_status

2

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

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

yancongadmin@node3:~$ rabbitmqctl start_app

6

9

设置 Erlang Cookie

Gracefully halting Erlang VM

24

node1:

23

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

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