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、目录结构如下

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、最后我们登录控制台查看

Logo

魔乐社区(Modelers.cn) 是一个中立、公益的人工智能社区,提供人工智能工具、模型、数据的托管、展示与应用协同服务,为人工智能开发及爱好者搭建开放的学习交流平台。社区通过理事会方式运作,由全产业链共同建设、共同运营、共同享有,推动国产AI生态繁荣发展。

更多推荐