`

ActiveMQ,InactivityIOException: Channel was inactive for too (>30000) long的问题分析

阅读更多

ActiveMQ集群中包括broker1和broker2,在broker1上建立connector连接到broker2。当两个broker启动后,在没有生产者、消费者的情况下,broker1持续出现InactivityIOException,不断断开链接并重连。测试发现在broker2上useInactivityMonitor设置为false。

分析结果如下:

useInactivityMonitor在客户端和服务器端有不同的含义。

在客户端,useInactivityMonitor为true意味着AbstractInactivityMonitor会定时检查读取的消息数量。如果数量没有变化,则抛出InactivityIOException,导致链接断开。如果useInactivityMonitor为true,则不做检查。

在服务端,useInactivityMonitor为true意味着服务端会定时发送KeepAliveInfo,保持链接的活跃。如果useInactivityMonitor为false则不发送KeepAliveInfo。在出现异常的这个集群中,broker1为客户端,broker2为服务端。由于connector链接没有设置useInactivityMonitor,其默认值为true,所以broker1会检查读取的消息数量。由于broker2的useInactivityMonitor为false,所以不会发送KeepAliveInfo,导致broker1一直没有收到消息,就自动断开了链接。

分享到:
评论

相关推荐

    qt5.8 msvc2015 +activemq

    qt5.8 msvc2015 加载activemq 成功自发自首,编写了模块,可以自行下载,activemq里面的dll,也都存在, 调用方法 CSpiderPluginAMq::GetInstance()->InitNetwork(); CSpiderPluginAMq::GetInstance()->...

    高可用之ActiveMQ集群:网络连接模式(network connector)详解.docx

    配置网络连接器主要涉及在 `activemq.xml` 文件中 `<networkConnectors>` 节点内添加 `<networkConnector>` 元素。例如: ```xml <networkConnectors> <networkConnector uri="static:(tcp://localhost:62001)"/> ...

    ActiveMQ集群:网络连接模式(network connector)详解.docx

    ActiveMQ 集群网络连接模式(Network Connector)详解 ActiveMQ 集群网络连接模式(Network Connector)是 ActiveMQ 提供的一种集群功能,旨在提高消息服务的横向扩展性和高可用性。通过将多个不同的 broker 实例...

    ActiveMQ路由配置方式

    ActiveMQ路由配置方式 ActiveMQ路由配置是Apache ActiveMQ项目中的一种重要配置方式,它依赖另一个Apache项目Camel。ActiveMQ集成了Camel,启动时同时会启动Camel。通过Camel Web Console可以进行Routing配置。 ...

    activeMQ-cpp 测试文件

    ActiveMQ 是一个开源的消息中间件,它遵循开放消息模型(Open Message Model)并支持多种协议,包括AMQP、STOMP、XMPP等。ActiveMQ-cpp是ActiveMQ的C++客户端库,允许开发者在C++应用程序中使用ActiveMQ的功能。 在...

    linux-apache-activemq-5.15.3和 linux-jdk1.8

    特别需要注意的是,ActiveMQ 5.15.3版本明确要求使用JDK 1.8,因为较旧或更新版本的JDK可能无法提供必要的兼容性或者会导致性能问题。 在Linux环境中配置和运行ActiveMQ和JDK 1.8时,需要遵循以下步骤: 1. 安装...

    activemq-cpp-library-3.9.5-src.zip

    《ActiveMQ-CPP库3.9.5源代码解析与应用》 ActiveMQ-CPP库是Apache ActiveMQ项目的一部分,它提供了一套C++接口,用于与ActiveMQ消息代理进行通信。这个库允许开发者在C++应用程序中实现高级消息队列协议(AMQP)和...

    apache-activemq-5.8.0.zip

    apache-activemq-5.8.0,包解压后可以直接使用,用于系统间的消息的发布与消费。 pom添加: <dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-all</artifactId> <version>5.11.1...

    activemq-web-4.0-M3.jar.zip

    《ActiveMQ Web 4.0-M3:Java消息服务(JMS)的Web集成与实践》 Apache ActiveMQ是开源的、高性能的消息中间件,它实现了Java消息服务(JMS)标准,为分布式系统提供了可靠的异步通信能力。在本文中,我们将探讨...

    消息队列中间件ActiveMQ入门到精通视频教程及资料

    001-ActiveMQ基础;002-安全机制+签收模式+发送模式+MessageProducer;003-顺序消费+消息过滤SELECTOR+MessageConsumer+MySql持久化;004-p2p模式+pulish-subscribe发布订阅模式+与spring集成;005-集群部署1;006-...

    activemq spring 客户端配置

    标题中的“activemq spring 客户端配置”指的是如何在Spring框架中设置Apache ActiveMQ作为消息中间件的客户端。ActiveMQ是Apache软件基金会开发的一个开源消息代理,它实现了多种消息协议,如JMS(Java Message ...

    MQTTClient:Android <-> ActiveMQ客户端

    **MQTTClient: Android <-> ActiveMQ 客户端** 在移动应用开发中,尤其是在物联网(IoT)领域,实时通信是至关重要的。MQTT(Message Queuing Telemetry Transport)是一种轻量级、发布/订阅模式的协议,适用于资源...

    linux activemq-cpp-library-3.8.2-src.tar.gz

    《Linux环境下ActiveMQ-CPP库3.8.2版本的深度解析与应用》 ActiveMQ是Apache软件基金会的一款开源消息中间件,它提供了一个高效、灵活且强大的消息传递平台,支持多种协议,如OpenWire、AMQP、STOMP等。在C++编程...

    ActiveMQ问题解决记录

    这篇博客"ActiveMQ问题解决记录"可能涵盖了作者在使用ActiveMQ过程中遇到的问题以及解决这些问题的经验分享。 首先,让我们了解一下ActiveMQ的基本概念。ActiveMQ作为消息中间件,它充当应用程序之间的桥梁,负责...

    activemq_demo:使用 activemq5.7.0 的 activemq 演示

    #ActiveMQ DEMO 管理页面: activemq 端口:61616 activemq start:apache-activemq-5.11.1/bin/macosx/activemq start

    activemq的简单配置

    对于需要解决异步消息处理、高并发访问等问题的应用场景而言,ActiveMQ无疑是一个值得考虑的选择。此外,通过PHP等语言实现消息的发送和接收也变得非常便捷,有助于快速搭建起基于消息驱动的应用系统。

    activemq网站:Apache ActiveMQ网站

    Apache ActiveMQ网站 这是位于的Apache ActiveMQ网站的存储库。 这个怎么运作 存储库的此分支包含用于生成最终被推送到站点HTML的源文件。 对分支进行提交时,将自动在CI中执行Jekyll构建,并将生成的站点输出提交回...

    ActiveMQ 配置文件详解

    **ActiveMQ配置文件详解** ...同时,ActiveMQ的源码分析也是一个深入学习的过程,可以揭示其内部工作原理,有助于解决实际问题。在实际操作中,记得根据自己的需求进行调整,确保服务器的稳定性和性能。

    Linux下activeMQ的启动和停止.docx

    在Linux环境下,Apache ActiveMQ是一个广泛使用的开源消息代理和队列服务器,它是Java Message Service (JMS) 的实现,能够处理大量的并发消息传递。ActiveMQ提供了高可用性、可扩展性和稳定性,使得它成为分布式...

    Vs2015ActiveMq测试工具.rar

    运行环境是 win10 64位系统,开发环境是VS2015 ...问题分析:这个崩溃操作是因为没有执行activemq初始化函数,所以现在构造函数中加上activemq初始化语句如下: activemq::library::ActiveMQCPP::initializeLibrary();

Global site tag (gtag.js) - Google Analytics