redis lua

wskickahn

　　需求是在缓存最近一周内用户所有消息列表，考虑用Redis 存储；为每个存储一个独立Sorted Set，value 为消息体，Score 为MessageId，用以实现增量消息同步。
　　问题就来了：Sorted Set 怎么清理？
　　-设计内存容量只允许放一周内最新的，太久了缓存意义不大，太浪费。
　　-再者存在百万级/s群发请求，不允许写入时触发清理。
　　理想模型：如果使用磁盘则使用MyIsam堆表，数据按照顺序写入，再建立以uid为索引，删除却是完全顺序的。内存里面的话Hash 表 + RB 树两个维度索引，RB树可按照时间顺序清理。
　　解决方案：
　　- 写入第一条时，设置一周过期时间
　　判断是否第一条：zadd key 0 0 value score 返回2 说明第一条，1 不是第一条，只是多一条0的数据
　　- 用户每天第一次登陆，触发一次清理
　　清理需要遍历Sorted Set上，消息一般不小，浪费io流量了，所以考虑采用lua 脚本实现。
　　- 这样保证，通过pipeline只是高并发写入，同时保证活跃用户一周内消息都在内存（不活跃不保证），清理简单
　　
　　清理脚本如下：



local ltime = 0
local dels = 0
local lefts = 0
local list = redis.call("ZRANGE", KEYS[1], 1, -1)
if(list[1] == nil) then
return {-1, 0}
end
for _,v in ipairs(list) do
if lefts == 0 then
ltime = struct.unpack('