Jms术语、接口、操作流程概览
2006-06-08 22:28
357 查看
一、消息术语
消息:
封装发送方及接收方之间传递的信息,包括消息主体(数据)、标头及可选的一些属性
标头:
包含客户端及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对象的句柄,读取消息的内容并处理它
消息:
封装发送方及接收方之间传递的信息,包括消息主体(数据)、标头及可选的一些属性
标头:
包含客户端及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对象的句柄,读取消息的内容并处理它
相关文章推荐
- V4L2视频采集操作流程和接口说明
- V4L2视频采集操作流程和接口说明
- OpenGL 4.0 GLSL 基础教程概览——VAO和VBO常用操作接口
- 企业商家支付宝接口调试操作流程
- V4L2视频采集操作流程和接口说明
- V4L2视频采集操作流程和接口说明
- V4L2视频采集操作流程和接口说明
- V4L2视频采集操作流程和接口说明
- V4L2视频采集操作流程和接口说明
- V4L2视频采集操作流程和接口说明
- 嵌入式Linux:V4L2视频采集操作流程和接口说明
- 情绪版(Mood board)操作流程的新思考
- git 基本操作与规范流程
- Oracle11G impdp,empdp导入导出数据库操作流程
- 文件操作接口类
- 通用接口的配置和调用流程
- 无法嵌入互操作类型“Dongle.DongleClass”。请改用适用的接口。
- Linux设备驱动之一 ---- 驱动的框架及其操作流程
- 无法嵌入互操作类型 请改用适用的接口
- WF4.0应用篇(七):请假流程(带驳回操作)