`
myrev
  • 浏览: 163951 次
  • 性别: Icon_minigender_1
  • 来自: 福建
社区版块
存档分类
最新评论

Spring 2.5 + ActiveMQ 5.2.0 Embedded Broker实现

阅读更多
    要的代码实现在上一篇文章,而本篇文章重点是说明 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-nettysocketio +netty+activeMq在线客服系统

    springboot +netty+activeMq在线客服系统springboot +netty+activeMq在线客服系统springboot +netty+activeMq在线客服系统springboot +netty+activeMq在线客服系统springboot +netty+activeMq在线客服系统springboot...

    spring2 activemq5 tomcat6构建jms

    标题“spring2 ...分析这些文件可以帮助理解如何将Spring、ActiveMQ和Tomcat集成在一起,实现消息传递功能。学习这个例子可以加深对JMS、Spring集成以及Web应用部署的理解,对于提升Java EE开发技能非常有帮助。

    JMS之Spring +activeMQ实现消息队列

    总结起来,"JMS之Spring + ActiveMQ实现消息队列"涉及到的关键知识点包括:Spring框架的JMS支持、ActiveMQ的使用、ConnectionFactory的配置、JmsTemplate和MessageListener的实现,以及消息队列在解决系统解耦和异步...

    Spring+JMS+ActiveMQ+Tomcat实现消息服务的demo

    基于Spring+JMS+ActiveMQ+Tomcat,我使用的版本情况如下所示:Spring 3.2.0,ActiveMQ 5.4.3,Tomcat 6.0.43。本例通过详细的说明和注释,实现消息服务的基本功能:发送与接收。Spring对JMS提供了很好的支持,可以...

    ActiveMQ5.1+Spring2.5 Demo

    **ActiveMQ5.1+Spring2.5 Demo详解** ActiveMQ是Apache软件基金会下的一个开源项目,它是一款功能强大的消息中间件,支持多种消息协议,如AMQP、STOMP、OpenWire等。在版本5.1中,ActiveMQ提供了一流的消息传输性能...

    spring+activemq必备jar包

    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

    综上所述,Spring整合JMS和ActivemQ提供了一套完整的解决方案,帮助开发者轻松地在应用中实现消息的发送和接收。通过这种方式,可以构建出高可用、松耦合、可扩展的分布式系统,提高系统的稳定性和响应速度。在实际...

    【毕业设计】基于springCloud +activemq的智慧物业综合管理平台【后端源码】.zip

    【毕业设计】基于springCloud +activemq的智慧物业综合管理平台【后端源码】.zip 技术架构: Java + spring cloud + mybatis + mysql + activemq + redis 1.0 小区商家 1 美食 外卖 生鲜 超市 家政 其他 2.0 小区...

    spring3+ActiveMQ+blazeds+flex consumer

    本项目“spring3+ActiveMQ+blazeds+flex consumer”旨在整合一系列技术,以实现这样的功能。下面将详细阐述这些技术及其整合过程。 首先,Spring框架(Spring3)是Java领域最流行的轻量级应用框架之一,它提供了...

    Spring+ActiveMQ整合实例代码工程

    如果使用Spring Boot,可以简化配置,只需在`application.properties`中添加ActiveMQ的相关配置,如`spring.activemq.broker-url`,然后通过`@Autowired`注解注入`JmsTemplate`和`ConnectionFactory`即可。...

    SpringBoot+ActiveMq+MQTT实现消息的发送和接收

    在本文中,我们将深入探讨如何使用SpringBoot、ActiveMQ和MQTT来实现消息的发送与接收。这是一个典型的分布式系统中的消息通信场景,其中SpringBoot作为应用程序框架,ActiveMQ作为消息中间件,而MQTT(Message ...

    基于Spring+JMS+ActiveMQ+Tomcat的整合ActiveMQSpringDemo实例源码.zip

    基于Spring+JMS+ActiveMQ+Tomcat的整合ActiveMQSpringDemo实例源码,此实例基于Spring+JMS+ActiveMQ+Tomcat,注解的完整实例,包含jar包,可供学习及设计参考。

    Spring+JMS+ActiveMQ+Tomcat实现消息服务_服务器应用

    ### Spring+JMS+ActiveMQ+Tomcat 实现消息服务 #### 一、技术栈介绍 在本案例中,我们采用的技术栈为Spring 2.5、ActiveMQ 5.4.0 和 Tomcat 6.0.30。这些技术的结合能够有效地构建一个可靠的消息传递系统。 - **...

    spring+activemq

    在IT行业中,Spring框架与...总结,Spring与ActiveMQ的集成为开发者提供了强大而便捷的工具来实现异步通信,提高了系统的可扩展性和解耦性。通过理解并熟练运用这些技术,开发者能够构建出高效、稳定的分布式应用。

    jms Spring+ActiveMQ 5.4.2

    总结起来,"jms Spring+ActiveMQ 5.4.2"是一个关于如何利用Spring框架和ActiveMQ实现高效、可靠的JMS通信的教程或示例。通过学习这个主题,开发者可以掌握如何在Java环境中构建健壮的、分布式的消息驱动系统。

    基于Spring+JMS+ActiveMQ+Tomcat整合

    基于Spring+JMS+ActiveMQ+Tomcat,做一个Spring4.1.0和ActiveMQ5.11.1整合实例,实现了Point-To-Point的异步队列消息和PUB/SUB(发布/订阅)模型,简单实例,不包含任何业务。

    springMvc+spring+activeMq+mybaits

    在IT行业中,构建高效、可扩展的Web应用是至关重要的,而"springMvc+spring+activeMq+mybaits"这个项目组合提供了一个强大的框架基础。本文将深入探讨这四个关键技术及其相互间的协同工作。 首先,Spring MVC是...

    apache-activemq-5.2.0.zip_activeMq 5.2.0_apache mq

    ActiveMQ 5.2.0是该产品的一个较早版本,但仍然包含了丰富的功能和特性,对于理解消息队列的基本概念和工作原理非常有帮助。 在ActiveMQ 5.2.0中,我们首先会接触到JMS,它是Java平台上的一个标准接口,用于在不同...

    Spring+JMS+ActiveMQ+Tomcat jar下载

    在"Spring+JMS+ActiveMQ+Tomcat"的组合中,Spring作为核心框架负责应用的结构和依赖管理,而JMS提供消息传递机制。ActiveMQ作为JMS的实现,承担起消息队列的职责,确保消息的可靠传输。Tomcat则作为运行环境,承载着...

    Spring+ActiveMQ实现,基于Maven

    在企业级应用开发中,Spring框架与ActiveMQ的结合使用是一种常见的消息中间件解决方案,用于实现应用程序间的异步通信和解耦。本项目基于Maven构建,提供了对Topic的实现,同时也支持轻松切换到Queue模式。 **...

Global site tag (gtag.js) - Google Analytics