Docker 验证证据

Apache RocketMQ 已验证 · Verified 🕒 快照采集: 2026-08-23 15:19:49 UTC

🐳 镜像:server:apache/rocketmq:5.5.0

🛠️ 关键工具:mqadminmqbrokermqnamesrv

🔨 构建/检查mqadmin updateTopic

🚀 运行/交互mqadmin sendMessage → consumeMessage

docker-session.out.txt

## status
[cli-tools] $ mqadmin clusterList -n namesrv:9876
#Cluster Name           #Broker Name            #BID  #Addr                  #Version              #InTPS(LOAD)                   #OutTPS(LOAD)  #Timer(Progress)        #PCWait(ms)  #Hour         #SPACE    #ACTIVATED
DefaultCluster          hello-mq-broker         0     172.18.0.3:10911       V5_5_0                 0.00(0,0ms)               0.00(0,0ms|0,0ms)  0-0(0.0w, 0.0, 0.0)               0  496527.32     0.4300          true

## create
[cli-tools] $ mqadmin updateTopic -n namesrv:9876 -c DefaultCluster -t ordersCli
create topic to 172.18.0.3:10911 success.
TopicConfig [topicName=ordersCli, readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, order=false, attributes={}]

## produce
[cli-tools] $ mqadmin sendMessage -n namesrv:9876 -t ordersCli -p order-cli-1 -c TagCli
#Broker Name                      #QID  #Send Result            #MsgId
hello-mq-broker                   1     SEND_OK                 AC12000301C213221655749568150000
[cli-tools] $ mqadmin sendMessage -n namesrv:9876 -t ordersCli -p order-cli-2 -c TagCli
#Broker Name                      #QID  #Send Result            #MsgId
hello-mq-broker                   6     SEND_OK                 AC120003020113221655749578D80000
[cli-tools] $ mqadmin sendMessage -n namesrv:9876 -t ordersCli -p order-cli-3 -c TagCli
#Broker Name                      #QID  #Send Result            #MsgId
hello-mq-broker                   2     SEND_OK                 AC120003023F13221655749589930000

## consume
[cli-tools] $ mqadmin consumeMessage -n namesrv:9876 -t ordersCli
MessageQueue [topic=ordersCli, brokerName=hello-mq-broker, queueId=7] print msg finished. status=NO_NEW_MSG, offset=0
Consume ok
MSGID: AC120003020113221655749578D80000 MessageExt [brokerName=hello-mq-broker, queueId=6, storeSize=237, queueOffset=0, sysFlag=0, bornTimestamp=1787498352857, bornHost=/172.18.0.3:58854, storeTimestamp=1787498352875, storeHost=/172.18.0.3:10911, msgId=AC12000300002A9F00000000000000ED, commitLogOffset=237, bodyCRC=63934924, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message{topic='ordersCli', flag=0, properties={MSG_REGION=DefaultRegion, UNIQ_KEY=AC120003020113221655749578D80000, CLUSTER=DefaultCluster, MIN_OFFSET=0, TAGS=TagCli, WAIT=true, TRACE_ON=true, MAX_OFFSET=1}, body=[111, 114, 100, 101, 114, 45, 99, 108, 105, 45, 50], transactionId='null'}] BODY: order-cli-2
MessageQueue [topic=ordersCli, brokerName=hello-mq-broker, queueId=6] print msg finished. status=NO_NEW_MSG, offset=1
MessageQueue [topic=ordersCli, brokerName=hello-mq-broker, queueId=3] print msg finished. status=NO_NEW_MSG, offset=0
Consume ok
MSGID: AC120003023F13221655749589930000 MessageExt [brokerName=hello-mq-broker, queueId=2, storeSize=237, queueOffset=0, sysFlag=0, bornTimestamp=1787498357140, bornHost=/172.18.0.3:58862, storeTimestamp=1787498357151, storeHost=/172.18.0.3:10911, msgId=AC12000300002A9F00000000000001DA, commitLogOffset=474, bodyCRC=1959305562, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message{topic='ordersCli', flag=0, properties={MSG_REGION=DefaultRegion, UNIQ_KEY=AC120003023F13221655749589930000, CLUSTER=DefaultCluster, MIN_OFFSET=0, TAGS=TagCli, WAIT=true, TRACE_ON=true, MAX_OFFSET=1}, body=[111, 114, 100, 101, 114, 45, 99, 108, 105, 45, 51], transactionId='null'}] BODY: order-cli-3
MessageQueue [topic=ordersCli, brokerName=hello-mq-broker, queueId=2] print msg finished. status=NO_NEW_MSG, offset=1
MessageQueue [topic=ordersCli, brokerName=hello-mq-broker, queueId=5] print msg finished. status=NO_NEW_MSG, offset=0
MessageQueue [topic=ordersCli, brokerName=hello-mq-broker, queueId=4] print msg finished. status=NO_NEW_MSG, offset=0
Consume ok
MSGID: AC12000301C213221655749568150000 MessageExt [brokerName=hello-mq-broker, queueId=1, storeSize=237, queueOffset=0, sysFlag=0, bornTimestamp=1787498348566, bornHost=/172.18.0.3:35074, storeTimestamp=1787498348608, storeHost=/172.18.0.3:10911, msgId=AC12000300002A9F0000000000000000, commitLogOffset=0, bodyCRC=449233014, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message{topic='ordersCli', flag=0, properties={MSG_REGION=DefaultRegion, UNIQ_KEY=AC12000301C213221655749568150000, CLUSTER=DefaultCluster, MIN_OFFSET=0, TAGS=TagCli, WAIT=true, TRACE_ON=true, MAX_OFFSET=1}, body=[111, 114, 100, 101, 114, 45, 99, 108, 105, 45, 49], transactionId='null'}] BODY: order-cli-1
MessageQueue [topic=ordersCli, brokerName=hello-mq-broker, queueId=1] print msg finished. status=NO_NEW_MSG, offset=1
MessageQueue [topic=ordersCli, brokerName=hello-mq-broker, queueId=0] print msg finished. status=NO_NEW_MSG, offset=0

## verify
[cli-tools] $ mqadmin topicStatus -n namesrv:9876 -t ordersCli
#Broker Name                      #QID  #Min Offset           #Max Offset             #Last Updated
hello-mq-broker                   0     0                     0                       
hello-mq-broker                   1     0                     1                       2026-08-23 15:19:08,608
hello-mq-broker                   2     0                     1                       2026-08-23 15:19:17,151
hello-mq-broker                   3     0                     0                       
hello-mq-broker                   4     0                     0                       
hello-mq-broker                   5     0                     0                       
hello-mq-broker                   6     0                     1                       2026-08-23 15:19:12,875
hello-mq-broker                   7     0                     0                       

Topic Put TPS: 0.0