JMS 描述

JMS接口描述

　　JMS 支持两种消息类型PTP 和Pub/Sub，分别称作：PTP Domain 和Pub/Sub Domain，这两种接口都继承统一的JMS Parent 接口，JMS 主要接口如下所示：

　　JMS Parent PTPDomain Pub/Sub Domain

　　ConnectionFactory QueueConnectionFactory TopicConnectionFactory

　　Connection QueueConnection TopicConnection

　　Destination Queue Topic

　　Session QueueSession TopicSession

　　MessageProducer QueueSender TopicPublisher

　　MessageConsumer QueueReceiver,QueueBrowser TopicSubscriber

　　以下是对这些接口的简单描述：

　　ConnectionFactory ：连接工厂，JMS 用它创建连接

　　Connection ：JMS 客户端到JMS Provider 的连接

　　Destination ：消息的目的地

　　Session： 一个发送或接收消息的线程

　　MessageProducer： 由Session 对象创建的用来发送消息的对象

　　MessageConsumer： 由Session 对象创建的用来接收消息的对象

JMS消息模型

综述　　
JMS 消息由以下几部分组成：消息头，属性，消息体。
Message 分为三个组成部分： 
  1.Header 是一组标准字段，客户机和提供者都用它们来标识和路由消息。
  JMSMessageID——惟一标识提供者发送的每一条消息。这个字段是在发送过程中由提供者设置的，客户机只能在消息发送后才能确定消息的 JMSMessageID。
JMSDestination——消息发送的 Destination，在发送过程中由提供者设置。
JMSDeliveryMode——包含值 DeliveryMode.PERSISTENT 或者 DeliveryMode.NON_PERSISTENT。持久性消息被传输并且只被传输一次，非持久性消息最多被传输一次。要知道“最多一次”包括根本不传输。非持久性消息在应用程序或者系统出故障时被提供者弄丢。因此要格外小心，确保持久性消息不受故障的影响。这比开销通常被认为是发送持久性消息方面的开销，在决定消息的发送模式时，必须仔细考虑，在可靠性和性能之间进行权衡。
JMSTimestamp——提供者发送消息的时间，由提供者在发送过程中设置。
JMSExpiration——消息失效的时间。这个值是在发送过程中计算的，是发送方法的生存时间（time-to-live）值和当前时间值的和。提供者不应发送过期的消息。值 0 表明消息不会过期。
JMSPriority——消息的优先级，由提供者在发送过程中设置。优先级 0 的优先级最低，优先级 9 的优先级最高。
JMSCorrelationID——通常用来链接响应消息与请求消息，由发送消息的 JMS 程序设置。响应来自另一个 JMS 程序的消息的 JMS 程序将正响应消息的 JMSMessageID 拷贝到这个字段中，这样，正作出响应的程序就可以与它所发出的特定请求的响应相 关联。
JMSReplyTo——请求程序用它来指出回复消息应发送的地方，由发送消息的 JMS 程序设置。
JMSType——JMS 程序用它来指出消息的类型。一些提供者维护着一个消息类型仓库，并用该字段引用仓库中的定义类型，在这里，JMS 程序不应该使用这个字段。
JMSRedelivered——指出消息被过早地发送给了 JMS 程序，程序不知道消息的接收者是谁；由提供者在接收过程中设置。
2.Properties 提供了一个给消息添加可选标题字段的实用工具。如果应用程序需要用标准标题字段没有提供的方法
对消息进行归类或分类，那么可以为消息添加一个属性来实现这种归类和分类；提供了 set<Type>Property(...) 
和 get<Type>Property(...) 方法来设置和获得各种 Java 类型的属性，其中包括 Object。JMS 定义了提供者
可以选择性提供的一组标准属性。
JMSXUserID——类型为 string 发送消息的用户的身份。
JMSXApplID——类型为 string 发送消息的应用程序的身份。
JMSXDeliveryCount——类型为 int 已经尝试发送消息的次数。
JMSXGroupID——类型为 string 该消息所属的消息组的身份。
JMSXGroupSeq——类型为 int 该消息在消息组中的序号。
JMSXProducerTXID——类型为 string 生成该消息的事务的身份。
JMSXConsumerTXID——类型为 string 使用该消息的事务的身份。
JMSXRcvTimestamp——类型为 long JMS 将消息发送给客户的时间。
JMSXState——类型为 int 提供者用它来维护消息的消息仓库，通常，它与 JMS 生产者和客户关系不大。
JMSX_<vendor_name> 为特定于提供者的属性而保留。


3.Body 包含将发送到接收应用程序的内容。每一个消息接口都专用于它所支持的内容类型。
属性
(Properties) - 除了消息头中定义好的标准属性外，JMS 提供一种机制增加新属性到消息头中，这种新属性包含以下几种： 
　　1. 应用需要用到的属性; 
　　2. 消息头中原有的一些可选属性; 
　　3. JMS Provider 需要用到的属性。 
　　标准的JMS 消息头包含以下属性： 
　　JMSDestination --消息发送的目的地 
　　JMSDeliveryMode --传递模式，有两种模式： PERSISTENT 和NON_PERSISTENT，PERSISTENT 表示该消息一定要被送到目的地，否则会导致应用错误。NON_PERSISTENT 表示偶然丢失该消息是被允许的，这两种模式使开发者可以在消息传递的可靠性和吞吐量之间找到平衡点。 
　　JMSMessageID 唯一识别每个消息的标识，由JMS Provider 产生。 
　　JMSTimestamp 一个消息被提交给JMS Provider 到消息被发出的时间。 
　　JMSCorrelationID 用来连接到另外一个消息，典型的应用是在回复消息中连接到原消息。 
　　JMSReplyTo 提供本消息回复消息的目的地址。 
　　JMSRedelivered 如果一个客户端收到一个设置了JMSRedelivered 属性的消息，则表示可能该客户端曾经在早些时候收到过该消息，但并没有签收(acknowledged)。 
　　JMSType 消息类型的识别符。 
　　JMSExpiration 消息过期时间，等于QueueSender 的send 方法中的timeToLive 值或TopicPublisher 的publish 方法中的timeToLive 值加上发送时刻的 GMT  时间值。如果timeToLive值等于零，则JMSExpiration 被设为零，表示该消息永不过期。如果发送后，在消息过期时间之后消息还没有被发送到目的地，则该消息被清除。 
　　JMSPriority 消息优先级，从0-9 十个级别，0-4 是普通消息，5-9 是加急消息。JMS 不要求JMS Provider 严格按照这十个优先级发送消息，但必须保证加急消息要先于普通消息到达。 

消息体

　　(Body) - JMS API 定义了5种消息体格式，也叫消息类型，你可以使用不同形式发送接收数据并可以兼容现有的消息格式，下面描述这5种类型：

　　消息类型 消息体

　　TextMessage java.lang.String对象，如xml文件内容

　　MapMessage 名/值对的集合，名是String对象，值类型可以是Java任何基本类型

　　BytesMessage 字节流

　　StreamMessage Java中的输入输出流

　　ObjectMessage Java中的可序列化对象

　　Message 没有消息体，只有消息头和属性。

下例演示创建并发送一个TextMessage到一个队列： 
　　TextMessage message = queueSession.createTextMessage(); message.setText(msg_text); // msg_text is a String
queueSender.send(message);