欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Docker部署RocketMQ的實現(xiàn)示例

 更新時間：2024年10月13日 10:58:46   作者：特立獨行的Mr高  
本文主要介紹了Docker部署RocketMQ的實現(xiàn)示例,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧

1.namesrv

1.1 拉取rocketMQ鏡像

docker pull apache/rocketmq:4.9.4

1.2  創(chuàng)建nameserver數(shù)據(jù)存儲目錄

rocketMQ 分為nameserver和broker兩部分，在啟動時應該先啟動nameserver，因此我們現(xiàn)在先創(chuàng)建nameserver的日志和數(shù)據(jù)存放目錄。這個目錄可由我們自己定義路徑，這里我將其放到data路徑

mkdir -p /app/rocketmq/logs /app/rocketmq/store

1.3 構建namesrv容器并啟動

我們已經創(chuàng)建好了nameserver的日志和數(shù)據(jù)的存放路徑，此時我們只需要掛在日志和數(shù)據(jù)路徑，執(zhí)行以下命令啟動nameserver即可

docker run -d -p 9876:9876 --restart=always \
  -v /app/rocketmq/namesrv/logs:/home/rocketmq/logs \
  -v /app/rocketmq/namesrv/store:/home/rocketmq/store \
  --name mqnamesrv \
  --network rocketmq \
  -e"JAVA_OPT_EXT=-server -Xms512m -Xmx512m -Xmn512m" \
  apache/rocketmq:4.9.4 \
  sh mqnamesrv

2.broker

2.1 創(chuàng)建broker數(shù)據(jù)存儲路徑

在操作這步之前，我們已經將nameserver啟動成功，則接下來我們將要為broker創(chuàng)建數(shù)據(jù)掛載目錄和配置文件，以確保broker能夠成功啟動。

mkdir -p /app/rocketmq/broker/logs  /app/rocketmq/broker/store /app/rocketmq/broker/conf

說明：logs:是broker的日志目錄，store:是broker的數(shù)據(jù)目錄(該目錄需求所有讀寫權限)，conf是broker的配置信息目錄

2.2 創(chuàng)建broker配置文件

我們剛剛已經創(chuàng)建了broker配置目錄(/data/rocketmqbroker/conf)，現(xiàn)在我們要在改配置目錄下增加一個broker的配置文件，命名叫broker.conf

cd /app/rocketmq/broker/conf
vi broker.conf

注意：將一下信息復制到broker.conf文件中，請注意修改brokerIP1，改為您服務器的IP地址！注意修改namesrvAddr，改為您nameserver的IP地址！

# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements.  See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License.  You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
#  Unless required by applicable law or agreed to in writing, software
#  distributed under the License is distributed on an "AS IS" BASIS,
#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
#  See the License for the specific language governing permissions and
#  limitations under the License.


# 所屬集群名字
brokerClusterName=DefaultCluster
# broker 名字，注意此處不同的配置文件填寫的不一樣，如果在 broker-a.properties 使用: broker-a,
# 在 broker-b.properties 使用: broker-b
brokerName=broker-a
# 0 表示 Master，> 0 表示 Slave
brokerId=0
# nameServer地址，分號分割
namesrvAddr=192.168.18.200:9876
# 啟動IP,如果 docker 報 com.alibaba.rocketmq.remoting.exception.RemotingConnectException: connect to <192.168.0.120:10909> failed
# 解決方式1 加上一句 producer.setVipChannelEnabled(false);，解決方式2 brokerIP1 設置宿主機IP，不要使用docker 內部IP
#producer.setVipChannelEnabled=false
brokerIP1=192.168.18.200

# 在發(fā)送消息時，自動創(chuàng)建服務器不存在的topic，默認創(chuàng)建的隊列數(shù)
defaultTopicQueueNums=4
# 是否允許 Broker 自動創(chuàng)建 Topic，建議線下開啟，線上關閉 ?。。∵@里仔細看是 false，false，false
autoCreateTopicEnable=true
# 是否允許 Broker 自動創(chuàng)建訂閱組，建議線下開啟，線上關閉
autoCreateSubscriptionGroup=true
# Broker 對外服務的監(jiān)聽端口
listenPort=10911
# 刪除文件時間點，默認凌晨4點
deleteWhen=04
# 文件保留時間，默認48小時
fileReservedTime=120
# commitLog 每個文件的大小默認1G
mapedFileSizeCommitLog=1073741824
# ConsumeQueue 每個文件默認存 30W 條，根據(jù)業(yè)務情況調整
mapedFileSizeConsumeQueue=300000
# destroyMapedFileIntervalForcibly=120000
# redeleteHangedFileInterval=120000
# 檢測物理文件磁盤空間
diskMaxUsedSpaceRatio=88
# 存儲路徑
# storePathRootDir=/home/ztztdata/rocketmq-all-4.1.0-incubating/store
# commitLog 存儲路徑
# storePathCommitLog=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/commitlog
# 消費隊列存儲
# storePathConsumeQueue=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/consumequeue
# 消息索引存儲路徑
# storePathIndex=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/index
# checkpoint 文件存儲路徑
# storeCheckpoint=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/checkpoint
# abort 文件存儲路徑
# abortFile=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/abort
# 限制的消息大小
maxMessageSize=65536
# flushCommitLogLeastPages=4
# flushConsumeQueueLeastPages=2
# flushCommitLogThoroughInterval=10000
# flushConsumeQueueThoroughInterval=60000
# Broker 的角色
# - ASYNC_MASTER 異步復制Master
# - SYNC_MASTER 同步雙寫Master
# - SLAVE
brokerRole=ASYNC_MASTER
# 刷盤方式
# - ASYNC_FLUSH 異步刷盤
# - SYNC_FLUSH 同步刷盤
flushDiskType=ASYNC_FLUSH
# 發(fā)消息線程池數(shù)量
# sendMessageThreadPoolNums=128
# 拉消息線程池數(shù)量
# pullMessageThreadPoolNums=128

