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

ActiveMQ的异步转发(DispatchAsync)功能

 
阅读更多

1.       消息者异步转发功能
 
针对正常情况下,在一个fast consumer的时候,为了避免同步和队列的切换采用设置:dispatchAsync=true(默认)。在slow consumer的时候,可能服务端就可能阻塞了。为了提高吞吐量和改变slow consumer消息的现状,可能需要设置为false;
  A.ConnectionFactory
级别配置:

       ((ActiveMQConnectionFactory)connectionFactory).setDispatchAsync(false);

  B.Connection级别设置:

        ((ActiveMQConnection)connection).setDispatchAsync(false);

  C.消息者级别设置:

        queue = new ActiveMQQueue("TEST.QUEUE?consumer.dispatchAsync=false");

        consumer = session.createConsumer(queue);
 
以上几种方法的设置是通过重写覆盖ConnectionFactoryConnection中的方法。

分享到:
评论

相关推荐

    zis.rar_active MQ_activemq_java activeMQ_java 转发

    在这个"zis.rar_active MQ_activemq_java _activeMQ_java 转发"的压缩包中,我们可以推测其主要内容可能涉及如何使用ActiveMQ在Java环境中实现消息的转发功能。 首先,我们需要理解ActiveMQ的基本概念。ActiveMQ...

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

    Spring框架和ActiveMQ的结合使用,为开发者提供了强大的异步消息传递能力。本文将深入探讨如何结合Spring 2.0与ActiveMQ来实现异步消息调用,并分享相关知识点。 首先,Spring 2.0是一个广泛使用的Java应用框架,它...

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

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

    activemq 虚拟topic与路由功能

    ### ActiveMQ虚拟Topic与路由功能详解 在ActiveMQ消息中间件中,为了更好地实现消息的分发和管理,引入了虚拟Topic(Virtual Topic)的概念。本文将深入探讨虚拟Topic及路由功能,帮助读者理解如何利用这些特性来...

    ActiveMq+SpringMVC实现邮件异步发送

    在本项目中,ActiveMQ与SpringMVC框架结合,实现了邮件的异步发送功能。 首先,我们需要理解ActiveMQ的基本概念。ActiveMQ是Apache软件基金会的产品,遵循JMS(Java消息服务)规范,支持多种协议,并且可以跨平台...

    ActiveMQ+Websoket异步信息处理

    **ActiveMQ+WebSocket异步信息处理** 在现代的分布式系统中,实时通信和消息传递扮演着至关重要的角色。Apache ActiveMQ是Apache软件基金会开发的一款开源的消息中间件,它支持多种消息协议,包括JMS(Java Message...

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

    2. **特性**:ActiveMQ具有高可用性、持久化、事务支持、多协议支持、集群和网络拓扑等功能。 3. **配置**:ActiveMQ可以通过XML配置文件进行设置,包括服务器端配置和客户端连接配置。 4. **JMS接口**:Java消息...

    ActiveMQ开发规范及方案

    作为一种消息队列 middleware,ActiveMQ提供了许多功能,例如支持多种消息协议、事务支持、持久化机制等。为了确保ActiveMQ的正确使用和开发,需要遵守一定的开发规范和方案。 规则定义 在使用ActiveMQ之前,需要...

    activeMQ收发工具.rar

    ActiveMQ收发工具的核心功能是通过Java应用程序发送和接收ActiveMQ消息。这个jar包简化了对ActiveMQ服务器的交互过程,使得开发者无需编写复杂的代码就能进行消息传递的测试和调试。通过在命令行中执行`java -jar ...

    apache-activemq-5.17.3

    这个名为"apache-activemq-5.17.3"的压缩包包含了ActiveMQ的5.17.3版本,这是一个稳定且功能丰富的发布版本。在深入探讨其具体内容之前,我们首先需要了解ActiveMQ的基本概念以及它与Java开发环境的关系。 ActiveMQ...

    ActiveMQ

    ActiveMQ 的核心功能是作为消息代理,支持多种消息协议,如 OpenWire、AMQP、STOMP、MQTT 和 WebSocket,使得不同系统和语言间的通信变得更加便捷。 在 IT 领域,消息队列(Message Queue)扮演着至关重要的角色,...

    windows版activemq启动包

    ActiveMQ的核心功能是作为消息代理,它接收和转发消息,连接不同的应用程序,使得它们之间可以进行异步通信。通过消息队列,ActiveMQ可以实现应用解耦,提高系统的可扩展性和容错性。它支持多种协议,如OpenWire、...

    activeMQ入门到精通.txt

    根据提供的文件信息:“activeMQ入门到精通”,我们可以深入探讨ActiveMQ的相关知识点,包括其基本概念、安装配置步骤、核心功能特性以及应用场景等。 ### ActiveMQ简介 ActiveMQ是一款开源的消息中间件,它支持...

    apache-activemq-5.16.5

    Apache ActiveMQ是业界广泛使用的开源消息中间件,它基于Java消息服务(JMS)标准,提供了高度可扩展、可靠的异步通信能力。标题"apache-activemq-5.16.5"指的是该软件的一个特定版本,即5.16.5版本,通常每个新版本...

    最新稳定版ActiveMQ5.15.0

    在最新的稳定版5.15.0中,它提供了可靠的消息传递功能,适用于分布式应用程序之间的通信,实现了异步处理、解耦组件以及数据传输等功能。ActiveMQ支持多种协议,包括开放消息存取协议(OpenWire)、简单对象访问协议...

    apache-activemq Linux版本

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

    ActiveMQ高并发处理方案

    Apache ActiveMQ作为一款成熟且功能强大的开源消息中间件,被广泛应用于各种高并发场景下。然而,在处理大量并发连接和消息时,ActiveMQ可能会遇到性能瓶颈,例如连接资源耗尽、消息处理不均等问题。本文将详细介绍...

    Spring集成ActiveMQ配置

    Spring集成ActiveMQ是将Spring框架与ActiveMQ消息中间件相结合,实现异步处理和解耦应用程序的关键技术。在本文中,我们将深入探讨如何配置和使用这一组合,以及它在实际项目中的应用。 首先,让我们了解Spring框架...

    activemq

    通过上述内容的学习,我们可以了解到 ActiveMQ-CPP 提供了丰富的功能来支持 C++ 开发者进行消息队列的开发。无论是对于初学者还是有经验的开发者来说,理解这些概念都是非常重要的。掌握了 CMS 的基本原理和 ...

Global site tag (gtag.js) - Google Analytics