root@f2b36aa77e34:/opt/rocketmq/bin# mqadmin clusterList -n n1:9876
#Cluster Name #Broker Name #BID #Addr #Version #InTPS(LOAD) #OutTPS(LOAD) #Timer(Progress) #PCWait(ms) #Hour #SPACE #ACTIVATED
DefaultCluster q1 0 192.168.88.123:11911 V5_3_0 0.00(0,0ms) 0.00(0,0ms) 0-0(0.0w, 0.0, 0.0) 0 480097.14 0.0100 true
DefaultCluster q1 1 192.168.88.123:12911 V5_3_0 0.00(0,0ms) 0.00(0,0ms) 2-0(0.0w, 0.0, 0.0) 0 480097.14 0.0100 false
DefaultCluster q3 0 192.168.88.123:13911 V5_3_0 0.00(0,0ms) 0.00(0,0ms) 1-0(0.0w, 0.0, 0.0) 0 480097.14 0.0100 true
DefaultCluster q3 1 192.168.88.123:14911 V5_3_0 0.00(0,0ms) 0.00(0,0ms) 3-0(0.0w, 0.0, 0.0) 0 480097.14 0.0100 false
root@f2b36aa77e34:/opt/rocketmq/bin# mqadmin updateTopic -n n1:9876 -c DefaultCluster -t hello -r 3 -w 3
create topic to 192.168.88.123:11911 success.
create topic to 192.168.88.123:13911 success.
TopicConfig [topicName=hello, readQueueNums=3, writeQueueNums=3, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, order=false, attributes={}]
root@f2b36aa77e34:/opt/rocketmq/bin# mqadmin topicStatus -n n1:9876 -t hello
#Broker Name #QID #Min Offset #Max Offset #Last Updated
q1 0 0 0
q1 1 0 0
q1 2 0 0
q3 0 0 0
q3 1 0 0
q3 2 0 0
root@f2b36aa77e34:/opt/rocketmq/bin# mqadmin updateTopic -n n1:9876 -c DefaultCluster -t my -r 2 -w 2
create topic to 192.168.88.123:11911 success.
create topic to 192.168.88.123:13911 success.
TopicConfig [topicName=my, readQueueNums=2, writeQueueNums=2, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, order=false, attributes={}]
root@f2b36aa77e34:/opt/rocketmq/bin# mqadmin topicStatus -n n1:9876 -t my
#Broker Name #QID #Min Offset #Max Offset #Last Updated
q1 0 0 0
q1 1 0 0
q3 0 0 0
q3 1 0 0
mqadmin updateTopic -n n1:9876 -c DefaultCluster -t book -r 1 -w 1
create topic to 192.168.88.123:11911 success.
create topic to 192.168.88.123:13911 success.
root@f2b36aa77e34:/opt/rocketmq/bin# mqadmin topicStatus -n n1:9876 -t book
#Broker Name #QID #Min Offset #Max Offset #Last Updated
q1 0 0 0
q3 0 0 0 1group-raft ≈ 1m2s
root@c48216352093:/opt/rocketmq/bin# mqadmin clusterList -n n1:9876
#Cluster Name #Broker Name #BID #Addr #Version #InTPS(LOAD) #OutTPS(LOAD) #Timer(Progress) #PCWait(ms) #Hour #SPACE #ACTIVATED
RaftCluster RaftNode00 0 192.168.88.128:11911 V5_3_0 0.00(0,0ms) 0.00(0,0ms) 0-0(0.0w, 0.0, 0.0) 0 480099.47 0.0100 true
RaftCluster RaftNode00 2 192.168.88.128:12911 V5_3_0 0.00(0,0ms) 0.00(0,0ms) 1-0(0.0w, 0.0, 0.0) 0 480099.47 0.0100 false
RaftCluster RaftNode00 3 192.168.88.128:13911 V5_3_0 0.00(0,0ms) 0.00(0,0ms) 2-0(0.0w, 0.0, 0.0) 0 480099.47 0.0100 false
RaftCluster RaftNode01 0 192.168.88.128:14911 V5_3_0 0.00(0,0ms) 0.00(0,0ms) 0-0(0.0w, 0.0, 0.0) 0 480099.47 0.0100 true
RaftCluster RaftNode01 2 192.168.88.128:15911 V5_3_0 0.00(0,0ms) 0.00(0,0ms) 3-0(0.0w, 0.0, 0.0) 0 480099.47 0.0100 false
RaftCluster RaftNode01 3 192.168.88.128:16911 V5_3_0 0.00(0,0ms) 0.00(0,0ms) 604757-0(0.0w, 0.0, 0.0) 0 480099.47 0.0100 false| 模式 | 说明 |
|---|---|
| 单组节点单副本模式 | |
| 多组节点（集群）单副本模式 | 一个集群内全部部署 Master 角色，不部署Slave 副本，例如2个Master或者3个Master，这种模式的优缺点如下： 优点：配置简单，单个Master宕机或重启维护对应用无影响，在磁盘配置为RAID10时，即使机器宕机不可恢复情况下，由于RAID10磁盘非常可靠，消息也不会丢（异步刷盘丢失少量消息，同步刷盘一条不丢），性能最高； 缺点：单台机器宕机期间，这台机器上未被消费的消息在机器恢复之前不可订阅，消息实时性会受到影响。 |
| 每个Master配置一个Slave，有多组 Master-Slave，HA采用异步复制方式，主备有短暂消息延迟（毫秒级），这种模式的优缺点如下： 优点：即使磁盘损坏，消息丢失的非常少，且消息实时性不会受影响，同时Master宕机后，消费者仍然可以从Slave消费，而且此过程对应用透明，不需要人工干预，性能同多Master模式几乎一样； 缺点：Master宕机，磁盘损坏情况下会丢失少量消息。 |
|
| 每个Master配置一个Slave，有 优点：数据与服务都无单点故障，Master宕机情况下，消息无延迟，服务可用性与数据可用性都非常高； 缺点：性能比异步复制模式略低（大约低10%左右），发送单个消息的RT会略高，且目前版本在主节点宕机后，备机不能自动切换为主机。 |
# spring-boot3 pom.xml
./mvnw -B package -Dmaven.test.skip=true --file pom.xml
cp -f target/rocketmq-0.0.1-SNAPSHOT.jar target/rocketmq-spring-boot3.jar
# spring-boot2 pom-legacy.xml
./mvnw -B package -Dmaven.test.skip=true --file pom-legacy.xml
cp -f target/rocketmq-0.0.1-SNAPSHOT.jar target/rocketmq-spring-boot2.jar