Lua+Redis 抢红包

相关技术

Redis是一个开源的使用ANSI C语言编写，支持网络、可基于内存亦可持久化的、日志型的KV数据库，Redis提供多种语言API。从2010年3年15日起，Redis的开发工作由VMware主持并由Pivotal赞助。

为什么要使用Redis

• 速度快
  单节点每秒可处理10W次请求，具体和机器配置相关。Redis对外提供的服务为单线程，采用了多路复用的方式较快的速度。
• 持久化
• Value值支持多种数据类型
  hash、list、set、map...
• 支持多种编程语言
• 功能丰富
• 主从复制
• 高可用及分布式

Redis使用KV键值对，其中key为字符串，value具有5种类型：

1. List列表类型

# 向key键添加v1 v2 v3三个数据
lpush key v1 v2 v3...
# 计算key键的个数
llen key
# 获取key键末尾节点并从list上删除
rpop key

2. Hash哈希类型

# 设置键名为key的hash数据
hset key field value
# 检查键名为key的某个字段是否有值
hexists key field

Redis的弱事务操作

为什么选择Lua实现核心业务

Lua是一个小巧的脚本语言，由标准ANSI C语言编写，Lua解释器不超过200K，是目前最快的脚本引擎。Lua语言提供数据操作的原子性。Lua脚本的特点是要么操作全部成功，要么操作全部失败，可弥补Redis的弱事务。

流程设计

1. 将所有红包全部存储到redis，也就是红包池子。
2. 用户抢了多少个红包，记录红包被抢的详细数据。
3. 用户只能抢一次红包，不能重复抢红包。

如何将多个红包放到队列中，用来初始化红包池子。

list

# 放入红包：将多个红包放入list队列
lpush redbagPool {rid:1001, money:1}
lpush redbagPool {rid:1002, money:2}
lpush redbagPool {rid:1003, money:3} 

# 抢红包：按顺序从队列依次弹出
rpop redbagPool

如何记录用户和抢了多少钱

记录用户和抢了多少钱

# 记录用户抢红包记录
lpush redbagUser {rid:1001, money:1, userid:101, create_time:'2019-92-16 12:00:00'}
lpush redbagUser {rid:1002, money:2, userid:102, create_time:'2019-92-16 12:00:00' }
lpush redbagUser {rid:1003, money:3, userid:103, create_time:'2019-92-16 12:00:00'}

如何记录当前哪些用户已经抢过红包，防止重复抢？

抢过红包的人

# 将已经抢过红包的用户加入黑名单
hset redbagBlacklist 101 1001
hset redbagBlacklist 102 1002
hset redbagBlacklist 103 1003
  
# 检查是否有重复记录若返回1则表示已经存在
hexists redbagBlacklist 101

实现步骤

1. Redis初始化红包

# 将多个红包数据存入redbagPool列表中
plush redbagPool {rid:1001, money:1}
...

2. Lua实现抢红包流程

   
   Lua实现抢红包流程

3. 代码实现

do
    local userid = 101
    -- 查询用户是否已经抢过红包
    if redis.call("hexists", "redbagBlacklist", userid)~=0 then
        return nil
    end

    -- 从红包池中获取红包
    local redbag = redis.call("rpop", "redbagPool")
    -- 判断红包池是否为空
    if redbag==nil then
        return nil
    end


    -- 解析红包数据
    local item = cjson.decode(redbag)

    -- 将抢过的用户与红包添加到黑名单
    redis.call("hset", "redbagBlacklist", userid, item["rid"])

    -- 将抢红包结果存入记录
    item["userid"] = userid
    item["create_time"] = os.time()
    local redbagUser = cjson.encode(item)
    redis.call("lpush", "redbagUser", redbagUser)

    return redbagUser
end