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

activemq中持久化订阅

    博客分类:
  • jms
阅读更多

       在activemq中,当我们第一次通过session.createDurableSubscriber(topic,name)创建一个特定名称的持久化订阅时,broker就会为这个持久化订阅者维护一个主题消息列表,该主题消息列表存放了所有未被持久化订阅者消费的消息,持久化订阅者一旦消费了这条消息,这条消息就会从主题消息列表中移除,这样一来,持久化订阅者所在的机器如果突然宕机,那么当系统重启之后,持久化订阅者依然能够接受到在宕机期间,主题发布者发布的消息,从这点上看,和点对点的队列消息域中的消费模式有点类似,但这种能够获得其不在线时主题发布者发布的消息的能力,是在创建了持久化订阅之后才拥有的。

分享到:
评论

相关推荐

    spring+activemq topic持久化订阅

    spring +activemq topic消息持久化订阅实例,整个项目中有activemq和spring的整合的所有实例,topic的持久化配置是在ApplicationContext3C、ApplicationContext3C2以及ApplicationContext3P三个中,消息生产者:...

    activemq消息持久化所需Jar包

    activemq消息持久化所需Jar包,详情请参见博文:http://blog.csdn.net/l1028386804/article/details/68997105

    ActiveMQ订阅模式持久化实现

    一个订阅通道,支持多个客户端监听,当某个客户端掉线后,再上线的时候可以收到它没有接收到的消息。

    spring集成activemq演示queue和topic 持久化

    本人在学习activemq,然后 测试完成的demo, 包含了queue,topic,持久化到mysql,订阅模式,包好用

    activemq-demo

    集成activemq和spring 的消息推送 包含普通队列消息和持久化订阅消息

    ActiveMQ中文手册

    2.3 持久化 12 2.3.1 AMQ Message Store 12 2.3.2 Kaha Persistence 12 2.3.3 JDBC Persistence 13 2.3.4 Disable Persistence 13 2.4 安全机制 13 2.4.1 Simple Authentication Plugin 13 2.4.2 JAAS...

    boot-example-activemq-topic-2.0.5

    SpringBoot+ActiveMQ-发布订阅 Topic 主题 * 消息消费者(订阅方式)消费该消息 ...* 当生产者发布消息,不管是否有消费者,都不会保存消息,如果对订阅消息提前做了持久化操作,还是可以收到的。

    消息队列中间件ActiveMQ入门到精通视频教程及资料

    003-顺序消费+消息过滤SELECTOR+MessageConsumer+MySql持久化;004-p2p模式+pulish-subscribe发布订阅模式+与spring集成;005-集群部署1;006-集群部署2;007-集群部署3;activemq集群配置文档.pdf;ActiveMQ(中文)...

    ActiveMQ.chm

    activeMQ集成流程: activceMQ从了解过程,安装,消息发送模式的讲解,从点对点模式到订阅模式,及深入了解JMS,再到集成到spring,.消息的持久化,高级特性,应用场景,面试常用问题

    ActiveMQ从入门到精通(二)

    本文来自于jianshu,介绍了消息的顺序消费、JMSSelectors、消息的同步/异步接受方式、Message、P2P/PubSub、持久化订阅、持久化消息到MySQL以及与Spring整合等知识。接上一篇,本篇主要讨论的话题是:消息的顺序消费...

    java实现的消息中间件之AcitveMQ详解,学习学习

    KahaDB他是默认的持久化策略,所有消息都会顺序添加到一个日志文件中,同时另外有一个索引文件记录指向这些日志的存储地址,还有一个事务日志用于消息回复操作。是一个专门针对消息持久化的解决方案,它对典型的消息...

    ActiveMQ是Apache软件基金会所研发开源的消息中间件,为应用程序提供高效的、可扩展的、稳定的和安全的企业级消息通信

    抛开网络服务(Network Services)不说,我们应该知道的是ActiveMQ的三个重要组成部分:连接(Connectors)、消息模式(Topic,Queue)、消息持久化方式。 连接(Connectors)  ActiveMQ提供了多种应用协议,如...

    消息中间件实例项目

    activemq实现,提供消费方和消费方简单实例代码,分为点对点,发布订阅(发布订阅分为持久化和非持久化,非持久化需要消费方在线才可以收到消息。持久化,消费方如果没有在线,上线之后可以接收到消息)

    apache-artemis包

    选择Artemis的原因开源、高可用性、Java编写、高性能的日志保证持久化消息像非持久化消息一样拥有出色的表现、功能齐全、简洁的设计、灵活的集群可以通过不可靠的全球网络创建地理上分布的集群。

    ActiveMq由浅入深讲解+面试题50道讲解

    内容包括MQ概述和工作流程,启动过程与启动异常分析,消息的基本模型,基于队列的生产者和消费者,基于发布-订阅的生产者和消费者,消息的同步消费和异步消费,消息的数据类型,身份认证,持久化配置与实现,...

    EventCenter:EventCenter 事件中心,用于分布式系统中广播发布事件, 目前只有activemq 实现

    广播式事件(持久化事件) 一个事件可以由多个监听器处理,每个监听器处理负责不同的逻辑。 场景: 一个事件需要做多个扩展逻辑. 举例: 用户注册事件发布以后,可以有两个监听器,分别负责用户统计、欢迎邮件。 广播式...

    Java思维导图xmind文件+导出图片

    图解Redis中的AOF和RDB持久化策略的原理 redis读写分离架构实践 redis哨兵架构及数据丢失问题分析 redis Cluster数据分布算法之Hash slot redis使用常见问题及性能优化思路 redis高可用及高并发实战 缓存击穿...

    Redis:Redis代码

    Redis真的那么好用吗? 一、Redis是什么? Redis是一个开源的底层使用C语言...持久化数据访问较慢、 用key查询 2、消息队列 相当于消息订阅系统,比如ActiveMQ、RocketMQ。如果对数据有较高一致性要求时,还是建议使用

    xmljava系统源码-high-end-technology::angry_face_with_horns:Sharesomeofthehigh-endtechnologiescomm

    xml java系统源码 高端技术 :wolf: 分享一些大型互联网架构常用的高端技术 目录 消息队列 ActiveMQ ActiveMQ 是Apache出品,最流行的,能力强劲的开源消息总线...C语言编写、支持网络、可基于内存亦可持久化的日志型、K

Global site tag (gtag.js) - Google Analytics