快捷導(dǎo)航

docker安裝rocketMQ和安裝過(guò)程中出現(xiàn)問(wèn)題的解決

更新時(shí)間：2021年12月27日 09:38:09 作者：Y呀

本文主要介紹了docker安裝rocketMQ和安裝過(guò)程中出現(xiàn)問(wèn)題的解決，文中通過(guò)示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

本文主要介紹安裝rocketMQ4.4.0，主要分為四步，分別為：
1、拉取rocketmq鏡像。
2、創(chuàng)建namesrv。
3、創(chuàng)建broker節(jié)點(diǎn)，我在這里介紹的是創(chuàng)建單個(gè)broker的。
4、rocketMQ-console服務(wù)，用于管理rocketMQ的管理界面。

拉取rocketmq鏡像

docker命令如下

docker pull rocketmqinc/rocketmq:4.4.0

創(chuàng)建namesrv

docker命令

docker run -d --name rmqnamesrv -p 9876:9876 -v C:\data\rocketmq\logs:/root/logs -v C:\data\rocketmq\store:/root/store -e "MAX_POSSIBLE_HEAP=100000000" rocketmqinc/rocketmq:4.4.0 sh mqnamesrv

參數(shù)解釋

參數(shù)	描述
-d	以守護(hù)進(jìn)程的方式啟動(dòng)
- -name	設(shè)置容器的名字
-p	容器9876端口映射到本機(jī)9876端口上
-v	把容器/root/logs(日志文件)目錄映射到本機(jī)對(duì)應(yīng)路徑上 /把容器/root/store(數(shù)據(jù)存儲(chǔ))目錄映射到本機(jī)對(duì)應(yīng)路徑上
-e	設(shè)置容器最大堆內(nèi)存為 100000000
rocketmqinc/rocketmq:4.4.0	鏡像名稱:版本
sh	啟動(dòng)服務(wù)mqnamesrv

創(chuàng)建單個(gè)broker節(jié)點(diǎn)

docker命令

docker run -d --name rmqbroker --link rmqnamesrv:namesrv -p 10911:10911 -p 10909:10909 --privileged=true -v? C:\data\broker\logs:/root/logs -v? C:\data\broker\store:/root/store -v C:\data\broker\conf\broker.conf:/opt/rocketmq-4.4.0/conf/broker.conf -e "NAMESRV_ADDR=namesrv:9876" -e "MAX_POSSIBLE_HEAP=200000000" rocketmqinc/rocketmq:4.4.0 sh mqbroker -c /opt/rocketmq-4.4.0/conf/broker.conf

參數(shù)解釋

參數(shù)	描述
-d	以守護(hù)進(jìn)程的方式啟動(dòng)
- -name	設(shè)置容器的名字
- -link	和rmqnamesrv 容器建立通訊
-p 10911:10911	把容器的非VIP通訊端口10911映射到本機(jī)10911端口
-p 10909:10909	把容器的VIP通訊端口1090映射到本機(jī)10909端口
–privileged=true	設(shè)置允許掛載私有文件夾
-v	把容器/root/logs(日志文件)目錄映射到本機(jī)對(duì)應(yīng)路徑上 /把容器/root/store(數(shù)據(jù)存儲(chǔ))目錄映射到本機(jī)對(duì)應(yīng)路徑上 / 把容器/opt/rocketmq-4.4.0/conf/broker.conf配置文件映射到本機(jī)對(duì)應(yīng)路徑上(每次可以修改本機(jī)上的broker.conf文件，重啟容器即可)
-e “NAMESRV_ADDR=namesrv:9876”	指定namesrv的地址為本機(jī)的9876
-e “MAX_POSSIBLE_HEAP=200000000”	設(shè)置broker服務(wù)的最大堆內(nèi)存為 200000000
rocketmqinc/rocketmq:4.4.0	鏡像名稱:版本
sh mqbroker	啟動(dòng)服務(wù)mqbroker
-c /opt/rocketmq-4.4.0/conf/broker.conf	指定配置文件啟動(dòng)broker

