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的配置可能会变得越来越复杂。因此,在大型系统中,建议采用自动化工具来进行配置管理...
38 -设备部经理绩效考核表1
在做了充分的需求分析之后,将一站式电脑配件交易平台的需求分为商品管理、订单管理、配送管理、组装管理和评论管理等多个子模块,随后对系统进行设计,设计主要从系统整体架构和数据库两方面进行分析和设计,系统的核心功能主要包括商品管理、订单管理、配送管理、组装管理和评论管理,而非核心功能主要包含了用户管理和用户登录管理等模块。而后,对系统进行了编码并实现了所有功能,最后,对系统相关功能展开测试,并通过了系统测试,充分验证了系统可用性。
数据名称:2000-2022年各县市区主要社会经济发展指标面板数据 数据类型:dta格式 数据来源:中国县域统计
内容概要:本文提供了针对大学生英语竞赛写作准备的重要资源——一系列通用的英文句子模板。这些模板涵盖了现代经济社会的各种话题,从科技进步到环境保护,以及个人品质和社会责任等,并且适用于论述类文章、观点对比和个人见解的表达。文章通过对每一句话的应用环境解释和语法提示,确保使用者可以在实际写作中正确且有效地应用这些表达方式。 适合人群:正在准备参加大学生英语竞赛的学生及其他希望提高书面表达能力的学习者。 使用场景及目标:考生能够在竞赛时间内迅速构建思路完整的文章,增强语言表达的流利性和规范性;帮助学习者积累高级词汇,提升英语写作水平并培养良好的思维逻辑。 阅读建议:结合历年优秀范文进行深入学习,熟悉不同类型话题下的表述方法;练习将提供的句子融入自身创作的文章中,通过不断修订和完善来巩固记忆。同时也可以用于日常的英语写作训练当中。
本代码参考网络大神代码以及结合自身理解,编写的关于使用STM32F103C8T6芯片,通过ESP8266模块,连接阿里云物联网平台的代码历程,文件内包含了如何修改代码连接自己的设备的教程(readme.txt)文件,请读者仔细阅读。
宽带折叠传输阵天线.pdf
这是一个exe程序,解压后可以批量将Word文件转为PDF文件。
09 -单证部经理绩效考核表1
2009-2022年农村金融发展水平省级面板数据 31省份金融发展水平数据(不含港澳台地区) 涉农贷款金额亿元/第一产业增加值 30省份第一产业产值(2009-2022年) 30省份农业金融发展水平(2009-2022年)
2022年9月全国大学生英语竞赛A类初赛参考答案
Python源码03之解决对图片格式进行批量转换的问题.zip
病毒
基于向量特征的车辆轨迹预测.pdf
10-15-物控人员绩效考核表(自动计算、等级评价、任意设置)
员工末位淘汰考评表
1、操作简单,导入(待分班的数据xlsx格式),分班、导出三步。 2、分班条件设置:可选科类组合,设置起始班级和学生预设班级。 3、分班结果:班级人数均衡、男女均衡,各科成绩和总分班级均衡,最大分差不超过0.5分。 4、导出xlsx格式的分班结果。含各班单独的工作表和统计数据表。
人事档案登记及查询系统
第3课《安塞腰鼓》课件-语文八年级下册
C语言之考勤模拟系统平台(千行代码)