微服务框架 SpringCloud微服务架构服务异步通讯 50 消息可靠性 50.4 失败重试机制 50.4.1 消费者失败重试

news2024/11/23 10:39:34

微服务框架

【SpringCloud+RabbitMQ+Docker+Redis+搜索+分布式，系统详解springcloud微服务技术栈课程|黑马程序员Java微服务】

服务异步通讯

文章目录

- - 微服务框架
  - 服务异步通讯
  - 50 消息可靠性
  - - 50.4 失败重试机制
    - - 50.4.1 消费者失败重试

50 消息可靠性

50.4 失败重试机制

50.4.1 消费者失败重试

OK，上回我们已经实现了消费者的确认机制，

在这里插入图片描述

这种机制就能够确保消息至少能被消费者消费一次

不过这种模式也有一个问题：当消费者消费失败后，它会返回nack，这样消息会回到MQ 的队列中，这种消费者又监听到了，但是又消费失败，就出现了上节中的刷屏画面

如果代码没问题，可能消息最终可以被消费掉，但是如果代码本身有问题

在这里插入图片描述

这样就会一直“踢皮球”，给服务器带来很多的压力

【消费者失败重试机制】

当消费者出现异常后，消息会不断requeue（重新入队）到队列，再重新发送给消费者，然后再次异常，再次requeue，无限循环，导致mq的消息处理飙升，带来不必要的压力：

在这里插入图片描述

我们可以利用Spring的retry机制，在消费者出现异常时利用本地重试，而不是无限制的requeue到mq队列。

在这里插入图片描述

【牛逼！！】

试试

retry:
  enabled: true
  initial-interval: 1000
  multiplier: 3
  max-attempts: 4

在这里插入图片描述

修改一下监听

package cn.itcast.mq.listener;

import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Slf4j
@Component
public class SpringRabbitListener {

    @RabbitListener(queues = "simple.queue")
    public void listenSimpleQueue(String msg) {
        log.debug("消费者接收到simple.queue的消息：【" + msg + "】");
        System.out.println(1 / 0);
        log.info("消费者处理消息成功!");
    }
}