首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往
  • 您找到你想要的搜索结果了吗?
    是的
    没有找到

    Redis锁的介绍「建议收藏」

    Redis锁的实现: 由于Redis是单进程的,可以简单用setnx这个命令进行加锁操作,谁能操作成功,谁就可以获得锁。简单的代码如下: def acquire_lock(): # identifier: 唯一标识客户端 # lockname 锁名字 # redis 客户端连接 if redis.setnx(lockname, identifier): return True return False 这里有一个问题,就是如果客户端在获得锁的时候崩溃了,服务器就无法再把锁分配给其他客户端使用了,为了解决这个问题,我们可以利用redis的超时特性,给锁加上超时时间 def acquire_lock(): # identifier: 唯一标识客户端 # lockname 锁名字 # redis 客户端连接 # timeout 超时时间 if redis.setnx(lockname, identifier): redis.expire(lockname, timeout) return True elif not redis.ttl(lockname): redis.expire(lockname, timeout) return False return False 可以这样认为,多个客户端同时设置过期时间也是差别不大的,我们在发现锁已经存在并且没有超时限制时,给锁加上超时限制,这样可以在其他客户端获得锁并未设置超时时间崩溃了,也能在过期时间到了让其他客户端获取到锁。最新官方文档支持用set命令指定超时和nx特性, def acquire_lock(): # identifier: 唯一标识客户端 # lockname 锁名字 # redis 客户端连接 # timeout 超时时间 if redis.set(lockname, identifier, nx=True, ex=timeout): return True return False 解锁操作,直接执行一段lua脚本 def release_lock(): # identifier: 唯一标识客户端 # lockname 锁名字 # redis 客户端连接 script = “”” if redis.call(‘GET’, KEYS[1]) == ARGV[1] then return redis.call(‘DEL’, KEYS[1]) else return 0 “”” return redis.eval(script, lockname, identifier) 使用lua脚本可以原子的操作解锁过程,这里需要注意点,eval的key是要传的,这样代码也可以在redis集群中使用,否则redis不知道lua脚本应该在哪一个槽进行执行,具体可以看官方的文档

    02

    Go实战项目-Beego的Session、日志文件的使用和redis的选择使用

    go标准库里面没有实现这功能,只能靠自己实现了,哦,不,是第三方库。好在beego就自带session功能,这个之前就说过了。我们只是简单使用下,高并发场景估计还得自己来实现,单纯的靠这个框架,够呛。来看下怎么使用: 1、在调用之前就需要开启 beego.BConfig.WebConfig.Session.SessionOn = true //开始session beego目前支持四种session的存储引擎 memory、file、Redis 和 MySQL 默认就是memory ,但是,你重启之后就失效了,这除了写demo可以用之外,就算是保活的进程也是很肉痛,基于之前PHP框架保存文件的处理方式,我这边也是存放文件中。 2、设置存储引擎 beego.BConfig.WebConfig.Session.SessionProvider = “file” //指定文件存储方式 3、设置存储路径 beego.BConfig.WebConfig.Session.SessionProviderConfig = “./.tmp” //指定文件存储路径地址,也可以不指定,有默认的地址。 建议,存储的文件夹名称加上“.”,这样方便git提交的时候直接过滤,但是一般情况下,没事不要去下载,或者放在项目以外的其他路径也是可以的。这样就是永久保存了,重启依然有效。

    03
    领券