ActiveMQ高可用架构涉及常用功能整理

ActiveMQ高可用架构涉及常用功能整理

  • 1. activemq的集群模式
  • 2. 镜像模式高可用系统架构和相关组件
    • 2.1 架构说明
    • 2.2 相关概念说明
    • 2.3 消息模型
      • 2.3.1 点对点
      • 2.3.2 发布订阅
  • 3. activemq常用命令
  • 4. activemq配置集群
  • 5. 疑问和思考
    • 5.1 activemq的数据删除策略是怎样的?
    • 5.2 activemq希望一个数据能够被多个消费者消费,该如何实现?
  • 6. 参考文档

探讨activemq的系统架构以及以及整体常用的命令和系统分析,本文主要探讨高可用版本的activemq集群,并基于日常工作中的沉淀进行思考和整理。更多关于分布式系统的架构思考请参考文档关于常见分布式组件高可用设计原理的理解和思考


1. activemq的集群模式

activemq通常只有2种模式架构

  • 单机模式
    通常activemq只是支持单机模式,进行数据存储和提供服务,这种模式下,activemq不支持HA能力。

  • 主从模式
    为了解决单机模式下的高可用问题,activemq能够搭建主从模式,但是由于activemq本身不支持不同节点直接同步数据,因此这种模式下,activemq将数据保存在了远端的数据库。常用的架构如下
    在这里插入图片描述

在这里插入图片描述

2. 镜像模式高可用系统架构和相关组件

2.1 架构说明

activemq的整体架构如下
在这里插入图片描述

相关核心的组件和角色作用如下

组件部署模式组件作用备注
producer客户端部署生产者创建消息消息一般可以包含 2 个部分: 消息体和标签
broker多机部署它负责接收、存储和管理消息数据接收和存储消息数据:activemq broker接收来自producer发送的消息,并将这些消息存储在自己的磁盘上。
consumer客户端部署消费者连接到 ActiveMQ 服务器,订阅到队列。消费者消费一条消息时,只消费消息的消息体(payload)在消息路由的过程中,消息的标签会丢弃,存入到队列中的消息只有消息体,消费者只会消费到消息体,也就不知道消息的生产者是谁,当然消费者也不需要知道

镜像镜像队列本质上是一个HA模式的集群

  • Leader提供读写服务,数据写入需要从Leader开始,而后同步到Follower节点
  • Follower提供读服务

普通模式配置镜像模式,只需要进行如下配置即可。

# 所有队列exchangess都为镜像模式
activemqctl set_policy ha-all "^" '{"ha-mode":"all"}'
Setting policy "ha-all" for pattern "^" to "{"ha-mode":"all"}" with priority "0" for vhost "/" ...# # 所有队列queue都为镜像模式
activemqctl set_policy --priority 0 --apply-to queues mirror_queue "^" '{"ha-mode":"exactly","ha-params":2,"ha-sync-mode":"automatic"}'

在这里插入图片描述

2.2 相关概念说明

角色说明角色作用备注
channel消息通道,在客户端的每个连接里,可建立多个 channel,每个 channel 代表一个会话任务
exchange消息交换机,它指定消息按什么规则,路由到哪个队列交换机提供了消息的路由能力,根据不同的消息特性提供不同的路由策略
routing key路由关键字,exchange 根据这个关键字进行消息投递
binding绑定,它的作用就是把 exchange 和 queue 按照路由规则绑定起来
vhost虚拟主机,一个 broker 里可以开设多个 vhost,用作不同用户的权限分离消息和权限设计都是基于vhost,可以通过vhost配置多租户进行数据和权限隔离

2.3 消息模型

activemq的消息发布模型只有2种

  • 点对点: 一条消息只能被消费一次,消费后就会被删除,发布者和消费者能够解耦
  • 发布/订阅: 一条消息能够被多个消费者订阅,消费者只能订阅到后续的消息(不会维护消费位点,因此消费者订阅的消息是可能会出现丢失的)

2.3.1 点对点

在这里插入图片描述
在点对点通信模式中,应用程序由消息队列,发送方,接收方组成,每个消息队列都被发送到一个特定的队列, 接收者从队列中获取消息,队列保留这消息,直到他们被消费或者超时.

特点

  • 每个消息只要一个消费者.
  • 发送者和接收者在时间上是没有时间的约束,即发送者在发送完消息后,不管接收者有没有接收消息,都不会影响发送方发送消息到消息队列中.
  • 发送方不管是否在发送消息,接收方都可以从消息队列中去到消息.
  • 接收方在接收完消息之后,需要向消息队列应答成功.### 2.3.2 发布订阅

2.3.2 发布订阅

在这里插入图片描述

在发布/订阅消息模型中,发布者发布一个消息,该消息是topic传递给所有的客户端。在该模式下,发布者和订阅者都是匿名的,即发布者与订阅者都不知道对方是谁.并且可以动态的发布和订阅Topic。Topic主要用于保存和传递消息,且会一直保存消息直到消息被传递给客户端.

