Spring源码分析之spring-jms模块详解

0 概述

spring提供了一个jms集成框架，这个框架如spring 集成jdbc api一样，简化了jms api的使用。

jms可以简单的分成两个功能区，消息的生产和消息的消费。JmsTemplate类用来生成消息和同步接受消息。和其它java ee的消息驱动样式一样，对异步消息，spring也提供了许多消息监听容器用来创建消息驱动的POJO(MDPs)。spring同时也提供了创建消息监听器的声明方式。

org.springframework.jms.core 提供了使用JMS的核心功能，它包含JmsTemplate类，该类类似于jdbc中的jdbdTemplate，它通过对资源的创建和释放处理来简化jms开发。spring的模板类作为一种设计原则在spring框架中广泛使用，模板类对简单操作提供了帮助方法；对复杂操作，通过继承回调接口提供了重要处理过程的代理。jmsTemplate同样遵循这一设计原则，它提供了发送消息、同步消费消息、为用户提供JMS session和消息生产者的多种便利方法。

org.springframework.jms.support提供了JmsException转译功能。它将checked的JmsException层次转换成uncheckedd异常的镜像层次。若抛出的异常不是javax.jms.JmsException的子类，这个异常将被封装成unchecked异常UncategorizedJmsException。

org.springframework.jms.support.converter 提供了在java对象和jms消息之间转换的抽象MessageConverter。

org.springframework.jms.support.destination提供了管理jms destination的多种策略，如对存放在jndi的destionation提供服务定位功能。

org.springframework.jms.annotation通过使用@JmsListener提供了对注解驱动的监听端的支持。

org.springframework.jms.config 支持jms命名空间的解析，同时也支持配置监听容器和生成监听端。

最后，org.springframework.jms.connection提供了适用于standonle应用的ConnectionFactory的实现。它也了spring PlatFormTransactionManager对jms的事务管理实现jmsTranscationmanager. 这允许jms 作为事务资源无缝的集成到Spring事务管理机制中。

1. 异常处理类模块

异常的转换在JmsUtils中来做的：

/**
     * Convert the specified checked {@link javax.jms.JMSException JMSException} to a
     * Spring runtime {@link org.springframework.jms.JmsException JmsException} equivalent.
     * @param ex the original checked JMSException to convert
     * @return the Spring runtime JmsException wrapping the given exception
     */
    public static JmsException convertJmsAccessException(JMSException ex) {
        Assert.notNull(ex, "JMSException must not be null");

        if (ex instanceof javax.jms.IllegalStateException) {
            return new org.springframework.jms.IllegalStateException((javax.jms.IllegalStateException) ex);
        }
        if (ex instanceof javax.jms.InvalidClientIDException) {
            return new InvalidClientIDException((javax.jms.InvalidClientIDException) ex);
        }
        if (ex instanceof javax.jms.InvalidDestinationException) {
            return new InvalidDestinationException((javax.jms.InvalidDestinationException) ex);
        }
        if (ex instanceof javax.jms.InvalidSelectorException) {
            return new InvalidSelectorException((javax.jms.InvalidSelectorException) ex);
        }
        if (ex instanceof javax.jms.JMSSecurityException) {
            return new JmsSecurityException((javax.jms.JMSSecurityException) ex);
        }
        if (ex instanceof javax.jms.MessageEOFException) {
            return new MessageEOFException((javax.jms.MessageEOFException) ex);
        }
        if (ex instanceof javax.jms.MessageFormatException) {
            return new MessageFormatException((javax.jms.MessageFormatException) ex);
        }
        if (ex instanceof javax.jms.MessageNotReadableException) {
            return new MessageNotReadableException((javax.jms.MessageNotReadableException) ex);
        }
        if (ex instanceof javax.jms.MessageNotWriteableException) {
            return new MessageNotWriteableException((javax.jms.MessageNotWriteableException) ex);
        }
        if (ex instanceof javax.jms.ResourceAllocationException) {
            return new ResourceAllocationException((javax.jms.ResourceAllocationException) ex);
        }
        if (ex instanceof javax.jms.TransactionInProgressException) {
            return new TransactionInProgressException((javax.jms.TransactionInProgressException) ex);
        }
        if (ex instanceof javax.jms.TransactionRolledBackException) {
            return new TransactionRolledBackException((javax.jms.TransactionRolledBackException) ex);
        }

        // fallback
        return new UncategorizedJmsException(ex);
    }

