Docker搭建RabbitMQ双节点集群

• 创建持久化文件夹

  1 2 3 4

  #在192.168.56.110上执行命令 mkdir -p /home/rabbitmq/cluster/rabbitmq01 #在192.168.56.111上执行命令 mkdir -p /home/rabbitmq/cluster/rabbitmq02

• 启动RabbitMQ

  1 2 3 4

  #在192.168.56.110上执行 docker run -d --hostname rabbitmq01 --name rabbitmq01 --add-host=rabbitmq01:192.168.56.110 --add-host=rabbitmq02:192.168.56.111 -v /home/rabbitmq/cluster/rabbitmq01:/var/lib/rabbitmq --privileged=true -p 15672:15672 -p 5672:5672 -p 5671:5671 -p 4369:4369 -p 25672:25672 -e RABBITMQ_ERLANG_COOKIE='rabbitmqCookie' rabbitmq:3.8.14-management #在192.168.56.111上执行 docker run -d --hostname rabbitmq02 --name rabbitmq02 --add-host=rabbitmq01:192.168.56.110 --add-host=rabbitmq02:192.168.56.111 -v /home/rabbitmq/cluster/rabbitmq02:/var/lib/rabbitmq --privileged=true -p 15672:15672 -p 5672:5672 -p 5671:5671 -p 4369:4369 -p 25672:25672 -e RABBITMQ_ERLANG_COOKIE='rabbitmqCookie' rabbitmq:3.8.14-management

• 目前这两个节点没什么关系，接下来让他们成为一个集群

  1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17

  #在192.168.56.110上执行 docker exec -it rabbitmq01 bash rabbitmqctl stop_app rabbitmqctl reset rabbitmqctl start_app exit #在192.168.56.111上执行 docker exec -it rabbitmq02 bash rabbitmqctl stop_app rabbitmqctl reset #ram是内存节点根据需要选择，不加就是磁盘节点 rabbitmqctl join_cluster --ram rabbit@rabbitmq01 rabbitmqctl start_app exit

• 目前为止，我们的集群为普通集群，要做成镜像集群的话

  1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17

  CMD docker exec -it rabbitmq01 bash rabbitmqctl set_policy -p / "ha" "^" '{"ha-mode":"all","ha-sync-mode":"automatic"}' ## 可用rabbitmqctl list_policies -p /; --查看vhost / 下的所有策略 ## 在 cluster中任意节点启用策略，策略会自动同步到集群节点 ## 策略模式all即复制到所有节点，包含新增节点，策略正则表达式为“^表示所有匹配所 参数 ha-mode：策略键 1.all 队列镜像在群集中的所有节点上。当新节点添加到群集时，队列将镜像到该节点 2.exactly 集群中的队列实例数。 3.nodes 队列镜像到节点名称中列出的节点。 ha-sync-mode：队列同步 1.manual手动<默认模式>.新的队列镜像将不会收到现有的消息，它只会接收新的消息。 2.automatic自动同步.当一个新镜像加入时，队列会自动同步。队列同步是一个阻塞操作。

1

界面操作

我们进入web界面是可以看到：

• 负载均衡

  1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60

  在192.168.56.110上创建nginx的conf文件，/home/rabbitmq/cluster/nginx/nginx-rabbitmq01.conf user nginx; worker_processes 1; error_log /var/log/nginx/error.log warn; pid /var/run/nginx.pid; events { worker_connections 1024; } http { include /etc/nginx/mime.types; default_type application/octet-stream; log_format main '$remote_addr - $remote_user [$time_local] "$request" ' '$status $body_bytes_sent "$http_referer" ' '"$http_user_agent" "$http_x_forwarded_for"'; access_log /var/log/nginx/access.log main; sendfile on; #tcp_nopush on; keepalive_timeout 65; #gzip on; proxy_redirect off; proxy_set_header Host $host; proxy_set_header X-Real-IP $remote_addr; proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for; client_max_body_size 10m; client_body_buffer_size 128k; proxy_connect_timeout 5s; proxy_send_timeout 5s; proxy_read_timeout 5s; proxy_buffer_size 4k; proxy_buffers 4 32k; proxy_busy_buffers_size 64k; proxy_temp_file_write_size 64k; #rabbitmq管理界面 upstream rabbitManage { server 192.168.56.110:15672; server 192.168.56.111:15672; } server { listen 15672; server_name 192.168.56.110; location / { proxy_pass http://rabbitManage; index index.html index.htm; } } } # rabbitmq通信 stream{ upstream rabbitTcp{ server 192.168.56.110:5672; server 192.168.56.111:5672; } server { listen 5673; proxy_pass rabbitTcp; } }

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62

在192.168.56.111上创建nginx的conf文件，/home/rabbitmq/cluster/nginx/nginx-rabbitmq02.conf


user  nginx;
worker_processes  1;
error_log  /var/log/nginx/error.log warn;
pid        /var/run/nginx.pid;
events {
    worker_connections  1024;
}
http {
    include       /etc/nginx/mime.types;
    default_type  application/octet-stream;

    log_format  main  '$remote_addr - $remote_user [$time_local] "$request" '
                      '$status $body_bytes_sent "$http_referer" '
                      '"$http_user_agent" "$http_x_forwarded_for"';
    access_log  /var/log/nginx/access.log  main;
    sendfile        on;
    #tcp_nopush     on;
    keepalive_timeout  65;
    #gzip  on;
    proxy_redirect          off;
    proxy_set_header        Host $host;
    proxy_set_header        X-Real-IP $remote_addr;
    proxy_set_header        X-Forwarded-For $proxy_add_x_forwarded_for;
    client_max_body_size    10m;
    client_body_buffer_size   128k;
    proxy_connect_timeout   5s;
    proxy_send_timeout      5s;
    proxy_read_timeout      5s;
    proxy_buffer_size        4k;
    proxy_buffers           4 32k;
    proxy_busy_buffers_size  64k;
    proxy_temp_file_write_size 64k;
    #rabbitmq管理界面
    upstream rabbitManage {
        server 192.168.56.110:15672;
        server 192.168.56.111:15672;
    }
    server {
        listen       15672;
        server_name  192.168.56.111; 
        location / {  
            proxy_pass   http://rabbitManage;
            index  index.html index.htm;  
        }  

    }
}
# rabbitmq通信
stream{
    upstream rabbitTcp{
        server 192.168.56.110:5672;
        server 192.168.56.111:5672;
    }

    server {
        listen 5673;
        proxy_pass rabbitTcp;
    }
}

• 最后启动nginx(nginx -s reload)

  1 2 3 4

  #在192.168.56.110上执行 docker run -it -d --name nginxRmq -v /home/rabbitmq/cluster/nginx/nginx-rabbitmq01.conf:/etc/nginx/nginx.conf --privileged --net=host nginx #在192.168.56.111上执行 docker run -it -d --name nginxRmq -v /home/rabbitmq/cluster/nginx/nginx-rabbitmq02.conf:/etc/nginx/nginx.conf --privileged --net=host nginx