`
zengshaotao
  • 浏览: 788857 次
  • 性别: Icon_minigender_1
  • 来自: 上海
社区版块
存档分类
最新评论

activeMQ spring集成

    博客分类:
  • JMS
 
阅读更多

applicationContext.xml

 

[html] view plain copy
 
  1. <!--创建连接工厂 -->  
  2. <bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">  
  3.     <property name="brokerURL" value="tcp://localhost:61616"></property>  
  4. </bean>  
  5.   
  6.   
  7. <!-- 声明ActiveMQ消息目标,目标可以是一个队列,也可以是一个主题ActiveMQTopic -->  
  8. <bean id="destinationOne" class="org.apache.activemq.command.ActiveMQQueue">  
  9.     <constructor-arg index="0" value="testQueOne"></constructor-arg>  
  10. </bean>  
  11.   
  12.   
  13. <!-- 设置 消息目的地 start -->  
  14. <bean id="jmsTemplateOne" class="org.springframework.jms.core.JmsTemplate">  
  15.     <property name="connectionFactory" ref="connectionFactory"></property>  
  16.     <property name="defaultDestination" ref="destinationOne"></property>  
  17.     <property name="receiveTimeout" value="6000"></property>  
  18. </bean>  
  19. <!-- 设置 消息目的地 end -->  
  20.   
  21. <!-- 配置生产者 start -->  
  22. <bean id="senderOne" class="com.dly.avtivemqtest.SenderOne">  
  23.     <property name="jmsTemplateOne" ref="jmsTemplateOne"></property>  
  24. </bean>  
  25. <!-- 配置生产者 end -->  
  26.   
  27. <!-- 配置消费者 start -->  
  28. <bean id="receiverOne" class="com.dly.avtivemqtest.ReceiverOne">  
  29.      <!-- <property name="jmsTemplate" ref="jmsTemplate"></property> -->  
  30. </bean>  
  31.    <!-- 配置消费者 end -->  
  32.      
  33. <!-- 消息监听器 -->  
  34. <bean id="consumerMessageListenerOfOne" class="com.dly.avtivemqtest.ReceiverOne" />  
  35.   
  36. <!-- 消息监听容器 消息接收监听器用于异步接收消息 -->  
  37. <bean id="jmsContainerOne" class="org.springframework.jms.listener.DefaultMessageListenerContainer">  
  38.     <property name="connectionFactory" ref="connectionFactory" />  
  39.     <property name="destination" ref="destinationOne" />  
  40.     <property name="messageListener" ref="consumerMessageListenerOfOne" />  
  41. </bean>  
  42. lt;/beans>  

SenderOne.java

 

 

[html] view plain copy
 
  1. public class SenderOne {  
  2.     private JmsTemplate jmsTemplateOne;  
  3.   
  4.     public JmsTemplate getJmsTemplateOne() {  
  5.         return jmsTemplateOne;  
  6.     }  
  7.   
  8.     public void setJmsTemplateOne(JmsTemplate jmsTemplateOne) {  
  9.         this.jmsTemplateOne = jmsTemplateOne;  
  10.     }  
  11.       
  12. //测试的  
  13.     public void sendInfo(final String messageRecord,final String flag) {  
  14.         jmsTemplateOne.send(new MessageCreator() {  
  15.             public Message createMessage(Session session) throws JMSException {  
  16.                 TextMessage message = session.createTextMessage();  
  17.                 return message;  
  18.             }  
  19.         });  
  20.     }  
  21. }  


ReceiverOne.java

 

 

[html] view plain copy
 
  1. public class ReceiverOne  implements MessageListener {    
  2.     //测试方法  
  3.       public void onMessage(Message message, Session session) {    
  4.   
  5.             //这里我们知道生产者发送的就是一个纯文本消息,所以这里可以直接进行强制转换    
  6.           TextMessage textMsg = (TextMessage) message;  
  7.             try {  
  8.                 String endStr = textMsg.getText();  
  9.                 Integer endInt = Integer.parseInt(endStr);  
  10.                 System.out.println("消息:==="+endInt);  
  11.             } catch (Exception e) {    
  12.                 e.printStackTrace();  
  13.                 System.out.println("异常信息是:===:" + e.getMessage());  
  14.             }  
  15.         }  
  16.   
  17. }  

JMSTest.java

 

 

[html] view plain copy
 
  1. public class JMSTest {  
  2.     public static void main(String[] args) {  
  3.           
  4.         ApplicationContext context = new ClassPathXmlApplicationContext("resources/applicationContext.xml");  
  5.         SenderOne sender = (SenderOne) context.getBean("senderOne");  
  6.         sender.sendInfo("10","2");  
  7.     }  
  8. }  
分享到:
评论

相关推荐

    Spring-ActiveMQ.rar_Spring Activemq_activemq_activemq spring

    而Spring框架,作为一个Java平台的全功能模块化解决方案,提供了与ActiveMQ集成的能力,让开发者能够轻松地在Spring应用中使用消息队列。本篇将深入探讨Spring与ActiveMQ的集成及其配置过程。 首先,理解Spring与...

    消息队列:ActiveMQ:ActiveMQ的Spring集成.docx

    消息队列:ActiveMQ:ActiveMQ的Spring集成.docx

    activemq springMVC集成jar包

    3. **Spring配置**:集成ActiveMQ到Spring MVC需要在Spring的配置文件(如`applicationContext.xml`)中声明一个`ConnectionFactory`和`Destination`。`ConnectionFactory`用于创建连接到消息队列的连接,`...

    ActiveMQ与spring集成实例之使用Maven构建

    标题中的“ActiveMQ与Spring集成实例之使用Maven构建”是指在Java开发环境中,通过Maven构建工具将Apache ActiveMQ消息中间件与Spring框架整合在一起的实际操作案例。这个主题涵盖了几大关键知识点: 1. **Apache ...

    activeMQ_spring简单案例(含XML配置)

    总的来说,集成ActiveMQ和Spring可以简化消息传递的复杂性,提高应用程序的可扩展性和解耦性。通过XML配置,我们可以灵活地管理消息生产和消费,实现异步通信,提高系统的响应速度和并发处理能力。在实际项目中,...

    activeMQ和Spring集成Demo

    ActiveMQ和Spring的集成是企业级Java应用中常见的消息中间件解决方案,用于实现解耦、异步处理和系统间的通信。在本示例中,我们将深入探讨如何将这两个组件结合在一起,以创建一个高效且可扩展的应用架构。 首先,...

    spring集成activemq例子demo

    在Spring框架中集成ActiveMQ,我们可以创建一个高效的、可扩展的系统,利用消息队列来解耦生产者和消费者,提高系统的响应速度和可靠性。以下将详细介绍如何进行Spring与ActiveMQ的集成,并提供一些关键知识点。 1....

    activemq5.5.1 Spring模板

    本文将深入探讨ActiveMQ 5.5.1版本与Spring框架的集成,以及如何利用Spring的模板模式简化ActiveMQ的使用。 一、ActiveMQ基础介绍 ActiveMQ是Apache软件基金会下的一个项目,遵循JMS(Java消息服务)规范,支持多种...

    ActiveMQ与spring集成实例之使用消息监听器

    **ActiveMQ与Spring集成实例详解** ActiveMQ是Apache软件基金会下的一个开源项目,它是一个功能丰富的Java消息服务(JMS)提供商,支持多种协议,并且能够处理大量的并发消息传输。而Spring框架则是一个广泛使用的...

    ActiveMQ与spring集成实例

    通过以上步骤,你已经成功地将ActiveMQ与Spring集成,并实现了基本的消息收发功能。在实际项目中,你可能需要根据需求调整配置,例如设置消息的持久化、事务支持、消息优先级等高级特性。此外,ActiveMQ还提供了管理...

    activeMQ_spring_Demo.zip_DEMO_activemq_activemq spring_rowbv3

    《ActiveMQ与Spring整合实战教程》 在Java企业级应用中,消息中间件扮演着至关重要的角色,它能够实现应用间的解耦,提高系统的可扩展性和可靠性。ActiveMQ作为Apache基金会的一个开源项目,是Java消息服务(JMS)...

    ActiveMQ与spring集成实例之使用消息转换器

    **ActiveMQ与Spring集成实例——使用消息转换器** 在企业级应用开发中,消息队列(Message Queue,MQ)作为一种解耦和异步处理的重要工具,被广泛应用。Apache ActiveMQ 是一个开源的消息中间件,它支持多种消息...

    Spring集成ActiveMQ配置.docx

    Spring 集成 ActiveMQ 配置 Spring 集成 ActiveMQ 配置是指将 Spring 框架与 ActiveMQ 消息队列集成,以实现基于 JMS(Java Message Service)的消息传递。ActiveMQ 是 Apache 软件基金会的一个开源的消息队列系统...

    ActiveMQ与Spring整合示例Demo

    **ActiveMQ与Spring整合详解** ...通过这个项目,你可以了解到如何在Spring应用中集成并使用ActiveMQ,以及如何设计消息的生产和消费流程。理解并熟练运用这些知识,对于构建高可用、高性能的企业级应用至关重要。

    activemq spring

    标题 "activemq spring" 指涉的是Apache ActiveMQ集成到Spring框架中的主题,这是一个在企业级Java应用中常见的消息中间件集成实践。ActiveMQ是Apache软件基金会开发的一个开源消息代理,它遵循开放消息中间件协议...

    ActiveMQ+spring配置方案详解

    当我们需要在Spring应用中集成ActiveMQ时,就需要进行相应的配置。本文将深入讲解ActiveMQ与Spring的整合配置方案。 首先,我们需要在项目中引入ActiveMQ的相关依赖。这通常通过在`pom.xml`文件中添加Maven依赖来...

    spring配置activemq详解

    - 结合Spring Boot的自动配置能力,可以极大地简化ActiveMQ的集成过程,只需少量配置就能快速启动和运行。 7. **监控和管理**: - ActiveMQ提供了Web控制台,可以通过浏览器进行监控和管理,查看队列状态、消息...

Global site tag (gtag.js) - Google Analytics