IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> 大数据 -> Rocketmq 双主双从集群搭建 -> 正文阅读

[大数据]Rocketmq 双主双从集群搭建

rocketmq简介:RocketMQ 是阿里巴巴开源的分布式消息中间件。2017年捐献给apache开源基金会,次年成为apache顶级项目
是一个队列模型的消息中间件,具有高性能、高可靠、高实时、分布式等特点

liunx 下 rocketmq 双主双从集群搭建

IP地址 角色

192.168.180.133 master1

192.168.180.133 master2-slave

192.168.180.245 master2

192.168.180.245 master1-slave

在这里插入图片描述

安装部署:
1.下载:https://github.com/apache/rocketmq
2.上传133 和 245 服务器 解压
unzip rocketmq-all-4.9.2-bin-release.zip
3.创建持久化存储目录
a.主节点 目录

mkdir store
cd store/
mkdir commitlog
mkdir consumequeue
 mkdir index

在这里插入图片描述
b.从节点 目录
在这里插入图片描述

4.修改配置文件 133 配置文件修改 ,这里2m-2s-async表示双主双从异步
先修改133主节点
vim ./conf/2m-2s-async/broker-a.properties

brokerClusterName=rocketmq-cluster
brokerName=broker-a
brokerId=0
deleteWhen=04
fileReservedTime=48
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH
namesrvAddr=192.168.180.133:9876;192.168.180.245:9876
listenPort=10911
#存储路径
storePathRootDir=/opt/software/rocketmq/rocketmq-4.9.2/store
#commitLog 存储路径
storePathCommitLog=/opt/software/rocketmq/rocketmq-4.9.2/store/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/opt/software/rocketmq/rocketmq-4.9.2/store/consumequeue
#消息索引存储路径
storePathIndex=/opt/software/rocketmq/rocketmq-4.9.2/store/index
#checkpoint 文件存储路径
storeCheckpoint=/opt/software/rocketmq/rocketmq-4.9.2/store/checkpoint
#abort 文件存储路径
abortFile=/opt/software/rocketmq/rocketmq-4.9.2/store/abort
brokerRole=SYNC_MASTER

修改133从节点

vim ./conf/2m-2s-async/broker-b-s.properties

brokerClusterName=rocketmq-cluster
brokerName=broker-b-s
brokerId=1
deleteWhen=04
fileReservedTime=48
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH
namesrvAddr=192.168.180.133:9876;192.168.180.245:9876
listenPort=10921
#存储路径
storePathRootDir=/opt/software/rocketmq/rocketmq-4.9.2/store-s
#commitLog 存储路径
storePathCommitLog=/opt/software/rocketmq/rocketmq-4.9.2/store-s/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/opt/software/rocketmq/rocketmq-4.9.2/store-s/consumequeue
#消息索引存储路径
storePathIndex=/opt/software/rocketmq/rocketmq-4.9.2/store-s/index
#checkpoint 文件存储路径
storeCheckpoint=/opt/software/rocketmq/rocketmq-4.9.2/store-s/checkpoint
#abort 文件存储路径
abortFile=/opt/software/rocketmq/rocketmq-4.9.2/store-s/abort

同理 245 也需要配置

先修改245主节点
vim ./conf/2m-2s-async/broker-b.properties

brokerClusterName=rocketmq-cluster
brokerName=broker-b
brokerId=0
deleteWhen=04
fileReservedTime=48
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH
namesrvAddr=192.168.180.133:9876;192.168.180.245:9876
listenPort=10911
#存储路径
storePathRootDir=/opt/software/rocketmq/rocketmq-4.9.2/store
#commitLog 存储路径
storePathCommitLog=/opt/software/rocketmq/rocketmq-4.9.2/store/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/opt/software/rocketmq/rocketmq-4.9.2/store/consumequeue
#消息索引存储路径
storePathIndex=/opt/software/rocketmq/rocketmq-4.9.2/store/index
#checkpoint 文件存储路径
storeCheckpoint=/opt/software/rocketmq/rocketmq-4.9.2/store/checkpoint
#abort 文件存储路径
abortFile=/opt/software/rocketmq/rocketmq-4.9.2/store/abort
brokerRole=SYNC_MASTER

修改245从节点

vim ./conf/2m-2s-async/broker-a-s.properties

brokerClusterName=rocketmq-cluster
brokerName=broker-a-s
brokerId=1
deleteWhen=04
fileReservedTime=48
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH
listenPort=10921
namesrvAddr=192.168.180.133:9876;192.168.180.245:9876
#存储路径
storePathRootDir=/opt/software/rocketmq/rocketmq-4.9.2/store-s
#commitLog 存储路径
storePathCommitLog=/opt/software/rocketmq/rocketmq-4.9.2/store-s/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/opt/software/rocketmq/rocketmq-4.9.2/store-s/consumequeue
#消息索引存储路径
storePathIndex=/opt/software/rocketmq/rocketmq-4.9.2/store-s/index
#checkpoint 文件存储路径
storeCheckpoint=/opt/software/rocketmq/rocketmq-4.9.2/store-s/checkpoint
#abort 文件存储路径
abortFile=/opt/software/rocketmq/rocketmq-4.9.2/store-s/abort

5.启动133 和 245 nameserver

nohup sh ./bin/mqnamesrv &
6.启动133 和 245的broker
133环境 broker-a

  nohup sh mqbroker -c /opt/software/rocketmq/rocketmq-4.9.2/conf/2m-2s-async/broker-a.properties &
  133环境   broker-b-s
  nohup sh mqbroker -c /opt/software/rocketmq/rocketmq-4.9.2/conf/2m-2s-async/broker-b-s.properties &
  245环境   broker-b
  nohup sh mqbroker -c /opt/software/rocketmq/rocketmq-4.9.2/conf/2m-2s-async/broker-b.properties &
  245环境   broker-a-s
  nohup sh mqbroker -c /opt/software/rocketmq/rocketmq-4.9.2/conf/2m-2s-async/broker-a-s.properties &
 7启动后可以在 rocketmq-dashboard上查看
 github地址:https://github.com/apache/rocketmq-dashboard
 下载后修改配置文件:  nameserver地址换成自己的nameserve
 rocketmq:

config:
# if this value is empty,use env value rocketmq.config.namesrvAddr NAMESRV_ADDR | now, default localhost:9876
# configure multiple namesrv addresses to manage multiple different clusters
namesrvAddrs:
- 192.168.180.133:9876
- 192.168.180.245:9876
在这里插入图片描述

集群部署坑点:
1.java.net.BindException: 地址已在使用
从节点监听端口不能和主节点一样listenPort=10921 ,最好和主节点端口相隔大于2
2.节点启动后,在dashboard 刷新不可见,因为从节点配置文件没有注册到nameserver:namesrvAddr=192.168.180.133:9876;192.168.180.245:9876
3.rocketmq dashboard 始终只有一个broker-a,配置文件中brokerName 每个节点都不能相同

  大数据 最新文章
实现Kafka至少消费一次
亚马逊云科技:还在苦于ETL?Zero ETL的时代
初探MapReduce
【SpringBoot框架篇】32.基于注解+redis实现
Elasticsearch:如何减少 Elasticsearch 集
Go redis操作
Redis面试题
专题五 Redis高并发场景
基于GBase8s和Calcite的多数据源查询
Redis——底层数据结构原理
上一篇文章      下一篇文章      查看所有文章
加:2022-03-17 22:14:33  更:2022-03-17 22:18:31 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年11日历 -2024/11/24 6:18:58-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码