docker-compose单机部署rocketmq集群(双主双从，同步双写)

news2024/9/24 15:19:41

1.本文以RocketMQ 5.3.0 版本的镜像为例。

2.首先先更新docker，之前旧版docker，导致rocketmq一直起不来，一直报错。

3.安装docker-compose。


服务器环境（目前只用192.168.25.135后期改ip地址即可）
| 1    | 192.168.25.135 | nameserver、brokerserver | Master1、Slave2 |
| ---- | -------------- | ------------------------ | --------------- |
| 2    | 192.168.25.138 | nameserver、brokerserver | Master2、Slave1 |

Host添加信息
vim /etc/hosts

配置如下:
# nameserver
192.168.25.135 rocketmq-nameserver1
192.168.25.138 rocketmq-nameserver2
# broker
192.168.25.135 rocketmq-master1
192.168.25.135 rocketmq-slave2
192.168.25.138 rocketmq-master2
192.168.25.138 rocketmq-slave1

配置完成后, 重启网卡
systemctl restart network

开放端口号
* `nameserver` 默认使用 9876 端口
* `master` 默认使用 10911 端口
* `slave` 默认使用11011 端口

4.拉取镜像

docker pull apache/rocketmq:5.3.0


5.创建消息存储路径

mkdir -p /usr/local/rocketmq/broker-1-m/conf
touch    /usr/local/rocketmq/broker-1-m/conf/broker.conf
mkdir -p /usr/local/rocketmq/broker-1-m/logs
mkdir -p /usr/local/rocketmq/broker-1-m/store

mkdir -p /usr/local/rocketmq/broker-1-s/conf
touch    /usr/local/rocketmq/broker-1-s/conf/broker.conf
mkdir -p /usr/local/rocketmq/broker-1-s/logs
mkdir -p /usr/local/rocketmq/broker-1-s/store

mkdir -p /usr/local/rocketmq/broker-2-m/conf
touch    /usr/local/rocketmq/broker-2-m/conf/broker.conf
mkdir -p /usr/local/rocketmq/broker-2-m/logs
mkdir -p /usr/local/rocketmq/broker-2-m/store

mkdir -p /usr/local/rocketmq/broker-2-s/conf
touch    /usr/local/rocketmq/broker-2-s/conf/broker.conf
mkdir -p /usr/local/rocketmq/broker-2-s/logs
mkdir -p /usr/local/rocketmq/broker-2-s/store

6.授权

chmod 777 -R /usr/local/rocketmq

7.修改/usr/local/rocketmq/broker-1-m/conf/broker.conf配置文件

vim /usr/local/rocketmq/broker-1-m/conf/broker.conf
#集群名称
brokerClusterName=rocketmq-cluster
#broker名称
brokerName=broker1
#brokerId master用0 slave用其他
brokerId=0
#清理时机
deleteWhen=4
#文件保留时长 48小时
fileReservedTime=48
#broker角色 -ASYNC_MASTER异步复制 -SYNC_MASTER同步双写 -SLAVE
brokerRole=SYNC_MASTER
#刷盘策略 - ASYNC_FLUSH 异步刷盘 - SYNC_FLUSH 同步刷盘
flushDiskType=ASYNC_FLUSH
#主机ip
brokerIP1=192.168.25.135
#从节点ip(目前是本机ip)
brokerIP2=192.168.25.135
#对外服务的监听接口，同一台机器上部署多个broker,端口号要不相同
listenPort=10911
#是否能够自动创建topic
autoCreateTopicEnable=true

8.修改/usr/local/rocketmq/broker-2-s/conf/broker.conf配置文件

