当前位置导航:炫浪网>>网络学院>>编程开发>>JAVA教程>>J2EE

Activemq和Lingo实现JMS和异步调用


  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\\test\\com\\wosame\\room\\jms\\jms.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==================================
  
  <?xml version="1.0" encoding="UTF-8"?>
  <!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN"
  "http://www.springframework.org/dtd/spring-beans.dtd">
  
  <beans>
  
  <!--嵌入式的JMS连接,也就是跟随JVM一起启动,可以参看activemq的文档-->
  <bean id="connectionFactory" class="org.activemq.ActiveMQConnectionFactory"> <property name="brokerURL" value="vm://localhost"/>
  <property name="useEmbeddedBroker" value="true"/>
  </bean>
  
  <!--消息监听器,也就是消息的具体的处理器-->
  <bean id="HelloMDP" class="HelloMDP"/>
  
  <!--jms监听需要JTA容器的支持-->
  <bean id="activeMQContainer" class="org.activemq.jca.JCAContainer">
  <property name="workManager">
  <bean id="workManager" class="org.activemq.work.SpringWorkManager"/>
  </property>
  <property name="resourceAdapter">
  <bean id="activeMQResourceAdapter" class="org.activemq.ra.ActiveMQResourceAdapter">
  <property name="serverUrl" value="vm://localhost"/>
  </bean>
  </property>
  </bean>
  
  <!--消息的消费者,也就是将监听器与具体的队列关联-->
  <bean id="HelloQueueConsumer" factory-method="addConnector" factory-bean="activeMQContainer">
  <property name="activationSpec">
  <bean class="org.activemq.ra.ActiveMQActivationSpec">
  <property name="destination" value="Hello.Queue"/>
  <property name="destinationType" value="javax.jms.Queue"/>
  </bean>
  </property>
  <property name="ref" value="HelloMDP"/>
  </bean>
  
  <!--spring的JMS template,用来发送JMS消息到指定的队列-->
  <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
  <property name="defaultDestinationName" value="Hello.Queue"/>
  <property name="connectionFactory" ref="connectionFactory"/>
  </bean>
  </beans>
相关内容
赞助商链接