docker安裝rocketmq

時間  2019-11-18
標籤 docker 安裝 rocketmq 欄目 Docker 简体版
原文   原文鏈接

1、單機部署web

一、拉取鏡像：foxiswho/rocketmq:server  cabel/rocketmq:broker styletang/rocketmq-console-ngdocker

二、建立目錄：data/{brokerconf,logs,store}服務器

三、建立data/brokerconf/broker.conf異步

# 所屬集羣名字
brokerClusterName=Duojia

# broker 名字，注意此處不一樣的配置文件填寫的不同，若是在 broker-a.properties 使用: broker-a,
# 在 broker-b.properties 使用: broker-b
brokerName=broker-a

# 0 表示 Master，> 0 表示 Slave
brokerId=0

# nameServer地址，分號分割
namesrvAddr=192.168.100.55:9876;192.168.100.56: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
brokerIP1=192.168.100.55
brokerIP2=192.168.100.56

# 在發送消息時，自動建立服務器不存在的topic，默認建立的隊列數
defaultTopicQueueNums=4

# 是否容許 Broker 自動建立 Topic，建議線下開啓，線上關閉 ！！！這裏仔細看是 false，false，false
autoCreateTopicEnable=false

# 是否容許 Broker 自動建立訂閱組，建議線下開啓，線上關閉
autoCreateSubscriptionGroup=false

# Broker 對外服務的監聽端口
listenPort=10911

# 刪除文件時間點，默認凌晨4點
deleteWhen=04

# 文件保留時間，默認48小時
fileReservedTime=120

# commitLog 每一個文件的大小默認1G
mapedFileSizeCommitLog=1073741824

# ConsumeQueue 每一個文件默認存 30W 條，根據業務狀況調整
mapedFileSizeConsumeQueue=300000

# destroyMapedFileIntervalForcibly=120000
# redeleteHangedFileInterval=120000
# 檢測物理文件磁盤空間
diskMaxUsedSpaceRatio=88
# 存儲路徑
storePathRootDir=/opt/rkmq/store
# commitLog 存儲路徑
storePathCommitLog=/opt/rkmq/commitlog
# 消費隊列存儲
storePathConsumeQueue=/opt/rkmq/consumequeue
# 消息索引存儲路徑
storePathIndex=/opt/rkmq/index
# checkpoint 文件存儲路徑
storeCheckpoint=/opt/rkmq/checkpoint
# abort 文件存儲路徑
abortFile=/opt/rkmq/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

# 發消息線程池數量
# sendMessageThreadPoolNums=128
# 拉消息線程池數量
# pullMessageThreadPoolNums=128
View Code

PS：以上配置文件的namesrvAddr選項修改爲一個，集羣配置多個ide

四、建立docker-compose.yaml文件spa

version: '3.0'
services:
  rmqnamesrv:
    image: foxiswho/rocketmq:server
    container_name: rmqnamesrv
    ports:
      - 9876:9876
    volumes:
      - ./data/logs:/opt/logs
      - ./data/store:/opt/store

  rmqbroker:
    image: cabel/rocketmq:broker
    container_name: rmqbroker
    ports:
      - 10909:10909
      - 10911:10911
    volumes:
      - ./data/logs:/opt/logs
      - ./data/store:/opt/store
      - ./data/brokerconf/broker.conf:/etc/rocketmq/broker.conf
    environment:
        NAMESRV_ADDR: "rmqnamesrv:9876"
        JAVA_OPTS: " -Duser.home=/opt"
        JAVA_OPT_EXT: "-server -Xms128m -Xmx128m -Xmn128m"
    command: mqbroker -c /etc/rocketmq/broker.conf
    depends_on:
      - rmqnamesrv

  rmqconsole:
    image: styletang/rocketmq-console-ng
    container_name: rmqconsole
    ports:
      - 18080:8080
    environment:
        JAVA_OPTS: "-Drocketmq.namesrv.addr=rmqnamesrv:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false"
    depends_on:
      - rmqnamesrv
View Code

五、docker-compose up -d啓動便可線程

六、而後訪問18080端口便可進入web頁面code

2、集羣部署server

集羣部署與單機部署不一樣之處是在broker.conf配置文件的不一樣：blog

master-1的broker.conf

# 所屬集羣名字
brokerClusterName=Duojia

# broker 名字，注意此處不一樣的配置文件填寫的不同，若是在 broker-a.properties 使用: broker-a,
# 在 broker-b.properties 使用: broker-b
brokerName=broker-a

# 0 表示 Master，> 0 表示 Slave
brokerId=0

