RabbitMQ消费端异常进入死循环

您所在的位置:网站首页 rabbitmq报错后一直发消息 RabbitMQ消费端异常进入死循环

RabbitMQ消费端异常进入死循环

2024-07-08 05:26| 来源: 网络整理| 查看: 265

RabbitMQ实现消费端异常处理 前言

思考:因为在开发项目时,RabbitMQ的消费端出现了异常(工具类操作文件时,未找到文件路径)。由于在此之前并未对该异常进行预判,导致异常出现后,消费端仍然对MQ的消息进行消费,但是出现异常后无法对MQ进行回复,所以造成后果消费端一直消费该条信息,进入死循环!

从而引发了自己的思考:1. 开发时难免会出现异常,这种异常如果事先未预判,那么在程序运行中,消费端该怎么避免以上出现的死循环;2. 如果事先预判到异常,对其进行了抛出或捕获,消费端又该如何表现?

异常

第一种方法,可以对可能发生异常的部分try、catch;只要事先将问题catch住,就证明消费端已经将该问题消费掉,然后该消息就不存在于队列中,不会造成无限报错的情况。这里,你可以在catch中写一些业务,把这个出现异常的“消息”记录到数据库或者怎么怎么处理,反正是相当于被消费掉了。

第二种方法,"消费者重试"模式。基本配置同一,只是在catch中显式的抛异常。这样其实就和没有catch差不多,就相当于未知状况下出现了异常。catch是为了解决业务问题,在这里处理自己需要的业务。catch中的throw有什么用呢?

throw配合着application.yml中的“开启消费者重试”模式:若异常发生,重试n次(n为yml中的 max-attempts),之后消息就自动进入死信队列(或者如果没配置死信队列,消息被扔掉)。

具体如下,消费者的mq配置类中设置了死信队列(参数只有死信交换机和路由,没有TTL)。

@Configuration public class RabbitmqConfig { public static final String QUEUE_INFORM_EMAIL = "queue_inform_email"; public static final String EXCHANGE_TOPICS_INFORM="exchange_topics_inform"; public static final String ROUTINGKEY_EMAIL="inform.#.email.#"; //声明交换机 @Bean(EXCHANGE_TOPICS_INFORM) public Exchange EXCHANGE_TOPICS_INFORM(){ return ExchangeBuilder.topicExchange(EXCHANGE_TOPICS_INFORM).durable(true).build(); } //声明QUEUE_INFORM_EMAIL队列,配置死信队列需要的参数 @Bean


【本文地址】


今日新闻


推荐新闻


CopyRight 2018-2019 办公设备维修网 版权所有 豫ICP备15022753号-3