Activemq和Lingo實現JMS和異步調用

2019-11-18 12:24:12

字體：大中小

來源：轉載

供稿：網友

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>
　　
　　
　　<bean id="connectionFactory" class="org.activemq.ActiveMQConnectionFactory"> <property name="brokerURL" value="vm://localhost"/>
　　<property name="useEmbeddedBroker" value="true"/>
　　</bean>
　　
　　
　　<bean id="HelloMDP" class="HelloMDP"/>
　　
　　
　　<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>
　　
　　
　　<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
　　<property name="defaultDestinationName" value="Hello.Queue"/>
　　<property name="connectionFactory" ref="connectionFactory"/>
　　</bean>
　　</beans>

上一篇：面向服務架構（SOA）推薦方法(組圖)

下一篇：封裝JNDI操作LDAP服務器的工具類(1)