粉色的网站,企业网络组建工作流程,稿定设计app下载安装,工作表现怎么写什么是幂等性#xff1f;----》多次调用接口#xff0c;得到的结果都一样。
用幂等性来解决重复消费的问题。
重复消费可以解决吗-----》重复消费根部避免不了。只能从消息的幂等消费入手。
为什么会有重复消费#xff1f;
由于我们要求RocketMQ消息不丢失#xff0c;要…什么是幂等性----》多次调用接口得到的结果都一样。
用幂等性来解决重复消费的问题。
重复消费可以解决吗-----》重复消费根部避免不了。只能从消息的幂等消费入手。
为什么会有重复消费
由于我们要求RocketMQ消息不丢失要保证消息不丢失就会有重传机制。消息发送成功但是broker端提示你发送消息失败了可能是因为网络波动导致超时的生产者就会重新发送所以生产者就重复发送了2条数据。远程网络环境成功的一定成功失败的不一定失败可能由于网络原因ack没有打到生产者那里生产者要重发。
**既然避免不了消息的重复消费那下游如何做幂等**
上游给下游传递一个唯一的unique key 比如订单就用订单号下游根据这个key建立数据库的唯一索引约束每次消费的时候就可以通过这个唯一索引来判断是否已经被消费过了。为了性能更高的话还可以考虑加分布式锁。