部署安裝

下載

下載地址：https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.3.2/rocketmq-all-4.3.2-bin-release.zip

版本使用目前最新版：4.3.2

非Docker安裝

cd /haoke unzip rocketmq-all-4.3.2-bin-release.zip cd rocketmq-all-4.3.2-bin-release #啟動(dòng)nameserver bin/mqnamesrv # The Name Server boot success. serializeType=JSON 看到這個(gè)表示已經(jīng)提供成功 #啟動(dòng)broker bin/mqbroker -n 172.16.185.55:9876 #-n 指定nameserver地址和端口 #啟動(dòng)出錯(cuò) Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00000005c0000000, 8589934592, 0) failed; error='Cannot allocate memory' (errno=12) ……………………………………………………………………………………

啟動(dòng)錯(cuò)誤，是因?yàn)閮?nèi)存不夠，導(dǎo)致啟動(dòng)失敗，原因：RocketMQ的配置默認(rèn)是生產(chǎn)環(huán)境的配置，設(shè)置的jvm的內(nèi)存大小值比較大，對(duì)于學(xué)習(xí)而言沒有必要設(shè)置這么大，測(cè)試環(huán)境的內(nèi)存往往都不是很大，所以需要調(diào)整默認(rèn)值。

#調(diào)整默認(rèn)的內(nèi)存大小參數(shù) cd bin/ vim runserver.sh JAVA_OPT="${JAVA_OPT} -server -Xms128m -Xmx128m -Xmn128m -XX:MetaspaceSize=128m - XX:MaxMetaspaceSize=128m" cd bin/ vim runbroker.sh JAVA_OPT="${JAVA_OPT} -server -Xms128m -Xmx128m -Xmn128m" #從新啟動(dòng)測(cè)試 bin/mqbroker -n 172.16.55.185:9876 The broker[itcast, 172.17.0.1:10911] boot success. serializeType=JSON and name server is 172.16.185.55:9876

下面進(jìn)行發(fā)送消息測(cè)試：

export NAMESRV_ADDR=127.0.0.1:9876 cd bin sh tools.sh org.apache.rocketmq.example.quickstart.Producer #測(cè)試結(jié)果 SendResult [sendStatus=SEND_OK, msgId=AC110001473C7D4991AD336AEA5703E0, offsetMsgId=AC11000100002A9F00000000000E8580, messageQueue=MessageQueue [topic=TopicTest, brokerName=learn, queueId=3], queueOffset=1323] SendResult [sendStatus=SEND_OK, msgId=AC110001473C7D4991AD336AEA5903E1, offsetMsgId=AC11000100002A9F00000000000E8634, messageQueue=MessageQueue [topic=TopicTest, brokerName=learn, queueId=0], queueOffset=1323] SendResult [sendStatus=SEND_OK, msgId=AC110001473C7D4991AD336AEA5F03E2, offsetMsgId=AC11000100002A9F00000000000E86E8, messageQueue=MessageQueue [topic=TopicTest, brokerName=learn, queueId=1], queueOffset=1323] SendResult [sendStatus=SEND_OK, msgId=AC110001473C7D4991AD336AEA6103E3, offsetMsgId=AC11000100002A9F00000000000E879C, messageQueue=MessageQueue [topic=TopicTest, brokerName=learn, queueId=2], queueOffset=1323] #可以正常發(fā)送消息

測(cè)試接收消息：

sh tools.sh org.apache.rocketmq.example.quickstart.Consumer #測(cè)試結(jié)果 ConsumeMessageThread_7 Receive New Messages: [MessageExt [queueId=2, storeSize=180, queueOffset=1322, sysFlag=0, bornTimestamp=1544456244818, bornHost=/172.16.55.185:33702, storeTimestamp=1544456244819, storeHost=/172.17.0.1:10911, msgId=AC11000100002A9F00000000000E84CC, commitLogOffset=951500, bodyCRC=684865321, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message{topic='TopicTest', flag=0, properties={MIN_OFFSET=0, MAX_OFFSET=1325, CONSUME_START_TIME=1544456445397, UNIQ_KEY=AC110001473C7D4991AD336AEA5203DF, WAIT=true, TAGS=TagA}, body=[72, 101, 108, 108, 111, 32, 82, 111, 99, 107, 101, 116, 77, 81, 32, 57, 57, 49], transactionId='null'}]] ConsumeMessageThread_6 Receive New Messages: [MessageExt [queueId=2, storeSize=180, queueOffset=1323, sysFlag=0, bornTimestamp=1544456244833, bornHost=/172.16.55.185:33702, storeTimestamp=1544456244835, storeHost=/172.17.0.1:10911, msgId=AC11000100002A9F00000000000E879C, commitLogOffset=952220, bodyCRC=801108784, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message{topic='TopicTest', flag=0, properties={MIN_OFFSET=0, MAX_OFFSET=1325, CONSUME_START_TIME=1544456445397, UNIQ_KEY=AC110001473C7D4991AD336AEA6103E3, WAIT=true, TAGS=TagA}, body=[72, 101, 108, 108, 111, 32, 82, 111, 99, 107, 101, 116, 77, 81, 32, 57, 57, 53], transactionId='null'}]] #從結(jié)果中，可以看出，接收消息正常

?

總結(jié)

以上是生活随笔為你收集整理的通过非docker的方式进行RocketMQ的安装的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。