1 出现场景

rabbitmq 默认情况下,如果消费者程序出现异常，会自动实现补偿机制
消费者出现异常,消息不会消费成功

2 实现原理

2.1 @RabbitListener

@RabbitListener底层,使用Aop进行拦截，如果程序没有抛出异常，自动提交事务
如果Aop使用异常通知拦截 获取异常信息的话，自动实现补偿机制 ，该消息会缓存到rabbitmq服务器端进行存放，一直重试到不抛异常为准。

3 自定义重试

spring:
  rabbitmq:
    # 连接地址
    host: 127.0.0.1
    # 端口号
    port: 5672
    # 账号
    username: guest
    # 密码
    password: guest
    # 地址
    virtual-host: /
    listener:
      simple:
        retry:
          # 开启消费者（程序出现异常的情况下会）进行重试
          enabled: true
          # 最大重试次数
          max-attempts: 5
          # 重试间隔次数
          initial-interval: 3000
        # 开启手动ack
        acknowledge-mode: manual

4 如何选择重试机制

4.1 需要重试

调用第三方接口,提示连接超时,可以重试

通常来说:无需发布版本即可解决的异常都可以重试

4.2 无需重试

系统异常,如:空指针,数据转换异常等

通常来说:需发布版本即可解决的异常都无需重试

采用日志记录+定时任务+人工补偿进行解决

5 幂等性

设置消息id,如果消息消费成功,不在消费
如果业务逻辑中存在唯一id,如订单id,也可用订单id判重