#集群名称
brokerClusterName=rocketmq-cluster
#broker名称
brokerName=broker2
#brokerId master用0 slave用其他
brokerId=1
#清理时机
deleteWhen=4
#文件保留时长 48小时
fileReservedTime=48
#broker角色 -ASYNC_MASTER异步复制 -SYNC_MASTER同步双写 -SLAVE
brokerRole=SLAVE
#刷盘策略 - ASYNC_FLUSH 异步刷盘 - SYNC_FLUSH 同步刷盘
flushDiskType=ASYNC_FLUSH
#主机ip
brokerIP1=192.168.25.135
#对外服务的监听接口，同一台机器上部署多个broker,端口号要不相同
listenPort=11911
#是否能够自动创建topic
autoCreateTopicEnable=true

9.修改/usr/local/rocketmq/broker-2-m/conf/broker.conf配置文件

#集群名称
brokerClusterName=rocketmq-cluster
#broker名称
brokerName=broker2
#brokerId master用0 slave用其他
brokerId=0
#清理时机
deleteWhen=4
#文件保留时长 48小时
fileReservedTime=48
#broker角色 -ASYNC_MASTER异步复制 -SYNC_MASTER同步双写 -SLAVE
brokerRole=SYNC_MASTER
#刷盘策略 - ASYNC_FLUSH 异步刷盘 - SYNC_FLUSH 同步刷盘
flushDiskType=ASYNC_FLUSH
#主机ip
brokerIP1=192.168.171.134
#从节点ip(目前是本机ip)
brokerIP2=192.168.25.135
#对外服务的监听接口，同一台机器上部署多个broker,端口号要不相同
listenPort=12911
#是否能够自动创建topic
autoCreateTopicEnable=true

10.修改/usr/local/rocketmq/broker-1-s/conf/broker.conf配置文件

#集群名称
brokerClusterName=rocketmq-cluster
#broker名称
brokerName=broker1
#brokerId master用0 slave用其他
brokerId=1
#清理时机
deleteWhen=4
#文件保留时长 48小时
fileReservedTime=48
#broker角色 -ASYNC_MASTER异步复制 -SYNC_MASTER同步双写 -SLAVE
brokerRole=SLAVE
#刷盘策略 - ASYNC_FLUSH 异步刷盘 - SYNC_FLUSH 同步刷盘
flushDiskType=ASYNC_FLUSH
#主机ip
brokerIP1=192.168.25.135
#对外服务的监听接口，同一台机器上部署多个broker,端口号要不相同
listenPort=13911
#是否能够自动创建topic
autoCreateTopicEnable=true

11.新建docker-compose文件

touch /usr/local/rocketmq/docker-compose.yml
vim /usr/local/rocketmq/docker-compose.yml

12.粘贴以下内容到docker-compose.yml

