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

时间:2008年07月02日   作者: 河外科技  

    

    在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

     <bean id="connectionFactory"

     class="org.apache.activemq.ActiveMQConnectionFactory">

     <property name="brokerURL" value="tcp://localhost:61616" /> </bean>

    这里用到的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

     <bean id="jmsTemplate"

     class="org.springframework.jms.core.JmsTemplate102">

     <property name="connectionFactory" ref="connectionFactory"/>

     <property name="timeToLive" value="86400000"/>

     <property name="defaultDestinationName" value="cmpp" />

     <property name="messageConverter" ref="messageConverter" />

     <property name="receiveTimeout" value="30000" />

     </bean>

    上面的配置中用到了第一步配置的connectionFactory以及一个消息转换的类messageConverter,这个类实现了org.springframework.jms.support.converter.MessageConverter接口,可以在消息发送之前和接受之后进行消息类型转换。具体的看最后的实例代码。

    配置代码如下:

     Copy code

     <!-- Spring JMS SimpleConverter -->

     <bean id="simpleConverter" class="org.springframework.jms.support.converter.SimpleMessageConverter" />

    <!-- Message Converter -->

     <bean id="messageConverter"

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

     <property name="converter">

     <ref local="simpleConverter" />

     </property>

     </bean>

    这里还配置了发送的消息的存在时间timeToLive,目标Queue的名字defaultDestinationName,接受消息超时时间receiveTimeout配置发送代码:

     Copy code

本文共2页,当前在第1页  1  2  

 

相关新闻:

 

 

 

 

 
打印]    [关闭