当前位置:

首页 > 编程开发 > 如何在Java分布式系统中保证幂等性?

如何在Java分布式系统中保证幂等性?

1、幂等的概念面试官:幂等的概念你了解吗,你设计的系统里有哪些接口使用到了幂等设计?问题分析:幂等的概念首先你肯定理解了,简单通俗易懂,就是无论你是Http接口还是RPC接口,入参不变的情况下,无论请求多少次,结果都是一样的,请求结果不会因为请求次数不同而改变,没有任务副作用。答:我参加工作的第一年,在某在线购票(电影票)App的一家公司做后台系统开发,当时我负责积分系统,工作中接到这样一个线上活动需求。业务场景描述:用户每天使用App点击签到按钮参加活动,领取相应的积分,每个用户每天只能参加一次签到领积

本文目录

      1、幂等的概念

      面试官:

      幂等的概念你了解吗,你设计的系统里有哪些接口使用到了幂等设计?

      问题分析:

      幂等的概念首先你肯定理解了,简单通俗易懂,就是无论你是 Http 接口还是 RPC 接口,入参不变的情况下,无论请求多少次,结果都是一样的,请求结果不会因为请求次数不同而改变,没有任务副作用。

      答:我参加工作的第一年,在某在线购票(电影票)App的一家公司做后台系统开发,当时我负责积分系统,工作中接到这样一个线上活动需求。业务场景描述:用户每天使用 App 点击签到按钮参加活动,领取相应的积分,每个用户每天只能参加一次签到领积分活动,签到按钮在点击一次后会自设置灰色变为不可点击的状态,这个领积分的接口由我负责开发,提供 API 给客户端同事,上线后出现这样一个bug,当时没有完善的业务监控系统,功能上线后第二天问出于好奇系统里积分最高的人有多少积分,就在后台跑了一个sql,这一好奇,惊奇的发现有的用户积分高达几万分,因为积分除了签到领取外,大多都是消费累计积分,一块钱才能累积一分,我表示怀疑,什么能人看电影能看几万块钱?

      带着这个疑问,我查询了他的积分累积记录,发现大部分积分都是靠签到领积分获得的,按照活动规则,一个人一天只能参加一次签到,不可能有这么多积分,而这个用户一天签到几百次,后来经过和前端一同检查bug发现问题所在,原因是签到按钮虽然变灰,但是请求的 url 没有在前端页面隐藏,用户通过技术手段绕过 button 变灰的前端限制重复刷新了接口,重复获得积分。

      事后问题分析:

      这个bug最大问题还在我这里,因为我的接口没有做幂等设计,正确的逻辑应该是根据系统当前日期做幂等,幂等后无论用户发起多少次请求,最后的结果都是一样的,积分只累加一次。好在这个bug没有被黑产发现,只有几个用户发现损失可控。

      因为我缺少设计经验,不懂幂等设计,领导也没提醒我,所以出现这种bug,经历更多和钱相关的系统开发后,我明白一个道理,任何系统设计,都要考虑业务的安全性,内部系统可以为了节省人力,适当简化设计,做到防君子不防小人,假设你的同事都是君子,对C端用户的系统,不光要防君子,还要防小人,风险防范不能全指望风控系统,有时bug可能会来自系统内部,比如用户并没有恶意盗刷之意,只是网络不好,用户等了两秒钟还没加载完就多点了几次签到按钮,我的接口没有做幂等设计,只要收到请求就会多给用户加积分,这个时候能怪用户吗?很显然是开发者的责任。

      关于这个接口的幂等设计

      我是这样解决的:

      积分接口后台根据用户手机号 + userId + 系统当前日期拼接后生成唯一流水号,根据流水号后保存,如果用户重复发起请求,先根据唯一流水号校验在后台做校验,如果流水号存在直接返回上一次请求结果,考虑到并发的情况下,状态判断使用了锁处理。

      开发业务监控系统,采用定时任务每天生成系统里 Top100 积分增长最多名单,运营或者术人员每天观察有没有异常。

      如何在Java分布式系统中保证幂等性?

      经过这次bug反思,学习到两点:

      理解幂等设计的重要性,凡是和钱相关的功能请谨慎。

      监控系统的重要性,这里的监控说的是业务类监控,如果那天我没有好奇系统里谁的积分最高,这个bug会什么时候发现?

      面试官: 嚯,有点意思,你还真的是写了个大bug,弄懂了吸取教训就好,可别进了我的项目组后拿我们的系统写这bug。

      深入分析:

      在编程中一个幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同。幂等函数,或幂等方法,是指可以使用相同参数重复执行,并能获得相同结果的函数。这些函数不会影响系统状态,也不用担心重复执行会对系统造成改变。例如,“setTrue()”函数就是一个幂等函数,无论多次执行,其结果都是一样的。更复杂的操作幂等保证是利用唯一交易号(流水号)实现。

       —— 百度百科

      如果你了解 Restful 风格接口,相信你对 GET / POST / DELETE 几个动词不陌生,在一次面试锤子科技的过程中,面试官问我是否了解 Rest 接口,我balabala回答了这几常用的动词,面试官又问我:那你除了知道 GET 是从服务器获取资源,还有别的理解吗?当时我没答上来,出了公司以后才想起,GET 动作的设计应该是幂等的。同理 DELETE 也是幂等的,如果你设计的接口 GET / DELETE 不是幂等的,那么你可能要重新思考一下了。

      2、工作中常见的幂等设计场景

      如果你做的功能和钱相关,或者是能还钱的,那么你就要小心了,每一个接口都要先考虑下是否需要幂等设计,下面是两种常见的需求场景。

      发券/积分接口,通常通过 orderId userId 做幂等校验。

      支付/退款接口,我们不希望用户发起多次支付都收到用户的钱,用户会投诉,还要把钱退还给用户,对系统还是客服人员来说都是无用功,支付系统非常复杂,想做好支付系统,还有很多东西需要学习,要考虑网络延迟,服务异常,订单中心回掉超时等各种不稳定的因素,通常采用前端控制,逻辑层状态的控制,数据层唯一索引的控制,以及分布式锁的控制,在幂等篇不过过多讨论。

      3、幂等接口常见设计方案

      客户端按钮提交限制,每次提交一个请求时,按钮置为不可用。

      后台系统逻辑层处理,生成保存唯一ID(流水号),每次请求先校验流水号是否已经存在,存在则表示重复操作,直接返回上一次操作结果。

      token校验机制,客户端请求前先申请token,同一个token只处理一次,无token或者相同token不做处理。

      分布式锁,如引入 Redis 分布式锁,防止其他请求重复操作。

      请求队列,引入 MQ 排队的方式让请求有序处理,关于异步操作的应用会在后面的章节讲解。

      每一种方案都有自己的优缺点,比如客服端按钮提交限制,实现简单,但是不能从根本上解决问题,后台生成唯一ID,判断存在状态必须要保证原子操作,可以采用多种方案组合的方式解决幂等问题,我们的目标是,用最容易维护的方法解决问题。

      本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系bd@zhengruan.com
      作者最新文章
      编程开发 Java
      相关文章 更多
      Java单元测试入门:使用JUnit 5编写第一个测试用例
      Java单元测试入门:使用JUnit 5编写第一个测试用例

      面向初学者的JUnit 5实用入门指南。从测试概念、Maven依赖配置,到手把手编写首个单元测试用例及断言验证,助你掌握Java单元测试的核心流程。

      Java变量未初始化报错解析:局部变量与成员变量默认值差异
      Java变量未初始化报错解析:局部变量与成员变量默认值差异

      深入解析Java中局部变量未初始化编译报错与成员变量自动赋予默认值的机制差异,涵盖JVM内存分配、编译期确定性赋值检查与实际排查修复方案。

      Java获取当前时间并格式化输出:DateTimeFormatter与SimpleDateFormat
      Java获取当前时间并格式化输出:DateTimeFormatter与SimpleDateFormat

      详细讲解在Java中获取当前系统时间并进行格式化输出的两种核心方案:基于Java 8全新日期时间API的DateTimeFormatter与传统遗留的SimpleDateFormat,包含完整代码示例、线程安全机制对比及生产选型建议。

      Java中final与static final常量的定义及初始化规则
      Java中final与static final常量的定义及初始化规则

      深入解析Java中final变量与static final常量的定义、内存语义、初始化时机及合法赋值路径,涵盖编译期常量优化与实战避坑指南。

      Java抽象方法与接口方法的区别及选型建议
      Java抽象方法与接口方法的区别及选型建议

      深入对比Java中抽象类抽象方法与接口方法的语法演进、设计意图及运行期差异,并提供清晰的架构选型决策流程与实战范例。

      Java实现HTTP请求与JSON解析的完整代码示例
      Java实现HTTP请求与JSON解析的完整代码示例

      本文提供Java标准库HttpClient发起HTTP GET/POST请求并结合Jackson进行JSON数据反序列化与序列化的完整代码示例与工程实践指南。

      Java递归出现StackOverflowError的原因分析及栈空间优化方案
      Java递归出现StackOverflowError的原因分析及栈空间优化方案

      详细分析Java递归调用出现StackOverflowError的原因,结合代码说明线程栈、栈帧和递归深度之间的关系,并介绍终止条件排查、迭代改写、减少栈帧开销以及通过-Xss调整JVM栈空间的方法。

      Java空指针异常(NPE)的代码排查与修复实例
      Java空指针异常(NPE)的代码排查与修复实例

      针对Java中常见的NullPointerException(NPE),本文从堆栈日志定位、典型代码触发场景、具体修复代码对比到防御体系进行系统讲解,提供实用且易上手的排查与修复方案。

      selenium上传文件教程本地文件路径设置方法
      selenium上传文件教程本地文件路径设置方法

      深入解析Selenium处理文件上传的技术细节,涵盖标准HTML控件的路径直接注入法与非标准控件的系统级模拟方案,提供Windows与Linux环境下的路径设置最佳实践及常见异常排查。

      大数据开发语言选型:Java对比Scala与Python的优缺点及适用场景
      大数据开发语言选型:Java对比Scala与Python的优缺点及适用场景

      针对大数据工程场景,系统对比Java、Scala与Python在执行性能、生态结合、开发效率和维护成本上的核心差异,给出清晰的架构选型依据与落地方案。

      查看更多
      精品专题 更多
      装机必备
      装机必备

      正软商城装机必备专区,精选办公、浏览器、安全防护、影音播放、压缩解压、设计创作和系统工具等电脑常用正版软件,帮助用户快速完成新电脑软件配置。

      Windows
      Windows

      正软商城Windows软件专区,汇集适用于Windows电脑的办公、设计、安全防护、影音播放、开发工具和系统优化软件,提供软件介绍、系统要求、正版授权及购买下载服务。

      PDF教程
      PDF教程

      正软商城PDF教程频道提供PDF编辑、转换、合并、拆分、压缩及格式处理方法,同时介绍常用PDF软件和工具的使用技巧。

      Mac软件 更多
      讯飞智作 网页版
      讯飞智作 网页版
      Windows/ macOS/ Linux

      讯飞智作是一款基于语音合成技术、虚拟人驱动技术与数字人形象声音构建能力的 AI 数字人音视频创作平台。

      火山引擎 网页版
      火山引擎 网页版
      Windows/ macOS/ Linux

      火山引擎是字节跳动旗下企业级云与AI服务平台。聚焦大模型核心能力,依托字节自研豆包多模态大模型,凭借火山方舟一站式平台,提供模型精调、推理部署、智能应用搭建等全链路服务,结合高性能AI算力,助力各行业快速落地大模型数字化与智能化应用。

      Aperty macOS版
      Aperty macOS版
      macOS

      Aperty 是 Skylum 推出的 AI 人像修图软件,支持自然肤质修饰、瑕疵处理、面部与身体调整、预设及批量同步。

      WINDOWS 更多
      讯飞智作 网页版
      讯飞智作 网页版
      Windows/ macOS/ Linux

      讯飞智作是一款基于语音合成技术、虚拟人驱动技术与数字人形象声音构建能力的 AI 数字人音视频创作平台。

      火山引擎 网页版
      火山引擎 网页版
      Windows/ macOS/ Linux

      火山引擎是字节跳动旗下企业级云与AI服务平台。聚焦大模型核心能力,依托字节自研豆包多模态大模型,凭借火山方舟一站式平台,提供模型精调、推理部署、智能应用搭建等全链路服务,结合高性能AI算力,助力各行业快速落地大模型数字化与智能化应用。

      PixTV 网页版
      PixTV 网页版
      Windows

      PixTV 是一款在浏览器中使用的 AI 视觉内容创作平台,提供图片、视频、音频、文字生成、AI 分镜、局部重绘、提示词反推和无限画布等工具,适合短剧、漫剧、广告及社交媒体内容制作。