JMS的可靠性

-----------------------------------------------------------------------------------------------------

消息接收确认
 JMS消息只有在被确认之后,才认为已经被成功地消费了。消息的成功消费通常包含三个阶段:客户接收消息、客户处理消息和消息被确认。
  在事务性会话中,当一个事务被提交的时候,确认自动发生。
  在非事务性会话中,消息何时被确认取决于创建会话时的应答模式(acknowledgement mode)。该参数有以下三个可选值:
    Session.AUTO_ACKNOWLEDGE:当客户成功的从receive方法返回的时候,或者从MessageListenner.onMessage方法成功返回的时候,会话自动确认客户收到消息。
   Session.CLIENT_ACKNOWLEDGE:客户通过调用消息的acknowledge方法确认消息。需要注意的是,在这种模式中,确认是在会话层上进行,确认一个被消费的消息将自动确认所有已被会话消费的消息。列如,如果一个消息消费者消费了10个消息,然后确认了第5个消息,那么所有10个消息都被确认。
   Session.DUPS_ACKNOWLEDGE:该选择只是会话迟钝的确认消息的提交。如果JMS Provider失败,那么可能会导致一些重复的消息。如果是重复的消息,那么JMS Provider必须把消息头的JMSRedelivered字段设置为true

消息持久性,JMS支持以下两种消息提交模式:
  PERSISTENT: 指示JMS provider持久保存消息,以保证消息不会因为JMS provider的失败而丢失
  NON_PERSISTENT: 不要求JMS provider持久保存消息

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

消息过期
  可以设置消息在一定时间后过期,默认是永不过期。

消息的临时目的地
  可以通过会话上的createTemporaryQueue方法和createTemporaryTopic方法来创建临时目的地。它们的存在时间只限于创建它们的连接所保存的时间。只有创建该临时的地方的连接上的消息消费者才能够从临时目的地中提取消息。

持久订阅

  首先消息生产者必须使用PERSISTENT提交消息。客户可以通过会话上的createDurableSubscriber方法来创建一个持久订阅,该方法的第一个参数必须是一个topic,第二个参数是订阅的名称。

  JMS provider会存储发布到持久订阅对应的topic上的消息。如果最初创建持久订阅的客户或者任何其它客户,使用相同的连接工厂和连接的客户ID,相同的主题和相同的订阅名,再次调用会话上的createDurableSubscriber方法,那么该持久订阅就会被激活。JMS provider会向客户发送客户处于非激活状态时所发布的消息。

  持久订阅在某个时刻只能有一个激活的订阅者。持久订阅在创建之后会一直保留,直到应用程序调用会话上的unsubscribe方法。

JMS的PTP模型

  JMS PTP(point-to-point)模型定义了客户端如何向队列发送消息,从队列接收消息,以及浏览队列的消息。

  PTP模型是基于队列的,生产者发送消息到队列,消费者从队列接收消息,队列的存在使得消息的异步传输成为可能。JMS Provider提供工具管理队列的创建和删除。

  PTP的一些特点:

    1.如果在Session关闭时,有一些消息已经被收到,但是还没有签收(acknowledged),那么,当消费者下次连接到相同的队列时,这些消息还会被再次接收。

    2.如果用户在receive方法中设定了消息选择条件,那么不符合条件的消息会留在队列中,不会被接收到。

    3.队列可以长久地保存消息直到消费者收到消息。消费者不需要因为担心消息会丢失而时刻和队列保持激活的连接状态,充分体现了异步传输模式的优势。

JMS的Pub/Sub模型

  JMS Pub/Sub 模型定义了如何向一个内容节点发布和订阅消息,这些节点被称作主题(topic)

  主题可以被认为是消息的传输中介,发布者(publisher)发布消息到主题,订阅者(subscribe)从主题订阅消息。主题使得消息订阅者和消息发布者保持互相独立,不需要接触即可保证消息的传送。

  Pub/Sub的一些特点:

    1.消息订阅分为非持久订阅和持久订阅

      非持久订阅只有当客户端处于激活状态,也就是和JMS Provider保持连接状态才能收到发送的某个主题的消息,而当客户端处于离线状态,这个时间段发到主题的消息将会丢失,永远不会收到。

      持久订阅时,客户端向JMS注册一个识别自己身份的ID,当这个客户端处于离线时,JMS Provider会为这个ID保存所有发送到主题的消息,当客户端再次连接到JMS Provider时,会根据自己的ID得到所有当自己处于离线时发送的主题的消息。

    2.如果用户在receive方法中设定了消息的选择条件,那么不符合条件的消息不会被接收

    3.非持久订阅状态下,不能恢复或重新派送一个未签收的消息。只有持久订阅才能恢复或重新派送一个未签收的消息

    4.当所有的消息必须被接收,则用持久订阅。当丢失消息能够被容忍,则用非持久订阅。

时间: 2024-10-05 16:57:18

