RabbitMQ--消息重复/重复消费--原因/如何解决/避免--消息异常

阳光穿透心脏的1/2处 2022-09-14 00:22 313阅读 0赞

原文网址：RabbitMQ—消息重复/重复消费—原因/如何解决/避免—消息异常_IT利刃出鞘的博客-CSDN博客

什么时候会重复消费

自动提交模式时

消费者收到消息后，要自动提交，但提交后，网络出故障，RabbitMQ服务器没收到提交消息，那么此消息会被重新放入队列，会再次发给消费者。

手动提交模式时

情景1：网络故障问题，同上。
情景2：接收到消息并处理结束了，此时消费者挂了，没有手动提交消息。

解决方案

简介

造成消息重复的两个原因是：网络不可达、消费端宕机。无法避免这两个问题，解决方法就是绕过这个问题。

问题就变成了：如果消费端收到两条一样的消息，应该怎样处理？

方案1：消费者保证业务幂等性

消费端处理消息的业务逻辑保持幂等性。

  • 比如你拿个数据要写库，先根据主键查一下，如果这数据有了，就别插入了，update 一下。
  • 比如你是写 Redis，那没问题了，反正每次都是 set，天然幂等性。

方案2：消费者用消息日志保证幂等

利用一张日志表来记录已经处理成功的消息的 ID，如果新到的消息 ID 已经在日志表中，那么就不再处理这条消息。

注意：此时需要保证每个消息都有唯一的id。

发表评论

表情：
评论列表 （有 0 条评论，313人围观）

还没有评论，来说两句吧...

相关阅读

    相关 MQ如何避免消息重复消费

        消息中间件是分布式系统常用的组件，无论是异步化、解耦、削峰等都有广泛的应用价值。     我们通常会认为，消息中间件是一个可靠的组件——这里所谓的可靠是指，只要我把消

    今天药忘吃喽~今天药忘吃喽~/ 0 赞/ 69 阅读

    相关 队列消息重复消费解决

    如何保证消息不被重复消费（如何保证消息消费时的幂等性）？ 其实这个很常见的一个问题，这俩问题基本可以连起来问。既然是消费消息，那肯定要考虑考虑会不会重复消费？能不能避免重

    曾经终败给现在曾经终败给现在/ 0 赞/ 83 阅读

    相关 RabbitMQ消息重复消费问题

    业务背景 消息队列在数据传输的过程中，为了保证消息传递的可靠性，一般会对消息采用ack确认机制，如果消息传递失败，消息队列会进行重试，此时便可能存在消息重复消费的问题。

    Bertha 。Bertha 。/ 0 赞/ 274 阅读

    相关 如何解决消息的重复消费

    如何解决消息的重复消费 面试题引入 面试题剖析 面试题引入 在消息队列领域，如何解决消息的重复消费是很常见的一个问题。既然是消费消息，那肯定要考虑会不

    末蓝、末蓝、/ 0 赞/ 819 阅读