上文可见,JMS Native API使用起来不是特别方便。好在Spring提供了很好的JMS支持。
(一)配置ConnectionFactory
如果使用连接池的话,不要忘记activemq-pool-5.6.0.jar
<bean id="connectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory" destroy-method="stop">
<property name="connectionFactory" ref="innerConnectionFactory" />
</bean>
<bean id="innerConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61616" />
</bean>
(二)配置一个Destination作为默认投递目标
<bean id="defaultDestination" class="org.apache.activemq.command.ActiveMQQueue">
<constructor-arg index="0" value="ztgame.amt.default.queue" />
</bean>
(三)核心JmsTemplate
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="connectionFactory" />
<property name="defaultDestination" ref="defaultDestination" />
</bean>
(四)JMS事务
<bean id="jmsTransactionManager" class="org.springframework.jms.connection.JmsTransactionManager">
<property name="connectionFactory" ref="connectionFactory" />
</bean>
<tx:annotation-driven transaction-manager="jmsTransactionManager" />
(五)编写消息驱动Bean,两个接口实现一个即可
- javax.jms.MessageListener
- org.springframework.jms.listener.SessionAwareMessageListener
package com.ztgame.amt.jms.mdp;
import javax.jms.JMSException;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.springframework.jms.listener.SessionAwareMessageListener;
import org.springframework.stereotype.Component;
@Component("defaultMessageHandler")
public class DefaultMessageHandler implements SessionAwareMessageListener<TextMessage> {
public void onMessage(TextMessage message, Session session)
throws JMSException {
String text = message.getText();
if (text.length() == 0) {
System.out.println("<empty>");
} else {
System.out.println(text);
}
}
}
(六)配置消息驱动Bean
<!-- Message Driven POJOs -->
<jms:listener-container connection-factory="connectionFactory">
<jms:listener destination="ztgame.amt.default.queue" ref="defaultMessageHandler" />
</jms:listener-container>
(七)编写测试代码
package junit;
import java.util.UUID;
import javax.annotation.Resource;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
import org.junit.Test;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.AbstractJUnit4SpringContextTests;
@ContextConfiguration({ "classpath:spring-beans.xml", "classpath:spring-jms.xml" })
public class TestSomeService extends AbstractJUnit4SpringContextTests {
@Resource
private JmsTemplate jmsTempalte;
@Test
public void test() {
jmsTempalte.send(new MessageCreator() {
public Message createMessage(Session session) throws JMSException {
return session.createTextMessage(UUID.randomUUID().toString());
}
});
}
}
分享到:
相关推荐
activeMq代码记录(jmsspring+jmstest)
详细内容: SpringJMS整合ActiveMQ.doc 详细说明文档 apache-activemq-5.8.0-bin.zip ActiveMQ安装包 JMSTest.rar MyEclipse8.5下web工程
activemq与spring整合发送jms消息入门实例 jar 包和实例代码都在压缩包里了
支持持久化的采用Spring整合activeMQ与quartz的JMS数据同步实例,包含依赖的jar包
activeMQ学习笔记,JMS有两种传递消息的方式。标记为NON_PERSISTENT的消息最多投递一次,而标记为PERSISTENT的消息将使用暂存后再转送的机理投递。如果一个JMS服务离线,那么持久性消息不会丢失但是得等到这个服务...
spring-boot-rest-jms-activemq:REST,JMS,ActiveMQ,Spring Boot:gradle包含构建,gradle多项目构建,gradle propdeps-plugin,gradle节点插件,gradle docker-compose插件,spring-boot,sprinb-mvc ,spring ...
JMS与SPRING的整合实例(基于Apache ActiveMQ) 定义JMS连接工厂 定义JMS Template 定义消息目的地 定义接收监听器 定义一个JMS话题 定义消费者(接收端) 定义发布者 JAVA核心代码一般由三个部分组成: 监听器...
activemq activeMq笔记.docx
spring3.0整合了activemQ和jms可以发送信息和接收消息
基于Spring+JMS+ActiveMQ+Tomcat,我使用的版本情况如下所示:Spring 3.2.0,ActiveMQ 5.4.3,Tomcat 6.0.43。本例通过详细的说明和注释,实现消息服务的基本功能:发送与接收。Spring对JMS提供了很好的支持,可以...
利用ActiveMQ中间件发送JMS消息的例子
cJMS之ActiveMQ与Spring整合源码
ActiveMQ 中javax.jms的源码 javax.jms-sources-1.1.zip
activemq学习笔记 activemq学习笔记 activemq学习笔记 activemq学习笔记 activemq学习笔记 activemq学习笔记
jms 简单的案例,用的activemq,使用jms前请先启动activemq服务器
本章我将通过spring jms和activemq实现单Web项目服务器间异步访问和多Web项目服务器间异步访问。 一. 简介 1. 什么是Apache ActiveMq Apache ActiveMq是最流行和最强大的开源消息和集成服务器。同时Apache ActiveMq...
JMS_MQ系统之Spring中嵌入ActiveMQ,JMS_MQ系统之Spring中嵌入ActiveMQ
Spring+ActiveMQ active基本例子 注解的完整实例,包含jar包
消息中间件的学习笔记