win 下rocketMQ简单启动

记录下win下rocketMQ的简单使用

官网下载了rocketmq-all-4.9.4-bin-release.zip 4.9版本

D:\worksoft\rocketmq4.9.4-001 根目录

1.修改conf下的broker.conf配置文件

brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
namesrvAddr=192.168.0.80:9876   //注意这里为了外部访问，指定了nameserver的ip
brokerIP1=192.168.0.80 //这里指定了broker的ip

2.配置环境变量

ROCKETMQ_HOME = D:\worksoft\rocketmq4.9.4-001 

3. 首先启动 nameserver服务

start mqnamesrv.cmd -n 192.168.0.80   指定ip

这里会新弹出个cmd窗口显示
Java HotSpot(TM) 64-Bit Server VM warning: Using the DefNew young collector with the CMS collector is deprecated and will likely be removed in a future release
Java HotSpot(TM) 64-Bit Server VM warning: UseCMSCompactAtFullCollection is deprecated and will likely be removed in a future release.
The Name Server boot success. serializeType=JSON

4.启动broker 

start mqbroker.cmd -c ../conf/broker.conf autoCreateTopicEnable=true
这里会新弹出个cmd窗口显示
The broker[broker-a, 192.168.0.80:10911] boot success. serializeType=JSON and name server is 192.168.0.80:9876

指定配置文件  ， 选择自动创建topic 。自己玩的环境就先自己自动创建了

5.可以使用tool.cmd 来测试下

开两个cmd窗口到bin目录先

消费者窗口

set NAMESRV_ADDR=192.168.0.80:9876  //设置nameserver的地址
tools.cmd org.apache.rocketmq.example.quickstart.Consumer

生产者窗口

set NAMESRV_ADDR=192.168.0.80:9876  //设置nameserver的地址
tools.cmd org.apache.rocketmq.example.quickstart.Producer

完了之后会出现下面的刷刷刷一堆
SendResult [sendStatus=SEND_OK, msgId=7F000001304C7ADF9F5F8A7B045C0000, offsetMsgId=C0A8005000002A9F000000000011A05A, messageQueue=MessageQueue [topic=TopicTest, brokerName=broker-a, queueId=0], queueOffset=0]
SendResult [sendStatus=SEND_OK, msgId=7F000001304C7ADF9F5F8A7B049A0001, offsetMsgId=C0A8005000002A9F000000000011A118, messageQueue=MessageQueue [topic=TopicTest, brokerName=broker-a, queueId=1], queueOffset=0]
SendResult [sendStatus=SEND_OK, msgId=7F000001304C7ADF9F5F8A7B04A10002, offsetMsgId=C0A8005000002A9F000000000011A1D6, messageQueue=MessageQueue [topic=TopicTest, brokerName=broker-a, queueId=2], queueOffset=0]


然后你的consumer窗口会跟着输出一堆
ConsumeMessageThread_please_rename_unique_group_name_4_2 Receive New Messages: [MessageExt [brokerName=broker-a, queueId=0, storeSize=192, queueOffset=486, sysFlag=0, bornTimestamp=1679923339853, bornHost=/192.168.0.80:57233, storeTimestamp=1679923339854, storeHost=/192.168.0.80:10911, msgId=C0A8005000002A9F00000000001753BE, commitLogOffset=1528766, bodyCRC=1948249169, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message{topic='TopicTest', flag=0, properties={MIN_OFFSET=0, MAX_OFFSET=500, CONSUME_START_TIME=1679923343597, UNIQ_KEY=7F000001369C7ADF9F5F8A7B5A4D03B3, CLUSTER=DefaultCluster, TAGS=TagA}, body=[72, 101, 108, 108, 111, 32, 82, 111, 99, 107, 101, 116, 77, 81, 32, 57, 52, 55], transactionId='null'}]]
ConsumeMessageThread_please_rename_unique_group_name_4_4 Receive New Messages: [MessageExt [brokerName=broker-a, queueId=0, storeSize=192, queueOffset=484, sysFlag=0, bornTimestamp=1679923339833, bornHost=/192.168.0.80:57233, storeTimestamp=1679923339834, storeHost=/192.168.0.80:10911, msgId=C0A8005000002A9F0000000000174DBE, commitLogOffset=1527230, bodyCRC=1558599569, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message{topic='TopicTest', flag=0, properties={MIN_OFFSET=0, MAX_OFFSET=500, CONSUME_START_TIME=1679923343596, UNIQ_KEY=7F000001369C7ADF9F5F8A7B5A3903AB, CLUSTER=DefaultCluster, TAGS=TagA}, body=[72, 101, 108, 108, 111, 32, 82, 111, 99, 107, 101, 116, 77, 81, 32, 57, 51, 57], transactionId='null'}]]