005.JMS可靠性机制

1. 消息接收确认

JMS消息只有在被确认以后,才认为已经被成功地消费了。消息的成功消费一般包含三个阶段:异步

  • 客户接收消息
  • 客户处理消息
  • 消息被确认

在事务性会话中,当一个事务被提交的时候,确认自动发生。
在非事务性会话中,消息什么时候被确认取决于建立会话时的应答模式(Acknowledge mode),该参数有如下三个可选值ide

  • Session.AUTO_ACKNOWLEGDE: 当消费者成功的从receive方法返回的时候,或者从MessageListener.onMessage方法成功返回的时候,会话自动确认消费者收到的消息。
  • Session.CLIENT_ACKNOWLEDGE: 客户经过调用消息的acknowledge方法确认消息。须要注意的是,在这种模式中,确认是在会话层上进行,确认一个被消费的消息将自动确认全部已被会话消费的消息。例如,若是一个消息消费者消费了10个消息,而后确认第5个消息,那么全部10个消息都被确认。
  • Session.DUPS_ACKNOWLEDGE: 该选择只是会话迟钝的确认消息的提交。若是JMS provider失败,那么可能会致使一些重复的消息。若是是重复的消息,那么JMS provider必须把消息头的JMSRedelivered字段设置为true。

2. 消息的持久性

JMS支持一下两种消息的提交模式:工具

  • PERSISTENT: 指示JMS provider持久保存消息,以保证消息不会由于JMS provider的失败而丢失;
  • NON_PRESISTENT: 不要求JMS provider持久保存消息。

3. 消息的优先级

可使用消息优先级来指示JMS provider首先提交紧急的消息。优先级分10个级别,从0(最低)到9(最高)。若是不指定优先级,默认级别是4。须要注意的是,JMS provider并不必定保证按照优先级的顺序提交消息。code

4. 消息过时

能够设置消息在必定时间后过时,默认是永不过时能够设置消息在必定时间后过时,默认是永不过时。队列

5. 消息的临时目的地

能够经过会话上的createTemporaryQueue 方法和createTemporaryTopic方法来建立临时目的地。它们的存在时间只限于建立它们的链接所保持的时间。
只有建立该临时目的地的链接上的消息消费者才可以从临时目的地中提取消息。
能够在producer一方,经过message.setJMSReplyTo(replyTo);方法将其传递给consumer,用来进行消息响应。事务

6. 持久订阅

首先消息生产者必须使用PERSISTENT提交消息。消费者能够经过会话上的createDurableSubscriber方法来建立一个持久订阅,该方法的第一个参数必须是一个topic。第二个参数是订阅名称Subscription Name
JMS provider会存储发布到持久订阅对应的topic上的消息。若是最初建立持久订阅的客户或者任何其它客户,使用相同的链接工厂链接的客户ID,相同的topic和相同的订阅名称Subscription Name,再次调用会话上的createDurableSubscriber方法,那么该持久订阅就会被激活。JMS provider会向客户发送客户处于非激活状态时所发布的消息。
持久订阅在某个时刻只能有一个激活的订阅者。持久订阅在建立以后会一直保留,直到应用程序调用会话上的unsubscribe方法。ip

7. JMS的PTP模型

JMS PTP(Point-to-Point)模型定义了客户端如何向队列发送消息,从队列接收消息,以及浏览队列中的消息。
PTP模型是基于队列的,生产者发消息到队列,消费者从队列接收消息,队列的存在使得消息的异步传输成为可能。和邮件系统中的邮箱同样,队列能够包含各类消息,JMS Provider 提供工具管理队列的建立、删除。io

7.1. PTP的一些特色:

  1. 若是在Session 关闭时,有一些消息已经被收到,但尚未被签收(acknowledged),那么,当消费者下次链接到相同的队列时,这些消息还会被再次接收;
  2. 若是用户在receive 方法中设定了消息选择条件,那么不符合条件的消息会留在队列中,不会被接收到;
  3. 队列能够长久地保存消息直到消费者收到消息。消费者不须要由于担忧消息会丢失而时刻和队列保持激活的链接状态,充分体现了异步传输模式的优点;

8. JMS Pub/Sub 模型

JMS Pub/Sub 模型定义了如何向一个内容节点发布和订阅消息,这些节点被称做topictopic能够被认为是消息的传输中介,发布者(publisher)发布消息到topic订阅者(subscribe)topic订阅消息。topic使得消息订阅者消息发布者保持互相独立,不须要接触便可保证消息的传送。List

8.1. Pub/Sub的一些特色:

  1. 消息订阅分为非持久订阅和持久订阅:
  • 非持久订阅只有当客户端处于激活状态,也就是和JMS Provider保持链接状态才能收到发送到某个主题的消息,而当客户端处于离线状态,这个时间段发到主题的消息将会丢失,永远不会收到;
  • 持久订阅时,客户端向JMS 注册一个识别本身身份的ID,当这个客户端处于离线时,JMS Provider会为这个ID 保存全部发送到主题的消息,当客户再次链接到JMSProvider时,会根据本身的ID 获得全部当本身处于离线时发送到主题的消息。
  1. 若是用户在receive 方法中设定了消息选择条件,那么不符合条件的消息不会被接收;
  2. 非持久订阅状态下,不能恢复或从新派送一个未签收的消息。只有持久订阅才能恢复或从新派送一个未签收的消息;
  3. 当全部的消息必须被接收,则用持久订阅。当丢失消息可以被容忍,则用非持久订阅。
相关文章
相关标签/搜索