activemq消息丢失和重复消费 消息队列,如何保证消息不被重复消费?
浏览量:1416
时间:2021-03-17 10:29:32
作者:admin
消息队列,如何保证消息不被重复消费?
现在消息机制一般是通过中间件实现的,如Kafka、ActiveMQ等。一般来说,有两种消费策略:至少一次和最多一次。
首先,至少一次。在这种情况下,使用消息很重要,不能容忍丢失。使用者从中间件集群中提取消息,在内部消费,并将消费结果通知集群。如果用户计算机重新启动或网络丢失数据包,此时将提取重复的消息。一般的解决方案是保证对使用者业务逻辑进行幂等处理。
第二,至少再来一次。此时,消息可能会丢失,并且不会重复消费。
作为接收器,保持接口幂等是一项基本功能。它可以处理一些意外情况,例如集群失败,或者需要跟踪消息数据的历史以便重新处理等。
activemq消息丢失和重复消费 activemq如何保证消息不丢失 activemq消息持久化
版权声明:本文内容由互联网用户自发贡献,本站不承担相关法律责任.如有侵权/违法内容,本站将立刻删除。