`
dingjun1
  • 浏览: 208988 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

改造VirtualTopic消除多次内容复制

阅读更多
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可以默认为相同的值)

分享到:
评论

相关推荐

    基于go语言的类python生态中LangChain的LLMs接口框架,

    Go语言(也称为Golang)是由Google开发的一种静态强类型、编译型的编程语言。它旨在成为一门简单、高效、安全和并发的编程语言,特别适用于构建高性能的服务器和分布式系统。以下是Go语言的一些主要特点和优势: 简洁性:Go语言的语法简单直观,易于学习和使用。它避免了复杂的语法特性,如继承、重载等,转而采用组合和接口来实现代码的复用和扩展。 高性能:Go语言具有出色的性能,可以媲美C和C++。它使用静态类型系统和编译型语言的优势,能够生成高效的机器码。 并发性:Go语言内置了对并发的支持,通过轻量级的goroutine和channel机制,可以轻松实现并发编程。这使得Go语言在构建高性能的服务器和分布式系统时具有天然的优势。 安全性:Go语言具有强大的类型系统和内存管理机制,能够减少运行时错误和内存泄漏等问题。它还支持编译时检查,可以在编译阶段就发现潜在的问题。 标准库:Go语言的标准库非常丰富,包含了大量的实用功能和工具,如网络编程、文件操作、加密解密等。这使得开发者可以更加专注于业务逻辑的实现,而无需花费太多时间在底层功能的实现上。 跨平台:Go语言支持多种操作系统和平台,包括Windows、Linux、macOS等。它使用统一的构建系统(如Go Modules),可以轻松地跨平台编译和运行代码。 开源和社区支持:Go语言是开源的,具有庞大的社区支持和丰富的资源。开发者可以通过社区获取帮助、分享经验和学习资料。 总之,Go语言是一种简单、高效、安全、并发的编程语言,特别适用于构建高性能的服务器和分布式系统。如果你正在寻找一种易于学习和使用的编程语言,并且需要处理大量的并发请求和数据,那么Go语言可能是一个不错的选择。

    基于go的轻量化key-value服务.zip

    Go语言(也称为Golang)是由Google开发的一种静态强类型、编译型的编程语言。它旨在成为一门简单、高效、安全和并发的编程语言,特别适用于构建高性能的服务器和分布式系统。以下是Go语言的一些主要特点和优势: 简洁性:Go语言的语法简单直观,易于学习和使用。它避免了复杂的语法特性,如继承、重载等,转而采用组合和接口来实现代码的复用和扩展。 高性能:Go语言具有出色的性能,可以媲美C和C++。它使用静态类型系统和编译型语言的优势,能够生成高效的机器码。 并发性:Go语言内置了对并发的支持,通过轻量级的goroutine和channel机制,可以轻松实现并发编程。这使得Go语言在构建高性能的服务器和分布式系统时具有天然的优势。 安全性:Go语言具有强大的类型系统和内存管理机制,能够减少运行时错误和内存泄漏等问题。它还支持编译时检查,可以在编译阶段就发现潜在的问题。 标准库:Go语言的标准库非常丰富,包含了大量的实用功能和工具,如网络编程、文件操作、加密解密等。这使得开发者可以更加专注于业务逻辑的实现,而无需花费太多时间在底层功能的实现上。 跨平台:Go语言支持多种操作系统和平台,包括Windows、Linux、macOS等。它使用统一的构建系统(如Go Modules),可以轻松地跨平台编译和运行代码。 开源和社区支持:Go语言是开源的,具有庞大的社区支持和丰富的资源。开发者可以通过社区获取帮助、分享经验和学习资料。 总之,Go语言是一种简单、高效、安全、并发的编程语言,特别适用于构建高性能的服务器和分布式系统。如果你正在寻找一种易于学习和使用的编程语言,并且需要处理大量的并发请求和数据,那么Go语言可能是一个不错的选择。

    蓝桥杯嵌入式组第十二届国赛程序题

    蓝桥杯嵌入式组第十二届国赛程序题

    shufflenet模型-python语言pytorch框架训练识别樱桃新鲜度-不含数据集图片-含逐行注释和说明文档.zip

    shufflenet模型_python语言pytorch框架训练识别樱桃新鲜度-不含数据集图片-含逐行注释和说明文档 本代码是基于python pytorch环境安装的。 下载本代码后,有个环境安装的requirement.txt文本 如果有环境安装不会的,可自行网上搜索如何安装python和pytorch,这些环境安装都是有很多教程的,简单的 环境需要自行安装,推荐安装anaconda然后再里面推荐安装python3.7或3.8的版本,pytorch推荐安装1.7.1或1.8.1版本 首先是代码的整体介绍 总共是3个py文件,十分的简便 且代码里面的每一行都是含有中文注释的,小白也能看懂代码 然后是关于数据集的介绍。 本代码是不含数据集图片的,下载本代码后需要自行搜集图片放到对应的文件夹下即可 在数据集文件夹下是我们的各个类别,这个类别不是固定的,可自行创建文件夹增加分类数据集 需要我们往每个文件夹下搜集来图片放到对应文件夹下,每个对应的文件夹里面也有一张提示图,提示图片放的位置 然后我们需要将搜集来的图片,直接放到对应的文件夹下,就可以对代码进行训练了。 运行

    bleder 教室学校学生教育室办公室考试

    bleder 教室学校学生教育室办公室考试

    华为OD机试C卷- 单词加密(Java & JS & Python).md- 免费看解析和代码

    私信博主获取三天体验卡,免费看所有华为OD真题、考试报告、手撕代码、面试记录

    基于TUN&GO实现的跨平台浙大校园网客户端,不依赖xl2tpd和pppd.zip

    Go语言(也称为Golang)是由Google开发的一种静态强类型、编译型的编程语言。它旨在成为一门简单、高效、安全和并发的编程语言,特别适用于构建高性能的服务器和分布式系统。以下是Go语言的一些主要特点和优势: 简洁性:Go语言的语法简单直观,易于学习和使用。它避免了复杂的语法特性,如继承、重载等,转而采用组合和接口来实现代码的复用和扩展。 高性能:Go语言具有出色的性能,可以媲美C和C++。它使用静态类型系统和编译型语言的优势,能够生成高效的机器码。 并发性:Go语言内置了对并发的支持,通过轻量级的goroutine和channel机制,可以轻松实现并发编程。这使得Go语言在构建高性能的服务器和分布式系统时具有天然的优势。 安全性:Go语言具有强大的类型系统和内存管理机制,能够减少运行时错误和内存泄漏等问题。它还支持编译时检查,可以在编译阶段就发现潜在的问题。 标准库:Go语言的标准库非常丰富,包含了大量的实用功能和工具,如网络编程、文件操作、加密解密等。这使得开发者可以更加专注于业务逻辑的实现,而无需花费太多时间在底层功能的实现上。 跨平台:Go语言支持多种操作系统和平台,包括Windows、Linux、macOS等。它使用统一的构建系统(如Go Modules),可以轻松地跨平台编译和运行代码。 开源和社区支持:Go语言是开源的,具有庞大的社区支持和丰富的资源。开发者可以通过社区获取帮助、分享经验和学习资料。 总之,Go语言是一种简单、高效、安全、并发的编程语言,特别适用于构建高性能的服务器和分布式系统。如果你正在寻找一种易于学习和使用的编程语言,并且需要处理大量的并发请求和数据,那么Go语言可能是一个不错的选择。

    华为OD机试D卷 - ABR车路协同场景 - 免费看解析和代码

    私信博主获取三天体验卡,免费看所有华为OD真题、考试报告、手撕代码、面试记录

    基于51单片机的蓝牙点灯实验代码

    基于51单片机的蓝牙点灯实验是一个常见的嵌入式系统项目,主要用于教学或DIY爱好者的学习实践。这个实验的目标是通过手机蓝牙控制51单片机上的LED灯,实现远程开关灯的功能。以下是进行此类实验的基本步骤和要点: 所需材料 51系列单片机(如AT89C51或STC89C51等)。 蓝牙模块(常用的是HC-05或HC-06,这些模块通常支持串行通信)。 LED灯及限流电阻。 面包板、杜邦线用于电路搭建。 电源供应(如USB转5V电源)。 电脑与开发环境(如Keil uVision用于编程单片机)。 蓝牙调试APP(用于手机端发送控制指令)。 硬件连接 将51单片机的VCC和GND分别连接到电源的正负极。 LED的一端(阳极,通常较长的一端)通过一个限流电阻(如220欧姆)连接到单片机的一个I/O口(如P1.0),LED的另一端连接到GND。 蓝牙模块的VCC和GND也连接到电源的正负极。 蓝牙模块的RXD连接到单片机的TXD(例如P3.1),TXD连接到RXD(例如P3.0),实现串行通信。 软件编程 使用Keil uVision编写51单片机的控制程序。程序需要监听蓝牙模块传来的数据,并

    课堂举手数据集VOC+YOLO格式4001张1类别.zip

    数据集格式:Pascal VOC格式+YOLO格式(不包含分割路径的txt文件,仅仅包含jpg图片以及对应的VOC格式xml文件和yolo格式txt文件) 图片数量(jpg文件个数):4001 标注数量(xml文件个数):4001 标注数量(txt文件个数):4001 标注类别数:1 标注类别名称:["risehand"] 每个类别标注的框数: risehand 框数 = 11248 总框数:11248 使用标注工具:labelImg 标注规则:对类别进行画矩形框

    stm大纲资料.txt

    stm32cubemx

    shufflenet模型-基于人工智能的卷积网络训练识别航空图像中的云种类分类-不含数据集图片-含逐行注释和说明文档.zip

    shufflenet模型_基于人工智能的卷积网络训练识别航空图像中的云种类分类-不含数据集图片-含逐行注释和说明文档 本代码是基于python pytorch环境安装的。 下载本代码后,有个环境安装的requirement.txt文本 如果有环境安装不会的,可自行网上搜索如何安装python和pytorch,这些环境安装都是有很多教程的,简单的 环境需要自行安装,推荐安装anaconda然后再里面推荐安装python3.7或3.8的版本,pytorch推荐安装1.7.1或1.8.1版本 首先是代码的整体介绍 总共是3个py文件,十分的简便 且代码里面的每一行都是含有中文注释的,小白也能看懂代码 然后是关于数据集的介绍。 本代码是不含数据集图片的,下载本代码后需要自行搜集图片放到对应的文件夹下即可 在数据集文件夹下是我们的各个类别,这个类别不是固定的,可自行创建文件夹增加分类数据集 需要我们往每个文件夹下搜集来图片放到对应文件夹下,每个对应的文件夹里面也有一张提示图,提示图片放的位置 然后我们需要将搜集来的图片,直接放到对应的文件夹下,就可以对代码进行训练了。 运行

    基于 go 模板引擎的 web开发 代码生成器 code generator.zip

    Go语言(也称为Golang)是由Google开发的一种静态强类型、编译型的编程语言。它旨在成为一门简单、高效、安全和并发的编程语言,特别适用于构建高性能的服务器和分布式系统。以下是Go语言的一些主要特点和优势: 简洁性:Go语言的语法简单直观,易于学习和使用。它避免了复杂的语法特性,如继承、重载等,转而采用组合和接口来实现代码的复用和扩展。 高性能:Go语言具有出色的性能,可以媲美C和C++。它使用静态类型系统和编译型语言的优势,能够生成高效的机器码。 并发性:Go语言内置了对并发的支持,通过轻量级的goroutine和channel机制,可以轻松实现并发编程。这使得Go语言在构建高性能的服务器和分布式系统时具有天然的优势。 安全性:Go语言具有强大的类型系统和内存管理机制,能够减少运行时错误和内存泄漏等问题。它还支持编译时检查,可以在编译阶段就发现潜在的问题。 标准库:Go语言的标准库非常丰富,包含了大量的实用功能和工具,如网络编程、文件操作、加密解密等。这使得开发者可以更加专注于业务逻辑的实现,而无需花费太多时间在底层功能的实现上。 跨平台:Go语言支持多种操作系统和平台,包括Windows、Linux、macOS等。它使用统一的构建系统(如Go Modules),可以轻松地跨平台编译和运行代码。 开源和社区支持:Go语言是开源的,具有庞大的社区支持和丰富的资源。开发者可以通过社区获取帮助、分享经验和学习资料。 总之,Go语言是一种简单、高效、安全、并发的编程语言,特别适用于构建高性能的服务器和分布式系统。如果你正在寻找一种易于学习和使用的编程语言,并且需要处理大量的并发请求和数据,那么Go语言可能是一个不错的选择。

    go+gin+网关+go-micro+traefik+etcd+docker-compose+kubernets基于GO的微服务

    Go语言(也称为Golang)是由Google开发的一种静态强类型、编译型的编程语言。它旨在成为一门简单、高效、安全和并发的编程语言,特别适用于构建高性能的服务器和分布式系统。以下是Go语言的一些主要特点和优势: 简洁性:Go语言的语法简单直观,易于学习和使用。它避免了复杂的语法特性,如继承、重载等,转而采用组合和接口来实现代码的复用和扩展。 高性能:Go语言具有出色的性能,可以媲美C和C++。它使用静态类型系统和编译型语言的优势,能够生成高效的机器码。 并发性:Go语言内置了对并发的支持,通过轻量级的goroutine和channel机制,可以轻松实现并发编程。这使得Go语言在构建高性能的服务器和分布式系统时具有天然的优势。 安全性:Go语言具有强大的类型系统和内存管理机制,能够减少运行时错误和内存泄漏等问题。它还支持编译时检查,可以在编译阶段就发现潜在的问题。 标准库:Go语言的标准库非常丰富,包含了大量的实用功能和工具,如网络编程、文件操作、加密解密等。这使得开发者可以更加专注于业务逻辑的实现,而无需花费太多时间在底层功能的实现上。 跨平台:Go语言支持多种操作系统和平台,包括Windows、Linux、macOS等。它使用统一的构建系统(如Go Modules),可以轻松地跨平台编译和运行代码。 开源和社区支持:Go语言是开源的,具有庞大的社区支持和丰富的资源。开发者可以通过社区获取帮助、分享经验和学习资料。 总之,Go语言是一种简单、高效、安全、并发的编程语言,特别适用于构建高性能的服务器和分布式系统。如果你正在寻找一种易于学习和使用的编程语言,并且需要处理大量的并发请求和数据,那么Go语言可能是一个不错的选择。

    基于单片机protues仿真的AD0832设计的电压表32X16点阵显示设计

    基于单片机protues仿真的AD0832设计的电压表32X16点阵显示设计 1、系统使用51单片机为系统设计; 2、protues仿真设计; 3、keil软件编写程序,C语言设计; 4、提供仿真图和源代码; 5、直接使用,方便二次开发; 6、AD0832设计的电压表32X16点阵显示; 软件说明; roteus软件是英国Lab Center Electronics公司出版的EDA工具软件。它不仅具有其它EDA工具软件的仿真功能,还能仿真单片机及外围器件。它是比较好的仿真单片机及外围器件的工具。虽然国内推广刚起步,但已受到单片机爱好者、从事单片机教学的教师、致力于单片机开发应用的科技工作者的青睐。 Proteus是英国著名的EDA工具(仿真软件),从原理图布图、代码调试到单片机与外围电路协同仿真,一键切换到PCB设计,真正实现了从概念到产品的完整设计。是世界上唯一将电路仿真软件、PCB设计软件和虚拟模型仿真软件三合一的设计平台,其处理器模型支持8051、HC11、PIC10/12/16/18/24/30/DSPIC33、AVR、ARM、8086和MSP430等,2010年又增加了Cor

    APM32 32位工业级-车规级MCU GW系列无线MCU选型表&型号指南

    介绍极海半导体公司的32位ARM芯片选型

    UHF RFID防碰撞算法,标签清点率计算

    UHF RFID防碰撞算法,标签清点率计算

    r0NwJI2f.html

    r0NwJI2f.html

    华为HCIE-Security学习备考资料汇总集

    华为HCIE-Security学习备考资料汇总集

Global site tag (gtag.js) - Google Analytics