特点

  • 一个消息可以传递多个订阅者
  • 发布者和订阅者具有时间约束,这一点和上面的点对点模式是相反的. 针对某个主题(Topic)的订阅者.它必须创建一个订阅者之后,才能消费发布者的消息.而且是为了消费消息,订阅者必须保持运行的状态.
  • 为了缓和这样严格的时间相关性,JMS允许订阅者创建一个可持久化的订阅,这样,即使订阅者没有被激活(运行),他也能接收到发布者的消息.

3. activemq常用命令

#启动
activemq start#停止
activemq stop# 删除队列中的所有消息,队列名称是FOO.BAR
activemq purge FOO.BAR# 显示默认broker的所有主题和队列统计信息
activemq dstat# 显示的主题统计信息
activemq dstat topics# 显示队列的统计信息
activemq dstat queuedtsat就是显示图形化中query的图。
Queue Size 表示queue的大小。 Producer表示生产者
Consumer 消费者
Enqueue 一共进入了多少队列
Dequeue 一共消费的多少队列

4. activemq配置集群

参考文档 ActiveMQ高可用集群部署方案

5. 疑问和思考

5.1 activemq的数据删除策略是怎样的?

ActiveMQ 提供了两种清除策略,用于清理过期的消息:

  • 消费删除:1个队列中的消息,被消费后就会被主动删除
  • 删除策略(Delete Policy):该策略会直接删除过期的消息,释放存储空间。可以通过设置 expiryDelay 参数来配置消息的过期时间。默认情况下,消息在没有消费者消费的情况下会一直保留,直到达到过期时间。
  • 移动策略(Move Policy):该策略会将过期的消息移动到一个指定的目标队列,而不是直接删除。可以通过设置 deadLetterStrategy 参数来指定目标队列。移动策略可以用于日志记录和审计等需求,以便在稍后分析过期消息。

这些清除策略可以单独或同时使用,根据需要进行配置。请注意,配置清除策略可能会影响 ActiveMQ 的性能和存储空间使用情况,所以需要根据具体情况进行权衡和调整。

5.2 activemq希望一个数据能够被多个消费者消费,该如何实现?

只能使用发布订阅模式,但是也通常要求消费者实时在线,否则消费者可能无法消费到完整的数据。

6. 参考文档

暂无

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

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

相关文章

C++ 中的单例模式singleton

C 中的单例模式 引言 在面向对象编程中,设计模式是解决常见问题的最佳实践。单例模式是其中之一,它确保一个类只有一个实例,并提供一个全局访问点来获取该实例。在本文中,我们将详细介绍 C 中的单例模式。 什么是单例模式&…

【软考问题】-- 1 - IT知识 - 信息化发展

一、基础问题 问题1:信息系统的生命周期可以简化为哪5个阶段? (1)系统规划(可行性分析与项目开发计划)(2)系统分析(需求分析) (3)系统设计(概要设计、 详细设计) (4)系统实施(编码、 测试) (5)系统运行和维护问题2:国家信息化体系六要素分别是什么? 1信息…

ChatGPT-用ChatGPT指令,自学任何领域的系统知识

1. 指令位置 Github仓库:Mr Ranedeer AI Tutor 但是需要开通chatgtp plus版本,并且打开代码解释器 2 使用 学习内容 开始学习 GPT甚至可以给你思考题,给出的答案还能进行评价 配置 通过配置表修改 深度 学习风格 沟通风格 语气风格 …

探索Nginx:一款高效、稳定的Web服务器和反向代理工具