JMS的可靠性的相关文章

ActiveMQ(03):JMS的可靠性机制

一.消息接收确认 JMS消息只有在被确认之后,才认为已经被成功地消费了.消息的成功消费通常包含三个阶段:客户接收消息.客户处理消息和消息被确认. 事务相关 1.在事务性会话中,当一个事务被提交的时候,确认自动发生.     final Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);     ....     session.commit(); 2.在非事务性会话中,消息何时被确

ActiveMQ(三)——理解和掌握JMS

一.JMS基本概念 JMS是什么JMS Java Message Service,Java消息服务,是JavaEE中的一个技术. JMS规范JMS定义了Java中访问消息中间件的接囗,并没有给予实现,实现JMS接囗的消息中间件称为JMS Provider,例如ActiveMQ?JMS provider:实现JMS接囗和规范的消息中间件?JMS message:JMS的消息,JMS消息由以下三部分组成:1:消息头:每个消息头字段都有相应的getter和setter方法2消息属性:如果需要除消息头字

私塾在线JAVA高级软件架构师实战培训阶段一

第01节课:整体课程内容概览 -----------------------以下为Maven补充和Git部分------------------------------------------------------------------ 第02节课:Maven补充:分模块.分工程管理第03节课:Maven补充:多模块,多Web应用,合并成一个War包第04节课:Git快速上手:Git简介.基本原理.安装.Git服务器配置.插件Egit第05节课:Git快速上手:TortoiseGit的本地使

java高级软件架构师实战视频教程 Spring+Mybatis+SpringMVC+Ehcache+Memcached+Redis+Nginx+Varnish+ActiveMQ+Keepalived+MySQL+MongoDB

java高级软件架构师实战阶段1视频教程 迅雷下载  百度云 第001节:整体课程概览第002节:分模块.分工程管理第003节:多模块多Web应用合并War包第004节:Git基本原理和安装配置使用第005节:TortoiseGit的本地使用第006节:Egit的本地使用第007节:远程使用以及冲突解决第008节:基本业务功能和数据字典第009节:搭建基础的开发环境第010节:Spring+Mybatis实现DAO第011节:Mybatis的分页实现第012节:Service的实现以及模块化第0

java高级软件架构师实战培训阶段一

第01节课:整体课程内容概览 -----------------------以下为Maven补充和Git部分------------------------------------------------------------------ 第02节课:Maven补充:分模块.分工程管理第03节课:Maven补充:多模块,多Web应用,合并成一个War包第04节课:Git快速上手:Git简介.基本原理.安装.Git服务器配置.插件Egit第05节课:Git快速上手:TortoiseGit的本地使

ActiveMQ RabbitMQ RokcetMQ Kafka实战 消息队列中间件视频教程

ActiveMQ 第01节:ActiveMQ入门和消息中间件第02节:JMS基本概念和模型第03节:JMS的可靠性机制第04节:JMS的API结构和开发步骤_rec_rec第05节:Broker的启动方式吖第06节:ActiveMQ结合Spring开发吖第07节:ActiveMQ支持的传输协议吖第08节:ActiveMQ消息存储持久化_rec_rec第09节:ActiveMQ的静态网络链接吖第10节:多线程consumer访问集群第11节:集群下的消息回流功能第12节:容错的链接和动态网络连接第

更多免费初级中级高级大数据java视频教程下载 加(微***信((号keepper,请备注java或扫下面2二3维4码架构师148讲视频教程(71-80讲)

更多免费初级中级高级大数据java视频教程下载 加(微***信((号keepper,请备注java或扫下面2二3维4码架构师148讲视频教程(71-80讲)java视频教程第71节:ActiveMQ入门和消息中间件.avijava视频教程第72节:JMS基本概念和模型.avijava视频教程第73节:JMS的可靠性机制.avijava视频教程第74节:JMS的API结构和开发步骤.avijava视频教程第75节:Broker的启动方式.avijava视频教程第76节:ActiveMQ结合Spri

JMS消息的可靠性机制

ActiveMQ消息签收机制: 客户端成功接收一条消息的标志是一条消息被签收,成功应答. 消息的签收请求分为两种: 1.带事务的session 如果session带有事务,并且事务成功提交,则消息被自动签收.如果事务回滚,则消息会被再次传送. 2.不带事务的session 不带事务的session的签收方式,取决于session的配置 ActiveMQ支持以下三种模式: Seesion.AUTO_ACKNOWLEDGE:消息自动签收: Session.CLIENT_ACKNOWLEDGE:客户端

JMS开发步骤和持久化/非持久化Topic消息

------------------------------------------------ 开发一个JMS的基本步骤如下: 1.创建一个JMS connection factory 2.通过connection factory来创建JMS connection 3.启动JMS connection 4.通过connection创建JMS session 5.创建JMS destination 6.创建JMS producer 或者创建JMS message,并设置destination 7