服务器A的IP服务器B的IP
192.168.56.110192.168.56.111
  • 创建持久化文件夹
    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