# nameServer地址，分號分割
namesrvAddr=192.168.100.55:9876;192.168.100.56: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
brokerIP1=192.168.100.55

# 在發送消息時，自動建立服務器不存在的topic，默認建立的隊列數
defaultTopicQueueNums=4

# 是否容許 Broker 自動建立 Topic，建議線下開啓，線上關閉 ！！！這裏仔細看是 false，false，false
autoCreateTopicEnable=false

# 是否容許 Broker 自動建立訂閱組，建議線下開啓，線上關閉
autoCreateSubscriptionGroup=false

# Broker 對外服務的監聽端口
listenPort=10911

# 刪除文件時間點，默認凌晨4點
deleteWhen=04

# 文件保留時間，默認48小時
fileReservedTime=120

# commitLog 每一個文件的大小默認1G
mapedFileSizeCommitLog=1073741824

# ConsumeQueue 每一個文件默認存 30W 條，根據業務狀況調整
mapedFileSizeConsumeQueue=300000

# destroyMapedFileIntervalForcibly=120000
# redeleteHangedFileInterval=120000
# 檢測物理文件磁盤空間
diskMaxUsedSpaceRatio=88
# 存儲路徑
storePathRootDir=/opt/rkmq/store
# commitLog 存儲路徑
storePathCommitLog=/opt/rkmq/commitlog
# 消費隊列存儲
storePathConsumeQueue=/opt/rkmq/consumequeue
# 消息索引存儲路徑
storePathIndex=/opt/rkmq/index
# checkpoint 文件存儲路徑
storeCheckpoint=/opt/rkmq/checkpoint
# abort 文件存儲路徑
abortFile=/opt/rkmq/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

# 發消息線程池數量
# sendMessageThreadPoolNums=128
# 拉消息線程池數量
# pullMessageThreadPoolNums=128
View Code

slave-1的broker.conf

# 所屬集羣名字
brokerClusterName=Duojia

# broker 名字，注意此處不一樣的配置文件填寫的不同，若是在 broker-a.properties 使用: broker-a,
# 在 broker-b.properties 使用: broker-b
brokerName=broker-b

# 0 表示 Master，> 0 表示 Slave
brokerId=10

# nameServer地址，分號分割
namesrvAddr=192.168.100.55:9876;192.168.100.56: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
brokerIP1=192.168.100.56

# 在發送消息時，自動建立服務器不存在的topic，默認建立的隊列數
defaultTopicQueueNums=4

# 是否容許 Broker 自動建立 Topic，建議線下開啓，線上關閉 ！！！這裏仔細看是 false，false，false
autoCreateTopicEnable=false

# 是否容許 Broker 自動建立訂閱組，建議線下開啓，線上關閉
autoCreateSubscriptionGroup=false

# Broker 對外服務的監聽端口
listenPort=10911

# 刪除文件時間點，默認凌晨4點
deleteWhen=04

# 文件保留時間，默認48小時
fileReservedTime=120

# commitLog 每一個文件的大小默認1G
mapedFileSizeCommitLog=1073741824

# ConsumeQueue 每一個文件默認存 30W 條，根據業務狀況調整
mapedFileSizeConsumeQueue=300000

# destroyMapedFileIntervalForcibly=120000
# redeleteHangedFileInterval=120000
# 檢測物理文件磁盤空間
diskMaxUsedSpaceRatio=88
# 存儲路徑
storePathRootDir=/opt/rkmq/store
# commitLog 存儲路徑
storePathCommitLog=/opt/rkmq/commitlog
# 消費隊列存儲
storePathConsumeQueue=/opt/rkmq/consumequeue
# 消息索引存儲路徑
storePathIndex=/opt/rkmq/index
# checkpoint 文件存儲路徑
storeCheckpoint=/opt/rkmq/checkpoint
# abort 文件存儲路徑
abortFile=/opt/rkmq/abort
# 限制的消息大小
maxMessageSize=65536

# flushCommitLogLeastPages=4
# flushConsumeQueueLeastPages=2
# flushCommitLogThoroughInterval=10000
# flushConsumeQueueThoroughInterval=60000

# Broker 的角色
# - ASYNC_MASTER 異步複製Master
# - SYNC_MASTER 同步雙寫Master
# - SLAVE
brokerRole=SLAVE

# 刷盤方式
# - ASYNC_FLUSH 異步刷盤
# - SYNC_FLUSH 同步刷盤
flushDiskType=ASYNC_FLUSH

# 發消息線程池數量
# sendMessageThreadPoolNums=128
# 拉消息線程池數量
# pullMessageThreadPoolNums=128
View Code

其中的compose文件，rmqconsole服務僅配置一個便可。

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程