结合Spring2.0和ActiveMQ进行异步消息调用

    在Spring 2.0之前，Spring的JMS的作用局限于产生消息。这个功能（封装在 JmsTemplate 类中）当然是很好的， 但是，它没有描述完整的JMS堆栈，比如像消息的 异步 产生和消耗。JMS堆栈缺少的这一部分已经被添加，Spring 2.0现在提供对消息异步消耗的完整支持。
       让我们从一个例子开始。
       首先我们打开ActiveMQ。从ActiveMQ的安装路径上的bin目录，那里有一个ActiveMQ.bat，双击执行即可。不过要注意必须先设置java_home环境变量。ActiveMQ默认的服务端口是61616。
       然后我们开始配置Spring配置文件。我起名为spring-jms.xml
    首先要配置一个ConnectionFactory代码如下
    Copy code
             class="org.apache.activemq.ActiveMQConnectionFactory">
        
      这里用到的ConnectionFactory是ActiveMQ提供的工厂，为了能使用这个工厂，我们必须在项目中添加以下几个jar文件： geronimo-jms_1.1_spec-1.0.jar, activeio-core-3.0-beta3.jar, activemq-core-4.0.1.jar, backport-util-concurrent-2.1.jar, commons-logging-1.0.4.jar, geronimo-j2ee-management_1.0_spec-1.0.jar 以上这些Jar文件都存在于ActiveMQ安装目录的lib目录下，这些可是我一个一个试验出来的，累个半死。。
    然后应该配置一个Queue（我使用的是点对点方式），不过ActiveMQ只要提供一个名字就可以自动创建队列，因此这一步省了。
    下面就轮到Spring的支持类了，首先是JmsTemplate。这个类提供了大量的方法简化我们对JMS的操作。常用的有两个，org.springframework.jms.core.JmsTemplate102和org.springframework.jms.core.JmsTemplate，这两个类分别支持JMS的1.02版本和1.1版本。现在比较常用的还是1.02版本。配置如下
    Copy code
                 class="org.springframework.jms.core.JmsTemplate102">
        
        
        
        
        
    
    上面的配置中用到了第一步配置的connectionFactory以及一个消息转换的类messageConverter，这个类实现了org.springframework.jms.support.converter.MessageConverter接口，可以在消息发送之前和接受之后进行消息类型转换。具体的看最后的实例代码。配置代码如下：
    Copy code
       
       

              class="com.liangj.apmgt.jms.ApmgtMessageConverter">
        
            
        
    
 

[1]  

【责编:landy】

--------------------next---------------------