注册本站  论坛  繁體中文

电脑技巧
手机 | MP3 | MP4 | 显卡 | 主板 | 显示器 | 光存储 | 笔记本 | 网络设备 | 移动存储 | 数码相机
键鼠 | CPU | 音箱 | GPS | 电视 | 服务器 | 投影机 | 机箱电源 | 品牌电脑 | 办公打印 |
| 网站首页 | Cisco | Windows | Linux | Java | Dotnet | Oracle | 网页设计 | 平面设计 | 安全 | 软件应用 | 电脑维修 | 办公维修 |
您现在的位置: 电脑技巧 >> Java >> 开源技术 >> Spring >> Java正文

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

文章来源:中国IT实验室收集整理 作者:佚名 更新时间:2008-6-28 20:35:48 【 】 【加入收藏

    在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
        <!-- Message porducer -->
     <bean id="producer"
         class="com.liangj.apmgt.jms.DefaultApmgtMessageProducer">
         <property name="jmsTemplate" ref="jmsTemplate" />
     </bean>
    接着配置监听器,这是Spring2.0新增的功能,配置如下:
    Copy code
        <!-- this is the Message Driven POJO (MDP) -->
     <bean id="messageListener"
         class="org.springframework.jms.listener.adapter.MessageListenerAdapter">
         <constructor-arg>
             <bean
                 class="com.liangj.apmgt.jms.DefaultApmgtMessageListener" />
         </constructor-arg>
         <property name="defaultListenerMethod" value="onMessage" />
         <property name="messageConverter" ref="messageConverter" />
     </bean>
     <!-- and this is the attendant message listener container -->
     <bean id="listenerContainer"
         class="org.springframework.jms.listener.DefaultMessageListenerContainer">
         <property name="connectionFactory" ref="connectionFactory" />
         <property name="destinationName" value="${jms.destinationName.cmpp}" />
         <property name="messageSelector" value="${jms.messageSelector}" />
         <property name="messageListener" ref="messageListener" />
     </bean>
          Spring配置监听器有很多种选择,在这里我选择这回种MessageListenerAdapter方法主要是因为这个方法比较灵活。实现他只要一个很普通的java类即可,和JMS以及Spring的耦合度最低。其中方法onMessage可以随便修改方法名,只要在配置文件中对应的修改就好了。
      MessageListenerAdapter还有一个功能就是如果处理方法(我这里是onMessage)返回一个非空值,它将自动返回一个响应消息。这个消息会返回给JMS Reply-To属性定义的目的地(如果存在),或者MessageListenerAdapter设置(如果配置了)的缺省目的地;如果没有定义目的地,那么将产生一个InvalidDestinationException异常(此异常将不会只被捕获而不处理,它将沿着调用堆栈上传)。

  • 上一篇Java:

  • 下一篇Java:
  • 最 新 热 门
     手机开发平台指南、教程和资料介绍
     关于什么叫面向接口编程
     编写高级JavaScript应用代码
     不要验证,直接转化科学计数法
     Eclipse插件开发中实现刷新和重编译介绍
     Java开源技术:Eclipse的使用技巧详解
     配置eclipse 3.2 使用JDK1.5中文JavaAPI
     集成Windows本地应用到Eclipse RCP 程序中
     hibernate.cfg.xml配置文件的说明
     eclipse开发jface时,main.class解决方法
    最 新 推 荐
     ibatis+spring 集成
     结合Spring2.0和ActiveMQ进行异步消息调用
     servlet中如何访问spring容器
     Spring MVC与struts比较
     Spring security 命名空间的使用
     spring AOP面向切面编程
     关于String对象解析
     关于Spring切点函数@args()
     Spring中事务的传播属性详解
     Spring+Ibatis+事务处理
    相 关 文 章

    ibatis+spring 集成
    servlet中如何访问spring容器
    Spring MVC与struts比较
    Spring security 命名空间的使用
    spring AOP面向切面编程
    关于Spring切点函数@args()
    Spring中事务的传播属性详解
    Spring+Ibatis+事务处理
    基于Spring事务的集成测试
    Spring 控制反转(IoC)容器

    | 设为首页 | 加入收藏 | 联系站长 | 友情链接 | 版权申明 | 网站公告

     

    Copyright 2006-2008 pcjx.com All Rights Reserved
    电脑技巧 版权所有 粤ICP备06059145号 地图
    本网站所有内容未经许可不得转载或做其他使用