redis使用Lua腳本解決多線程下的超賣(mài)問(wèn)題及原因解析

更新時(shí)間：2023年05月08日 09:23:05 作者：David.Meng

這篇文章主要介紹了redis使用Lua腳本解決多線程下的超賣(mài)問(wèn)題，本文給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下

一.多線程下引起的超賣(mài)問(wèn)題呈現(xiàn)

1.1.我先初始化庫(kù)存數(shù)量為1、訂單數(shù)量為0

1.2.開(kāi)啟3個(gè)線程去執(zhí)行業(yè)務(wù)

業(yè)務(wù)為：判斷如果說(shuō)庫(kù)存數(shù)量大于0，則庫(kù)存減1，訂單數(shù)量加1

結(jié)果為：庫(kù)存為-2，訂單數(shù)量為3

原因：如下圖所示，這是因?yàn)榉謩e有6個(gè)指令（3個(gè)庫(kù)存減1指令，3個(gè)訂單數(shù)量加1指令）在redis服務(wù)端執(zhí)行導(dǎo)致的。

namespace MengLin.Shopping.Redis.LuaScript
{
    public class SecKillOriginal
    {
        static SecKillOriginal()
        {
            using (RedisClient client = new RedisClient("127.0.0.1", 6379))
            {
                //刪除當(dāng)前數(shù)據(jù)庫(kù)中的所有Key, 默認(rèn)刪除的是db0
                client.FlushDb();
                //刪除所有數(shù)據(jù)庫(kù)中的key 
                client.FlushAll();
                //初始化庫(kù)存數(shù)量為1和訂單數(shù)量為0
                client.Set("inventoryNum", 1);
                client.Set("orderNum", 0);
            }
        }
        public static void Show()
        {
            for (int i = 0; i < 3; i++)
            {
                Task.Run(() =>
                {
                    using (RedisClient client = new RedisClient("127.0.0.1", 6379))
                    {
                        int inventoryNum = client.Get<int>("inventoryNum");
                        //如果庫(kù)存數(shù)量大于0
                        if (inventoryNum > 0)
                        {
                            //給庫(kù)存數(shù)量-1
                            var inventoryNum2 = client.Decr("inventoryNum");
                            Console.WriteLine($"給庫(kù)存數(shù)量-1后的數(shù)量-inventoryNum: {inventoryNum2}");
                            //給訂單數(shù)量+1
                            var orderNum = client.Incr("orderNum");
                            Console.WriteLine($"給訂單數(shù)量+1后的數(shù)量-orderNum: {orderNum}");
                        }
                        else
                        {
                            Console.WriteLine($"搶購(gòu)失敗: 原因是因?yàn)闆](méi)有庫(kù)存");
                        }
                    }
                });
            }
        }
    }
}

二.使用Lua腳本解決多線程下超賣(mài)的問(wèn)題以及為什么

2.1.修改后的代碼如下

結(jié)果為：如下圖所示，庫(kù)存為0、訂單數(shù)量為1，并沒(méi)有出現(xiàn)超賣(mài)的問(wèn)題且有2個(gè)線程搶不到。

namespace MengLin.Shopping.Redis.LuaScript
{
    public class SecKillLua
    {
        /// <summary>
        /// 使用Lua腳本解決多線程下變賣(mài)的問(wèn)題
        /// </summary>
        static SecKillLua()
        {
            using (RedisClient client = new RedisClient("127.0.0.1", 6379))
            {
                //刪除當(dāng)前數(shù)據(jù)庫(kù)中的所有Key, 默認(rèn)刪除的是db0
                client.FlushDb();
                //刪除所有數(shù)據(jù)庫(kù)中的key 
                client.FlushAll();
                //初始化庫(kù)存數(shù)量為1和訂單數(shù)量為0
                client.Set("inventoryNum", 1);
                client.Set("orderNum", 0);
            }
        }
        public static void Show()
        {
            for (int i = 0; i < 3; i++)
            {
                Task.Run(() =>
                {
                    using (RedisClient client = new RedisClient("127.0.0.1", 6379))
                    {
                        //如果庫(kù)存數(shù)量大于0，則給庫(kù)存數(shù)量-1，給訂單數(shù)量+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" }));
                    }
                });
            }
        }
    }
}