- 时间:2022-07-18 00:20 编辑: 来源: 阅读:286
- 扫一扫,手机访问
摘要:原来大厂的Redis分布式锁都是这样设计的!
<导航网站源码>
1常用本地锁,即JDK自带的锁,如synchronize或lock,只能锁定当前进程,只适用于单片架构服务。 但在分布式多服务实例场景下,需要使用分布式锁2分布式锁2.1分布式锁原理。厕所占坑理论可以同时去一个地方“占坑”:如果被占,执行逻辑或者等到锁可以释放,“占坑”可以去Redis,DB,所有服务都可以访问的任何地方。 2.2分布式锁进化阶段1//占领分布式锁,移除redis占领坑布尔锁= redistemplate.ops for value()。setifabsent ("lock "," 111 ");If(lock) {//锁定成功...执行业务地图< String,List & ltCatelog2Vo & gt& gtdata fromdb = getDataFromDb();redisTemplate。delete(键:“锁”);//fhti返回数据romDb} else {//锁定失败,请重试 Synchronized() //休眠100ms后再试//Spin返回GetCatalogJSONFromdBWITHREDISLOCK();}问题场景setnx占了坑,但是执行过程中业务代码异常或者程序宕机,即不执行成功删除锁的逻辑,导致死锁处理方案:设置锁自动过期,即使不删除也自动删除。 阶段2 // 1\。占用分布式锁,移除redis以占用pit布尔锁= redistemplate.ops for value()。Setifabsent ("lock "," 110 ")if(lock){//锁定成功...执行业务//突然断电// 2\。设置过期时间redistemplate.expire ("lock ",timeout: 30,time unit . seconds);地图& lt字符串,列表& ltCatelog2Vo & gt& gtdata fromdb = getDataFromDb();//删除锁redisTemplate。删除(键;“锁”);返回dataFromDb} else {//锁定失败...再试一次。 Synchronized () //休眠100ms重试//Spin方式返回getCatalogJSONF romdbwithRedisLock();}问题场景setnx设置完毕,即将设置到期时间、停机时间、死锁。解决方案:设置到期时间和占用必须是原子操作。 Redis支持使用setNxEx命令phase three image// 1\分布式锁坑布尔锁= redistemplate。价值运营()。Setifabsent("锁"," 110 ",300,时间单位。秒);如果(lock)( //锁定成功,则执行业务// 2\。设置到期时间,必须和lock//redisttemplate . expire(" lock ",з 0,timeunit.seconds)一起作为原子操作使用;地图& lt字符串,列表& ltCatelog2Vo & gt& gtdata fromdb = getDataFromDb();//删除锁redis template . Delete(key:“lock”)并从db返回数据;Else {//锁失败,再试//休眠100ms,再试//Spin Return GetCatalogJSONFromdBithreDislock()}第四期已经拿到了lockvalue,有UUID,但是现在已经过期了!其余的人得到了锁并设置了新的值,所以如果删除了其他人的锁!!也就是说,删除锁不是原子操作。 地图& lt字符串,列表& ltCatelog2Vo & gt& gtdata fromdb = getDataFromDb();string lock value = redis template . ops for value()。get(" lock ");If(uuid.equals(lockValue)) {//删除我自己的锁redis template . Delete(" lock ");}问题场景如果恰好是当前值,在锁即将被删除的时候,锁已经过期,别人已经成功设置了新值。 删除的是别人的锁。删除锁时,解决方案必须确保原子性。 使用redis+Lua脚本 第五阶段,确保锁定/解锁是原子操作string script = " ifredis . call(' get ',keys [1]) = = argv [1]然后返回redis.call ('del ',keys [1])否则返回0 end ";保证锁定[占用+到期时间]和删除[判断+删除]的原子性。 更困难的事情,锁的自动更新 写到最后,如果看完还有什么不明白的,可以在下面留言讨论。感谢您的观看。 记得关注我,觉得文章对你有帮助就给我赞!作者:JavaEdge in掘金链接:https://juejin.cn/post/6922275721431744525