`

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集群:网络连接模式(network connector)详解

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

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

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

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

    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.jar.zip,activemq,web,4.0,M3,jar.zip包下载,依赖包

    activemq_demo:使用 activemq5.7.0 的 activemq 演示

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

    activemq网站:Apache ActiveMQ网站

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

    MQTTClient:Android <-> ActiveMQ客户端

    Android MQTT客户端 Apache ActiveMQ连接示例

    activemq, Apache ActiveMQ镜像.zip

    activemq, Apache ActiveMQ镜像 欢迎来到 Apache ActiveMQis是一个高性能的Apache 2.0许可以消息代理和 JMS 1.1实现。正在启动要帮助你入门,请尝试以下链接:入门http://activemq.apache.org/version-

    ActiveMQ集群

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

    Vs2015ActiveMq测试工具.rar

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

    activemq-all-5.8.0.jar

    activemq-all-5.8.0.jar 下载 activemq-all-5.8.0.jar 下载 activemq-all-5.8.0.jar 下载 activemq-all-5.8.0.jar 下载 activemq-all-5.8.0.jar 下载

    activeMq 实战

    activemq实战

    ActiveMQ_使用failover模式进行连接切换时,线程断开

    ActiveMQ_使用failover模式进行连接切换时,线程断开 ,ActiveMQ_使用failover模式进行连接切换时,线程断开

    activemq官方安装包

    ActiveMQ介绍: 特点: 1、支持多种语言编写客户端 2、对spring的支持,很容易和spring整合 3、支持多种传输协议:TCP,SSL,NIO,UDP等 4、支持AJAX

    activemq配置

    -- 持久化策略 --> <amq:persistenceAdapter > <amq:jdbcPersistenceAdapter dataSource="#oracle-ds"/> </amq:persistenceAdapter> <!-- Oracle DataSource Sample Setup --> ...

    activemq-core-5.7.0-API文档-中文版.zip

    赠送jar包:activemq-core-5.7.0.jar; 赠送原API文档:activemq-core-5.7.0-javadoc.jar; 赠送源代码:activemq-core-5.7.0-sources.jar; 包含翻译后的API文档:activemq-core-5.7.0-javadoc-API文档-中文...

    ActiveMQ_in_Action.doc

    ActiveMQ 实践之路(一) 启动你的ActiveMQ 程度: 入门 一.安装ActiveMQ 首先去http://activemq.apache.org/download.html 下载最新版本4.1.0release (http://activemq.apache.org/activemq-410-release.html), ...

    ActiveMQ部署方案分析对比

    构建高可用的ActiveMQ系统在生产环境中是非常重要的,单点的ActiveMQ作为企业应用无法满足高可用和集群的需求,所以ActiveMQ提供 了master-slave、broker cluster等多种部署方式,但通过分析多种部署方式之后我认为...

Global site tag (gtag.js) - Google Analytics