怎么使用Go和Lua解决Redis秒杀中库存与超卖问题

这篇文章主要介绍“怎么使用Go和lua解决Redis秒杀中库存与超卖问题”，在日常操作中，相信很多人在怎么使用Go和Lua解决Redis秒杀中库存与超卖问题问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”怎么使用Go和Lua解决Redis秒杀中库存与超卖问题”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！

0、简介

• Go语言连接go-redis进行数据库的连接，如果你对这部分尚不了解，建议你先学习这部分知识。

• 另外，本秒杀主要解决两个问题，第一个就是超卖问题，另一个就是库存问题。

• 没有设计专门的页面来模拟并发，我们直接使用gorountine，在调用请求前停留10s。

• 针对超卖问题，引入go-redis的watch搭配事务处理即可【相当于乐观锁】。

而针对库存的问题较为麻烦一点，需要使用Lua编辑脚本，但是你无需在自己的机器上下载lua的编译环境，go提供了其相关的支持。针对这一部分，不用慌张，其基本架构如下：

1、简单版

面对并发的情况下会出现超卖的情况，redis数据库中会出现负值的情况。即使你在操作之前进行了数据的判断。

func MsCode(uuid, prodid string) bool {     // 1、对uuid和prodid进行非空判断     if uuid == "" || prodid == "" {        return false     }       //2、获取连接     rdb := DB       //3、拼接key     kcKey := "kc:" + prodid + ":Qt"     userKey := "sk:" + prodid + ":user"       //4、获取库存     str, err := rdb.Get(ctx, kcKey).Result()     if err != nil {        fmt.Println(err)        fmt.Println("秒杀还未开始.......")        return false     }       // 5、判断用户是否重复秒杀操作     flag, err := rdb.SIsMember(ctx, userKey, userKey).Result()     if err != nil {        fmt.Println(err)     }     if flag {        fmt.Println("你已经参加了秒杀，无法再次参加。。。。")        return false     }       // 6、判断商品数量，如果库存数量小于1，秒杀结束     str, err = rdb.Get(ctx, kcKey).Result()     if err != nil {        fmt.Println(err)     }     n, err := strconv.Atoi(str)     if err != nil {        fmt.Println(err)     }     if n < 1 {        fmt.Println("秒杀结束，请下次再来吧。。。。")        return false     }       // 7、秒杀过程     // 7.1、库存减1     num, err := rdb.Decr(ctx, kcKey).Result()     if err != nil {        fmt.Println(err)     }     if num != 0 {        // 7.2、添加用户        rdb.SAdd(ctx, userKey, uuid)     }     return true  }func main() {    // 并发的版本    for i := 0; i < 20; i++ {        go func() {            uuid := GenerateUUID()            prodid := "1023"            time.Sleep(10 * time.Second)            MsCode(uuid, prodid)        }()    }    time.Sleep(15 * time.Second)}

2、解决超卖

使用watch进行监视key，关键部分如下。但是这样会造成一个问题，就是抢购不完，会有一些库存，但是又有人没有抢到。

err = rdb.Watch(ctx, func(tx *redis.Tx) error {     n, err := tx.Get(ctx, kcKey).Int()     if err != nil && err != redis.Nil {        return err     }     if n <= 0 {        return fmt.Errorf("抢购结束了！请下次早点来。。。。")     }     _, err = tx.TxPipelined(ctx, func(pipeliner redis.Pipeliner) error {        err := pipeliner.Decr(ctx, kcKey).Err()        if err != nil {           return err        }        err = pipeliner.SAdd(ctx, userKey, uuid).Err()        if err != nil {           return err        }        return nil     })     return err  }, kcKey)

3、解决库存问题Lua

Lua操作redis能够比较好的解决这个问题。因为redis中使用watch是使用了悲观锁的形态，而悲观锁会自然得造成库存问题，因此要使用乐观锁。而redis天然不支持乐观锁，基于此，需要时lua来编写相关脚本。其主要有以下优势：

• 将复杂的或者多步的redis操作，写为一个脚本，一次提交给redis执行，减少反复连接redis的次数。提升性能。

• luan脚本类似redis事务，有一定的原子性，不会被其他命令插队，可以完成一些redis事务性的操作。

• redis的lua脚本功能，只有在redis2.6以上的版本才可以使用。

• 利用lua脚本淘汰用户，解决超卖问题。

• redis2.6版本以后，通过lua脚本解决争夺问题，实际上是redis利用其单线程的特性，用任务队列的方式解决多任务并发问题。

import (    "context"    "fmt"    "GitHub.com/go-redis/redis/v8"    "net"    "time")func useLua(userid, prodid string) bool {    //编写脚本 - 检查数值，是否够用，够用再减，否则返回减掉后的结果    var luaScript = redis.NewScript(`        local userid=KEYS[1];        local prodid=KEYS[2];        local qTKEy="sk:"..prodid..":qt";        local userKey="sk:"..prodid..":user";        local userExists=redis.call("sismember",userKey,userid);        if tonumber(userExists)==1 then         return 2;        end        local num=redis.call("get",qtKey);        if tonumber(num)<=0 then         return 0;        else         redis.call("decr",qtKey);         redis.call("SAdd",userKey,userid);        end        return 1;    `)    //执行脚本    n, err := luaScript.Run(ctx, DB, []string{userid, prodid}).Result()    if err != nil {        return false    }    switch n {    case int64(0):        fmt.Println("抢购结束")        return false    case int64(1):        fmt.Println(userid, "：抢购成功")        return true    case int64(2):        fmt.Println(userid, "：已经抢购了")        return false    default:        fmt.Println("发生未知错误！")        return false    }    return true}func main() {    // 并发的版本    for i := 0; i < 20; i++ {        go func() {            uuid := GenerateUUID()            prodid := "1023"            time.Sleep(10 * time.Second)            useLua(uuid, prodid)        }()    }    time.Sleep(15 * time.Second)}

到此，关于“怎么使用Go和Lua解决Redis秒杀中库存与超卖问题”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注编程网网站，小编会继续努力为大家带来更多实用的文章！