2. config模块

支持jms命名空间的解析，同时也支持配置监听容器和生成监听端。其结构如下：

其中，在JmsNamespaceHandler中使用到了监听容器，如下：

public class JmsNamespaceHandler extends NamespaceHandlerSupport {

    @Override
    public void init() {
        registerBeanDefinitionParser("listener-container", new JmsListenerContainerParser());
        registerBeanDefinitionParser("jca-listener-container", new JcaListenerContainerParser());
    }

}

3. connection模块

提供了适用于standonle应用的ConnectionFactory的实现。它也了spring PlatFormTransactionManager对jms的事务管理实现jmsTranscationmanager. 这允许jms 作为事务资源无缝的集成到spring事务管理机制中。其结构如下：

JmsTemplate需要一个ConnectionFactory的引用，ConnectionFactory作为jsm规范的一部分，是作为和jms交互中一个关键因素，用来作为工厂创建和jms 提供者连接客户端应用的connection，并且封装了多种类型的配置参数，这些参数一般由jsm 提供者指明，例如ssl 配置选项。

SingleConnectionFactory 创建连接时返回同一个连接Connectin而忽略了close()调用。它适用于测试环境和standalone环境，因为相同的connection可以被多个JmsTemplate调用，这些调用可以跨越多个事务。SingleConnectionFactory有一个可能来自于jndi的标准ConnectionFactory引用。

CachingConnectionFactory扩展了SingleConnectionFactory的功能，增加了session的缓存，MessageProducer和messageConsumer。缓存的初始化size设置为1，使用

4. core模块

提供了使用JMS的核心功能。

使用jmsTemplate时只需要继承callback接口，通过继承call接口可以定义一个高级别的协议，MessageCreator callback接口在指定session创建一个消息，它只可以被JmsTemplate调用。为满足更jms api更复杂的应用，SessionCallBack给用户提供了jms session，ProducerCallback暴露了session和messageProducer两个。

jms api提供两种类型的send方法，一种设置delivery模式，优先级，存活时间(time-to-live)作为qos参数，另一种不提供qos参数而使用默认值。

5. Listener模块

消息监听容器(MessageListenerContainer)用来从jms 消息队列中接受消息，然后推送注册到它内部的消息监听器(MessageListener)中。spring提供了两种标准的jms 消息监听容器，特色如下：

SimpleMessageListenerContainer:在启动时，创建固定数目的jms 会话和一个消费者，使用标准的jms 　　　　MessageConsumer.setMessageListener()方法来注册监听器，让jms 提供者来让监听器返回。

DefaultMessageListenerContainer：支持在运行时动态适应，并且能参与到外部受管理事务。每个接收到的消息使用JtaTransactionManager注册为XA 事务，因而可以充分利用xa 事务语义进行处理。

6. remoting模块

org.aopalliance.intercept.MethodInterceptor 用来接收基于jms的远程服务。

JmsInvokerClientInterceptor：序列化远程触发对象和反序列化远程触发结果对象，使用java序列化方法，例如RMI.

JmsInvokerProxyFactoryBean：jms触发代理的工厂bean，暴露bean引用的代理服务，使用特定的服务接口。

JmsInvokerServiceExporter：jms消息监听器，暴露特定服务bean作为jsm消息的终端，通过jms 触发代理获取之。

小结

spring提供了一个jms集成框架，这个框架如spring 集成jdbc api一样，简化了jms api的使用。