jms是大家在項目中經(jīng)常用到的技術(shù)，而activemq又是開源的jms產(chǎn)品中比較優(yōu)秀的。在應(yīng)用JMS處理相關(guān)業(yè)務(wù)時，大家都是構(gòu)造消息，然后發(fā)送到隊列，最后用message監(jiān)聽器監(jiān)聽到消息，對消息進(jìn)行分析處理。在這個過程中，有兩步是比較麻煩和重復(fù)的，那就是構(gòu)造消息和拆解消息。并且這樣與面向?qū)ο蟮乃枷牒苁沁`背。如果這樣做顯然是面向消息數(shù)據(jù)的，而不是面向?qū)ο蟮?。基于以上原因，我向大家介紹一個我在項目中經(jīng)過實(shí)踐的開源框架：lingo.
lingo在JMS中起的主要作用就是對消息的封裝，它讓你可以不必關(guān)心消息的構(gòu)造和拆解，而只需關(guān)心你本身的業(yè)務(wù)邏輯。我將舉一個例子，分別用activemq直接實(shí)現(xiàn)和用lingo實(shí)現(xiàn)。在這個例子中我用到了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.*;
/**
*發(fā)送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>
<!--消息監(jiān)聽器，也就是消息的具體的處理器-->
<bean id="HelloMDP" class="HelloMDP"/>
<!--jms監(jiān)聽需要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>
<!--消息的消費(fèi)者，也就是將監(jiān)聽器與具體的隊列關(guān)聯(lián)-->
<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,用來發(fā)送JMS消息到指定的隊列-->
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="defaultDestinationName" value="Hello.Queue"/>
<property name="connectionFactory" ref="connectionFactory"/>
</bean>
</beans>