version: "3"
services:
  mqnamesrv:
    image: apache/rocketmq:5.3.0
    container_name: mqnamesrv
    ports:
      - 9876:9876
    environment:
      JAVA_OPT_EXT: "-Duser.home=/opt -Xms512m -Xmx512m -Xmn150m"
    command: sh mqnamesrv

  mqbroker-1-m:
    image: apache/rocketmq:5.3.0
    container_name: mqbroker-1-m
    ports:
      - 10911:10911
      - 10909:10909
      - 10912:10912
    volumes:
      - /usr/local/rocketmq/broker-1-m/conf/broker.conf:/home/rocketmq/conf/broker.conf
      - /usr/local/rocketmq/broker-1-m/logs:/home/rocketmq/logs
      - /usr/local/rocketmq/broker-1-m/store:/home/rocketmq/store
    environment:
      NAMESRV_ADDR: "mqnamesrv:9876"
      JAVA_OPTS: " -Duser.home=/opt"
      JAVA_OPT_EXT: "-server -Xms128m -Xmx128m -Xmn128m"
    command: sh mqbroker -c /home/rocketmq/conf/broker.conf
    depends_on:
      - mqnamesrv
  mqbroker-2-s:
    image: apache/rocketmq:5.3.0
    container_name: mqbroker-2-s
    ports:
      - 11911:11911
      - 11909:11909
      - 11912:11912
    volumes:
      - /usr/local/rocketmq/broker-2-s/conf/broker.conf:/home/rocketmq/conf/broker.conf
      - /usr/local/rocketmq/broker-2-s/logs:/home/rocketmq/logs
      - /usr/local/rocketmq/broker-2-s/store:/home/rocketmq/store
    environment:
      NAMESRV_ADDR: "mqnamesrv:9876"
      JAVA_OPTS: " -Duser.home=/opt"
      JAVA_OPT_EXT: "-server -Xms128m -Xmx128m -Xmn128m"
    command: sh mqbroker -c /home/rocketmq/conf/broker.conf
    depends_on:
      - mqnamesrv
	  
  mqbroker-2-m:
    image: apache/rocketmq:5.3.0
    container_name: mqbroker-2-m
    ports:
      - 12911:12911
      - 12909:12909
      - 12912:12912
    volumes:
      - /usr/local/rocketmq/broker-2-m/conf/broker.conf:/home/rocketmq/conf/broker.conf
      - /usr/local/rocketmq/broker-2-m/logs:/home/rocketmq/logs
      - /usr/local/rocketmq/broker-2-m/store:/home/rocketmq/store
    environment:
      NAMESRV_ADDR: "mqnamesrv:9876"
      JAVA_OPTS: " -Duser.home=/opt"
      JAVA_OPT_EXT: "-server -Xms128m -Xmx128m -Xmn128m"
    command: sh mqbroker -c /home/rocketmq/conf/broker.conf
    depends_on:
      - mqnamesrv
  mqbroker-1-s:
    image: apache/rocketmq:5.3.0
    container_name: mqbroker-1-s
    ports:
      - 13911:13911
      - 13909:13909
      - 13912:13912
    volumes:
      - /usr/local/rocketmq/broker-1-s/conf/broker.conf:/home/rocketmq/conf/broker.conf
      - /usr/local/rocketmq/broker-1-s/logs:/home/rocketmq/logs
      - /usr/local/rocketmq/broker-1-s/store:/home/rocketmq/store
    environment:
      NAMESRV_ADDR: "mqnamesrv:9876"
      JAVA_OPTS: " -Duser.home=/opt"
      JAVA_OPT_EXT: "-server -Xms128m -Xmx128m -Xmn128m"
    command: sh mqbroker -c /home/rocketmq/conf/broker.conf
    depends_on:
      - mqnamesrv

  mqconsole:
    image: styletang/rocketmq-console-ng:1.0.0
    container_name: mqconsole
    ports:
      - 19876:8080
    environment:
      JAVA_OPTS: -Drocketmq.namesrv.addr=mqnamesrv:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=falses
    depends_on:
      - mqnamesrv

13.在docker-compose.yml文件所在目录运行docker-compose.yml

docker-compose up -d

14.查看容器是否启动成功

docker ps
docker logs -f (容器id)

15.显示成功，就是成功了。

16.打开ip:19876

16.注意，记得把以上ip地址换成自己的。如果是云服务器，则需要把以上的端口都打开。注意路径不要错了。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/2078089.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

ArcGIS图斑导出CAD后变成三维多段线？

ArcGIS图斑导出CAD后变成三维多段线？

欢迎关注同名微信公众号，更多文章推送： 正常情况下，将ArcGIS中的图层导出为CAD，生成的是闭合多段线： 导出的CAD： 但是有时候导出的CAD变成三维多段线： 三维多段线有多麻烦用过CAD画图的人应该都…
阅读更多...
【GD32 MUC 移植教程】从 GD32F10x 移植到 GD32F30x

【GD32 MUC 移植教程】从 GD32F10x 移植到 GD32F30x

