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 成功自发自首,编写了模块,可以自行下载,activemq里面的dll,也都存在, 调用方法 CSpiderPluginAMq::GetInstance()->InitNetwork(); CSpiderPluginAMq::GetInstance()->...
消息队列:ActiveMQ:ActiveMQ消息类型:点对点与发布订阅.docx
配置网络连接器主要涉及在 `activemq.xml` 文件中 `<networkConnectors>` 节点内添加 `<networkConnector>` 元素。例如: ```xml <networkConnectors> <networkConnector uri="static:(tcp://localhost:62001)"/> ...
ActiveMQ 集群网络连接模式(Network Connector)详解 ActiveMQ 集群网络连接模式(Network Connector)是 ActiveMQ 提供的一种集群功能,旨在提高消息服务的横向扩展性和高可用性。通过将多个不同的 broker 实例...
消息队列:ActiveMQ:ActiveMQ的Web控制台使用.docx
消息队列:ActiveMQ:ActiveMQ的高级特性:虚拟目的地与代理.docx
ActiveMQ路由配置方式 ActiveMQ路由配置是Apache ActiveMQ项目中的一种重要配置方式,它依赖另一个Apache项目Camel。ActiveMQ集成了Camel,启动时同时会启动Camel。通过Camel Web Console可以进行Routing配置。 ...
ActiveMQ 是一个开源的消息中间件,它遵循开放消息模型(Open Message Model)并支持多种协议,包括AMQP、STOMP、XMPP等。ActiveMQ-cpp是ActiveMQ的C++客户端库,允许开发者在C++应用程序中使用ActiveMQ的功能。 在...
消息队列:ActiveMQ:ActiveMQ简介与安装.docx
消息队列:ActiveMQ:ActiveMQ的Spring集成.docx
消息队列:ActiveMQ:ActiveMQ的事务处理.docx
特别需要注意的是,ActiveMQ 5.15.3版本明确要求使用JDK 1.8,因为较旧或更新版本的JDK可能无法提供必要的兼容性或者会导致性能问题。 在Linux环境中配置和运行ActiveMQ和JDK 1.8时,需要遵循以下步骤: 1. 安装...
消息队列:ActiveMQ:ActiveMQ消息过滤与选择.docx
消息队列:ActiveMQ:ActiveMQ消息持久化机制.docx
《ActiveMQ-CPP库3.9.5源代码解析与应用》 ActiveMQ-CPP库是Apache ActiveMQ项目的一部分,它提供了一套C++接口,用于与ActiveMQ消息代理进行通信。这个库允许开发者在C++应用程序中实现高级消息队列协议(AMQP)和...
消息队列:ActiveMQ:ActiveMQ的高可用性配置.docx
消息队列:ActiveMQ:ActiveMQ的集群与负载均衡.docx
apache-activemq-5.8.0,包解压后可以直接使用,用于系统间的消息的发布与消费。 pom添加: <dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-all</artifactId> <version>5.11.1...
消息队列:ActiveMQ:ActiveMQ的安全性与权限管理.docx
《ActiveMQ Web 4.0-M3:Java消息服务(JMS)的Web集成与实践》 Apache ActiveMQ是开源的、高性能的消息中间件,它实现了Java消息服务(JMS)标准,为分布式系统提供了可靠的异步通信能力。在本文中,我们将探讨...