另外，本秒杀主要解决两个问题，第一个就是超卖问题，另一个就是库存问题。
没有设计专门的页面来模拟并发，我们直接使用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、解决库存问题lualua操作redis能够比较好的解决这个问题。为了避免悲观锁在redis中可能导致的库存问题，应该考虑使用乐观锁。因为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秒杀中库存与超卖问题的详细内容。