rocketmq一主多从搭建

1.四台服务器192.168.4.202(master),192.168.4.203,192.168.4.204,192.168.4.205

分别在四台机子上跑namesrv,无需修改参数及启动命令,官方默认启动即可。

2. broker

以下内容复制到4台机子的broker-a及broker-a-s的文件

-------------内容开始----------
# 这个NameserAddr 也是要配置的,我的是上次搭建集群配置了,这此不用写入了
namesrvAddr=192.168.4.205:9876;192.168.4.202:9876;192.168.4.203:9876;192.168.4.204:9876

# dleger 配置 
enableDLegerCommitLog = true
dLegerGroup = broker-a
dLegerPeers = n5-192.168.4.205:40911;n2-192.168.4.202:40911;n3-192.168.4.203:40911;n4-192.168.4.204:40911
# 注意:这里是 n0
dLegerSelfId = n2
sendMessageThreadPoolNums = 4
#是否允许 Broker 自动创建Topic,建议线下开启,线上关闭
autoCreateTopicEnable=true
#是否允许 Broker 自动创建订阅组,建议线下开启,线上关闭
autoCreateSubscriptionGroup=true

-------------内容结束----------

分别修改相应的配置参数

192.168.4.202 broker-a.properties   brokerId=0  brokerRole=ASYNC_MASTER  dLegerSelfId = n2
192.168.4.203 broker-a-s.properties brokerId=3  brokerRole=slave         dLegerSelfId = n3
192.168.4.204 broker-a-s.properties brokerId=4  brokerRole=slave         dLegerSelfId = n4
192.168.4.205 broker-a-s.properties brokerId=5  brokerRole=slave         dLegerSelfId = n5

其他参数可使用默认的。

3. 启动:

先启动namesrv  bin/mqnamesrv.sh

启动broker  bin/mqbroker -c conf/2m-2s-async/broker-a.properties

4. 测试是否成功

查看集群 bin/mqadmin clusterList

5.创建topic( 配了默认自动创建topic,可不用手动创建,建议生产环境关闭自动创建topic)

[root@localhost rocketmq-5.1.4]# bin/mqadmin updateTopic -n localhost:9876  -b 192.168.4.205:10911  -t topic_augur_zjb

6.集群查看

7.命令行快速验证

RocketMQ提供了一个tools.sh工具可以用来在命令行快速验证RocketMQ服务

发送消息:默认会发1000条消息

bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

接收消息:

bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

8.故障切换试试,关闭master的broker, 观察选举情况

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

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

文生图超级大合集!几乎包含所有模型,提示词教程

除了DALLE 3、Midjourney、Stable Difusion,你还知道哪些好用小众的文生图模型吗? 你知道一张精美的AI图片,需要哪些精准的提示词、效果融合以及制作流程吗? 如果把几乎所有文生图模型集合在一个平台中,并且还能叠加…

Django路由层

路由层(urls) Django的路由层是负责将用户请求映射到相应的视图函数的一层。在Django的MVT架构中,路由层负责处理用户的请求,然后将请求交给相应的视图函数进行处理,最后将处理结果返回给用户。 在Django中&#xff0c…

2013年5月23日 Go生态洞察:高级Go并发模式分析

🌷🍁 博主猫头虎(🐅🐾)带您 Go to New World✨🍁 🦄 博客首页——🐅🐾猫头虎的博客🎐 🐳 《面试题大全专栏》 🦕 文章图文…

2023最新版本 从零基础入门C++与QT(学习笔记) -4- C/C++混合编程

🎏在C兼容C只需要调用C头文件 🎄格式 🎈 -1- extern(关键字) “C”{ }(花括号) 🎈 -2- 花括号里面填写要包含的头文件 🎄代码段格式 extern "C" {#include “stdio.h”#include “string.h” }&#x…

【LeetCode】挑战100天 Day10(热题+面试经典150题)

【LeetCode】挑战100天 Day10(热题面试经典150题) 一、LeetCode介绍二、LeetCode 热题 HOT 100-122.1 题目2.2 题解 三、面试经典 150 题-123.1 题目3.2 题解 一、LeetCode介绍 LeetCode是一个在线编程网站,提供各种算法和数据结构的题目&…

7.jvm对象内存布局

目录 概述对象里的三个区对象头验证代码控制台输出分析 验证2代码控制台输出 实例数据对其填充 访问对象结束 概述 jvm对象内存布局详解。 相关文章在此总结如下: 文章地址jvm基本知识地址jvm类加载系统地址双亲委派模型与打破双亲委派地址运行时数据区地址运行时数…

Python之文件与文件夹操作及 pytest 测试习题

目录 1、文本文件读写基础。编写程序,在 当前目录下创建一个文本文件 test.txt,并向其中写入字符串 hello world。2、编写一个程序 demo.py,要求运行该程序后,生成 demo_new.py 文件,其中内容与demo.py 一样&#xff0…

竞赛 题目:基于LSTM的预测算法 - 股票预测 天气预测 房价预测

文章目录 0 简介1 基于 Keras 用 LSTM 网络做时间序列预测2 长短记忆网络3 LSTM 网络结构和原理3.1 LSTM核心思想3.2 遗忘门3.3 输入门3.4 输出门 4 基于LSTM的天气预测4.1 数据集4.2 预测示例 5 基于LSTM的股票价格预测5.1 数据集5.2 实现代码 6 lstm 预测航空旅客数目数据集预…

Ubuntu环境下以编译源码的方式安装Vim

目录 1. Ubuntu环境 2. 下载编译vim 2.1 效果截图 3. 配置环境变量 1. Ubuntu环境 Linux chris-166 6.2.0-36-generic #37~22.04.1-Ubuntu SMP PREEMPT_DYNAMIC Mon Oct 9 15:34:04 UTC 2 x86_64 x86_64 x86_64 GNU/Linux 2. 下载编译vim // 源码下载 chris_166chris-16…

【数据结构】手撕双向链表

目录 前言 1. 双向链表 带头双向循环链表的结构 2. 链表的实现 2.1 初始化 2.2 尾插 2.3 尾删 2.4 头插 2.5 头删 2.6 在pos位置之前插入 2.7 删除pos位置 3.双向链表完整源码 List.h List.c 前言 在上一期中我们介绍了单链表,也做了一些练习题&…

langchain实战-hello world

一、LangChain简介 github地址: GitHub - langchain-ai/langchain: ⚡ Building applications with LLMs through composability ⚡ LangChain是一个用于开发由语言模型支持的应用程序的框架。它使应用程序能够: 具有上下文感知能力:将语言模…

【树与二叉树的转换,哈夫曼树的基本概念】

文章目录 树与二叉树的转换将二叉树转化为树森林与二叉树的转化(二叉树与多棵树之间的关系)二叉树转换为森林森林的先序遍历1)先序遍历2)后序遍历 哈夫曼树的基本概念森林转换成二叉树(二叉树与多棵树的关系&#xff0…