2.3 構建broker容器并啟動

docker run -d -p 10911:10911 -p 10909:10909 \
-v /app/rocketmq/broker/logs:/home/rocketmq/logs \
-v /app/rocketmq/broker/store:/home/rocketmq/store \
-v /app/rocketmq/broker/conf/broker.conf:/home/rocketmq/rocketmq-4.9.4/conf/broker.conf \
--name rmqbroker \
-e "NAMESRV_ADDR=mqnamesrv:9876" \
 apache/rocketmq:4.9.4 \
sh mqbroker -n mqnamesrv:9876 \
-c  /home/rocketmq/rocketmq-4.9.4/conf/broker.conf autoCreateTopicEnable=true

3.RocketMQ-Console可視化界面

3.1 拉取rocketmq-console鏡像

docker pull styletang/rocketmq-console-ng

3.2 構建RocketMQ-Console容器并啟動

docker run -d --restart=always --name rocketmq-admin -e "JAVA_OPTS=-Drocketmq.namesrv.addr=mqnamesrv:9876 -Dcom.rocketmqsendMessageWithVIPChannel=false"  -p 18080 :8080  styletang/rocketmq-console-ng

注意：將一下信息Drocketmq.namesrv.addr后面的IP地址改為您的nameserver IP地址！

到此這篇關于Docker部署RocketMQ的實現(xiàn)示例的文章就介紹到這了,更多相關Docker部署RocketMQ內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

相關文章

  • docker中時區(qū)問題的處理方法

    docker中時區(qū)問題的處理方法

    這篇文章主要給大家介紹了關于docker中時區(qū)問題的處理方法，文中通過示例代碼介紹的非常詳細，對大家學習或者使用docker具有一定的參考學習價值，需要的朋友們下面來一起學習學習吧
    2019-09-09
  • MinIO存儲在docker中安裝及其使用方式

    MinIO存儲在docker中安裝及其使用方式

    這篇文章主要介紹了MinIO存儲在docker中安裝及其使用方式，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
    2023-04-04
  • 基于Docker的MongoDB實現(xiàn)授權訪問的方法

    基于Docker的MongoDB實現(xiàn)授權訪問的方法

    這篇文章主要介紹了基于Docker的MongoDB實現(xiàn)授權訪問的方法,需要的朋友可以參考下
    2017-03-03
  • Docker下Tomcat容器中使用Mysql的方法

    Docker下Tomcat容器中使用Mysql的方法

    這篇文章主要介紹了Docker下Tomcat容器中使用Mysql的方法,需要的朋友可以參考下
    2018-07-07
  • docker部署釘釘機器人報警通知的實現(xiàn)

    docker部署釘釘機器人報警通知的實現(xiàn)

    本文主要介紹了docker部署釘釘機器人報警通知的實現(xiàn)，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
    2022-05-05
  • Docker部署java項目的詳細步驟(利用Dockerfile方式)

    Docker部署java項目的詳細步驟(利用Dockerfile方式)

    docker可以利用簡單的編寫程序構建出任何你想要的環(huán)境,同時可以跟業(yè)務代碼相結合,快速構建和生成所需要的應用,下面這篇文章主要給大家介紹了關于Docker部署java項目的詳細步驟，本文主要利用的是Dockerfile方式,需要的朋友可以參考下
    2022-08-08
  • 解決Docker安裝錯誤failure:repodata/repomd.xml from docker-ce-stable

    解決Docker安裝錯誤failure:repodata/repomd.xml from docke

    在使用yum命令安裝docker或其他工具時可能會遇到failure_repodata_repomd.xmlfromdocker-ce-stable_[Errno256]Nomoremirrorstotry的錯誤,原因可能是yum源配置問題,解決方法包括重置yum源,刪除多余的repo文件
    2024-11-11
  • Docker?link實現(xiàn)容器互聯(lián)的方式

    Docker?link實現(xiàn)容器互聯(lián)的方式

    通過link方式創(chuàng)建容器，然后我們可以使用被link容器的別名進行訪問。本文重點給大家介紹Docker?link實現(xiàn)容器互聯(lián)的方式，感興趣的朋友一起看看吧
    2021-12-12
  • docker安裝Adminer并支持mysql和mongodb的詳細步驟

    docker安裝Adminer并支持mysql和mongodb的詳細步驟

    這篇文章主要介紹了docker安裝Adminer并支持mysql和mongodb,通過查找并拉取Adminer鏡像，啟動docker，支持mysq，本文分步驟給大家詳細講解，需要的朋友可以參考下
    2022-10-10
  • 詳解Docker基于已有的鏡像制新的鏡像

    詳解Docker基于已有的鏡像制新的鏡像

    本篇文章主要介紹了Docker基于已有的鏡像制新的鏡像，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
    2017-05-05

最新評論