当前位置:   article > 正文

消息队列中消息发送或者消费失败如何补偿_消息队列消费失败怎么办

消息队列消费失败怎么办

生产者发送消息失败:

​        设置mandatory=true:交换器无法根据自身的类型和路由键找到一个符合条件的队列的话,那么RabbitMQ会调用Basic.Return命令将消息返回给生产者

​        生产者将信道设置成confirm(确认)模式:一旦信道进入confirm模式,所有在该信道上面发布的消息都会被指派一个唯一的ID(从1开始),一旦消息被投递到所有匹配的队列之后,RabbitMQ就会发送一个确认(Basic.Ack)给生产者(包含消息的唯一ID)

消费者消费消息失败:

​        设置死信队列:消息进入死信队列,设置重新发送到正常队列的重试时间和重试间隔,重新发送到正常队列

​        将消息存入本地客户端:进行重发

​    补偿策略:当消息消费失败后,进入死信队列,获取对应死信队列的消息长度,当大于0时并判断未超过重试次数,自动将消息从死信队列迁移到正常队列

死信队列:如果队列里的消息出现存活时间超过设置的生存时间(TTL)时间、消息数量已经超过最大队列长度,该消息将成为“死信”。“死信”消息会被RabbitMQ进行特殊处理,如果配置了死信队列信息,那么该消息将会被丢进死信队列中,如果没有配置,则该消息将会被丢弃。

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/空白诗007/article/detail/996774
推荐阅读
相关标签
  

闽ICP备14008679号