ITPub博客

首页 > 应用开发 > IT综合 > Activemq和Lingo实现JMS和异步调用(转)

Activemq和Lingo实现JMS和异步调用(转)

原创 IT综合 作者:post0 时间:2007-09-06 09:00:49 0 删除 编辑
Activemq和Lingo实现JMS和异步调用(转)[@more@]

  jms是大家在项目中经常用到的技术,而activemq又是开源的jms产品中比较优秀的。在应用JMS处理相关业务时,大家都是构造消息,然后发送到队列,最后用message监听器监听到消息,对消息进行分析处理。在这个过程中,有两步是比较麻烦和重复的,那就是构造消息和拆解消息。并且这样与面向对象的思想很是违背。如果这样做显然是面向消息数据的,而不是面向对象的。基于以上原因,我向大家介绍一个我在项目中经过实践的开源框架:lingo.

  lingo在JMS中起的主要作用就是对消息的封装,它让你可以不必关心消息的构造和拆解,而只需关心你本身的业务逻辑。我将举一个例子,分别用activemq直接实现和用lingo实现。在这个例子中我用到了spring framework.

  =================================Hello.java===========================

  import java.io.Serializable;

  /**Hello.java用来传递JAVA对象

  * Author: cjp

  * Date: 2005-11-8

  * Time: 22:24:02

  */

  public class Hello implements Serializable {

  private String id;

  private Hello hello;

  private PointList pointList;

  public String getId() {

  return id;

  }

  public void setId(String id) {

  this.id = id;

  }

  public Hello getHello() {

  return hello;

  }

  public void setHello(Hello hello) {

  this.hello = hello;

  }

  }

  =========================SpringTest .java========================

  import org.springframework.jms.core.JmsTemplate;

  import org.springframework.jms.core.MessageCreator;

  import org.springframework.test.AbstractDependencyInjectionSpringContextTests;

  import javax.jms.*;

  /**

  *发送JMS消息

  */

  public class SpringTest extends AbstractDependencyInjectionSpringContextTests

  {

  protected String[] getConfigLocations()

  {

  return new String[]{"file:D:wosame estcomwosame oomjmsjms.xml"};

  }

  public void testSendMessage() throws Exception

  {

  JmsTemplate jmsTemplate = (JmsTemplate) applicationContext.getBean("jmsTemplate");

  jmsTemplate.send(new MessageCreator()

  {

  public Message createMessage(Session session) throws JMSException

  {

  ObjectMessage message=session.createObjectMessage();

  Hello hello=new Hello();

  hello.setId("test");

  message.setObject(hello);

  return message;

  }

  });

  }

  }

  ================================HelloMDP .java==================================

  /**

  处理JMS消息

  */

  import org.apache.commons.logging.Log;

  import org.apache.commons.logging.LogFactory;

  import javax.jms.*;

  public class HelloMDP implements MessageListener

  {

  protected Log log = LogFactory.getLog(HelloMDP.class);

  public void onMessage(Message message)

  {

  try

  {

  ObjectMessage objMessage = (ObjectMessage) message;

  Hello hello= (Hello) objMessage.getObject();

  System.out.println("hello.getId() = " + hello.getId());

  } catch (JMSException e)

  {

  log.error("Parse failed", e);

  }

  }

  }

  ================================jms.xml==================================

  

  

  "http://www.springframework.org/dtd/spring-beans.dtd">

  

  <!--嵌入式的JMS连接,也就是跟随JVM一起启动,可以参看activemq的文档-->

  

  

  

  <!--消息监听器,也就是消息的具体的处理器-->

  

  <!--jms监听需要JTA容器的支持-->

  

  

  

  

  

  

  

  

  

  

  <!--消息的消费者,也就是将监听器与具体的队列关联-->

  

  

  

  

  

  

  

  

  

  <!--spring的JMS template,用来发送JMS消息到指定的队列-->

  

  

  

  

  

本文来自:http://www.linuxpk.com/45020.html

-->linux电子图书免费下载和技术讨论基地

·上一篇:封装JNDI操作LDAP服务器的工具类(1)

·下一篇:关于J2EE中软件基础结构的瓶颈
 
     最新更新
·何种设计模式和构架才能开发出最好的企业程序

·成功规划面向服务的架构SOA实施

·基于JMX通知框架的AJAX深度开发

·struts+spring+ibatis轻量级J2EE开发

·如何使用动态代理实现AOP功能

·手把手教你使J2EE项目开发自动化

·WeblogicServer9新特性:J2EELibraries

·J2EE核心:iBatisDAO入门与进阶二

·J2EE核心:iBatisDAO入门与进阶一

·面向方面编程的Annotation简介

·在NetBeansIDE4.1中导入J2EE应用程序

·NetBeansIDE4.1J2EE程序快速入门指南

·乱码问题之终极解决

·J2EE项目执行:若干最佳实践

·为何不让SOA变得简单?

·使用WebLogicJMX进行定制调试

·J2EE工程实现中常见安全问题解决对策

·J2EE的四层模型

·J2EEDesignPatterns

·将J2EE平台提升到一个新的高度

·CMP实体bean实战开发

·JNDI设计内幕

·用VisualAgeforJava开发企业级bean

·使用消息驱动Beans(1)

·使用消息驱动Beans(2)

·使用消息驱动Beans(3)

·有状态会话bean运行结束时应及时被显示删除

·优化entityBean的七条准则

·使用JSF(JavaServerFaces)开发(一)

·使用JSF(JavaServerFaces)开发(二)


关于我们 | 联系方式 | 广告合作 | 诚聘英才 | 网站地图 | 网址大全 | 友情链接 | 免费注册

Copyright © 2004 - 2007 All Rights Reserved

来自 “ ITPUB博客 ” ,链接:http://blog.itpub.net/8225414/viewspace-968179/,如需转载,请注明出处,否则将追究法律责任。

请登录后发表评论 登录
全部评论