ActiveMQ学习笔记(二) JMS与Spring

上文可见，JMS Native API使用起来不是特别方便。好在Spring提供了很好的JMS支持。

(一)配置ConnectionFactory
如果使用连接池的话，不要忘记activemq-pool-5.6.0.jar

Xml代码

<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作为默认投递目标

Xml代码

<bean id="defaultDestination" class="org.apache.activemq.command.ActiveMQQueue">
<constructor-arg index="0" value="ztgame.amt.default.queue" />
</bean>

(三)核心JmsTemplate

Xml代码

<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="connectionFactory" />
<property name="defaultDestination" ref="defaultDestination" />
</bean>

(四)JMS事务

Xml代码

<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

Java代码

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

Xml代码

<jms:listener-container connection-factory="connectionFactory">
<jms:listener destination="ztgame.amt.default.queue" ref="defaultMessageHandler" />
</jms:listener-container>

(七)编写测试代码

Java代码

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());
}
});
}
}

spring-jms.zip (805 Bytes)
下载次数: 58

ActiveMQ学习笔记(二) JMS与Spring相关推荐

ActiveMQ学习笔记(2)——JMS消息模型
2019独角兽企业重金招聘Python工程师标准>>> 1.1 JMS模型简介 JMS支持两种消息通信模型: 点对点模型(Point to Point,P2P) 发布者/订阅者模型( ...
Spring Boot 框架学习笔记(二）（配置文件与数据注入 yaml基本语法 JSR303数据验证多环境切换）
Spring Boot 框架学习笔记(二) 六.appliaction.properties配置与数据注入 6.1 `@Value`注解测试注入数据读取输入流 6.2 读取配置文件数据注入单文件 ...
Spring Security技术栈学习笔记（十三）Spring Social集成第三方登录验证开发流程介绍
开发第三方登录,我们必须首先要了解OAuth协议(本文所讲述的OAuth协议指的是OAuth2协议),本文首先简单介绍OAuth协议,然后基于Spring Social来阐述开发第三方登录需要做哪些准 ...
motan学习笔记二 motan架构分析
motan学习笔记一微博轻量级RPC框架Motan motan学习笔记二 motan架构分析 motan学习笔记三 motan Demo 分析 motan学习笔记四 motan Demo 之 ...
ActiveMQ学习笔记07 - 优缺点
2019独角兽企业重金招聘Python工程师标准>>> 优点: 可以用JDBC 虽然使用JDBC会降低ActiveMQ的性能,但是数据库一直都是开发人员最熟悉的存储介质.将消息存到数 ...
Spring Security技术栈学习笔记（八）Spring Security的基本运行原理与个性化登录实现
正如你可能知道的两个应用程序的两个主要区域是"认证"和"授权"(或者访问控制).这两个主要区域是Spring Security的两个目标."认证&qu ...
码匠社区学习笔记(二)
所需资料教程视频地址 Bootstrap spring模板 elasticsearch中文社区(想模仿的效果) 码云aAuth 获取授权用户的资料 github第三方授权文档码匠社区学习笔记(二) ...
springmvc学习笔记二：重定向，拦截器，参数绑定
springmvc学习笔记二:重定向,拦截器,参数绑定 Controller方法返回值返回ModelAndView controller方法中定义ModelAndView对象并返回,对象中可添加mo ...
qml学习笔记(二)：可视化元素基类Item详解（上半场anchors等等）
原博主博客地址:http://blog.csdn.net/qq21497936 本文章博客地址:http://blog.csdn.net/qq21497936/article/details/7851 ...

ActiveMQ学习笔记(二) JMS与Spring

ActiveMQ学习笔记(二) JMS与Spring相关推荐

最新文章

热门文章