友情提示：如果本网页打开太慢或显示不完整，请尝试鼠标右键“刷新”本网页！
JMS简明教程(PDF格式)-第13部分
快捷操作: 按键盘上方向键 ← 或 → 可快速上下翻页 按键盘上的 Enter 键可回到本书目录页 按键盘上方向键 ↑ 可回到本页顶部! 如果本书没有阅读完，想下次继续接着阅读，可使用上方 "收藏到我的浏览器" 功能 和 "加入书签" 功能！
8。2 并发处理订阅的消息
JMS 提供了一个特殊的工具用于创建MessageConsumer，它可以并发的消费消息。
这个工具将这项工作分成三个角色：
z JMS 提供商——用于转发消息。
z 应用服务器——用于创建消费者和管理由并发MessageListener 对象使用的线程。
z 应用——用目的地和可选的消息选择器定义一个订阅，并提供一个单线程的
MessageListener 类来消费它的消息。应用服务器将构造这个类的多个对象来并发消
费消息。
8。2。1 Session
会话提供了应用服务器使用的三个方法：
z setMessageListener（） 和 getMessageListener（） ——会话的 MessageListener 通过
ConnectionConsumer 消费分配到这个会话的消息，如后面的几个段落描述。
z run（）——会话的MessageListener 依次处理由ConnectionConsumer 分配到会话的消
息。当监听器从最后一个消息处理返回时，run（）返回。
应用服务器通常被给一个 MessageListener 类，它包含了由应用程序员编写的处理消息
的单线程代码。应用服务器也被给监听器要消费消息的目的地和消息选择器。
应用服务器将负责创建处理消息处理的JMS Connection，ConnectionConsumer 和Session 。
应用服务器将按需创建MessageListener 实例并将它们注册到它自己的会话中。
由于许多监听器需要使用会话的服务，因此监听器很可能要求将它的会话传入到它的构
造器中。
8。2。2 ServerSession
ServerSession 是一个由应用服务器实现的对象。应用服务器使用它来将一个线程和一个
JMS 会话关联起来。
ServerSession 实现了两个方法：
z getSession（）——返回ServerSession 的JMS 会话。
z start（）——启动ServerSession 线程的执行，并执行关联的JMS 会话的run 方法。
8。2。3 ServerSessionPool
ServerSessionPool 是一个由应用服务器实现的对象，它提供了用于处理
ConnectionConsumer 的消息的ServerSession 池。
它只有一个方法是getServerSession（） 。这个方法从池中删除一个ServerSession 并将它返
回给调用者（假定是ConnectionConsumer ），用于消费一个或多个消息。
JMS 没有说明如何实现池。它可能是一个静态的ServerSession 池，或者它可以使用更专
业的算法来按需动态创建ServerSession 。
如果ServerSessionPool 没有了ServerSession，那么getServerSession（）方法可能阻塞。如
51 / 66
…………………………………………………………Page 52……………………………………………………………
果ConnectionConsumer 被阻塞，那么它不能转发新的消息直到ServerSession 返回。
8。2。4 ConnectionConsumer
对于应用服务器来说，连接提供了创建 ConnectionConsumer 的专用工具。它消费的消
息由目的地和消息选择器指定。另外，ConnectionConsumer 必须交给ServerSessionPool 用于
处理它的消息。指定 maxMessages 值用于限制 ConnectionConsumer 一次可以加载到
ServerSession 会话的消息数量。
通常，当拥堵轻微时，ConnectionConsumer 从池中得到一个ServerSession，用一个消息
加载它的会话，然后启动它。当拥堵严重时，消息可能被退回。如果发生退回，
ConnectionConsumer 可以用多个消息来加载每个 Session 。这减少了线程上下文的切换，减
小了某些消息处理排序时资源的使用。
8。2。5 ConnectionConsumer 如何使用ServerSession
由JMS 提供商实现的ConnectionConsumer 使用ServerSession 来处理一到多个到达的消
息。按以下方式做这项工作：
z 从ServerSessionPool 中得到一个ServerSession 。
z 得到ServerSession 的Session 。
z 用一个或多个消息加载Session 。
z 然后其他ServerSession 来消费这些消息。
用于QueueConnection 的ConnectionConsumer 将它的消息加载到QueueSession，同样，
用于TopicConnection 的ConnectionConsumer 加载TopicSession 。
注意，JMS 没有说明 ConnectionConsumer 如何用消息加载 Session 。由于
ConnectionConsumer 和Session 都由同一个JMS 提供商实现，因此它们可以用私有机制完成
这种加载。
8。2。6 应用服务器如何实现ServerSession
JMS 没有说明ServerSession 的实现。下面出现的普通实现解释了这个概念：
z 应用服务器为 ServerSession 创建一个线程，注册 ServerSession 的 runObject 。
runObject 的实现是应用服务器私有的。
z ServerSession 的start 方法调用线程的start 方法。和所有的java 线程一样，调用start
初始化线程的执行并调用线程的runObject。ServerSession。start（ConnectionConsumer）
的调用者和ServerSession 的runObject 现在运行在不同的线程中。
z runObject 将做一些内部处理然后调用会话的 run（）方法。在返回时，runObject 将
ServerSession 返回给ServerSessionPool 然后返回。这终止了ServerSession 线程的执
行，并再次循环启动。
8。2。7 结果
JMS 定义了灵活的机制将并发消息消费的工作拆分成适合于每个参与者的角色。
52 / 66
…………………………………………………………Page 53……………………………………………………………
应用程序员提供一种易于书写单线程的MessageListener 实现。
JMS 提供者保持对消息的控制直到它们被转发到MessageListener。这保证它是在消息确
认的直接控制之下。
应用服务器控制ConnectionConsumer 的设置和管理用于执行MessageListener 的线程。
下图解释了三个角色和它们实现的对象间的关系。
下图解释了ConnectionConsumer 将消息转发给MessageListener 的过程。
53 / 66
…………………………………………………………Page 54……………………………………………………………
8。3 XAConnectionFactory
某些应用服务器提供对用于分布式事务的资源分组提供支持。为了在分布式事务中包含
JMS 事务，应用服务器要求JTA 兼容JMS 提供商。JMS 提供商用JMS XAConnectionFactory 暴
露它的JTA 支持，应用服务器使用XAConnectionFactory 来创建XAConnection 。
XAConnectionFactory 提供了和ConnectionFactory 一样的授权选项。
XAConnectionFactory 对象是JMS 受管理对象，就像ConnectionFactory 对象。期望用应
用服务器使用JNDI 找到它们。
8。4 XAConnection
XAConnection 通过提供创建XASession 扩展了Connection 的能力。
8。5 XASession
XASession 提供了获取看起来象普通 Session 对象的对象和控制会话事务上下文的
javax。transaction。xa。XAResource 对象。XAResource 的功能非常类似于标准X/Open XA 资源接
口定义的功能。
应用服务器通过获取XAResource 来控制XASession 的事务分配。它使用XAResource 来
将会话分配给分布式事务，准备和提交事务上的工作等等。
XAResource 为多事务上的交叉工作、恢复处理中的事务列表等等提供了公平的专业工
具。JTA 感知的JMS 提供上必须全部实现这个功能。这可以通过使用支持XA 的数据库服务
来做到，或者JMS 提供商可以选择从基础开始来实现这个功能。
将XASession 的Session 赋给应用服务器的客户端。之后，应用服务器控制后台XASession
的事务管理。
但必须注意的是，分布式事务上下文不会随着消息流动；也就是说，接收消息的事务和
和生产消息的事务不能是同一个。这是异步消息和同步处理间的基本差别。消息生产者和消
费者使用两种方式来建立JMS 提供商保证一次只有一个消息被转发的能力。
再次重申，在Session 中生产和/或消费消息的行为都可以是事务性的。在不同会话间生
产和消费一个特定消息的行为不能是事务性的。
8。6 JMS 应用服务器接口
PTP 和Pub/Sub 两个域都提供了它们自己的JTS 感知的JMS 工具。
但是，应当优先使用公共接口。表8�1 列出了JMS 的公共接口。
表8�1 域内可选接口的关系
JMS 公共接口 PTP 接口 Pub/Sub 接口
ServerSessionPool 没有域特定的接口 没有域特定的接口
ServerSession 没有域特定的接口 没有域特定的接口
ConnectionConsumer 没有域特定的接口 没有域特定的接口
XAConnectionFactory XAQueueConnectionFactory XATopicConnectionFactory
54 / 66
…………………………………………………………Page 55……………………………………………………………
XAConnection XAQueueConnection XATopicConnection
XASession XAQueueSession XATopicSession
9 JMS 样例代码
本章给出了一些展示JMS 客户端如何使用JMS API 的代码样例。也解释了如何使用几个
消息类型。这些例子使用了支持统一消息模型的方法：这些例子使用点对点或发布/订阅进
行工作。用JMS API 进行工作是推荐的方式。
在JMS 规范的早期版本中，只支持消息域（点对点或发布/订阅）各自的接口，且客户
端要么使用点对点要么使用发布/订阅来进行编程。现在，JMS 客户端可以使用JMS 公共接
口进行编程。
在例子中，客户端应用发送和接收股票报价信息。客户端应用从股票报价服务中接收消
息。股票报价服务在这个例子中没有描述。
为了简化这个例子，没有对异常进行处理。
本章描述了为发送和接收消息而创建正确环境的步骤。
在描述了基本的功能后，本章描述如何执行一些其他的公共功能，例如使用消息选择器。
9。1 准备发送和接收消息
下面是建立连接然后准备发送和接收消息的基本步骤。
z 获得ConnectionFactory 和Destination。
z 创建Connection 和Session 。
z 创建MessageConsumer。
z 创建MessageProducer。
9。1。1 获取ConnectionFactory
消息生产者和消息消费者（发送者和接收者）都需要得到ConnectionFactory，并使用它
来建立Connection 和Session 。
通常，管理员已经为JMS 客户端创建和配置好了ConnectionFactory 。客户端程序通常使
用JNDI API 来查找ConnectionFactory 。
import javax。naming。*；
import javax。jms。*；
ConnectionFactory connectionFactory；
Context messaging = new InitialContext（）；
connectionFactory = （ConnectionFactory）
messaging。lookup（〃ConnectionFactory〃）；
55 / 66
…………………………………………………………Page 56……………………………………………………………
9。1。2 获取Destination
管理员已经创建和配置了一个名字为“StockQueue ”的Queue，它是股票报价消息被发
送和接收的地方。同样，可以使用JNDI API 来查找目的地。
Queue stockQueue；
stockQueue = （Queue）messaging。lookup（〃StockSource〃）；
9。1。3 创建Connection
在得到ConnectionFactory 之后，客户端程序使用它来创建Connection 。
Connection connection；
connection = ConnectionFactory。createConnection（）；
9。1。4 创建Session
在得到 Connection 之后，客户端程序使用它来创建 Session 。这个 Session 用于创建
MessageProducer （发送消息）或MessageConuser （接收消息）。
Connection。createSession 方法有两个参数：
z 一个表示会话是否是事务性的布尔。
z 消息确认模式。
Session session；
/* Session is not transacted；
* uses AUTO_ACKNOWLEDGE for message
* acknowledgement
快捷操作: 按键盘上方向键 ← 或 → 可快速上下翻页 按键盘上的 Enter 键可回到本书目录页 按键盘上方向键 ↑ 可回到本页顶部!
温馨提示： 温看小说的同时发表评论，说出自己的看法和其它小伙伴们分享也不错哦！发表书评还可以获得积分和经验奖励，认真写原创书评 被采纳为精评可以获得大量金币、积分和经验奖励哦！