Rabbitmq services 故障恢复正常后, Spring boot rabbitmq consumer 自动重连,重新消费消息。

2022-07-14 12:16:34

1,最近由于公司业务量剧增,后台数据库压力和数据越来越多,从而使spring boot 应用的rabbitmq consumer 消费消息速度变慢,导致rabbitmq集群的某个节点消息堆积,当节点的消息数堆积超过节点内存的极限时,节点就会挂掉,这是所有依赖rabbitmq这个节点的应用默认情况下就会重连三次,重连三次失败之后就放弃连接,这样会造成当rabbitmq节点问题解决后,所有连接该节点的应用要重新启动,才能让消费者消费,这对于要管理很多微服务的程序员同学来说,就不是很友好,所以下面为各位同学提供一个Spring boot 设置自动重连,重新消费消息的配置。具体实现如下:

 如图所示为SimpleRabbitListenerContainerFactory 设置MissingQueueFatal的属性值为false,即可。

  • 作者:Angy__
  • 原文链接:https://blog.csdn.net/weixin_39896810/article/details/121774885
    更新时间:2022-07-14 12:16:34