1 RocketMQ安装
1.1 RocketMQ下载
1.2 安装
1.2.1 解压rocketmq
unzip rocketmq-all-4.5.1-bin-release.zip
1.2.2 启动nameserver
前台启动
./mqnamesrv
后台启动
nohup ./mqnamesrv > /dev/null 2>&1 &
1.2.3 启动broker
前台启动
./mqbroker -n 192.168.81.130:9876 autoCreateTopicEnable=true
后台启动
nohup ./mqbroker -n 192.168.81.130:9876 autoCreateTopicEnable=true > /dev/null 2>&1 &
1.2.4 安装过程中可能出现的错误
01.png
错误原因：JDK版本不匹配，JDK必须是1.8以上。
02.png
错误原因：是因为内存不够，导致启动失败。RocketMQ的配置默认是生产环境的配置，设置的jvm的内存大小值比较大，对于学习而言没有必要设置这么大，测试环境的内存往往都不是很大，所以需要调整默认值。
解决方案：
修改runserver.sh
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn125m -XX:MetaspaceSize=128m - XX:MaxMetaspaceSize=320m"
修改runbroker.sh文件：
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"
1.2.5 消息测试
1.2.5.1 配置nameserver地址，设置nameserver服务器
vi /etc/profile
export NAMESRV_ADDR=192.168.81.130:9876
source /etc/profile
1.2.5.1 测试消息发送命令
sh tools.sh org.apache.rocketmq.example.quickstart.Producer
测试结果：
SendResult [sendStatus=SEND_OK, msgId=AC110001473C7D4991AD336AEA5703E0, offsetMsgId=AC11000100002A9F00000000000E8580, messageQueue=MessageQueue [topic=TopicTest, brokerName=itcast, queueId=3], queueOffset=1323]
SendResult [sendStatus=SEND_OK, msgId=AC110001473C7D4991AD336AEA5903E1, offsetMsgId=AC11000100002A9F00000000000E8634, messageQueue=MessageQueue [topic=TopicTest, brokerName=itcast, queueId=0], queueOffset=1323]
SendResult [sendStatus=SEND_OK, msgId=AC110001473C7D4991AD336AEA5F03E2, offsetMsgId=AC11000100002A9F00000000000E86E8, messageQueue=MessageQueue [topic=TopicTest, brokerName=itcast, queueId=1], queueOffset=1323]
SendResult [sendStatus=SEND_OK, msgId=AC110001473C7D4991AD336AEA6103E3, offsetMsgId=AC11000100002A9F00000000000E879C, messageQueue=MessageQueue [topic=TopicTest, brokerName=itcast, queueId=2], queueOffset=1323]
从结果中可以看出发送消息正常
1.2.5.1 测试消息接收命令
sh tools.sh org.apache.rocketmq.example.quickstart.Consumer
测试结果：
ConsumeMessageThread_3 Receive New Messages: [MessageExt [brokerName=localhost.localdomain, queueId=2, storeSize=203, queueOffset=196, sysFlag=0, bornTimestamp=1608801894315, bornHost=/192.168.81.130:46714, storeTimestamp=1608801894316, storeHost=/192.168.81.130:10911, msgId=C0A8518200002A9F0000000000026ED8, commitLogOffset=159448, bodyCRC=624148161, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message{topic='TopicTest', flag=0, properties={MIN_OFFSET=0, MAX_OFFSET=250, CONSUME_START_TIME=1608801970002, UNIQ_KEY=7F000001E8DA29453F447A2EE7AB0312, CLUSTER=DefaultCluster, WAIT=true, TAGS=TagA}, body=[72, 101, 108, 108, 111, 32, 82, 111, 99, 107, 101, 116, 77, 81, 32, 55, 56, 54], transactionId='null'}]]
ConsumeMessageThread_9 Receive New Messages: [MessageExt [brokerName=localhost.localdomain, queueId=2, storeSize=203, queueOffset=194, sysFlag=0, bornTimestamp=1608801894298, bornHost=/192.168.81.130:46714, storeTimestamp=1608801894299, storeHost=/192.168.81.130:10911, msgId=C0A8518200002A9F0000000000026880, commitLogOffset=157824, bodyCRC=1158909705, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message{topic='TopicTest', flag=0, properties={MIN_OFFSET=0, MAX_OFFSET=250, CONSUME_START_TIME=1608801970002, UNIQ_KEY=7F000001E8DA29453F447A2EE79A030A, CLUSTER=DefaultCluster, WAIT=true, TAGS=TagA}, body=[72, 101, 108, 108, 111, 32, 82, 111, 99, 107, 101, 116, 77, 81, 32, 55, 55, 56], transactionId='null'}]]
ConsumeMessageThread_7 Receive New Messages: [MessageExt [brokerName=localhost.localdomain, queueId=1, storeSize=203, queueOffset=129, sysFlag=0, bornTimestamp=1608801893711, bornHost=/192.168.81.130:46714, storeTimestamp=1608801893711, storeHost=/192.168.81.130:10911, msgId=C0A8518200002A9F0000000000019989, commitLogOffset=104841, bodyCRC=7528816, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message{topic='TopicTest', flag=0, properties={MIN_OFFSET=0, MAX_OFFSET=250, CONSUME_START_TIME=1608801969928, UNIQ_KEY=7F000001E8DA29453F447A2EE54F0205, CLUSTER=DefaultCluster, WAIT=true, TAGS=TagA}, body=[72, 101, 108, 108, 111, 32, 82, 111, 99, 107, 101, 116, 77, 81, 32, 53, 49, 55], transactionId='null'}]]
从结果中可以看出接收消息正常
1.2.6 关闭服务
关闭broker
./mqshutdown broker
关闭nameserver
./mqshutdown namesrv
