《JMS简明教程(PDF格式)》第24章

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?　列出了JMS　的公共接口。
表8?　域内可选接口的关系
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
*/
session　=　connection。createSession（false；　Session。AUTO_ACKNOWLEDGE）；
9。1。5　创建MessageProducer
在得到　Session 后，客户端程序使用　Session 来创建　MessageProducer　。这个　
MessageProducer　对象用于向目的地发送消息。通过使用Session。createProducer　方法来创建　
MessageProducer，参数是消息被发送的目的地。
MessageProducer　sender；
/*　Value　in　stockQueue　previously　looked　up　in　the　JNDI
* createProducer　takes　a　Destination
*/
sender　=　session。createProducer（stockQueue）；
9。1。6　创建MessageConsumer
消息可以被同步或异步的消费。这个例子展示了如何创建同步消费消息的消息消费者。　
56　/　66
…………………………………………………………Page　57……………………………………………………………
参见9。3。1 “异步接收消息”了解如何异步消费消息。
MessageConsumer