redis使用Lua脚本解决多线程下的超卖问题及原因解析

ID:954 / 打印

小伙伴们有没有觉得学习数据库很有意思？有意思就对了！今天就给大家带来《redis使用Lua脚本解决多线程下的超卖问题及原因解析》，以下内容将会涉及到多线程、redislua、超卖，若是在学习中对其中部分知识点有疑问，或许看了本文就能帮到你！

一.多线程下引起的超卖问题呈现

1.1.我先初始化库存数量为1、订单数量为0

1.2.开启3个线程去执行业务

业务为：判断如果说库存数量大于0，则库存减1，订单数量加1

结果为：库存为-2，订单数量为3

原因：如下图所示，这是因为分别有6个指令（3个库存减1指令，3个订单数量加1指令）在redis服务端执行导致的。

namespace MengLin.Shopping.Redis.LuaScript {     public class SecKillOriginal     {         static SecKillOriginal()         {             using (RedisClient client = new RedisClient("127.0.0.1", 6379))             {                 //删除当前数据库中的所有Key, 默认删除的是db0                 client.FlushDb();                 //删除所有数据库中的key                  client.FlushAll();                 //初始化库存数量为1和订单数量为0                 client.Set("inventoryNum", 1);                 client.Set("orderNum", 0);             }         }         public static void Show()         {             for (int i = 0; i                  {                     using (RedisClient client = new RedisClient("127.0.0.1", 6379))                     {                         int inventoryNum = client.Get("inventoryNum");                         //如果库存数量大于0                         if (inventoryNum > 0)                         {                             //给库存数量-1                             var inventoryNum2 = client.Decr("inventoryNum");                             Console.WriteLine($"给库存数量-1后的数量-inventoryNum: {inventoryNum2}");                             //给订单数量+1                             var orderNum = client.Incr("orderNum");                             Console.WriteLine($"给订单数量+1后的数量-orderNum: {orderNum}");                         }                         else                         {                             Console.WriteLine($"抢购失败: 原因是因为没有库存");                         }                     }                 });             }         }     } }

二.使用Lua脚本解决多线程下超卖的问题以及为什么

2.1.修改后的代码如下

结果为：如下图所示，库存为0、订单数量为1，并没有出现超卖的问题且有2个线程抢不到。

namespace MengLin.Shopping.Redis.LuaScript {     public class SecKillLua     {         ///          /// 使用Lua脚本解决多线程下变卖的问题         /// 
         static SecKillLua()         {             using (RedisClient client = new RedisClient("127.0.0.1", 6379))             {                 //删除当前数据库中的所有Key, 默认删除的是db0                 client.FlushDb();                 //删除所有数据库中的key                  client.FlushAll();                 //初始化库存数量为1和订单数量为0                 client.Set("inventoryNum", 1);                 client.Set("orderNum", 0);             }         }         public static void Show()         {             for (int i = 0; i                  {                     using (RedisClient client = new RedisClient("127.0.0.1", 6379))                     {                         //如果库存数量大于0，则给库存数量-1，给订单数量+1                         var lua = @"local count = redis.call('get',KEYS[1])                                         if(tonumber(count)>0)                                         then                                             --return count                                             redis.call('INCR',ARGV[1])                                             return redis.call('DECR',KEYS[1])                                         else                                             return -99                                         end";                         Console.WriteLine(client.ExecLuaAsString(lua, keys: new[] { "inventoryNum" }, args: new[] { "orderNum" }));                     }                 });             }         }     } }