首页 > java > JMS概述

JMS概述

2013年10月2日 亲亲宝宝 发表评论 阅读评论

jms即Java消息服务(Java Message Service)应用程序接口是一个Java平台中关于面向消息中间件(MOM)的API,用于在两个应用程序之间,或分布式系统中发送消息,进行异步通信。Java消息服务是一个与具体平台无关的API,绝大多数MOM提供商都对JMS提供支持。

JMS定义了两种消息传递域:点对点消息传递域和发布/订阅消息传递域。

点对点消息传递域的特点:
1. 每个消息只能有一个消费者;
2. 消息的生产者和消费者之间没有时间上的相关性。无论消费者在生产者发送消息的时候是否处于运行状态,它都可以提取消息。

发布/订阅消息传递域的特点:
1. 每个消息可以有多个消费者;
2. 生产者和消费者之间有时间上的关联性。订阅一个主题的消费者只能消费自它订阅之后发布的消息。JMS规范允许客户创建持久阅读,这在一定程度上放松了时间上的相关性要求。持久订阅允许消费者消费它在未处于激活状态时发送的消息。

在点对点消息传递域中,目的地为队列(Queue);在发布/订阅消息传递域中,目的地为主题(Topic)。

消息的消费可以采用以下两种方法之一:
1. 同步消费。通过调用消费者的receive方法从目的地中显式地提取消息。receive方法可以一直阻塞到消息到达;
2. 异步消费。客户可以为消费者注册一个消息监听器,以定义在消息到达时所采取的动作。

JMS消息由以下三部分组成:
1. 消息头。每个消息头字段都有相应的getter和setter方法;
2. 消息属性。如果需要除消息头字段以外的值,那么可以使用消息属性;
3. 消息体。JMS定义的消息类型有TextMessage、MapMessage、BytesMessage、StreamMessage和ObjectMessage。

JMS消息只有在被确认之后,才认为已经被成功消费。消息的成功消费通常包含三个阶段:客户接收消息、客户处理消息和消息被确认。

在事务性会话中,当一个事务被提交时,确认自动发生。在非事务性会话中,消息何时被确认取决于创建会话时的应答模式(acknowledgement mode)。该参数有以下三个可选值:
1. Session.Auto_ACKNOWLEDGE。当客户成功地从receive方法返回的时候,或者从MessageListener.onMessage方法成功返回的时候,会话自动确认客户收到的消息。
2. Session.CLIENT_ACKNOWLEDGE。客户通过消息的acknowledge方法确认消息。需要注意的是,在这种模式中,确认是在会话层进行:确认一个被消费的消息将自动确认所有已被会话消费的消息。例如,如果一个消息消费者消费了10个消息,然后确认第5个消息,那个所有10个消息都被确认。
3. Session.DUPS_ACKNOWLEDGE。在会话迟钝等情况下确认消息。如果JMS provider失败,那么可能会导致一些重复的消息。如果是重复的消息,那么JMS provider必须把消息头的JMSRecelivered字段设置为true。

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

分类: java 标签: 3,249 次阅读
原文链接:http://www.wenhq.com/article/view_788.html
欢迎转载,请注明出处:亲亲宝宝
  1. 2013年10月5日10:27 | #1

    我之前也看了jms的,没有实战经验!

    [回复]

  1. 本文目前尚无任何 trackbacks 和 pingbacks.