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

2024-08-27 14:12
文章标签 部署 集群 docker compose rocketmq 同步 单机 双写 双主双

本文主要是介绍docker-compose单机部署rocketmq集群(双主双从，同步双写)，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

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/storemkdir -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/storemkdir -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/storemkdir -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.0container_name: mqnamesrvports:- 9876:9876environment:JAVA_OPT_EXT: "-Duser.home=/opt -Xms512m -Xmx512m -Xmn150m"command: sh mqnamesrvmqbroker-1-m:image: apache/rocketmq:5.3.0container_name: mqbroker-1-mports:- 10911:10911- 10909:10909- 10912:10912volumes:- /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/storeenvironment:NAMESRV_ADDR: "mqnamesrv:9876"JAVA_OPTS: " -Duser.home=/opt"JAVA_OPT_EXT: "-server -Xms128m -Xmx128m -Xmn128m"command: sh mqbroker -c /home/rocketmq/conf/broker.confdepends_on:- mqnamesrvmqbroker-2-s:image: apache/rocketmq:5.3.0container_name: mqbroker-2-sports:- 11911:11911- 11909:11909- 11912:11912volumes:- /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/storeenvironment:NAMESRV_ADDR: "mqnamesrv:9876"JAVA_OPTS: " -Duser.home=/opt"JAVA_OPT_EXT: "-server -Xms128m -Xmx128m -Xmn128m"command: sh mqbroker -c /home/rocketmq/conf/broker.confdepends_on:- mqnamesrvmqbroker-2-m:image: apache/rocketmq:5.3.0container_name: mqbroker-2-mports:- 12911:12911- 12909:12909- 12912:12912volumes:- /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/storeenvironment:NAMESRV_ADDR: "mqnamesrv:9876"JAVA_OPTS: " -Duser.home=/opt"JAVA_OPT_EXT: "-server -Xms128m -Xmx128m -Xmn128m"command: sh mqbroker -c /home/rocketmq/conf/broker.confdepends_on:- mqnamesrvmqbroker-1-s:image: apache/rocketmq:5.3.0container_name: mqbroker-1-sports:- 13911:13911- 13909:13909- 13912:13912volumes:- /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/storeenvironment:NAMESRV_ADDR: "mqnamesrv:9876"JAVA_OPTS: " -Duser.home=/opt"JAVA_OPT_EXT: "-server -Xms128m -Xmx128m -Xmn128m"command: sh mqbroker -c /home/rocketmq/conf/broker.confdepends_on:- mqnamesrvmqconsole:image: styletang/rocketmq-console-ng:1.0.0container_name: mqconsoleports:- 19876:8080environment:JAVA_OPTS: -Drocketmq.namesrv.addr=mqnamesrv:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=falsesdepends_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地址换成自己的。如果是云服务器，则需要把以上的端口都打开。注意路径不要错了。

这篇关于docker-compose单机部署rocketmq集群(双主双从，同步双写)的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1111897。

相关文章

通过Docker容器部署Python环境的全流程

通过Docker容器部署Python环境的全流程

《通过Docker容器部署Python环境的全流程》在现代化开发流程中,Docker因其轻量化、环境隔离和跨平台一致性的特性,已成为部署Python应用的标准工具,本文将详细演示如何通过Docker容... 目录引言一、docker与python的协同优势二、核心步骤详解三、进阶配置技巧四、生产环境最佳实践
阅读更多...
Nginx部署HTTP/3的实现步骤

Nginx部署HTTP/3的实现步骤

《Nginx部署HTTP/3的实现步骤》本文介绍了在Nginx中部署HTTP/3的详细步骤,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学... 目录前提条件第一步：安装必要的依赖库第二步：获取并构建 BoringSSL第三步：获取 Nginx
阅读更多...
使用docker搭建嵌入式Linux开发环境

使用docker搭建嵌入式Linux开发环境

《使用docker搭建嵌入式Linux开发环境》本文主要介绍了使用docker搭建嵌入式Linux开发环境,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面... 目录1、前言2、安装docker3、编写容器管理脚本4、创建容器1、前言在日常开发全志、rk等不同
阅读更多...
Python与MySQL实现数据库实时同步的详细步骤

Python与MySQL实现数据库实时同步的详细步骤

《Python与MySQL实现数据库实时同步的详细步骤》在日常开发中,数据同步是一项常见的需求,本篇文章将使用Python和MySQL来实现数据库实时同步,我们将围绕数据变更捕获、数据处理和数据写入这... 目录前言摘要概述：数据同步方案1. 基本思路2. mysql Binlog 简介实现步骤与代码示例1
阅读更多...
redis-sentinel基础概念及部署流程

redis-sentinel基础概念及部署流程

《redis-sentinel基础概念及部署流程》RedisSentinel是Redis的高可用解决方案,通过监控主从节点、自动故障转移、通知机制及配置提供,实现集群故障恢复与服务持续可用,核心组件包... 目录一. 引言二. 核心功能三. 核心组件四. 故障转移流程五. 服务部署六. sentinel部署
阅读更多...
Redis中哨兵机制和集群的区别及说明

Redis中哨兵机制和集群的区别及说明

《Redis中哨兵机制和集群的区别及说明》Redis哨兵通过主从复制实现高可用,适用于中小规模数据；集群采用分布式分片,支持动态扩展,适合大规模数据,哨兵管理简单但扩展性弱,集群性能更强但架构复杂,根... 目录一、架构设计与节点角色1. 哨兵机制（Sentinel）2. 集群（Cluster）二、数据分片
阅读更多...
C#控制台程序同步调用WebApi实现方式

C#控制台程序同步调用WebApi实现方式

《C#控制台程序同步调用WebApi实现方式》控制台程序作为Job时,需同步调用WebApi以确保获取返回结果后执行后续操作,否则会引发TaskCanceledException异常,同步处理可避免异... 目录同步调用WebApi方法Cls001类里面的写法总结控制台程序一般当作Job使用，有时候需要控制
阅读更多...
Linux部署中的文件大小写问题的解决方案

Linux部署中的文件大小写问题的解决方案

《Linux部署中的文件大小写问题的解决方案》在本地开发环境（Windows/macOS）一切正常,但部署到Linux服务器后出现模块加载错误,核心原因是Linux文件系统严格区分大小写,所以本文给大... 目录问题背景解决方案配置要求问题背景在本地开发环境（Windows/MACOS）一切正常，但部署到
阅读更多...
Linux线程同步/互斥过程详解

Linux线程同步/互斥过程详解

《Linux线程同步/互斥过程详解》文章讲解多线程并发访问导致竞态条件,需通过互斥锁、原子操作和条件变量实现线程安全与同步,分析死锁条件及避免方法,并介绍RAII封装技术提升资源管理效率... 目录01. 资源共享问题1.1 多线程并发访问1.2 临界区与临界资源1.3 锁的引入02. 多线程案例2.1 为
阅读更多...
使用IDEA部署Docker应用指南分享

使用IDEA部署Docker应用指南分享

《使用IDEA部署Docker应用指南分享》本文介绍了使用IDEA部署Docker应用的四步流程：创建Dockerfile、配置IDEADocker连接、设置运行调试环境、构建运行镜像,并强调需准备本... 目录一、创建 dockerfile 配置文件二、配置 IDEA 的 Docker 连接三、配置 Do
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2