利用 WAS CE v2.1 创建基于 JMS 的应用

核心提示： 上述代码与 OrderSenderBean 中发送消息的代码十分相似，不同点在于这里使用了 JMS 的消息队列 (Queue) 资源 -OrderQueue，利用 WAS CE v2.1 创建基于 JMS 的应用(9)，而 OrderSenderBean 则使用了 JMS 的主题 (Topic)

上述代码与 OrderSenderBean 中发送消息的代码十分相似。不同点在于这里使用了 JMS 的消息队列 (Queue) 资源 -OrderQueue，而 OrderSenderBean 则使用了 JMS 的主题 (Topic) 资源。

接收消息

创建 ShopTransporter 类表示运输部门。与之前接收消息的方式相似，ShopTransporter 也是一个消息驱动组件 (MDB)。可见，MDB 可以方便的使用于接收任何一种 JMS 消息模型。

清单 10. ShopTransporter 的代码
@MessageDriven(activationConfig　=　{　
　　@ActivationConfigProperty(propertyName　=　
　　"destinationType",　propertyValue　=　"javax.jms.Queue"),　
　　@ActivationConfigProperty(propertyName　=　
　　"destination",　propertyValue　=　"OrderQueue"),})　
public　class　ShopTransporter　implements　MessageListener　{　
　　　　public　void　onMessage(Message　message)　{　
　　　　　　　　　　．．．．．．　
　　　　}　
}　

此段代码与之前的 MDB 非常相似，同样使用了 @ActivationConfigProperty 与 @MessageDriven 来绑定 JMS 资源。不同点在于，ShopTransporter 使用了消息队列 (Queue) 而不再是主题 (Topic), 表示 ShopTransporter 直接收 OrderQueue 中传递的消息。

运行

与前一篇文章相同，运行应用程序前，需要将 ShopEAR 部署至应用服务器上。登录后，用户可以点击“buy”链接，购买商品。上述代码中的输出信息将显示在应用服务器的终端中。

应用程序的输出信息如图 3 所示：

图 3. 运行结果

总结

本文以 WAS CE v2.1 为平台，通过一个示例向您阐述了 JMS 应用的基本开发过程，包括 JMS 资源及 Resouces Adapter 的创建、两类 JMS 消息 ( 通过 Queue 及 Topic) 的发送、JMS 消息的接收。无论采用何种消息模型，利用 WAS CE 2.1 开发 JMS 应用的基本流程可以归纳如下：

定义 JMS 资源

创建 JMS 资源定义文件，定义所需要的 JMS 资源

加入 ActiveMQ 资源适配器，作为应用程序的一个模块

发送消息

利用 ConnectionFactory 创建 Connection，连接至 JMS Provider

利用 Connection 创建 Session

利用 Session 创建发送者及消息

发送者发送消息

接收消息

创建 MDB，实现 java.jms.MessageListener 接口

实现 onMessage() 方法，接收并处理消息

WAS CE v2.1 为各种 Java EE 技术提供了强大的支持。通过 ActiveMQ 作为 JMS Provider，开发人员可以在 WAS CE 上便捷地开发出各种复杂应用。

本文示例源代码或素材下载