首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

ActiveMQ经典控制台持久订阅

是指在ActiveMQ消息中间件中使用经典控制台进行持久化订阅的一种方式。

ActiveMQ是一个开源的消息中间件,它实现了Java Message Service (JMS) API,提供了可靠的消息传递机制。经典控制台是ActiveMQ提供的一个管理工具,用于监控和管理消息队列。

持久订阅是一种订阅模式,它允许消费者在离线状态下接收消息。当消费者重新连接到ActiveMQ时,它会接收到在离线期间发送的消息。这种订阅模式适用于需要确保消息不丢失的场景,如实时通知、订单处理等。

优势:

  1. 可靠性:持久订阅可以确保消息在消费者离线期间不丢失,保证消息的可靠传递。
  2. 灵活性:消费者可以根据自己的需求选择订阅特定的消息主题或队列,灵活控制消息的接收。
  3. 实时性:持久订阅可以实时地将消息推送给消费者,使其能够及时处理相关业务。

应用场景:

  1. 实时通知:持久订阅可以用于实时通知系统,如即时聊天、实时监控等场景,确保消息的及时传递。
  2. 订单处理:在订单处理系统中,持久订阅可以确保订单状态的实时更新,避免订单丢失或延迟处理。
  3. 日志收集:持久订阅可以用于日志收集系统,将日志消息实时推送给相关的消费者,方便日志的分析和监控。

推荐的腾讯云相关产品: 腾讯云提供了一系列的云计算产品,其中包括消息队列 CMQ,可以用于实现消息的发布和订阅。CMQ支持持久订阅,可以满足各种场景的需求。

产品介绍链接地址:腾讯云消息队列 CMQ

页面内容是否对你有帮助?
有帮助
没帮助

相关·内容

activemq持久订阅工作原理