1. 前言 对于使用 GD32 系列微控制器进行产品开发的设计人员来说，因产品及功能升级，往往需要将一种微控制器替换成另一种微控制器，在保留既有功能的情况下增加新功能。为了更快地推出新产品，设计人员经常要将应用程序移植到新的…
阅读更多...
【数据分享】1999—2022年地级市各类交通工具的客货运量和拥有量数据（Shp/Excel格式）

【数据分享】1999—2022年地级市各类交通工具的客货运量和拥有量数据（Shp/Excel格式）

在之前的文章中，我们分享过基于2000-2023年《中国城市统计年鉴》整理的1999-2022年地级市的人口相关数据、各类用地面积数据、污染物排放和环境治理相关数据、房地产投资情况和商品房销售面积、社会消费品零售总额和年末金融机构存贷款余额、一般公共预算收支状况、…
阅读更多...
Transformer模型-4-Inputs

Transformer模型-4-Inputs

Encoder的输入层和Decoder的输入层是一样的结构，都是由Token embedding（词向量 word embedding） 和 Positional embedding(位置向量) 组合而成，并到最终的 输入向量x。 Transformer引入Positional embedding主要是解决词序问题。…
阅读更多...
开源程序实操：岩土工程渗流问题的有限单元法应用

开源程序实操：岩土工程渗流问题的有限单元法应用

有限单元法在岩土工程问题中应用非常广泛，很多商业软件如Plaxis/Abaqus/Comsol等都采用有限单元解法。尽管各类商业软件使用方便，但其使用对用户来说往往是一个“黑箱子”。相比而言，开源的有限元程序计算方法透明、计算过程可控，…
阅读更多...
Linux configure.ac:51: error: possibly undefined macro: AC_MSG_ERROR

Linux configure.ac:51: error: possibly undefined macro: AC_MSG_ERROR

ｂｕｇ： 解决方法： cd　/usr/local/share/autoconf/autoconf　 cp　*．m4　/usr/share/aclocal
阅读更多...
编程语言中的特殊类的设计

编程语言中的特殊类的设计

文章目录 不能被拷贝的类只能在堆上创建对象的类:方式一方式二 设计类只能创建栈对象实现类, 不能被继承单例模式设计饿汉模式懒汉模式线程安全问题 不能被拷贝的类 c98 只声明(不生成, 编译器默认会生成, 有浅拷贝等的问题), 不实现, 并将其访问设为private c11使用delete来…
阅读更多...
Python数据可视化库之bqplot使用详解

Python数据可视化库之bqplot使用详解

概要 在数据科学和机器学习领域，数据可视化是理解和分析数据的重要工具。bqplot 是一个基于 Jupyter Notebook 的 Python 可视化库，专注于交互式数据可视化。它结合了 D3.js 的强大功能和 Python 的易用性，使用户能够在 Jupyter 环境中创建丰富的交互式图表。bqplot 的设计…
阅读更多...
如何使用GPT画出带中文的图和表？-已解决GPT画图表出现乱码的问题

如何使用GPT画出带中文的图和表？-已解决GPT画图表出现乱码的问题

众所周知，GPT的中文库有点问题，要求他画带中文的图或表存在中文的时候，就会出现乱码或者方框。 可以发现，GPT的中文库有问题，那么该如何解决这个问题呢？ 直接在promote的时候上传你需要它使用的字体&…
阅读更多...
高斯混合模型GMM

高斯混合模型GMM

一、两个角度看GMM 1、从几何角度来看：加权平均值，多个高斯分布叠加而成 纵轴——f（x）概率密度函数，横轴——数据点 2、从混合模型角度看 x:observed variable z:latent variable →对应的样本是属于哪一个高斯分布&…
阅读更多...
【SQL】筛选上级经理离职的员工

【SQL】筛选上级经理离职的员工

目录 题目 分析 代码 题目 表: Employees ----------------------- | Column Name | Type | ----------------------- | employee_id | int | | name | varchar | | manager_id | int | | salary | int | ----------------------- 在 SQ…
阅读更多...
word文档合并样式问题

