`
jacally
  • 浏览: 772134 次
  • 性别: Icon_minigender_1
  • 来自: 广州
社区版块
存档分类
最新评论

activeMQ的疑问 如果系统中还有其他的异步服务

    博客分类:
  • JAVA
阅读更多
SpringSide中文论坛 » SpringSide深度讨论区 » activeMQ的疑问?

关于activemq部分,有两个疑问,想咨询一下:

1、现在的例子中,是以发送订单邮件为例的,如果系统中还有其他的异步服务,applicationContext-activemq- embedded-persistence.xml该如何配置?Message Driven POJO、listener container需要如何设置呢?监听容器如何设置多个异步服务?

希望得到高手的解答,谢谢!


1.
Q:现在的例子中,是以发送订单邮件为例的,如果系统中还有其他的异步服务?
A:applicationContext-activemq-embedded-persistence.xml 主要是启动内嵌的broker和为jmstemplate 提供连接connectionFactory
  而多个异步服务直接增加多个destination,和producer,然后注入Server即可 参考

xml 代码
  1. <amq:queue name="destination" physicalName="org.apache.activemq.spring.Test.spring.embedded"/>  
  2.   
  3.   
  4. <bean id="orderMessageProducer" class="org.springside.bookstore.components.activemq.OrderMessageProducer">  
  5. <property name="template" ref="jmsTemplate"/>  
  6. <property name="destination" ref="destination"/>  
  7. </bean>  

  以及在container里面配置consumer, 这样就可以组成一个完成的异步服务了(发送,接受)。

 

Q:Message Driven POJO、listener container需要如何设置呢?
A:http://wiki.springside.org.cn/display/springside/Home 在我们的wiki里面有详细的配置
  而且使用了Spring和jencks 2种container
  applicationContext-activemq-embedded-persistence.xml
  applicationContext-activemq-embedded-jencks-persistence.xml

Q:监听容器如何设置多个异步服务
 
  多个

xml 代码
  1. <bean id="listenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">  
  2. <property name="connectionFactory" ref="jmsConnectionFactory"/>  
  3. <property name="destination" ref="destination"/>  
  4. <property name="messageListener" ref="messageListener"/>  
  5. </bean>  

 
  或者使用jencks管理多个connector
xml 代码
  1.  <jencks:connectors>  
  2.   
  3.   <!-- use jencks container (use spring MessageListenerAdapter)-->  
  4.   <jencks:connector ref="messageListener">  
  5.    <jencks:activationSpec>  
  6.     <amqra:activationSpec destination="org.apache.activemq.spring.Test.spring.embedded"  
  7.            destinationType="javax.jms.Queue"/>  
  8.    </jencks:activationSpec>  
  9.   </jencks:connector>  
  10. </jencks:connectors>  
分享到:
评论

相关推荐

    springboot-nettysocketio +netty+activeMq在线客服系统

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

    ActiveMq+SpringMVC实现邮件异步发送

    在IT行业中,异步处理是提高系统性能和用户体验的关键技术之一。ActiveMQ作为一个开源的消息中间件,被广泛用于实现消息队列和发布/订阅模式,它允许应用将非实时任务如邮件发送等操作放到后台处理,从而提升系统的...

    ActiveMQ开发规范及方案

    分布式系统中使用ActiveMQ可以实现系统之间的解耦和异步通信,从而提高系统的性能和可靠性。 场景分析 分布式系统中使用ActiveMQ需要对系统进行场景分析,以确定系统的需求和限制。例如,需要确定系统的性能需求、...

    ActiveMQ消息服务器 v6.0.1.zip

    1. 微服务通信:在微服务架构中,ActiveMQ作为服务间通信的桥梁,实现异步解耦和数据同步。 2. 流程工作流:在复杂的业务流程中,ActiveMQ可以作为任务调度工具,管理不同阶段的任务分配和执行。 3. 应用监控:通过...

    ActiveMQ与Spring整合之异步发送邮件

    当ActiveMQ与Spring整合时,可以方便地实现异步处理,比如异步发送邮件,这在大型系统中尤为常见,因为它们能够避免阻塞主线程,提升系统性能。 **ActiveMQ基础** 1. **概念理解**:ActiveMQ作为消息代理,接收并...

    人工智能-项目实践-异步调度-ActiveMQ+Celery异步任务调度,Python AI.zip

    在本项目实践中,我们主要探讨的是如何利用ActiveMQ和Celery构建一个异步任务调度系统,这在处理大量计算密集型或耗时的任务时尤为重要,特别是在人工智能(AI)的场景中。下面将详细介绍这两个关键组件以及它们在...

    ActiveMQ消息服务器 v5.17.6.zip

    2. **异步处理**:对于耗时的操作,可以通过发送消息到队列,由后台服务异步处理,提高系统响应速度。 3. **流量控制**:在高峰时段,消息队列可以缓冲大量请求,避免系统过载。 4. **事件驱动架构**:在事件驱动...

    ActiveMQ消息服务器 v5.18.3.zip

    对于计算机案例和模板建站,ActiveMQ可以作为后台服务,提供异步通信能力,处理大量并发请求,从而提高系统的响应速度和用户体验。例如,用户提交表单后,ActiveMQ可以接收并处理这些请求,而前端不需要等待返回结果...

    apache-activemq Linux版本

    在Linux系统上部署和使用Apache ActiveMQ能够提供稳定、高效的消息传递服务,支持分布式系统中的异步通信和解耦。 Apache ActiveMQ的主要功能包括: 1. **消息队列**: 它允许应用程序将消息放入队列中,由其他应用...

    ActiveMQ

    4. **分布式系统通信**:在微服务架构中,ActiveMQ 可作为服务间的通信桥梁,简化服务间的交互。 5. **容错与备份**:通过消息持久化和集群部署,实现服务的容错和备份,保证系统的稳定性。 **TestMQ 文件详解** ...

    ActiveMQ的使用代码样例(异步邮件发送).rar

    总结来说,这个"ActiveMQ的使用代码样例(异步邮件发送)"提供了如何利用ActiveMQ实现异步通信的实际例子,特别在邮件服务场景中。通过理解这些关键概念和技术,开发者可以有效地构建自己的分布式系统,提高应用的...

    Spring集成ActiveMQ配置

    6. **Missian ActiveMQ-JMS简单实例**:这可能是一个具体的项目实例,它展示了如何在Spring应用中使用ActiveMQ实现异步RPC(远程过程调用)。在这种模式下,一个服务通过消息将请求发送到队列,另一端的服务监听队列...

    ActiveMq安装.docx

    这里提供了其他几个与服务管理相关的命令,如`./activemq stop`用于停止服务,`./activemq status`查询服务状态,以及`./activemq restart`重启服务。 为了验证ActiveMQ是否安装成功,可以通过Web控制台进行检查。...

    window系统搭建activeMQ集群和操作步骤

    在Windows系统上搭建ActiveMQ集群是一项关键的任务,它涉及到分布式消息传递系统的设计和优化。ActiveMQ是Apache软件基金会开发的一款开源消息代理,它遵循Java Message Service (JMS) 规范,提供高可靠的消息传递...

    39、ActiveMQ.pdf

    如果一个服务器出现故障,其他服务器可以接管其任务,确保消息传递不间断。此外,ActiveMQ提供了持久化机制,即使在服务器重启或网络中断后,也能保证消息的可靠传递。 在实际项目中,消息中间件常用于解决以下问题...

    ActiveMQ实战(英文版)

    在学习过程中,读者应结合实际项目需求,逐步掌握ActiveMQ的使用技巧,例如创建和管理消息队列,设置消息优先级,处理消息死信,以及使用ActiveMQ与其他系统如数据库、Web服务等集成。同时,熟悉ActiveMQ的Web控制台...

    ActiveMQ入门

    **定义**:松耦合是指系统中各组件之间依赖程度较低的一种设计模式,其中各个组件相对独立,可以单独更改而不影响其他组件。 **优点**: - **提高灵活性**:单个组件的变化不会对整个系统造成重大影响。 - **简化...

    ActiveMQ+Websoket异步信息处理

    在本文中,我们将探讨如何结合ActiveMQ和WebSocket实现异步信息处理。 首先,我们需要确保正确地设置和启动环境。在启动ActiveMQ之前,确保你的计算机名中没有横杆,因为这可能导致ActiveMQ无法正常启动。ActiveMQ...

    结合Spring2.0和ActiveMQ进行异步消息调用

    在IT行业中,异步消息处理是一种常见的优化系统性能和可扩展性的技术。Spring框架和ActiveMQ的结合使用,为开发者提供了强大的异步消息传递能力。本文将深入探讨如何结合Spring 2.0与ActiveMQ来实现异步消息调用,并...

    ActiveMQ(中文)参考手册

    ActiveMQ(中文)参考手册 ActiveMQ(中文)参考手册 ActiveMQ(中文)参考手册 ActiveMQ(中文)参考手册

Global site tag (gtag.js) - Google Analytics