理解JMS规范中的持久订阅和非持久订阅

jms1.1规范针对publisher/subscriber模型提出了持久订阅和非持久订阅者。我们用现实生活中的例子来说明,持久订阅和非持久订阅的区别。

1.非持久订阅

考虑学生听老师讲课的情景,大学老师讲课,一部分学生会去教室听课,另一部分学生会选择逃课在寝室睡觉。开始上课前,老师可能会点名,在教室听课的同学知道这个消息,逃课的同学就不知道这个消息(除非朋友电话通知的情况)。即老师发布消息的时候,如果学生在教室就能知道,不在教室就不知道。非持久订阅只有当客户端处于激活状态,也就是和JMS Provider 保持连接状态才能收到发送到某个主题的消息,而当客户端处于离线状态,这个时间段发到主题的消息将会丢失,永远不会收到。在我们的例子中,教室是jms
provider和主题,老师是消息发送者,学生是消息接受者。客户端处于激活状态,就相当与学生在教室中。创建非持久订阅者的代码如下:

TopicConnection connection = JmsUtils.getConnection();
Topic topic = JmsUtils.getTopic();

TopicSession session = connection.createTopicSession(false,Session.AUTO_ACKNOWLEDGE);

TopicSubscriber subscriber = session.createSubscriber(topic,null,true);

2.持久订阅

持久这个词往往和离线存储相关。大家都使用qq进行聊天,当你qq在线的时候,能够收到好友发送的消息;当你不在线,下次再登录的时候,仍然能够收到好友之前给你发送的消息。持久订阅时,客户端向JMS 服务器注册一个自己身份的ID,当这个客户端处于离线时,JMS Provider 会为这个ID 保存所有发送到主题的消息,当客户再次连接到JMS Provider时,会根据自己的ID得到所有当自己处于离线时发送到主题的消息。源码如下:

TopicConnection connection = JmsUtils.getConnection();
Topic topic = JmsUtils.getTopic();

// 创建持久订阅的时候,必须要设置client,否则会报错:
// javax.jms.JMSException: You cannot create a durable subscriber
// without specifying a unique clientID on a Connection

// 如果clientID重复(已经存在相同id的活动连接),会报错
// javax.jms.InvalidClientIDException: Broker: localhost - Client: 1
// already connected from tcp://127.0.0.1:2758
connection.setClientID("1");

TopicSession session = connection.createTopicSession(false,Session.AUTO_ACKNOWLEDGE);

// 在同一个连接的ClientID下,持久订阅者的名称必须唯一
// javax.jms.JMSException: Durable consumer is in use for client: 1 and
// subscriptionName: 11

TopicSubscriber subscriber = session.createDurableSubscriber(topic,"11");

创建持久订阅者,必须要指定connection的clientId和订阅者的名称。这个其实很好理解,你要想收到朋友发送的qq消息,前提就是你得先注册个QQ号,而且还要有台能上网的设备,电脑或手机。设备就相当于是clientId是唯一的;qq号相当于是订阅者的名称,在同一台设备上,不能用同一个qq号挂2个客户端。连接的clientId必须是唯一的,订阅者的名称在同一个连接内必须唯一。这样才能唯一的确定连接和订阅者。

3.持久订阅的实现机制

  • 发送者发送消息给jms provider,如果此时provider发现没有任何的消费者(包括在线/离线),那么就会认为该消息无用,不需要存储,会直接删除。
  • 如果有在线的消费者,那么provider会将消息直接传送给在线消费者,因为这个时候连接是通的,消息有传输的通道。
  • 如果有离线的消费者,那么provider会把属于该消费者的消息存储下来,等消费者在线的时候,在将保存的离线消息推送给它。对于持久订阅者,jms        provider会在该消费者第一次登录在线的时候,将它的身份信息记录下来。记录身份的关键就是clientId和订阅者name。当持久订阅者又重新在线的时        候,provider会根据当前连接的clientId和订阅者name,去查询属于它的离线消息,并进行推送。

理解JMS规范中的持久订阅和非持久订阅

时间: 2024-10-13 09:57:18

理解JMS规范中的持久订阅和非持久订阅的相关文章

理解JMS规范中消息的传输模式和消息持久化

JMS规范定义了2种消息传输模式:持久传送模式和非持久传输模式.发送者可以通过如下类似的代码进行设置 TopicPublisher publihser = session.createPublisher(topic); // 设置持久化传输 publihser.setDeliveryMode(DeliveryMode.PERSISTENT); 这种方式对publisher发送的所有消息都有效,相当于是一个全局的效果.如果只是想设置某一个消息的传输模式,可以通过以下代码设置消息头的属性来实现 Te

JMS-activeMq发布订阅模式(非持久订阅)