在网站性能优化和架构设计中,Nginx以其高性能、低资源消耗和良好的扩展性成为了许多开发者和服务器管理员的首选。本文将为您详细介绍Nginx的概念、特点、安装、配置和使用,帮助您更好地了解并运用这款优秀的工具。 一、Nginx简介 Nginx(发…

基于RWKV架构推理成本大降:Eagle 7B模型的十倍效能提升

前言 在今天这个数据驱动的时代,大型语言模型(LLM)在处理自然语言处理(NLP)任务时的效能和效率成为了众多研究者和工程师关注的焦点。尤其是在推理成本日益攀升的背景下,如何在保持甚至提升模型性能的同时…

【Java】数据类型与变量

1.数据类型 在Java中数据类型主要分为两类:基本数据类型和引用数据类型。 基本数据类型有四类八种: 四类:整型、浮点型、字符型以及布尔型八种: 注意:不论是在16位系统还是32位系统,int都占用4个字节&am…

js设计模式:原型模式

作用: 使用js特有的原型链机制,可以通过Object.create方法创建新对象,将一个对象作为另外一个对象的原型 也可以通过修改原型链上的属性,影响新对象的行为 可以更方便的创建一些对象 示例: let obj {getName: function(){return this.name},getAge:function(){return this…

VINS-FUSION 在Opencv4下编译报错,且ceres也报错

Opencv报错 /home/monica/Documents/code/vins-fusion-old-ws/src/VINS-Fusion-master/camera_models/src/chessboard/Chessboard.cc:20:38: error: ‘CV_GRAY2BGR’ was not declared in this scope 20 | cv::cvtColor(image, mSketch, CV_GRAY2BGR); | …

代码随想录算法训练营29期|day55 任务以及具体安排

第九章 动态规划part12 309.最佳买卖股票时机含冷冻期 class Solution {public int maxProfit(int[] prices) {//0代表持股票,1代表保持卖出状态,2代表卖出股票。3代表冷冻int[][] dp new int[prices.length][4];dp[0][0] -prices[0];for(int i 1 ; …

axios封装终极版实现token无感刷新及全局loading

前言 关于axios全局loading的封装博主已经发过一次了,这次是在其基础上增加了token的无感刷新。 token无感刷新流程 首次登录的时候会获取到两个token(AccessToken,RefreshToken)持久化保存起来(localStorage方案&a…

iOS 使用Image I/O 实现超大图片降采样

一个图片解码成未压缩的位图的时候,占用的内存和图片的文件大小没有关系,和图片的尺寸大小有关系,尺寸越大,所需要的像素点越多,所以超大图片,我们需要进行优化处理 这里直接上降采样代码 给UIImage 添加…

Emlog博客网站快速搭建并结合内网穿透实现远程访问本地站点

文章目录 前言1. 网站搭建1.1 Emolog网页下载和安装1.2 网页测试1.3 cpolar的安装和注册 2. 本地网页发布2.1 Cpolar临时数据隧道2.2.Cpolar稳定隧道(云端设置)2.3.Cpolar稳定隧道(本地设置) 3. 公网访问测试总结 前言 博客作为使…

【C++之语法篇003】

C学习笔记---003 C知识开篇1、内联函数1.1、什么是内联函数?1.2、解决外部头文件,重复定义问题1.3、内联函数的总结 2、auto关键字2.1、auto的作用2.2、auto的总结 3、范围for3.1、什么是范围for?3.2、范围for的循环应用 4、指针空值关键字nullptr4.1、…

nginx的底层理解

Nginx是一个高性能的Web服务器,同时也是一个反向代理服务器、负载均衡器和HTTP缓存器。它的底层设计注重效率和性能,能够支持高并发连接数,最大可以支持约50000个并发连接。以下是Nginx的一些关键特性和底层理解: 事件驱动模型&a…

机器人十大前沿技术(2023-2024年)

2023-2024年机器人十大前沿技术 1. 具身智能与垂直大模型 具身智能是指拥有自主感知、交互和行动能力的智能体,能够与环境进行实时互动,从而实现对环境的理解和适应。 “大模型”是指在深度学习和人工智能领域中,使用大量参数和数据进行训…

【PHP】web服务器支持PHP_环境配置

一、PHP运行目前为止主要有4方式 (1)以模块加载的方式运行,初学者可能不容易理解,其实就是将PHP集成到Apache服务器, 以同一个进程运行。 (2)以CGI的方式运行,CGI英文叫…

HarmonyOS4.0系列——08、整合UI常用组件

HarmonyOS4.0 系列——08、UI 组件 Blank Blank 组件在横竖屏占满空余空间效果 // xxx.ets Entry Component struct BlankExample {build() {Column() {Row() {Text(Button).fontSize(18)Blank()Toggle({type: ToggleType.Switch}).margin({top: 14,bottom: 14,left: 6,righ…

go-redis 使用 redis 6.0.14 版本错误: consider implementing encoding.BinaryMarshaler

使用方法 err : bp.data.redis.Get(ctx, policyKey).Scan(&result)起初在 redis 5.x.x 版本并没有遇到错误,但是在切换 redis 实例之后就出现了错误(他们之间只是版本不同)。 修复方法 看错误日志的描述,大概含义就是需要我们…

【Spring Boot 3】【JPA】一对一双向关联

【Spring Boot 3】【JPA】一对一双向关联 背景介绍开发环境开发步骤及源码工程目录结构总结背景 软件开发是一门实践性科学,对大多数人来说,学习一种新技术不是一开始就去深究其原理,而是先从做出一个可工作的DEMO入手。但在我个人学习和工作经历中,每次学习新技术总是要花…

Windows 使设置更改立即生效——并行发送广播消息

目录 前言 1 遍历窗口句柄列表 2 使用 SendMessageTimeout 发送延时消息 3 并行发送消息实现模拟广播消息 4 修改 UIPI 消息过滤器设置 5 托盘图标刷新的处理 6 完整代码和测试 本文属于原创文章,转载请注明出处: https://blog.csdn.net/qq_5907…