主要的代码实现在上一篇文章,而本篇文章重点是说明 ActiveMQ 5.2.0 Embedded Broker实现。
另外,打开 activemq-all-5.2.0.jar 修改 spring.schemas文件,在文件最后添加
\://activemq.apache.org/schema/core/activemq-core-5.2.0.xsd = activemq.xsd
这样应用系统启动时就不用到官方网站读 activemq-core-5.2.0.xsd 文件了,省了好多时间~
首先新建 applicationContext-jms.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:jee="http://www.springframework.org/schema/jee" xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:context="http://www.springframework.org/schema/context" xmlns:jms="http://www.springframework.org/schema/jms"
xmlns:amq="http://activemq.apache.org/schema/core"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd
http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-2.5.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd
http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms-2.5.xsd
http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core-5.2.0.xsd"
default-lazy-init="true">
<description>Spring JMS 配置文件</description>
</beans>
然后再加入Embedded Broker
<!-- lets create an embedded ActiveMQ Broker -->
<amq:broker useJmx="false" persistent="false">
<amq:persistenceAdapter>
<amq:amqPersistenceAdapter directory="I:/amq"/> //加入这句,就算服务器关闭,信息也不会丢失。
</amq:persistenceAdapter>
<amq:transportConnectors>
<amq:transportConnector uri="vm://localhost:0" />
</amq:transportConnectors>
</amq:broker>
加入连接
<!-- ActiveMQ connectionFactory to use -->
<amq:connectionFactory id="connectionFactory" brokerURL="vm://localhost"/>
队列
<!-- ActiveMQ destinations to use -->
<amq:queue name="destination" physicalName="myqueue"/>
JmsTemplate用来发送接收,还有转换器InnerMessageConverter,转换对象
<bean id="jmsTemplate"
class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="connectionFactory"></property>
<property name="defaultDestination" ref="destination"></property>
<property name="messageConverter" ref="innerMessageConverter"> </property>
</bean>
<bean id="innerMessageConverter" class="jmu.xmpg.service.jms.InnerMessageConverter"></bean>
MDB和监听容器
<bean id="messageListener" class="jmu.xmpg.service.jms.MessageMDB"></bean>
<bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer" lazy-init="false">
<property name="connectionFactory" ref="connectionFactory"></property>
<property name="destination" ref="destination"></property>
<property name="messageListener" ref="messageListener"></property>
<property name="concurrentConsumers" value="5"></property>
<!-- 0:CACHE_NONE,1:CACHE_CONNECTION,2:CACHE_SESSION,3:CACHE_CONSUMER,4:CACHE_AUTO -->
<property name="cacheLevel" value="0"/>
</bean>
总结:重点在于头部引入的amq空间,另外就是要加入activemq-all-5.2.0.jar 、spring-jms.jar 和 xbean-spring-3.4.jar,这些包在 apache-activemq-5.2.0\lib\optional 下有。
分享到:
相关推荐
springboot +netty+activeMq在线客服系统springboot +netty+activeMq在线客服系统springboot +netty+activeMq在线客服系统springboot +netty+activeMq在线客服系统springboot +netty+activeMq在线客服系统springboot...
标题“spring2 ...分析这些文件可以帮助理解如何将Spring、ActiveMQ和Tomcat集成在一起,实现消息传递功能。学习这个例子可以加深对JMS、Spring集成以及Web应用部署的理解,对于提升Java EE开发技能非常有帮助。
总结起来,"JMS之Spring + ActiveMQ实现消息队列"涉及到的关键知识点包括:Spring框架的JMS支持、ActiveMQ的使用、ConnectionFactory的配置、JmsTemplate和MessageListener的实现,以及消息队列在解决系统解耦和异步...
基于Spring+JMS+ActiveMQ+Tomcat,我使用的版本情况如下所示:Spring 3.2.0,ActiveMQ 5.4.3,Tomcat 6.0.43。本例通过详细的说明和注释,实现消息服务的基本功能:发送与接收。Spring对JMS提供了很好的支持,可以...
**ActiveMQ5.1+Spring2.5 Demo详解** ActiveMQ是Apache软件基金会下的一个开源项目,它是一款功能强大的消息中间件,支持多种消息协议,如AMQP、STOMP、OpenWire等。在版本5.1中,ActiveMQ提供了一流的消息传输性能...
spring+activemq必备jar包:activeio-core-3.1.4.jar,activemq-all-5.13.2.jar,activemq-pool-5.13.2.jar,commons-pool2-2.4.2.jar
综上所述,Spring整合JMS和ActivemQ提供了一套完整的解决方案,帮助开发者轻松地在应用中实现消息的发送和接收。通过这种方式,可以构建出高可用、松耦合、可扩展的分布式系统,提高系统的稳定性和响应速度。在实际...
【毕业设计】基于springCloud +activemq的智慧物业综合管理平台【后端源码】.zip 技术架构: Java + spring cloud + mybatis + mysql + activemq + redis 1.0 小区商家 1 美食 外卖 生鲜 超市 家政 其他 2.0 小区...
本项目“spring3+ActiveMQ+blazeds+flex consumer”旨在整合一系列技术,以实现这样的功能。下面将详细阐述这些技术及其整合过程。 首先,Spring框架(Spring3)是Java领域最流行的轻量级应用框架之一,它提供了...
如果使用Spring Boot,可以简化配置,只需在`application.properties`中添加ActiveMQ的相关配置,如`spring.activemq.broker-url`,然后通过`@Autowired`注解注入`JmsTemplate`和`ConnectionFactory`即可。...
在本文中,我们将深入探讨如何使用SpringBoot、ActiveMQ和MQTT来实现消息的发送与接收。这是一个典型的分布式系统中的消息通信场景,其中SpringBoot作为应用程序框架,ActiveMQ作为消息中间件,而MQTT(Message ...
基于Spring+JMS+ActiveMQ+Tomcat的整合ActiveMQSpringDemo实例源码,此实例基于Spring+JMS+ActiveMQ+Tomcat,注解的完整实例,包含jar包,可供学习及设计参考。
### Spring+JMS+ActiveMQ+Tomcat 实现消息服务 #### 一、技术栈介绍 在本案例中,我们采用的技术栈为Spring 2.5、ActiveMQ 5.4.0 和 Tomcat 6.0.30。这些技术的结合能够有效地构建一个可靠的消息传递系统。 - **...
在IT行业中,Spring框架与...总结,Spring与ActiveMQ的集成为开发者提供了强大而便捷的工具来实现异步通信,提高了系统的可扩展性和解耦性。通过理解并熟练运用这些技术,开发者能够构建出高效、稳定的分布式应用。
总结起来,"jms Spring+ActiveMQ 5.4.2"是一个关于如何利用Spring框架和ActiveMQ实现高效、可靠的JMS通信的教程或示例。通过学习这个主题,开发者可以掌握如何在Java环境中构建健壮的、分布式的消息驱动系统。
基于Spring+JMS+ActiveMQ+Tomcat,做一个Spring4.1.0和ActiveMQ5.11.1整合实例,实现了Point-To-Point的异步队列消息和PUB/SUB(发布/订阅)模型,简单实例,不包含任何业务。
在IT行业中,构建高效、可扩展的Web应用是至关重要的,而"springMvc+spring+activeMq+mybaits"这个项目组合提供了一个强大的框架基础。本文将深入探讨这四个关键技术及其相互间的协同工作。 首先,Spring MVC是...
ActiveMQ 5.2.0是该产品的一个较早版本,但仍然包含了丰富的功能和特性,对于理解消息队列的基本概念和工作原理非常有帮助。 在ActiveMQ 5.2.0中,我们首先会接触到JMS,它是Java平台上的一个标准接口,用于在不同...
在"Spring+JMS+ActiveMQ+Tomcat"的组合中,Spring作为核心框架负责应用的结构和依赖管理,而JMS提供消息传递机制。ActiveMQ作为JMS的实现,承担起消息队列的职责,确保消息的可靠传输。Tomcat则作为运行环境,承载着...
在企业级应用开发中,Spring框架与ActiveMQ的结合使用是一种常见的消息中间件解决方案,用于实现应用程序间的异步通信和解耦。本项目基于Maven构建,提供了对Topic的实现,同时也支持轻松切换到Queue模式。 **...