使用Spring JMS轻松实现异步消息传递.pdf

使用 Spring JMS 轻松实现异步消息

传递

异步进程通信是面向服务架构(SOA)一个重要的组成部分，因为企业里很多

系统通信，特别是与外部组织间的通信，实质上都是异步的。Java 消息服务

(JMS)是用于编写使用异步消息传递的 JEE 应用程序的 API。传统的使用 JMS

API 进行消息传递的实现包括多个步骤，例如 JNDI 查询队列连接工厂和 Queue

资源，在实际发送和接收消息前创建一个 JMS 会话。

Spring 框架则简化了使用 JEE 组件(包括 JMS)的任务。它提供的模板机制

隐藏了典型的 JMS 实现的细节，这样开发人员可以集中精力放在处理消息的实

在现实中，大多数 web 请求都是同步处理的。例如，当用户要登入一个网

站，首先输入用户名和密码，然后服务器验证登录合法性。如果验证成功，程

序将允许该用户进入网站。这里，登录请求在从客户端接收以后被即时处理了。

信用卡验证是另一个同步处理的例子；只有服务器证实输入的信用卡号是有效

的，同时客户在帐户上有足够的存款，客户才被允许继续操作。但是让我们思

考一下在顺序处理系统上的支付结算步骤。一旦系统证实该用户信用卡的信息

是准确的，并且在帐户上有足够的资金，就不必等到所有的支付细节落实、转

账完成。支付结算可以异步方式进行，这样客户可以继续进行核查操作。

需要比典型同步请求耗费更长时间的请求，可以使用异步处理。另一个异

步处理的例子是，在本地贷款处理程序中，提交至自动承销系统(AUS)的信用请

器断开连接。然后 AUS 服务从指定的队列中选出请求进行处理，并将处理得到

的消息放置在另一个消息队列里。最后，客户端程序从这个队列中选出处理结

果，紧接着处理这个信用历史数据。

JMS

如果您使用过 JMS 代码，您会发现它与 JDBC 或 JCA 很像。它所包含的样本

代码创建或 JMS 资源对象回溯，使得每一次您需要写一个新类来发送和接收消

息时，都具有更好的代码密集性和重复性。以下序列显示了传统 JMS 实现所包

括的步骤：

创建 JNDI 初始上下文(context)。

从 JNDI 上下文获取一个队列连接工厂。

业务要求无关的 JMS 资源，但是开发人员必须编写并维护这些额外步骤的代码。

Spring JMS Spring 框架提供了一个模板机制来隐藏 Java APIs 的细节。

JEE 开发人员可以使用 JDBCTemplate 和 JNDITemplate 类来分别访问后台数据

库和 JEE 资源(数据源，连接池)。JMS 也不例外。Spring 提供 JMSTemplate 类，

程序时 Spring 所具有一些的优势。

提供 JMS 抽象 API，简化了访问目标(队列或主题)和向指定目标发布消息

时 JMS 的使用。

JEE 开发人员不需要关心 JMS 不同版本(例如 JMS 1.0.2 与 JMS 1.1)之间的

差异。

开发人员不必专门处理 JMS 异常，因为 Spring 为所有 JMS 异常提供了一个

常，Spring 框架就会抛出异常，这个类是这些所抛出的异常的基(抽象)类。

JmsTemplate,JmsTemplate102 org.springframework.jms.core 这些是辅助类，

用于简化 JMS 的使用，处理 JMS 资源(如连接工厂，目标和发送者/接收者对象)

的创建和释放。JmsTemplate102 是 JmsTemplate 的子类，使用 JMS1.0.2 规范

MessageCreator org.springframework.jms.core 这是 JmsTemplate 类使用的

回叫接口，它为指定的会话创建 JMS 消息。MessageConverter

org.springframework.jms.support.converter 这个接口充当一个抽象，用来

在 Java 对象与 JMS 消息之间进行转换。DestinationResolver

org.springframework.jms.support.destination 这是 JmsTemplate 用来解析

目标名的接口。该接口的默认实现是 DynamicDestinationResolver 和

话，然后在这同一个 JMS 会话里，可以从一个 Queue(PTP)中接收消息，同时发

送另一个消息到一个 Topic(Pub/Sub)。JMS 1.1 向后兼容 JMS 1.0，应此根据

JMS 1.0 编写的代码仍可以适用于 JMS 1.1。

方法名称功能 send 发送消息至默认或指定的目标。JmsTemplate 包含 send

方法，它通过 javax.jms.Destination 或 JNDI 查询来指定目标。receive 从默

认或指定的目标接收消息，但只会在指定的时间后传递消息。我们可以通过

receiveTimeout 属性指定超时时间。convertAndSend 这个方法委托

MessageConverter 接口实例处理转换过程，然后发送消息至指定的目标。

receiveAndConvert 从默认或指定的目标接收消息。并将消息转换为 Java 对象。

目标可以通过 JNDI 上下文保存和获取。当配置 Spring 程序上下文

(application context)时，我们可以用 JndiObjectFactoryBean 类取得对 JMS

的引用。DestinationResolver 接口是用来把目标名称解析成 JMS 目标，当应

用程序存在大量目标时，这是非常有用的。

别将 String 转换为 JMS TextMessage，字节数组(byte)转换为 JMS

BytesMessage，Map 转换为 JMS MapMessage，和 Serializable 对象转换为 JMS