前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >记者式问答:组长能给我讲讲分布式锁吗?

记者式问答:组长能给我讲讲分布式锁吗?

作者头像
疯狂的KK
发布2020-06-28 15:34:51
4050
发布2020-06-28 15:34:51
举报
文章被收录于专栏:Java项目实战Java项目实战

前几天不是整理那个字节跳动的问题么,整理到了分布式锁,自己看了看有点无感,趁着业务需要,就问了下组长,并解释了情景及解决办法。

kk问:在忙吗?

组长答:不忙,在看昨天的问题。

kk问:我看**那业务那你写了个分布式锁,能讲下实现思路吗?

组长答:那个啊,那都写了好久了,我看下...

kk小声bb:我想问下咱们业务场景

组长答:这个就是咱们业务线在**业务这,以前没有定时任务,拉取热数据的时候,防止多服务拉取,出现重复调用什么的,情景很多,我先看下代码。

kk问:这个是基于redis实现的,但是我没看到哪里上锁啊?

组长答:这里么,大概思路就是先尝试获取下锁,

  1. 获取锁的时候,先判断能不能获取到锁,利用setNx,设置下k,v,超

时时间,如果返回1,就返回,因为K是唯一的么,这个判断及时多JVM线程进来

2.如果没获取到锁,ttl(key)判断下锁是不是过期了,锁已经过期,则认为业务流程失败,或出现意外,需要释放锁,释放锁时判断是否过期,以及是否是自己的锁,get(key).qeuals(v),然后del(key)

3.释放掉锁后,再加入新的锁。

kk问:这个我们传入的lock是啥啊?

组长答:这个我当时是用方法以及业务类型+时间戳的方式传进来的。

kk问:那这个超时时间呢?

组长答:这个不太好确定,因为你根据业务流程来看,有可能就是业务线响应慢,暂时没找到一个合适的超时时间。

kk问:那我不能在调用方法上加一个锁,使调用时串行化,或者用ReentryLock去加锁么?

组长答:你synchronized在多jvm下是无效的,单J锁在这种情况下都是失效的,现在分布式事务的话还是要用分布式锁,当然这个方法也存在很多问题。

kk问:什么情况会出现这个问题呢?

组长答:测试的时候,出现测试人员连点两下,极端情况下,一个线程打进来,进入A服务器进行获取,另一个线程进入B服务器获取,A获取到就返回了,B回去不到,就给释放了,不考虑redis崩的情况,后来让前端同学给按钮加了个禁用,点一次就让你等着就行了,然后测试拿着两台测试机,点一个页面后,在一一分钟后又点了一下,效果和这个相同,就为了防止这种现象。

kk问:这种场景会有什么问题吗?

组长(mmp,问个没完了):第一步获取锁的时候没问题,但是当连个线程同时打进来,都没过期的话,多JVM,一个线程去unlock了,两一个就的在这等,等等等,然后业务线下层调用响应时间又长,很容易超时,前端就得等

kk问:响应慢的话有什么解决办法吗?

组长答:有一个DefaultRedisList的实现,底层是队列BlockingDeque,你可以看下实现结合redis做的。

kk问:能举个例子么?

组长答:比如我们**业务,放两个队列,一个用来接收请求,一个用来异步回调,放两个MQ里,try...catch try send(),然后异步callback,这样的话基本时没有延迟的,用户感知很低,一个就去发送,异步的去拉队列就行了

kk问:callback能用Http吗?

组长答:不行,只能是mq去推,你看下其他的实现方法吧,整体逻辑是没问题的,但是现在这个方法被弃用了。

kk问:为什么被弃用了啊?

组长答:开始我们是为了防止多端定时任务同时拉取热数据的,但后来我们给定时任务Quartz做了,他基于数据库做的分布式锁,有一个定时在拉,其他的就不去执行了,你可以看看Quartz的实现。总体我们处理分布式锁的逻辑没有问题,你可以看看其他人的实现方式。

kk:好的,基本是了解了,我再消化消化,自己看还是不够主观,对场景不是很了解。

分布式锁总结见博客。

本文参与 腾讯云自媒体分享计划,分享自微信公众号。
原始发表:2020-06-20,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 赵KK日常技术记录 微信公众号,前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
相关产品与服务
云数据库 Redis
腾讯云数据库 Redis(TencentDB for Redis)是腾讯云打造的兼容 Redis 协议的缓存和存储服务。丰富的数据结构能帮助您完成不同类型的业务场景开发。支持主从热备,提供自动容灾切换、数据备份、故障迁移、实例监控、在线扩容、数据回档等全套的数据库服务。
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档