为了账号安全,请及时绑定邮箱和手机立即绑定

跪求!redis实现分布式锁,如何持续抢锁操作?

跪求!redis实现分布式锁,如何持续抢锁操作?

蓝山帝景 2019-06-13 09:55:56
新手初学redis,尝试redis锁的时候,go代码如下:funcmain(){client:=redis.NewClient(&redis.Options{Addr:"localhost:6379",})fori:=0;i<100;i++{gofunc(){for{//一直for循环抢锁吗?ok,err:=client.SetNX("sync",true,time.Second*5).Result()iferr==nil&&ok{res,err:=client.Get("num").Result()fmt.Printf("num:%s\n",res)num,err:=strconv.Atoi(res)err=client.Set("num",num+1,0).Err()_,err=client.Del("sync").Result()iferr!=nil{log.Println(err)}break}//time.Sleep(time.Millisecond*10)}}()}time.Sleep(time.Second*20)}代码中我开了100个协程抢锁,操作一个数据.我的疑问是,当一个协程抢到了这个sync锁,那么其他的99个协程,都一直在不停的在一个循环中重复抢锁吗?这样子是否会对redis产生大量的无意义的请求...网上搜了一下相关的实现demo代码,发现都是类似的while(true){//xxxxxxx}进行抢锁....所以很疑惑,若是真实生产环境也是这样实现嘛....还是我一开始就错了...如果有相关资料或者是搜索关键词,还望大佬指点一二.
查看完整描述

2 回答

?
PIPIONE

TA贡献1829条经验 获得超9个赞

看你要实现什么样的锁,或者基于什么样的使用场景,比如说排它锁,redis就实现不了,排它锁在获取不到锁的情况下会阻塞进入等待队列。在其他进程释放锁时会通知该进程再去获取锁,redis不提供这种基于key的通知机制,所以他实现不了排它锁。不过分布式排它锁,可以由Zookeeper实现。
另外一种分布式锁的实现方式是通过乐观锁和自旋的实现方式,就是你说的那种方式,不过一般会设置超时时间,也就是redis设置key的ttl。这样不至于进程一直等待下去。这种锁适应于锁内操作时间比较短,锁竞争不是那么激烈的情况。
你说的那种100个进程抢锁的情况,竞争这么激烈,还是用排它锁比较好。
                            
查看完整回答
反对 回复 2019-06-13
?
白衣染霜花

TA贡献1796条经验 获得超10个赞

这个原因充分说明了要项目驱动学习。只有你知道具体的项目的场景,才可以决定自己这个锁怎么处理。比如,你如果抢不到资源就必须等待,而且是同步请求,那么必须等待。比如,你如果可以接受若一致,就可以考虑等待多久锁,然后放弃,记录日志或者其他补偿机制。当然这个就类似于ReentrantLock里面的tryLock和tryLock(longtimeout,TimeUnitunit)的区别
                            
查看完整回答
反对 回复 2019-06-13
  • 2 回答
  • 0 关注
  • 753 浏览
慕课专栏
更多

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信