JMS持久化订阅的消息消费者由唯一的JMS客户端编号(clientId) 和 持久化订阅者的名字(subscriber name)。因此按照JMS规范,任何一个时间点一个JMS ClientId标识的链接只能有一个是有效的,同一个clientid和subscriber name标识的消费者只能有一个,这也就意味着topic不能具有下面的两个特性:
1、消费消息不能负载均衡
2、一个消费进程不工作,不能快速进行失效恢复
activemq提供了virtualtopic,使其具有topic的发布功能,不需要关系订阅者,订阅者在自己的队列上进行消费,这样消费者可以开启多个线程同时进行消费。
virtualtopic在接收到消息后会把查找所有关联的消费队列,把消息在这些队列中各保存一份。
这样就带来一个问题:
1、消息内容被复制了多份,随着消费队列的增加,发送性能会快速下降,在实际生产中,关联的消费者可能有几十个甚至上百个。
消费者数目发送时间
11.04ms
2014ms
为了解决虚拟主题内容被复制多份的问题,因此需要一种新的队列:VirtualQueue
VirtualQueue:
1、具有普通queue的特性,支持负载均衡
2、消息内容不单独保存,其消息映射到topic 上,一个queue在topic上创建一个 durable subscriber,消费确认通过对应的 durable subscriber进行。
消费流程:
1、queue对应的durable subscriber 加载消息到该queue
2、VirtualQueue把未消费的消费分发给队列上的多个消费者
改造需要解决:
1、消息在投递时,Message.regionDestination是topic,因此在进入VirtualQueue的时候需要变更,这样消息确认时通过regionDestination才能找到该VirtualQueue
2、生产者发送消息后,如果有对应的VirtualQueue在线,需要通知VirtualQueue有新消息,才能实时触发VirtualQueue进行消息投递。
3、VirtualQueue第一次创建的时候需要在topic上创建 durable subscriber (clientId可以默认为相同的值)
分享到:
相关推荐
例如,如果消息被复制到了多个目的地,那么应该明确指定哪些目的地需要返回确认。 3. **配置管理**:随着系统的扩展,虚拟Topic的配置可能会变得越来越复杂。因此,在大型系统中,建议采用自动化工具来进行配置管理...
Umi-OCR-main.zip
基于springboot+Web的毕业设计选题系统源码数据库文档.zip
基于springboot校外兼职教师考勤管理系统源码数据库文档.zip
58商铺全新UI试客试用平台网站源码
基于springboot大学生就业信息管理系统源码数据库文档.zip
基于SpringBoot的口腔诊所系统源码数据库文档.zip
数据存放网盘,txt文件内包含下载链接及提取码,永久有效。失效会第一时间进行补充。样例数据及详细介绍参见文章:https://blog.csdn.net/T0620514/article/details/143956923
3-240P2162218.zip
网络安全 基于Qt创建的Linux系统下的浏览器.zip
C++ 类和对象:多态-练习题目2(制作咖啡和茶叶)
基于springboot+J2EE在线项目管理与任务分配中的应用源码数据库文档.zip
简介本项目提供了一个在51单片机上运行的简单操作系统,旨在帮助学习者深入理解操作系统的基本原理和任务调度机制。该操作系统通过汇编和C语言编写,实现了任务调度、中断处理等核心功能,并提供了详细的源代码和注释,方便学习和实践。
本文将深度卷积神经网络(CNN)设计实现一个复杂结构的生成模型,旨在通过多阶段的编码器-解码器结构,能够有效地将灰度图像转换为彩色图像。最后,本文将实现一个简单的Web应用,用户可以通过上传灰度图像,应用会使用预训练的Caffe模型对其进行颜色化,并将结果返回给用户。 1.模型设计:模型由多个卷积层、ReLU激活函数和批归一化层组成,通过前向传播函数将输入的灰度图像(L通道)转换为彩色图像(ab通道)。如果指定了 pretrained=True,则会自动下载并加载预训练的模型权重。 2. 系统通过Flask框架提供了一个Web应用,用户可以上传灰度图像,系统会自动将其转换为彩色图像,并在网页上显示结果。整个过程包括文件验证、图像处理、颜色化预测和结果展示,具有较高的实用性和用户体验。
一个JAVA图形化的、联网的五子棋游戏.zip javaweb
KWDB 是一款面向 【AIoT 场景】的【分布式多模数据库】,支持在同一实例同时建立时序库和关系库并融合处理多模数据,具备千万级设备接入、百万级数据秒级写入、亿级数据秒级读取等时序数据高效处理能力,具有稳定安全、高可用、易运维等特点。
页面数量:7页 网页主题:网站模板、酒店网站模板、官方网站模板 网页页面:首页、关于我们、相关服务、服务详情、在线博客、博客详情、在线留言 页面实现元素:加载动画、滚动加载、主题切换、导航栏 、轮播图、图文列表、图片切换、 文字列表、 按钮悬停、图片悬停、表单 实现技术:HTML、CSS 、JQuery 源码样式及js文件均分开存放,所有内容仅供初学者学习参考
内容概要:本文档提供了详细的 Neo4j 安装与配置指南,涵盖 Windows、Linux 和 Mac 系统的安装步骤。具体包括下载、安装、启动服务、修改配置文件(如端口配置、远程访问和内存限制)、设置管理员密码以及基本的 Cypher 查询语言使用方法。同时,还提供了一些常见问题及其解决方案。 适合人群:数据库管理员、软件开发人员、系统管理员。 使用场景及目标:①帮助初学者快速掌握 Neo4j 的安装与配置;②适用于需要搭建和使用图数据库的项目;③为已有用户解决常见问题。 其他说明:本文档不仅包含了基础的安装和配置流程,还提供了实际操作中可能遇到的问题及其解决方法,有助于提高使用者的实际操作能力。
基于SpringBoot+Vue的软件产品展示销售系统源码数据库文档.zip
《书戴嵩画牛》教学课件.pptx