本文主要介紹安裝rocketmq4.4.0，主要分為四步，分別為：
1、拉取rocketmq鏡像。
2、創建namesrv。
3、創建broker節點，我在這里介紹的是創建單個broker的。
4、rocketmq-console服務，用于管理rocketmq的管理界面。
拉取rocketmq鏡像
docker命令如下
|
1
|
docker pull rocketmqinc/rocketmq:4.4.0 |
創建namesrv
docker命令
|
1
|
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 |
參數解釋
| 參數 | 描述 |
|---|---|
| -d | 以守護進程的方式啟動 |
| - -name | 設置容器的名字 |
| -p | 容器9876端口映射到本機9876端口上 |
| -v | 把容器/root/logs(日志文件)目錄映射到本機對應路徑上 /把容器/root/store(數據存儲)目錄映射到本機對應路徑上 |
| -e | 設置容器最大堆內存為 100000000 |
| rocketmqinc/rocketmq:4.4.0 | 鏡像名稱:版本 |
| sh | 啟動服務mqnamesrv |
創建單個broker節點
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
參數解釋
| 參數 | 描述 |
|---|---|
| -d | 以守護進程的方式啟動 |
| - -name | 設置容器的名字 |
| - -link | 和rmqnamesrv 容器建立通訊 |
| -p 10911:10911 | 把容器的非vip通訊端口10911映射到本機10911端口 |
| -p 10909:10909 | 把容器的vip通訊端口1090映射到本機10909端口 |
| –privileged=true | 設置允許掛載私有文件夾 |
| -v | 把容器/root/logs(日志文件)目錄映射到本機對應路徑上 /把容器/root/store(數據存儲)目錄映射到本機對應路徑上 / 把容器/opt/rocketmq-4.4.0/conf/broker.conf配置文件映射到本機對應路徑上(每次可以修改本機上的broker.conf文件，重啟容器即可) |
| -e “namesrv_addr=namesrv:9876” | 指定namesrv的地址為本機的9876 |
| -e “max_possible_heap=200000000” | 設置broker服務的最大堆內存為 200000000 |
| rocketmqinc/rocketmq:4.4.0 | 鏡像名稱:版本 |
| sh mqbroker | 啟動服務mqbroker |
| -c /opt/rocketmq-4.4.0/conf/broker.conf | 指定配置文件啟動broker |
broker.conf文件配置
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
#如果節點較多可以配置多個brokerclustername = defaultcluster#broker名稱，master和slave使用相同的名稱，表明他們的主從關系brokername = broker-a#0表示master，大于0表示不同的slavebrokerid = 0#表示幾點做消息刪除動作，默認是凌晨4點deletewhen = 04#在磁盤上保留消息的時長，單位是小時filereservedtime = 48#有三個值：sync_master，async_master，slave；同步和異步表示master和slave之間同步數據的機制；brokerrole = async_master#刷盤策略，取值為：async_flush，sync_flush表示同步刷盤和異步刷盤；sync_flush消息寫入磁盤后才返回成功狀態，async_flush不需要；flushdisktype = async_flush# 設置broker節點所在服務器的ip地址namesrvaddr = 本機ip地址:9876brokerip1 = 本機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服務
docker命令
可以不使用docker pull 命令進行鏡像拉取，直接執行docker run命令，如果此鏡像不存在會先拉取鏡像在執行docker run。
|
1
|
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 |
參數說明
| 描述 | 說明 |
|---|---|
| -d | 以守護進程的方式啟動 |
| - -name | 設置容器的名字 |
| -e "java_opts=-drocketmq.namesrv.addr=172.16.122.115:9876 | 設置namesrv服務的ip地址 |
| -dcom.rocketmq.sendmessagewithvipchannel=false" | 不使用vip通道發送消息 |
| -p 8081:8080 | 把容器內的端口8080映射到主機上的8081端口 |
rocketmq-console界面
容器運行成功后，使用瀏覽器打開 http://127.0.0.1:8081 就可以進入到rokcetmq-console管理界面，看到集群信息，說明rocketmq安裝成功了。
rocketmq-console生產者界面報錯問題
點擊搜索報錯，是因為生產者創建生產組后使用producer.shutdown()將它關閉了，將下面代碼注銷即可。
到此這篇關于docker安裝rocketmq和安裝過程中出現問題的解決的文章就介紹到這了,更多相關docker安裝rocketmq內容請搜索服務器之家以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持服務器之家！
原文鏈接：https://blog.csdn.net/weixin_45003796/article/details/122156567