broker.conf文件配置

#如果節(jié)點(diǎn)較多可以配置多個(gè)
brokerClusterName = DefaultCluster
#broker名稱，master和slave使用相同的名稱，表明他們的主從關(guān)系
brokerName = broker-a
#0表示Master，大于0表示不同的slave
brokerId = 0
#表示幾點(diǎn)做消息刪除動(dòng)作，默認(rèn)是凌晨4點(diǎn)
deleteWhen = 04
#在磁盤上保留消息的時(shí)長(zhǎng)，單位是小時(shí)
fileReservedTime = 48
#有三個(gè)值：SYNC_MASTER，ASYNC_MASTER，SLAVE；同步和異步表示Master和Slave之間同步數(shù)據(jù)的機(jī)制；
brokerRole = ASYNC_MASTER
#刷盤策略，取值為：ASYNC_FLUSH，SYNC_FLUSH表示同步刷盤和異步刷盤；SYNC_FLUSH消息寫入磁盤后才返回成功狀態(tài)，ASYNC_FLUSH不需要；
flushDiskType = ASYNC_FLUSH
# 設(shè)置broker節(jié)點(diǎn)所在服務(wù)器的ip地址
namesrvAddr = 本機(jī)ip地址:9876
brokerIP1 = 本機(jī)ip地址

broker.conf配置文件中如果不加namesrvAddr配置，運(yùn)行程序時(shí)會(huì)報(bào)如下的錯(cuò)：

Exception in thread "main" org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendDefaultImpl call timeout
?at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:588)
?at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1223)
?at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1173)
?at org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:214)
?at com.baojian.mob.base.producer.SyncProducer.main(SyncProducer.java:41)
15:22:31.455 [NettyClientSelector_1] INFO RocketmqRemoting - closeChannel: close the connection to remote address[] result: true
15:22:32.049 [NettyClientSelector_1] INFO RocketmqRemoting - closeChannel: close the connection to remote address[] result: true

rocketMQ-console服務(wù)

docker命令

可以不使用docker pull 命令進(jìn)行鏡像拉取，直接執(zhí)行docker run命令，如果此鏡像不存在會(huì)先拉取鏡像在執(zhí)行docker run。

docker run -d --name rmqadmin -e "JAVA_OPTS=-Drocketmq.namesrv.addr=172.16.122.115:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false" -p 8081:8080 pangliang/rocketmq-console-ng

參數(shù)說(shuō)明

描述	說(shuō)明
-d	以守護(hù)進(jìn)程的方式啟動(dòng)
- -name	設(shè)置容器的名字
-e "JAVA_OPTS=-Drocketmq.namesrv.addr=172.16.122.115:9876	設(shè)置namesrv服務(wù)的IP地址
-Dcom.rocketmq.sendMessageWithVIPChannel=false"	不使用VIP通道發(fā)送消息
-p 8081:8080	把容器內(nèi)的端口8080映射到主機(jī)上的8081端口

rocketmq-console界面
容器運(yùn)行成功后，使用瀏覽器打開 http://127.0.0.1:8081 就可以進(jìn)入到rokcetmq-console管理界面，看到集群信息，說(shuō)明rocketmq安裝成功了。

在這里插入圖片描述

rocketmq-console生產(chǎn)者界面報(bào)錯(cuò)問(wèn)題

在這里插入圖片描述

點(diǎn)擊搜索報(bào)錯(cuò)，是因?yàn)樯a(chǎn)者創(chuàng)建生產(chǎn)組后使用producer.shutdown()將它關(guān)閉了，將下面代碼注銷即可。

在這里插入圖片描述

到此這篇關(guān)于docker安裝rocketMQ和安裝過(guò)程中出現(xiàn)問(wèn)題的解決的文章就介紹到這了,更多相關(guān)docker安裝rocketMQ內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: