docker 部署rockermq双主双从集群

不念不忘少年蓝@ 2023-01-16 06:50 338阅读 0赞

1、pull rocketmq镜像

[root@rocketmq01 ~]# docker pull styletang/rocketmq-console-ng:latest
    latest: Pulling from styletang/rocketmq-console-ng
    e12c678537ae: Pull complete 
    8d9ed335b7db: Pull complete 
    3318dd58ae60: Pull complete 
    624ba6156166: Pull complete 
    c7a02d193df7: Pull complete 
    813b62320378: Pull complete 
    49e2d6393f32: Pull complete 
    0a2b7222259b: Pull complete 
    478657249124: Pull complete 
    5f8636e9fbb7: Pull complete 
    Digest: sha256:96e99d10eda871640b9529b75da30fa6ca85fc15722661acb9660639e6904fc3
    Status: Downloaded newer image for styletang/rocketmq-console-ng:latest
    docker.io/styletang/rocketmq-console-ng:latest
    [root@rocketmq01 ~]# docker pull rocketmqinc/rocketmq-namesrv:4.5.0-alpine
    4.5.0-alpine: Pulling from rocketmqinc/rocketmq-namesrv
    e7c96db7181b: Pull complete 
    f910a506b6cb: Pull complete 
    c2274a1a0e27: Pull complete 
    3082adf3b6c9: Pull complete 
    e68d20dcdd60: Pull complete 
    3d05e01bb7e4: Pull complete 
    b979d408762e: Pull complete 
    56f0d89ad183: Pull complete 
    c17d77502eba: Pull complete 
    Digest: sha256:be78c93341384522d3931bbe96af400fb914befdf292978dace7cd0fd8ba3e53
    Status: Downloaded newer image for rocketmqinc/rocketmq-namesrv:4.5.0-alpine
    docker.io/rocketmqinc/rocketmq-namesrv:4.5.0-alpine
    [root@rocketmq01 ~]# docker pull rocketmqinc/rocketmq-broker:4.5.0-alpine
    4.5.0-alpine: Pulling from rocketmqinc/rocketmq-broker
    e7c96db7181b: Already exists 
    f910a506b6cb: Already exists 
    c2274a1a0e27: Already exists 
    3082adf3b6c9: Already exists 
    e68d20dcdd60: Already exists 
    3d05e01bb7e4: Already exists 
    b979d408762e: Already exists 
    588a86b0a843: Pull complete 
    d115bab5495e: Pull complete 
    43f6588d6289: Pull complete 
    5befc0710618: Pull complete 
    Digest: sha256:2dc385241843d773ad26cb69021a310c36e2a3994a9ee298e272baf711fd62df
    Status: Downloaded newer image for rocketmqinc/rocketmq-broker:4.5.0-alpine
    docker.io/rocketmqinc/rocketmq-broker:4.5.0-alpine

2、目录结构如下

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JhaWR1XzM4NDMyNzMy_size_16_color_FFFFFF_t_70][]

3、查询rocketmq目录结构，两台机器上同步一致

[root@rocketmq01 rocketmq]# cat /data/rocketmq/master/01/broker.conf 
    brokerIP1 = 192.168.31.101
    brokerClusterName = sgpexchangeCluster
    brokerName = broker01
    brokerId = 0
    deleteWhen = 04
    fileReservedTime = 48
    brokerRole = ASYNC_MASTER
    flushDiskType = ASYNC_FLUSH
    [root@rocketmq01 rocketmq]# cat /data/rocketmq/master/02/broker.conf 
    brokerIP1 = 192.168.31.102
    brokerClusterName = sgpexchangeCluster
    brokerName = broker02
    brokerId = 0
    deleteWhen = 04
    fileReservedTime = 48
    brokerRole = ASYNC_MASTER
    flushDiskType = ASYNC_FLUSH
    [root@rocketmq01 rocketmq]# cat /data/rocketmq/slave/01/broker.conf 
    brokerIP1 = 192.168.31.102
    brokerClusterName = sgpexchangeCluster
    brokerName = broker01
    brokerId = 1
    deleteWhen = 04
    fileReservedTime = 48
    brokerRole = SLAVE 
    flushDiskType = ASYNC_FLUSH
    [root@rocketmq01 rocketmq]# cat /data/rocketmq/slave/02/broker.conf 
    brokerIP1 = 192.168.31.101
    brokerClusterName = sgpexchangeCluster
    brokerName = broker02
    brokerId = 1
    deleteWhen = 04
    fileReservedTime = 48
    brokerRole = SLAVE
    flushDiskType = ASYNC_FLUSH

4、启动name server（两台机器上都要操作）

