Rabbitmq services 故障恢复正常后, Spring boot rabbitmq consumer 自动重连,重新消费消息。
RabbitMQ集群节点挂掉,恢复之后,Spring boot应用重新连接恢复,自动消费消息的配置。
·
1,最近由于公司业务量剧增,后台数据库压力和数据越来越多,从而使spring boot 应用的rabbitmq consumer 消费消息速度变慢,导致rabbitmq集群的某个节点消息堆积,当节点的消息数堆积超过节点内存的极限时,节点就会挂掉,这是所有依赖rabbitmq这个节点的应用默认情况下就会重连三次,重连三次失败之后就放弃连接,这样会造成当rabbitmq节点问题解决后,所有连接该节点的应用要重新启动,才能让消费者消费,这对于要管理很多微服务的程序员同学来说,就不是很友好,所以下面为各位同学提供一个Spring boot 设置自动重连,重新消费消息的配置。具体实现如下:
如图所示为SimpleRabbitListenerContainerFactory 设置MissingQueueFatal的属性值为false,即可。
更多推荐
已为社区贡献2条内容
所有评论(0)