当前位置: 首页 > news >正文

ActiveMq学习⑨__基于zookeeper和LevelDB搭建ActiveMQ集群

引入消息中间件后如何保证其高可用?
基于zookeeper和LevelDB搭建ActiveMQ集群。集群仅提供主备方式的高可用集群功能,避免单点故障
http://activemq.apache.org/masterslave
在这里插入图片描述
LevelDB,5.6版本之后推出了LecelDB的持久化引擎,它使用了自定义的索引代替常用的BTree索引,其持久化性能高于KahaDB,虽然默认的持久化方式还是KahaDB,但是LevelDB可能会是趋势。
在5.9版本还提供了基于LevelDB和Zookeeper的数据复制方式,作为Master-Slave方式的首选数据复制方案。

Zookeeper+LevelDB的Master-Slave

从ActiveMQ5.9开始,ActiveMQ的集群实现方式取消了传统的Masster-Slave方式。增加了基于Zookeeper+LevelDB的Master-Slave实现方式,从5.9版本后也是官网的推荐。
基于Zookeeper和LevelDB搭建ActiveMQ集群,集群仅提供主备方式的高可用集群功能,避免单点故障。
官网:http://activemq.apache.org/replicated-leveldb-store

Replicated LevelDB Store使用Apache ZooKeeper从一组配置为复制LevelDB存储的代理节点中选择一个master。然后将所有从LevelDB存储与主机同步,通过从主机复制所有更新来保持它们的最新状态。
Replicated LevelDB Store使用与LevelDB存储相同的数据文件,因此您可以随时在已复制和未复制之间切换代理配置。

官网集群原理图

在这里插入图片描述
节点仲裁是什么
ActiveMQ节点仲裁是指在ActiveMQ集群中,当某个节点失效时,其他节点需要通过选举产生一个新的主节点来保证集群的正常运行。
集群中仲裁节点的作用
节点仲裁的作用是确保集群中只有一个主节点,避免出现多个主节点导致消息重复消费或消息丢失等问题。节点仲裁通常是通过ZooKeeper来实现的,ZooKeeper会监控ActiveMQ集群中各个节点的状态,并在节点失效时进行选举产生新的主节点。

说明:
使用Zookeeper集群注册所有的ActiveMQ Broker但`只有其中一个Broker可以提供服务,它将被视为Master,其他的Broker处于待机状态被视为Slave。
如果Master因故障而不能提供服务,Zookeeper会从Slave中选举出一个Broker充当Master。Slave连接Master并同步他们的存储状态,Slave不接受客户端连接。所有的存储操作都将被复制到连接至Maste的Slaves。
如果Master宕机得到了最新更新的Slave会变成Master。故障节点在恢复后会重新加入到集群中并连接Master进入Slave模式。

所有需要同步的消息操作都将等待存储状态被复制到其他法定节点的操作完成才能完成。
所以,如给你配置了replicas=3,name法定大小是(3/2)+1 = 2。Master将会存储更新然后等待(2-1)=1个Slave存储和更新完成,才汇报success,至于为什么是2-1,阳哥的zookeeper讲解过自行复习。
有一个node要作为观察者存在。当一个新的Master被选中,你需要至少保障一个法定node在线以能够找到拥有最新状态的node,这个node才可以成为新的Master。

因此,推荐运行至少3个replica nodes以防止一个node失败后服务中断。

部署规划和步骤

警告

LevelDB已经被官方废弃,不再受到支持。这是因为LevelDB的维护者已经不再维护该项目,而且LevelDB在某些情况下可能会出现数据损坏的问题。因此,官方建议使用更稳定的存储引擎,例如JDBC或KahaDB。但是我们还要学习
在这里插入图片描述

相关文章:

  • 论文阅读:Ensemble Knowledge Transfer for Semantic Segmentation
  • 阿里云99元服务器2核2G3M带宽_4年396元_新老用户均可
  • VScode + opencv + c++ + win配置教程
  • 初识微服务技术栈
  • iOS 让界面元素的文字随着语言的更改而变化——本地化文字跟随
  • 如何在 Unbuntu 下安装配置 Apache Zookeeper
  • 一触即发!拓世法宝商业数字人一体机,化身数字员工,助你开拓连锁餐饮市场
  • 工程车云管家|叉车智能管家安卓主板方案
  • FPGA配置采集AR0135工业相机,提供2套工程源码和技术支持
  • 算法题:33. 搜索旋转排序数组(二分法)
  • sqli-labs-1
  • nacos配置中心docker部署、配置及 goLang 集成使用
  • Kafka(消息队列)--简介
  • 单基因泛癌+实验简单验证,要素丰富,没研究方向的赶紧上车
  • Nginx 实现负载均衡
  • [case10]使用RSQL实现端到端的动态查询
  • css系列之关于字体的事
  • dva中组件的懒加载
  • Java 最常见的 200+ 面试题:面试必备
  • JavaSE小实践1:Java爬取斗图网站的所有表情包
  • Selenium实战教程系列(二)---元素定位
  • SpingCloudBus整合RabbitMQ
  • Spring Cloud中负载均衡器概览
  • Spring框架之我见(三)——IOC、AOP
  • v-if和v-for连用出现的问题
  • vue-router的history模式发布配置
  • Vue组件定义
  • 码农张的Bug人生 - 见面之礼
  • 前端面试题总结
  • 深入 Nginx 之配置篇
  • 什么是Javascript函数节流?
  • 使用common-codec进行md5加密
  • 为什么要用IPython/Jupyter?
  • 移动端唤起键盘时取消position:fixed定位
  • 用简单代码看卷积组块发展
  • 智能合约开发环境搭建及Hello World合约
  • 国内唯一,阿里云入选全球区块链云服务报告,领先AWS、Google ...
  • ​低代码平台的核心价值与优势
  • ​马来语翻译中文去哪比较好?
  • ## 临床数据 两两比较 加显著性boxplot加显著性
  • #vue3 实现前端下载excel文件模板功能
  • #WEB前端(HTML属性)
  • (30)数组元素和与数字和的绝对差
  • (Python第六天)文件处理
  • (附源码)springboot助农电商系统 毕业设计 081919
  • (学习日记)2024.03.12:UCOSIII第十四节:时基列表
  • (转)http协议
  • (轉貼) VS2005 快捷键 (初級) (.NET) (Visual Studio)
  • (总结)Linux下的暴力密码在线破解工具Hydra详解
  • *setTimeout实现text输入在用户停顿时才调用事件!*
  • ./configure,make,make install的作用
  • .locked1、locked勒索病毒解密方法|勒索病毒解决|勒索病毒恢复|数据库修复
  • .Net CF下精确的计时器
  • .NET 回调、接口回调、 委托
  • .NET 解决重复提交问题