还有工作就是如何接受JMS Message并进行处理了,spring中也有现成的框架进行处理MessageListenerAdapter和DefaultMessageListenerContainer,我们只要写一个普通类编写处理消息的逻辑,具体如何接收消息都由Spring完成。
spring-listener-jms.xml
<?xml version="1.0" encoding="GBK"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN 2.0//EN"
"http://www.springframework.org/dtd/spring-beans-2.0.dtd">
<beans>
<import resource="spring-jms.xml"/>
<bean id="messageListener" class="org.springframework.jms.listener.adapter.MessageListenerAdapter">
<constructor-arg>
<bean class="com.viva.server.message.jms.UserRegisterListener"/>
</constructor-arg>
<property name="defaultListenerMethod" value="onRegister"/>
<property name="messageConverter" ref="messageConvert"/>
</bean>
<bean id="queueListenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="jmsFactory"/>
<property name="destination" ref="queueDestination"/>
<property name="messageListener" ref="messageListener"/>
</bean>
<bean id="topicListenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="jmsFactory"/>
<property name="destination" ref="topicDestination"/>
<property name="messageListener" ref="messageListener"/>
</bean>
</beans>
从配置文件可以看出配置了一个Topic监听器和Queue监听器,实际的监听类就是一个UserRegisterListener,由它处理用户注册事件。
UserRegisterListener.java代码
public class UserRegisterListener {
public void onRegister(VivaUserRegisterMessage registerMessage){
System.out.println("User Register,tel="+ registerMessage.getTel()+ ",time="+registerMessage.getRegisterTime());
}
}
最后写一个JUnit测试用户来测试一下代码
JMSTestor.java
public class JMSTestor extends TestCase {
private ApplicationContext context;
public void testQueueSend(){
context = new ClassPathXmlApplicationContext("spring-jms.xml");
JmsTemplate jmsTemplate = (JmsTemplate) context.getBean("queueTemplate");
VivaUserRegisterMessage msg = new VivaUserRegisterMessage();
msg.setRegisterTime(new Date());
msg.setTel("1385199XXXX");
msg.setUserId(1);
jmsTemplate.convertAndSend(msg);
}
public void testTopicSend(){
context = new ClassPathXmlApplicationContext("spring-jms.xml");
JmsTemplate jmsTemplate = (JmsTemplate) context.getBean("topicTemplate");
VivaUserRegisterMessage msg = new VivaUserRegisterMessage();
msg.setRegisterTime(new Date());
msg.setTel("1385199XXXX");
msg.setUserId(1);
jmsTemplate.convertAndSend(msg);
}
public void testListener()throws Exception{
context = new ClassPathXmlApplicationContext("spring-listener-jms.xml");
Thread.sleep(1000*60*30);
}
}
执行testTopicSend发送JMS Message到Topic
执行testQueueSend发送JMS Message到Queue
执行testListener启动Topic和Queue监听器处理JMS Message
完成!另外ActiveMQ集成了Jetty服务,可以访问地址http://localhost:8161/admin/查看具体信息
分享到:
相关推荐
Apache ActiveMQ JMS实现
ApacheCamel-JMS-ActiveMQ Apache Camel JMS ActiveMQ 使用样例 1.从本地读取信息推送到MQ中 2.从MQ中读取信息保存到本地
Apache ActiveMQ教程 JMS 整合Tomcat
详细内容: SpringJMS整合ActiveMQ.doc 详细说明文档 apache-activemq-5.8.0-bin.zip ActiveMQ安装包 JMSTest.rar MyEclipse8.5下web工程
<a href=http://activemq.apache.org/version-5-getting-started.html >http://activemq.apache.org/version-5-getting-started.html</a> <a href=http://java.sun.com/j2ee/1.4/docs/tutorial/doc/index.html>...
同时Apache ActiveMq是速度快,支持多种跨语言客户端和协议,同时配有易于使用的企业集成模式和优秀的特性,并且支持JMS1.1和J2EE1.4。具体特性见官网:http://activemq.apache.org/ 2. 什么是JMS JMS的全称是Java ...
activemq, Apache ActiveMQ镜像 欢迎来到 Apache ActiveMQis是一个高性能的Apache 2.0许可以消息代理和 JMS 1.1实现。正在启动要帮助你入门,请尝试以下链接:入门http://activemq.apache.org/version-
JMS与SPRING的整合实例(基于Apache ActiveMQ) 定义JMS连接工厂 定义JMS Template 定义消息目的地 定义接收监听器 定义一个JMS话题 定义消费者(接收端) 定义发布者 JAVA核心代码一般由三个部分组成: 监听器...
Apache ActiveMQ是Apache软件基金会的一个开源项目,是一个基于消息的通信中间件。ActiveMQ是JMS的一个具体实现,支持JMS的两种消息模型。ActiveMQ使用AMQP协议集成多平台应用,使用STOMP协议通过websockets在Web...
ActiveMQ 是Apache出品,最流行的,能力强劲的开源jms服务器。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现,尽管JMS规范出台已经是很久的事情了,但是JMS在当今的J2EE应用中间仍然扮演着特殊的...
type="org.apache.activemq.command.ActiveMQQueue" description="My Message Queue" factory="org.apache.activemq.jndi.JNDIReferenceFactory" physicalName="MyMessageQueue"/> 说明:...
Apache ActiveMQ是Apache软件基金会所研发的开放源代码消息中间件;由于ActiveMQ是一个纯Java程序,因此只需要操作系统支持Java虚拟机,ActiveMQ便可执行。
SUN JMS 教程 APACHE ACTIVEMQ 教程
使用者/订户,它是充当接收者的客户端应用程序或JMS客户端。 消息,即消息或数据。 队列,这是客户端接收到的消息被排队并一个接一个地发送。 主题,即客户端接收到的消息被分发到每个连接的客户端。 Java消
ActiveMQ 是Apache出品,最流行的,能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现,尽管JMS规范出台已经是很久的事情了,但是JMS在当今的J2EE应用中间仍然扮演着特殊的...
最全的基于spring mvc的JMS+activeMQ实现的消息中间件代码例子,源程序和apache-activemq-5.10.0-bin.zip
ActiveMQ是Apache下的开源项目,完全支持JMS1.1和J2EE1.4规范的JMS Provider实现。 特点: 1、支持多种语言编写客户端 2、对spring的支持,很容易和spring整合 3、支持多种传输协议:TCP,SSL,NIO,UDP等 4、支持...
在Spring中安装ActiveMQ www.activemq.org apache-activemq-4.1.0-incubator.zip ,incubator.jar复制到lib中 启动ActiveMQ的脚本:运行刚下载的文件/bin/activemq.bat. 这样就可以使用ActiveMQ进行中介服务了。