当前位置: 首页 > article >正文

ActiveMQ监听器在MQ重启后不再监听问题

应用的监听器注解

@JmsListener(destination = "TopicName",containerFactory = "FactoryName")

工厂代码

@Bean
    JmsListenerContainerFactory<?> FactoryName(ConnectionFactory connectionFactory){
        SimpleJmsListenerContainerFactory factory = new SimpleJmsListenerContainerFactory();
    	factory.setConnectionFactory(connectionFactory);
        factory.setPubSubDomain(true);
        return factory;
    }

修改后的工厂代码

@Bean
    public JmsListenerContainerFactory<?> FactoryName(ConnectionFactory connectionFactory) {
        DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory);
        factory.setPubSubDomain(true); // 启用Topic模式
        factory.setRecoveryInterval(5000L); // 每5秒尝试恢复连接(关键配置!)
        return factory;
    }

优劣势

  • SimpleJmsListenerContainerFactory 的局限性:
    它缺乏可靠的重连机制,无法保证在 MQ 重启后能够恢复监听。
    没有配置重连间隔(如 recoveryInterval),导致重连行为不可控。

  • DefaultJmsListenerContainerFactory 的优势:
    提供了可靠的重连机制,支持自定义重连间隔(如 setRecoveryInterval(5000L))。
    支持会话缓存,能够更高效地恢复监听。
    MQ 重启后,能够自动恢复连接并继续监听消息。

注意:如果必须使用 SimpleJmsListenerContainerFactory,可以在应用层实现自定义的重连逻辑,但这种方式复杂且不够可靠。

总结

第一个代码(使用 SimpleJmsListenerContainerFactory)在 MQ 重启后可能无法实现重新监听,因为它缺乏可靠的重连机制和重连间隔配置。第二个代码(使用 DefaultJmsListenerContainerFactory)通过配置 recoveryInterval 和会话缓存,能够更可靠地恢复监听,因此更适合用于生产环境。


http://www.kler.cn/a/588735.html

相关文章:

  • Pytorch:Dataset的加载
  • 百度贴吧IP和ID是什么意思?怎么查看
  • NPU、边缘计算与算力都是什么啊?
  • [leetcode] 面试经典 150 题——篇3:滑动窗口
  • 一分钟了解深度学习
  • Lisp语言的网络管理
  • 利用Java爬虫根据关键词获取商品列表:实战指南
  • 一份C#的笔试题及答案
  • 【NLP】 4. NLP项目流程与上下文窗口大小参数的影响
  • Kafka可视化工具KafkaTool工具的使用
  • Lua语言的嵌入式调试
  • qt 自带虚拟键盘的编译使用记录
  • 深入解析 React Diff 算法:原理、优化与实践
  • C或C++中实现数据结构课程中的链表、数组、树和图
  • matlab 模糊pid实现温度控制
  • nginx请求限流设置:常见的有基于 IP 地址的限流、基于请求速率的限流以及基于连接数的限流
  • Windows系统中安装Rust工具链方法
  • 数据结构篇——树(1)
  • 人工智能中神经网络是如何进行学习的
  • 1.Windows+vscode+cline+MCP配置