Redis笔记

Redis

KV存储

发布日期: 2024-09-08

更新日期: 2024-09-08

文章字数: 619

阅读时长: 2 分

阅读次数:

常见应用¶

分布式锁¶

set key value ex 秒数 nx

客户端加锁失败¶

三种方式:

直接抛出异常,通知用户稍后重试
sleep一会重试
将请求转移到延时队列,一会儿再重试

超时问题¶

不要用于较长时间的任务.

set指令的时候value设置为一个随机值.释放锁的时候判断随机数是否一致,再删除key.为了保证这个一个原子操作,需要变成lua脚本:

# delifequals
if redis.call("get",KEYS[1])==ARGV[1] then
    	return redis.call("del",KEYS[1])
    else
    	return 0
    end

可重入¶

对客户端的set进行重写,使用线程的Threadlocal变量存储当前持有锁的计数.

如果没有当前锁的计数则赋值1.锁未释放再次加锁,计数+1.lock操作相反.但是更精确需要考虑内存锁计数的过期时间.不推荐使用.

异步队列¶

使用list实现.左进右出或者左出右进.

使用sleep处理队列为空的情况,会导致队列出现延迟.推荐使用阻塞读blpop/brpop.没有数据时会立即休眠,数据到达时会理解醒来.需要注意长期阻塞,redis客户端的连接就成空闲链接,当服务器断开连接减少闲置资源占用时会导致blpop/brpop抛出异常,需要捕获异常及其重试.

延时队列¶

使用zset实现,消息体序列化为value,score设置为到期处理时间,多线程轮训zset获取到期任务处理.通过zrangebyscore(,0,time.time().start=0,num=1).每次获取一个进行处理,多线程同时竞争通过zrem成功作为抢到的唯一属性.处理逻辑需要异常捕获,避免执行问题导致循环退出.

优化:多个线程获取到同一个任务浪费cpu,可以将zrangebyscore和zrem放在lua中进行缘之花操作.