博客

JMS消息接口

  • Post author:
  • Post category:其他





一、消息术语






消息：


封装发送方及接收方之间传递的信息，包括消息主体




(




数据




)




、标头及可选的一些属性



标头：




包含客户端及




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




对象的句柄，读取消息的内容并处理它


版权声明：本文为qqhejinqq原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。