Publisher的代码: import javax.jms.Connection; import javax.jms.ConnectionFactory; import javax.jms.DeliveryMode; import javax.jms.Destination; import javax.jms.JMSException; import javax.jms.MapMessage; import javax.jms.MessageProducer; import javax.jms

JMS学习(五)--ActiveMQ中的消息的持久化和非持久化 以及 持久订阅者 和 非持久订阅者之间的区别与联系

一,消息的持久化和非持久化 ①DeliveryMode 这是传输模式.ActiveMQ支持两种传输模式:持久传输和非持久传输(persistent and non-persistent delivery),默认情况下使用的是持久传输. 可以通过MessageProducer 类的 setDeliveryMode方法设置传输模式: MessageProducer producer = ...; producer.setDeliveryMode(DeliveryMode.PERSISTENT); 持

消息中间件系列一:入门、JMS规范、ActiveMQ使用

一.入门 1. 消息中间件的定义 没有标准定义,一般认为,采用消息传送机制/消息队列 的中间件技术,进行数据交流,用在分布式系统的集成 2. 为什么要用消息中间件 解决分布式系统之间消息的传递.电商场景: 用户下单减库存,调用物流系统.随着业务量的增大,需要对系统进行拆分(服务化和业务拆分),拆分后的系统之间的交互一般用RPC(远程过程调用).如果系统扩充到有几十个接口,就需要用消息中间件来解决问题. 3. 消息中间件和RPC有什么区别 3.1 功能特点: 在架构上,RPC和Message的差异

【J2EE】在项目中理解J2EE规范

J2EE平台由一整套服务(Service),应用程序接口(API)和协议构成,它对开发企业级应用提供了功能支持.13个核心技术分别是JDBC, JNDI, EJB, RMI, JSP, SERVLET, XML, JMS, JAVAIDL/CORBA, JTS, JTA, JAVAMAIL和 JAF. 何为企业级应用? 1.数据量特别大. 2.用户特别多. 3.性能要求高. 4.安全性要求高. 5.生命周期长. 这时候我们就要考虑数据存储和查询的问题,系统访问快慢即性能问题,如何使用事务保证安全

MQ学习(一)----JMS规范(转发整合)

最近进行ActiveMQ的学习,总结下已被不时之需. JMS规范: JMS即Java消息服务(Java Message Service)应用程序接口是一个Java平台中关于面向消息中间件(MOM)的API,用于在两个应用程序之间,或分布式系统中发送消息,进行异步通信.Java消息服务是一个与具体平台无关的API,绝大多数MOM提供商都对JMS提供支持. JMS是一种与厂商无关的 API,用来访问消息收发系统消息.它类似于JDBC(Java Database Connectivity):这里,JD

JAVA消息服务JMS规范及原理详解

一.简介 JMS即Java消息服务(Java Message Service)应用程序接口,是一个Java平台中关于面向消息中间件(MOM)的API,用于在两个应用程序之间,或分布式系统中发送消息,进行异步通信.Java消息服务是一个与具体平台无关的API,绝大多数MOM提供商都对JMS提供支持. JMS允许应用程序组件基于JavaEE平台创建.发送.接收和读取消息.它使分布式通信耦合度更低,消息服务更加可靠以及异步性. 二.常用术语介绍 在提到JMS时,我们通常会说到一些术语,解释如下: 消息

Java消息中间件的概述与JMS规范

为什么需要使用消息中间件 在介绍消息中间件之前,我们先来看一个故事: 老王的睡前故事: 在很久很久以前,小明隔壁有个姓王的邻居,姑且就叫隔壁老王吧.隔壁老王有个大女儿,名叫王兰花秀丽,秀丽从小就爱听老王讲睡前故事,每晚在入睡前都要老王讲了睡前故事才能睡的得着.但某一天秀丽到了外地去上大学,老王为了能给秀丽讲故事,只能通过打电话的方式进行,如下: 但是有时候可能由于秀丽的手机信号不好或者没电等情况,导致老王只能不停的联系,直到电话打通为止.老王内心:我能怎么办,我也很绝望啊.虽然秀丽可能会比较晚才

深刻理解:C#中的委托、事件

C#中的事件还真是有点绕啊,以前用JavaScript的我,理解起来还真是废了好大劲!刚开始还真有点想不明白为什么这么绕,想想和JS的区别,最后终于恍然大悟! C#中事件绕的根本原因: C#的方法,它不是一个类型,它只是其它类型的成员: C#是一个强类型的语言,定义方法时,它的参数必须指定类型,如 public void add(int n){...}; 所以,一个方法不能直接作为其它方法的参数,把一个方法名作为参数,无法指定类型啊,会报错!那我就想啊,既然不能直接传入,那我传入整个对象总可以吧