Activemq和Lingo实现JMS和异步调用(转)
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==================================
<?xml version="1.0" encoding="UTF-8"?>
P>
"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中软件基础结构的瓶颈
|
|
||
| 关于咱们 | 联系方式 | 广告合做 | 诚聘英才 | 网站地图 | 网址大全 | 友情连接 | 免费注册 | ||
|
|
||
| Copyright © 2004 - 2007 All Rights Reserved 来自 “ ITPUB博客 ” ，连接：http://blog.itpub.net/8225414/viewspace-968179/，如需转载，请注明出处，不然将追究法律责任。 php 
请登陆后发表评论
登陆
所有评论
<%=items[i].createtime%>
<%=items[i].content%>html <%if(items[i].items.items.length) { %>
<%for(var j=0;j
<%}%> <%}%>
<%=items[i].items.items[j].createtime%>
<%=items[i].items.items[j].username%> 回复 <%=items[i].items.items[j].tousername%>： <%=items[i].items.items[j].content%>java
还有<%=items[i].items.total-5%>条评论
) data-count=1 data-flag=true>点击查看
<%}%>
北京盛拓优讯信息技术有限公司. 版权全部 京ICP备09055130号-4 北京市公安局海淀分局网监中心备案编号：11010802021510算法 广播电视节目制做经营许可证(京) 字第1234号 中国互联网协会会员spring |
||
转载于:http://blog.itpub.net/8225414/viewspace-968179/apache