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>