[root@rocketmq01 rocketmq]# docker run --name="namesrv-sgpexchange" -p 9876:9876 -e      "JAVA_OPT_EXT=-server -Xms128m -Xmx128m -Xmn128m" -d  rocketmqinc/rocketmq-namesrv:4.5.0-alpine 
    5cdab1f468cb9ce864dca4262ddfd797f6a07025ca8c62fc2016e73f1bf14fa7
    [root@rocketmq01 rocketmq]# 
    [root@rocketmq01 rocketmq]# docker ps
    CONTAINER ID   IMAGE                                       COMMAND                 CREATED         STATUS         PORTS                                       NAMES
    5cdab1f468cb   rocketmqinc/rocketmq-namesrv:4.5.0-alpine   "/bin/bash mqnamesrv"   4 seconds ago   Up 2 seconds   0.0.0.0:9876->9876/tcp, :::9876->9876/tcp   namesrv-sgpexchange

5、依次启动broker

启动master01(在主机rocketmq01上启动)

[root@rocketmq01 data]# docker run --name="broker-master01" -p 10909:10909 -p 10911:10911 -e "JAVA_OPT_EXT=-server -Xms128m -Xmx128m -Xmn128m" -v /data/rocketmq/master/01/broker.conf:/home/rocketmq/rocketmq-4.5.0/conf/broker.conf -e "NAMESRV_ADDR=192.168.31.101:9876;192.168.31.102:9876" -d rocketmqinc/rocketmq-broker:4.5.0-alpine sh mqbroker -c /home/rocketmq/rocketmq-4.5.0/conf/broker.conf
    d0217d846d2ceb2626a64209df14e7d35940f1233cadc0d7995badc716dbf93c
    [root@rocketmq01 data]# docker ps
    CONTAINER ID   IMAGE                                       COMMAND                  CREATED         STATUS         PORTS                                                                                                     NAMES
    d0217d846d2c   rocketmqinc/rocketmq-broker:4.5.0-alpine    "sh mqbroker -c /hom…"   3 seconds ago   Up 2 seconds   0.0.0.0:10909->10909/tcp, :::10909->10909/tcp, 0.0.0.0:10911->10911/tcp, :::10911->10911/tcp, 10912/tcp   broker-master01
    3ddef418cb81   rocketmqinc/rocketmq-namesrv:4.5.0-alpine   "/bin/bash mqnamesrv"    4 minutes ago   Up 4 minutes   0.0.0.0:9876->9876/tcp, :::9876->9876/tcp                                                                 namesrv-sgpexchange

启动master02(在主机rocketmq02上启动)

[root@rocketmq02 data]# docker run --name="broker-master02" -p 10909:10909 -p 10911:10911 -e "JAVA_OPT_EXT=-server -Xms128m -Xmx128m -Xmn128m" -v /data/rocketmq/master/02/broker.conf:/home/rocketmq/rocketmq-4.5.0/conf/broker.conf -e "NAMESRV_ADDR=192.168.31.101:9876;192.168.31.102:9876" -d rocketmqinc/rocketmq-broker:4.5.0-alpine sh mqbroker -c /home/rocketmq/rocketmq-4.5.0/conf/broker.conf
    c9d30e0873754061fafb47761d4a697d8b775a047e46b1d3aa8153b02fda0804
    [root@rocketmq02 data]# docker ps
    CONTAINER ID   IMAGE                                       COMMAND                  CREATED         STATUS         PORTS                                                                                                     NAMES
    c9d30e087375   rocketmqinc/rocketmq-broker:4.5.0-alpine    "sh mqbroker -c /hom…"   4 seconds ago   Up 2 seconds   0.0.0.0:10909->10909/tcp, :::10909->10909/tcp, 0.0.0.0:10911->10911/tcp, :::10911->10911/tcp, 10912/tcp   broker-master02
    3ddef418cb81   rocketmqinc/rocketmq-namesrv:4.5.0-alpine   "/bin/bash mqnamesrv"    6 minutes ago   Up 6 minutes   0.0.0.0:9876->9876/tcp, :::9876->9876/tcp                                                                 namesrv-sgpexchange

启动master01(在主机rocketmq02上启动)

[root@rocketmq02 data]# docker run --name="broker-slave01" -p 10910:10909 -p 10912:10911 -e "JAVA_OPT_EXT=-server -Xms128m -Xmx128m -Xmn128m" -v /data/rocketmq/slave/01/broker.conf:/home/rocketmq/rocketmq-4.5.0/conf/broker.conf -e "NAMESRV_ADDR=192.168.31.101:9876;192.168.31.102:9876" -d rocketmqinc/rocketmq-broker:4.5.0-alpine sh mqbroker -c /home/rocketmq/rocketmq-4.5.0/conf/broker.conf
    22ffc1e5ac2adae4a3ba97e74ededc7b51205fb192eaae06ef9316cd03e99536
    [root@rocketmq02 data]# docker ps
    CONTAINER ID   IMAGE                                       COMMAND                  CREATED         STATUS         PORTS                                                                                                     NAMES
    22ffc1e5ac2a   rocketmqinc/rocketmq-broker:4.5.0-alpine    "sh mqbroker -c /hom…"   9 seconds ago   Up 3 seconds   10912/tcp, 0.0.0.0:10910->10909/tcp, :::10910->10909/tcp, 0.0.0.0:10912->10911/tcp, :::10912->10911/tcp   broker-slave01
    c9d30e087375   rocketmqinc/rocketmq-broker:4.5.0-alpine    "sh mqbroker -c /hom…"   2 minutes ago   Up 2 minutes   0.0.0.0:10909->10909/tcp, :::10909->10909/tcp, 0.0.0.0:10911->10911/tcp, :::10911->10911/tcp, 10912/tcp   broker-master02
    3ddef418cb81   rocketmqinc/rocketmq-namesrv:4.5.0-alpine   "/bin/bash mqnamesrv"    9 minutes ago   Up 9 minutes   0.0.0.0:9876->9876/tcp, :::9876->9876/tcp

