docker安裝rocketMQ和安裝過程中出現(xiàn)問題的解決
本文主要介紹安裝rocketMQ4.4.0，主要分為四步，分別為：
1、拉取rocketmq鏡像。
2、創(chuàng)建namesrv。
3、創(chuàng)建broker節(jié)點，我在這里介紹的是創(chuàng)建單個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 | 以守護進程的方式啟動 |
| - -name | 設(shè)置容器的名字 |
| -p | 容器9876端口映射到本機9876端口上 |
| -v | 把容器/root/logs(日志文件)目錄映射到本機對應(yīng)路徑上 /把容器/root/store(數(shù)據(jù)存儲)目錄映射到本機對應(yīng)路徑上 |
| -e | 設(shè)置容器最大堆內(nèi)存為 100000000 |
| rocketmqinc/rocketmq:4.4.0 | 鏡像名稱:版本 |
| sh | 啟動服務(wù)mqnamesrv |
創(chuàng)建單個broker節(jié)點
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 | 以守護進程的方式啟動 |
| - -name | 設(shè)置容器的名字 |
| - -link | 和rmqnamesrv 容器建立通訊 |
| -p 10911:10911 | 把容器的非VIP通訊端口10911映射到本機10911端口 |
| -p 10909:10909 | 把容器的VIP通訊端口1090映射到本機10909端口 |
| –privileged=true | 設(shè)置允許掛載私有文件夾 |
| -v | 把容器/root/logs(日志文件)目錄映射到本機對應(yīng)路徑上 /把容器/root/store(數(shù)據(jù)存儲)目錄映射到本機對應(yīng)路徑上 / 把容器/opt/rocketmq-4.4.0/conf/broker.conf配置文件映射到本機對應(yīng)路徑上(每次可以修改本機上的broker.conf文件，重啟容器即可) |
| -e “NAMESRV_ADDR=namesrv:9876” | 指定namesrv的地址為本機的9876 |
| -e “MAX_POSSIBLE_HEAP=200000000” | 設(shè)置broker服務(wù)的最大堆內(nèi)存為 200000000 |
| rocketmqinc/rocketmq:4.4.0 | 鏡像名稱:版本 |
| sh mqbroker | 啟動服務(wù)mqbroker |
| -c /opt/rocketmq-4.4.0/conf/broker.conf | 指定配置文件啟動broker |
broker.conf文件配置
#如果節(jié)點較多可以配置多個 brokerClusterName = DefaultCluster #broker名稱，master和slave使用相同的名稱，表明他們的主從關(guān)系 brokerName = broker-a #0表示Master，大于0表示不同的slave brokerId = 0 #表示幾點做消息刪除動作，默認(rèn)是凌晨4點 deleteWhen = 04 #在磁盤上保留消息的時長，單位是小時 fileReservedTime = 48 #有三個值：SYNC_MASTER，ASYNC_MASTER，SLAVE；同步和異步表示Master和Slave之間同步數(shù)據(jù)的機制； brokerRole = ASYNC_MASTER #刷盤策略，取值為：ASYNC_FLUSH，SYNC_FLUSH表示同步刷盤和異步刷盤；SYNC_FLUSH消息寫入磁盤后才返回成功狀態(tài)，ASYNC_FLUSH不需要； flushDiskType = ASYNC_FLUSH # 設(shè)置broker節(jié)點所在服務(wù)器的ip地址 namesrvAddr = 本機ip地址:9876 brokerIP1 = 本機ip地址
broker.conf配置文件中如果不加namesrvAddr配置，運行程序時會報如下的錯：
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 命令進行鏡像拉取，直接執(zhí)行docker run命令，如果此鏡像不存在會先拉取鏡像在執(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ù)說明
| 描述 | 說明 |
|---|---|
| -d | 以守護進程的方式啟動 |
| - -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映射到主機上的8081端口 |
rocketmq-console界面
容器運行成功后，使用瀏覽器打開 http://127.0.0.1:8081 就可以進入到rokcetmq-console管理界面，看到集群信息，說明rocketmq安裝成功了。
rocketmq-console生產(chǎn)者界面報錯問題
點擊搜索報錯，是因為生產(chǎn)者創(chuàng)建生產(chǎn)組后使用producer.shutdown()將它關(guān)閉了，將下面代碼注銷即可。
到此這篇關(guān)于docker安裝rocketMQ和安裝過程中出現(xiàn)問題的解決的文章就介紹到這了,更多相關(guān)docker安裝rocketMQ內(nèi)容請搜索本站以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持本站！
版權(quán)聲明：本站文章來源標(biāo)注為YINGSOO的內(nèi)容版權(quán)均為本站所有，歡迎引用、轉(zhuǎn)載，請保持原文完整并注明來源及原文鏈接。禁止復(fù)制或仿造本網(wǎng)站，禁止在非www.sddonglingsh.com所屬的服務(wù)器上建立鏡像，否則將依法追究法律責(zé)任。本站部分內(nèi)容來源于網(wǎng)友推薦、互聯(lián)網(wǎng)收集整理而來，僅供學(xué)習(xí)參考，不代表本站立場，如有內(nèi)容涉嫌侵權(quán)，請聯(lián)系alex-e#qq.com處理。
關(guān)注官方微信