activemq消息订阅模式来说有两种:持久订阅/非持久订阅。...非持久订阅consumer只能消费在该consumer激活状态时传送给对应topic的消息才能被该consumer消费,一旦该consumer 挂掉到下次启动期间发布到该topic的消息不能被该consumer...持久订阅订阅之后,无论消息是否是在该consumer激活或者down掉期间发送的,最终都会被该consumer接收到,直到被显示取消持久订阅(session.unscribe(“topic名字”))!...context, ConsumerInfo info) throws Exception { if (info.isDurable()) { //看该消息是否是持久订阅...,下面看下更核心的持久订阅与消息提供者断开连接时的处理: @Override public void removeConsumer(ConnectionContext context,

49310
  • ActiveMQ专题2: 持久

    ,原producer产生的消息丢失 ​ 持久化和非持久化最终队列控制台分别如下: ?...而支持持久化的设置,只要消息没有被消费,重启mq,仍然能被新加入的consumer消费。 订阅持久化 ​ JMS的规范是没有要求实现订阅持久化的。所幸的是activeMQ实现了这个特性。...个人认为所谓的订阅持久化相对于消息的持久化,不过是一种伪持久化。...: 要实现伪持久订阅,必须先向activeMQ发布持久订阅消息,通过clientId来标识不同的订阅渠道。...如果在发布持久订阅消息之前producer就向mq发送了topic消息,那么consumer还是没法接收 activeMQ确定是否是同一持久订阅者的依据条件有两个:connection.setClientID

    68430

    ActiveMQ入门系列三:发布订阅模式

    在上一篇《ActiveMQ入门系列二:入门代码实例(点对点模式)》中提到了ActiveMQ中的两种模式:点对点模式(PTP)和发布/订阅模式(Pub & Sub),详细介绍了点对点模式并用代码实例进行说明...,今天就介绍下发布/订阅模式。...一、理论基础 发布/订阅模式的工作示意图: 消息生产者将消息(发布)到topic中,可以同时有多个消息消费者(订阅)消费该消息。 和点对点方式不同,发布到topic的消息会被所有订阅者消费。...先执行生产者 在控制台页面的Topics下出现了我定义的topic并且有1条消息发送成功且未消费 然后执行两个消费者,两个消费者都没有消费到任何消息 并且,控制台页面只是多了2个消费者,已经消费的消息还是...就是这个原因 继续,我们在两个消费者启动好的前提下,再执行生产者, 这个时候会发现两个消费者都消费了该消息 再看下控制台页面 已消费消息这里是2,这个2并不是说之前发的两个消息都消费了,而是说第二个消息消费了

    46710

    MQ 系列之 ActiveMQ 消息持久化机制

    ActiveMQ 的消息持久化机制有 JDBC,AMQ,KahaDB 和 LevelDB,无论使用哪种持久化方式,消息的存储逻辑都是一致的。...用于存储订阅关系。...如果是持久化 Topic,订阅者和服务器的订阅关系在这个表保存;activemq_lock 在集群环境中才有用,只有一个 Broker 可以获得消息,称为 Master Broker,其他的只能作为备份等待...Topic 模式中先启动消费者订阅,在启动生产者,可以在数据库 activemq_acks 表中看到订阅者,该模式的消息依旧会被保存到数据库 activemq_msgs 表中,但是消息被订阅者签收后不会从数据库中删除...☞ 可能存在的问题 在配置关系型数据库作为 ActiveMQ持久化存储方案时,可能会出现以下问题  ♞ 需要使用到的相关 jar 文件放置到 ActiveMQ 安装路径下的 lib 目录,否则会找不到

    1.2K20

    SpringBoot使用ActiveMq同时支持点对点推送和发布订阅

    在SpringBoot中使用ActiveMq默认是只能点对点推送, ActiveMq还有一种方式就是发布订阅, 一个发布者, 多个订阅者, 形成一个点对面 先来配置一下点对面的。...application.properties 增加配置 #default point to point 开启发布订阅 spring.jms.pub-sub-domain=true xxApplication.java...Override public void publish(String message) { jmsMessagingTemplate.convertAndSend(topic, message); } 订阅者...这样就完成了我们的发布订阅, 但是测试的时候发现 点对点推送不好用, 消息开始堆积, 我们需要让它同时支持两种 默认消费者并不会消费订阅发布类型的消息,这是由于springboot默认采用的是p2p模式进行消息的监听...spring.jms.pub-sub-domain=true 修改 CommonTopicSub.java /** * @ JmsListener如果不指定独立的containerFactory的话是只能消费queue消息 是订阅不到消息的

    1.2K20

    ActiveMQ学习之消息存储和可持久

    一、activeMQ高可用 1、事物 2、签收 3、持久 4、可持久化 二、持久化机制...为了避免意外宕机以后丢失信息,需要做到重启后可以恢复消息队列,消息系统一般都会采用持久化机制 ActiveMQ持久化机制有:JDBC、AMQ、KahaDB和LevelDB,无论哪种持久化方式...KahaDB是一个专门针对消息持久化的解决方案,他对典型的消息使用模式进行优化。数据被追加到data logs中。...配置:1、进入到ActiveMQ安装目录下的conf文件夹下 2、编辑activemq.xml,在这里我们可以看到默认的存储方式就是...这种方式克服了JDBC store的不足,JDBC每次消息过来都需要去操作数据库,ActiveMQ journal,使用高速缓存写入技术,大大提高了性能。

    77510

    技术分享-持久性-WMI事件订阅

    通常,通过 WMI 事件订阅持久性需要创建以下三个类,它们用于存储有效负载或任意命令,指定将触发有效负载的事件并将两个类(__EventConsumer &__EventFilter)关联起来,以便执行和触发绑定一起...从交互式 ruby 控制台执行以下命令将生成 MOF。...通过 WMI 事件订阅持久性可以通过使用常见的 Microsoft 实用程序来实现,因此无需将文件放入磁盘。...有一个 PowerShell 模块可以通过在特定时间执行基于 64 编码的有效负载,在目标主机上部署 WMI 事件订阅持久性技术。...usemodule persistence/elevated/wmi_updater* 工具包 下表显示了红队可以使用的工具,以实现 WMI 事件订阅持久性技术以及每个工具的可用触发器选项。

    2.8K10

    JMS消息持久化,将ActiveMQ消息持久化到mySql数据库中

    前言 ActiveMQ 是Apache出品,最流行的,能力强劲的开源消息总线。...fr=aladdin ActiveMQ提供多种数据持久化方式:可以持久化到文件,也可以持久化到数据库,其中数据库可以支持MySQL和Oracle两种类型。...默认提供的是持久化到文件的方式,即activemq.xml文件中的: <kahaDBdirectory="${<em>activemq</em>.base}/data/kahadb...步骤 本文重点接收的是<em>持久</em>化到MySQL中的配置方式: 2.1    添加MySQL驱动 首先需要把MySql的驱动放到<em>ActiveMQ</em>的Lib目录下,我用的文件名字是: mysql-connector-java...此时,重新启动MQ,就会发现<em>activemq</em>库中多了三张表:<em>activemq</em>_acks,<em>activemq</em>_lock,<em>activemq</em>_msgs,OK,说明已经<em>持久</em>化成功啦!

    1.7K70

    ActiveMQ从入门到精通(一)JMSActiveMQ QuickStartWrite Code 4 ActiveMQ在说说Session关于消息的priorityttldeliveryMode

    这是关于消息中间件ActiveMQ的一个系列专题文章,将涵盖JMS、ActiveMQ的初步入门及API详细使用、两种经典的消息模式(PTP and Pub/Sub)、与Spring整合、ActiveMQ...在登录ActiveMQ Web控制台需要用户名、密码信息;在JMS CLIENT和ActiveMQ进行何种协议的连接、端口是什么等这些信息都在上面的配置文件中可以体现。...data目录下是ActiveMQ进行消息持久化存放的地方,默认采用的是kahadb,当然我们可以采用leveldb,或者采用JDBC存储到MySQL,或者干脆不使用持久化机制。...,直接activemq.bat启动它,并访问Web控制台!...ActiveMQ Start 到这里,ActiveMQ就已经启动了,So easy~  访问ActiveMQ web控制台的用户名、密码在哪里配置的?URL当中的端口是在哪里配置的? ?

    79820

    深入讲解ActiveMQ5.X消息的持久

    它允许我们在JMS领域使用发布订阅语义模型. 但当我们将一条消息标记为“持久的”而它并没有订阅者时会如何?...如果消息没有任何的订阅者(无活跃的或可持久订阅者),那么当消息被发布后(持久或非持久的),ActiveMQ 对此消息不会做任何的事情....如果消息有可持久订阅者(活跃或非活跃),那么ActiveMQ只是会存储这些消息....对于一个非活跃的可持久订阅, ActiveMQ 会将标记为“持久的”消息做持久存储并等待订阅者重新加入订阅,到那时它将会尝试投递消息....在ActiveMQ中,这些预取的消息在控制台里用的是“在飞行中”来代表. 它取决于消费者对消息的处理和确认(这取决于消息的确认模式… 默认模式是自动确认,即当消费者收到消息就会发送ACK..

    76450

    第一章:activeMQ原理,安装,queue,topic以及topic持久化方式介绍,包括修改ubuntu的jdk环境变量。

    点击Quenes如下,这个是点对点消息发送界面 再点击topic是发布/订阅模式界面 在Send中可以测试发送点对点或发布/订阅两种消息,如下图所示。...Enqueued 压入队列的消息数量 Messages Dequeued 出队列的消息数量,也就是被消费的消息数 五,topic 发布/订阅模式 生产者代码: /* * 订阅模式的生产者...三个进程控制台都有打印生产者消息。...生产者代码: /* * 订阅发布式 可持久化生产者 */ @Test public void TestTopicPersistenceProducer() throws JMSException...的activemq.xml文件,只需要添加一句配置,就是在<broker的末尾添加一句关于持久化的配置persistent=”true”即可。

    1K11

    activemq学习之activemq功能(一)

    61616端口提供JMS服务,使用8161 端口提供管理控制台服务,执行以下命令可以检查是否 成功启动 ActiveMQ 服务 netstat -an|grep 61616 通过 http:...消息会被持久化保存 直到消息被签收 发布订阅 持久订阅和非持久订阅持久订阅 不能回复或重新指标一个未签收的消息 如果所有消息必须要签收 则使用持久订阅 消息结构组成 JMS 消息由及部分组成:...持久订阅就是这样一个道理,持久订阅有两个特点: 持久订阅者和非持久订阅者针对的 Domain 是 Pub/Sub,而不是 P2P 当 Broker 发送消息给订阅者时,如果订阅者处于 未激活状态状态:持久订阅者可以收到消息...,而非持久订阅者则收不到消息。...当然这种方式也有一定的影响:当持久订阅者处于 未激活状态时,Broker 需要为持久订阅者保存消息;如果持久订 阅者订阅的消息太多则会溢出。

    1.1K20

    企业实战(12)消息队列之Docker安装部署ActiveMQ实战

    每个消息可以有多个消费者 发布者和订阅者之间有时间上的依赖性。针对某个主题(Topic)的订阅者,它必须创建一个订阅者之后,才能消费发布者的消息。 为了消费消息,订阅者必须保持运行的状态。  ...为了缓和这样严格的时间相关性,JMS允许订阅者创建一个可持久化的订阅。这样,即使订阅者没有被激活(运行),它也能接收到发布者的消息。  ...集群方案(Master / Slave) Pure Master Slave 无单点故障; 不需要依赖共享文件系统或是共享数据库,使用 KahaDB的方式持久化存储; 一个Master只能带一个Slave...61616是 activemq 的容器使用端口,8161是 web 页面管理端口 -d:后台运行容器 --name:指定容器名 -p:指定服务运行的端口(61616:应用访问端口;8161:控制台...=system //修改用户 activemq.password=manager //修改密码 guest.password=password 访问ActiveMQ控制台 默认账号

    2K30
    领券