微客导航 » 文章资讯 » ActiveMQ整合Spring入门用法解析

ActiveMQ整合Spring入门用法解析

2023-07-13 06:39:04 174

一.ActiveMQ整合Spring基础

ActiveMQ和Spring的整合，其实是把activemq的一些对象交给spring来管理，比如连接工厂，queue，top等等

二.依赖

除了activemq本身提供的jar包外，还需要两个spring整合activemq的jar：


org.springframework
spring-jms


org.springframework
spring-context-support



org.apache.activemq
activemq-all

三.在spring配置文件中，配置activemq相关的对象

》生产者需要配置的对象：activemq原生连接工厂，spring包装过的工厂，JmsTemplate（生产者），queue，topic

测试代码：

//测试生产者发生queue
@Test
publicvoidtestJMSTemplateByQueue()throwsException{

//创建spring容器
ApplicationContextioc=newClassPathXmlApplicationContext("classpath:spring/applicationContext-activemq.xml");

//获取jmstemplate
JmsTemplatejmsTemplate=ioc.getBean(JmsTemplate.class);

//获取目的对象
Destinationqueue=(Destination)ioc.getBean("queueDestination");

//发送消息，并设置目的对象和消息
jmsTemplate.send(queue,newMessageCreator(){

publicMessagecreateMessage(Sessionsession)throwsJMSException{

TextMessagemessage=session.createTextMessage();

message.setText("hellospringactivemq");

returnmessage;
}
});

小结：生产者是需要在特定的时间发送指定的消息内容，因此是需要书写代码的

》消费者需要配置的对象：activemq原生连接工厂，spring包装过的工厂，监听容器（消费者），监听器，queue，topic

》之前监听器我们是直接实现匿名内部类的方式，但是在spring这就不能了，还是书写一个实现类并继承messageListener接口

测试代码：

@Test
publicvoidtestListener()throwsIOException{
ApplicationContextioc=newClassPathXmlApplicationContext("classpath:spring/applicationContext-activemq.xml");
System.in.read();
}

小结：我们的测试代码很简单，只要把容器启动了，监听器就会一致监听着。不需要写任何代码，监听器只要一直关注目的对象Destination是否有消息发送过来

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。

声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。

返回顶部
3162201930
czq8825@qq.com

ActiveMQ整合Spring入门用法解析

热门推荐

随机推荐