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判重
网友评论