启动slave02(在主机rocketmq01上启动)

[root@rocketmq01 rocketmq]# docker run --name="broker-slave02" -p 10910:10909 -p 10912:10911 -e "JAVA_OPT_EXT=-server -Xms128m -Xmx128m -Xmn128m" -v /data/rocketmq/slave/02/broker.conf:/home/rocketmq/rocketmq-4.5.0/conf/broker.conf -e "NAMESRV_ADDR=192.168.31.101:9876;192.168.31.102:9876" -d rocketmqinc/rocketmq-broker:4.5.0-alpine sh mqbroker -c /home/rocketmq/rocketmq-4.5.0/conf/broker.conf
    578260dc27fdc7d3727b006c40e7c2203fec51ed03c7c5521c2631e647f0b652
    [root@rocketmq01 rocketmq]# docker ps
    CONTAINER ID   IMAGE                                       COMMAND                  CREATED          STATUS          PORTS                                                                                                     NAMES
    578260dc27fd   rocketmqinc/rocketmq-broker:4.5.0-alpine    "sh mqbroker -c /hom…"   6 seconds ago    Up 5 seconds    10912/tcp, 0.0.0.0:10910->10909/tcp, :::10910->10909/tcp, 0.0.0.0:10912->10911/tcp, :::10912->10911/tcp   broker-slave02
    ff406b17ca10   rocketmqinc/rocketmq-broker:4.5.0-alpine    "sh mqbroker -c /hom…"   30 minutes ago   Up 30 minutes   0.0.0.0:10909->10909/tcp, :::10909->10909/tcp, 0.0.0.0:10911->10911/tcp, :::10911->10911/tcp, 10912/tcp   broker-master01
    5cdab1f468cb   rocketmqinc/rocketmq-namesrv:4.5.0-alpine   "/bin/bash mqnamesrv"    37 minutes ago   Up 37 minutes   0.0.0.0:9876->9876/tcp, :::9876->9876/tcp                                                                 namesrv-sgpexchange

6、rocketmq01再起一台console用于监控

[root@rocketmq01 rocketmq]# docker run --name="rocketmq-console" -p 18080:8080 -v /root/rocketmq/logs/rocketmq-console:/root/logs -v /tmp/rocketmq-console:/tmp -e  "NAMESRV_ADDR=192.168.31.101:9876;192.168.31.102:9876" -e  "JAVA_OPTS=-Xms128m -Xmx128m -Xmn128m" -d      styletang/rocketmq-console-ng:latest
    96385af68c3e85ac4755f1b5cb4ee120465720e9b77c6587957e178a7f40039f
    [root@rocketmq01 rocketmq]# docker ps
    CONTAINER ID   IMAGE                                       COMMAND                  CREATED          STATUS          PORTS                                                                                                     NAMES
    96385af68c3e   styletang/rocketmq-console-ng:latest        "sh -c 'java $JAVA_O…"   7 seconds ago    Up 2 seconds    0.0.0.0:18080->8080/tcp, :::18080->8080/tcp                                                               rocketmq-console
    49a8a1b559cd   rocketmqinc/rocketmq-broker:4.5.0-alpine    "sh mqbroker -c /hom…"   2 minutes ago    Up 2 minutes    10912/tcp, 0.0.0.0:10910->10909/tcp, :::10910->10909/tcp, 0.0.0.0:10912->10911/tcp, :::10912->10911/tcp   broker-slave01
    ff406b17ca10   rocketmqinc/rocketmq-broker:4.5.0-alpine    "sh mqbroker -c /hom…"   5 minutes ago    Up 5 minutes    0.0.0.0:10909->10909/tcp, :::10909->10909/tcp, 0.0.0.0:10911->10911/tcp, :::10911->10911/tcp, 10912/tcp   broker-master01
    5cdab1f468cb   rocketmqinc/rocketmq-namesrv:4.5.0-alpine   "/bin/bash mqnamesrv"    13 minutes ago   Up 13 minutes   0.0.0.0:9876->9876/tcp, :::9876->9876/tcp                                                                 namesrv-sgpexchange

7、最后我们登录控制台查看

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JhaWR1XzM4NDMyNzMy_size_16_color_FFFFFF_t_70 1][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JhaWR1XzM4NDMyNzMy_size_16_color_FFFFFF_t_70]: /images/20221022/d75acff3ae1f48beaf9a47117ef6912e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JhaWR1XzM4NDMyNzMy_size_16_color_FFFFFF_t_70 1]: /images/20221022/f14145e914524758a78fc00d78e0f2a1.png