栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

分布式系统接口幂等性

分布式系统接口幂等性

一、什么是幂等性?

幂等性:指用户对于同一操作发起的一次请求或者多次请求的结果是一致的,不会因为多次点击而产生了不同结果。

二、为什么出现非幂等性问题?

在分布式系统中,接口由于有三态(成功、失败、无响应)的问题,为了提高系统的可用性,重试是不可避免的,重试就会引发幂等性问题,这是一个因果关系。

对于CRUD操作,查询和删除具有天然幂等性,而创建和更新操作将会产生幂等性问题。

三、如何解决幂等性?

3.1 前端页面控制

防止表单重复提交,按钮置灰、隐藏、不可点击等方式

3.2 防止重复处理

  • token
  • 状态机
  • redis去重

3.3 对于重试场景

  • 数据库唯一索引
  • 增加版本号
四、kafka如何保证消息幂等性?

4.1 消费者

防止重复消费:1、使用redis进行去重;

                         2、消息处理完成及时提交偏移量;

                         3、根据业务采取合理的方式;例如:如果是数据库则先判断消息是否存在,生产者记录全局ID,消费的时候判断全局ID是否存在,然后进行处理。

4.2 生产者

防止重复生产:1、生产端配置参数enable.idempotence = true,幂等性开启的时候acks即为all。

生产者发送给消息时携带消息的序号,broker端如果发现序号小于当前消息最小序号加一,说明该消息已经被发送过了,则拒绝接受。如果序号大于当前消息最小序号加一,则说明还有消息未发送成功,也拒绝接受。

kafka消息幂等性 - 简书 (jianshu.com)

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/674248.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号