JMS消息接口
一、消息术语 消息： 封装发送方及接收方之间传递的信息，包括消息主体 ( 数据 ) 、标头及可选的一些属性 标头： ???????? 包含客户端及 JSM 提供程序所需的标识、路由消息的信息 ???????? 各种类型的消息都具有相同的标头结构 主体： ???????? 包含具体的应用数据。 ???????? 据消息类型的不同有多种形式：简单文本字符串、 XML 、二进制流、已序列化的对象 被管理对象： ???????? 在 JMS 应用程序之外产生并维护的对象，提供访问消息提供程序、连接已定义队列和主题的通用手段。使用 JNDI 来定位被管理对象。 连接： ???????? 应用和 JMS 提供程序之间的链路 会话： ???????? 用于对消息的收发过程进行管理 ???????? 它建立在连接之上，负责创建生产者和消费者、创建消息对象、处理事务、控制确认等 目的地 ： ???????? JMS 消息的发送目标，可以是一个队列也可以是一个主题 队列： ???????? 点到点模式下的目的地。消息被送进队列，然后被一个接收者取走 主题 ： ???????? 发布 / 订阅模式下的目的地。消息被送进主题，然后 JMS 提供程序将其拷贝分发给该主题的订阅者 生产者 ： ???????? 消息的来源。有两种生产者：发送者 (Sender) 和发布者 (Publisher) 。 ???????? Sender 将消息发送到点到点模式下的队列 ???????? Publisher 将消息发布到发布 / 订阅模式下的主题 消费者 ： ???????? 消息的接收者。有两种消费者：接收者 (Receiver) 和订阅者 (SubScriber) ???????? Receiver 从点到点模式下的队列中取走消息 ???????? SubScriber 从发布 / 订阅模式下的主题中接收消息 ? 二、接口概览 消息接口 Message: ???????? 各类消息的基本接口。定义了消息的头、属性和主体 TextMessage: ???????? 定义包含 String 对象的消息主体。用于基本的文本消息及包含 XML 的消息 BytesMessage: ???????? 定义一个包含字节序列的消息主体。用于支持现有消息格式和非 Java 系统接口 ObjectMessage: ???????? 定义包含可序列化 Java 对象的消息主体，只能包含一个对象。如果需要发送多个对象，则需发送对象的集合 MapMessage: ???????? 定义包含一张映射表的消息主体，该映射表以字符串为关键字，以 Java 对象为值。可通过名字和按顺序访问对象 StreamMessage: ???????? 定义可作为 Java 对象流被访问的消息主体。访问它的方法与 java.io.DataInputStream 和 java.io.OutputStream 非常相似。用于写原语和对象序列 ? 点到点接口 Queue: ???????? 点到点消息的目的地。将消息发往队列，并在创建发送方和接收方的时候指明队列 QueueSender: ???????? 发送消息到指定队列 QueueReceiver: ???????? 从指定队列接收消息 QueueSession: ???????? 为某一队列创建发送方、接收方及各种类型的消息 QueueConnection: ???????? 建立与 JMS 提供程序的连接，用于为应用程序创建会话 QueueConnectionFactory: ???????? 一个与具体提供程序相捆绑的类，用于创建与 JMS 提供程序的连接，常在 JNDI 名字空间中查找它 ? 发布 / 订阅接口 Topic: ???????? 发布 / 订阅消息的目标地址。对于某一主题允许有多个发布者和订阅者 TopicPublisher: ???????? 发布消息到指定主题 TopicSubscriber: ? ???????? 订阅某一主题，同时支持阻塞和非阻塞的 receive 调用，另外也提供对已注册消息监听器的异步调用 TopicSession: ???????? 为指定的连接创建发布人、订阅人以及各种类型的消息 TopicConnection: ???????? 建立与 JMS 提供程序的连接，用于为应用创建对话 TopicConnectionFactory: ???????? 一个与具体提供程序相捆绑的类，用于创建与 JMS 提供程序的连接 ? 三、操作流程概览 使用 JMS 可以分为两个阶段：初始化 和消息处理 初始化过程建立与消息提供程序的连接，创建目的地、发送方和接收方； 消息处理完成消息的发送和接收 ? JMS 的初始化包括如下步骤： 1．?? 查找一个连接工厂 (QueueConnectonFactory 和 TopicConnectionFactory) 2．?? 使用工厂创建连接 (QueueConnection 和 TopicConnection) 3．?? 在连接上创建会话 (QueueSession 和 TopicSession) 4．?? 查找一个目的地 (Queue 或者 Topic) 5．?? 使用目的地在会话上创建发送方和接收方 (QueueSender/QueueReceiver 或者 TopicPublisher/Subscriber) 6．?? 对于异步接收者 / 消费者，注册一个消息监听器，用于监听消息的到达 ? JMS 对象的初始化完成后，按以下步骤发送消息： 1．?? 在会话之上建立消息对象 2．?? 填充消息的内容 3．?? 通过发送方或生产者发送消息 ? JMS 对象的初始化完成后还可以按以下步骤接收消息 1．?? 对于同步接收方式，使用接收方或消费者接收下一条可获得的消息； 对于异步发送方式，调用所连接对象的 start 方法开始接收消息 2．?? 通过前面得到的 Message 对象的句柄，读取消息的内容并处理它