word文档合并样式问题

word协同工作时，在mac用office编辑后发送给对方进行合并时，出现了一些不该看到的样式。 需要注意的几点： 1、大家均需要使用同样的软件，如office，如果使用wps，会导致新增很多样式。 2、在样式窗格&#…
阅读更多...
gitlab SSH的使用

gitlab SSH的使用

一、 安装git bash https://git-scm.com/download/win 下载windows 版本，默认安装即可。 二、使用命令 打开本地git bash,使用如下命令生成ssh公钥和私钥对 ssh-keygen -t rsa -C ‘xxxxxx.com’ 然后一路回车 (-C 参数是你的邮箱地址) 若是想输入密码可以输入…
阅读更多...
浅谈线性表——栈

浅谈线性表——栈

文章目录 一、什么是栈？二、栈顺序、链式存储时的时间复杂度三、自我实现一个栈3.1、实现代码3.2、熟练使用栈 四、栈的应用场景4.1、不可能的出栈顺序4.2、表达式4.2、OJ题 一、什么是栈？ 栈是一种特殊的线性表，他只允许在固定的一端进行插…
阅读更多...
直播美颜API与视频美颜SDK的开发指南：构建高效实时美颜工具

直播美颜API与视频美颜SDK的开发指南：构建高效实时美颜工具

在主播美颜的背后，直播美颜API与视频美颜SDK是实现这一切的技术核心。接下来，小编将深入讲解如何开发高效的直播美颜API与视频美颜SDK。 一、视频美颜SDK的概述 视频美颜SDK则是一个开发工具包，提供了完整的美颜功能实现，开发者…
阅读更多...
STM32（F103ZET6）第四课：串口中断

STM32（F103ZET6）第四课：串口中断

目录 需求一、串口中断过程与作用二、中断实现流程1.中断优先级分组2.配置串口中断 三、需求的实现 需求 1.设备上电后四个灯灭。 2.按下KEY1，LED1灯亮，同时串口发送“LED1灯亮”。 3.再次按下KEY1，LED1灯灭，同时串口发送“LED1灯…
阅读更多...
大数据计算-SQL优化手段(CBO)-以Flink为例

大数据计算-SQL优化手段(CBO)-以Flink为例

文章目录 背景理论知识示例结果展示结果解释 背景 大数据计算中，SQL生成的执行计划第一轮会经过固定规则的优化，第二轮会根据原计划，生成多条结合成本的的执行计划，根据cost 进行排序，选出最优的执行计划。 理论知识…
阅读更多...
深入调研亚马逊云科技AI平台Amazon Bedrock热门开发功能

深入调研亚马逊云科技AI平台Amazon Bedrock热门开发功能

国际数据公司（IDC）在2024 年 8 月发布了《 中国大模型平台市场份额， 2023 ：大模型元年——初局 》调研报告 。IDC的数据显示，2023年中国大模型平台及相关应用市场规模达惊人的17.65亿元人民币，且科学计算大…
阅读更多...
带有音频的ppt导出视频 带有音频的ppt自动播放

带有音频的ppt导出视频 带有音频的ppt自动播放

之前帮导师申请基金，基金委的要求是提交ppt的讲解视频，这个需求比较容易实现。只要提前把各页的音频录制好，插入对应页，然后直接选择导出-创建视频即可，不需要设置幻灯片自动切换，以及自动换片时间&#xf…
阅读更多...
C++ 设计模式——享元模式

C++ 设计模式——享元模式

C 设计模式——享元模式 C 设计模式——享元模式1. 主要组成成分2. 享元模式内部状态3. 享元模式外部状态4. 逐步构建享元模式4.1 抽象享元类定义4.2 具体享元类实现4.3 享元工厂类实现4.4 主函数 5. 享元模式 UML 图享元模式 UML 图解析 6. 享元模式的优点7. 享元模式的缺点8.…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023