EF+SQLSERVER控制併發下搶紅包減餘額（改進）

来源:http://www.cnblogs.com/chenjianxiang/archive/2017/02/10/6387784.html
-Advertisement-
Play Games

最近幾年想必大家一聽到哪裡有搶紅包可以搶，馬上會拿起手機點去~~~~然後問題來了。。。 如何控制在同一時間保證資料庫中扣減紅包餘額不會出錯。之前我們的做法是直接鎖程式，這樣子帶來的壞處就是等待時間太長，每當一個線程進去之後要經過以下幾個過程。 過程分別是 1. 查表 2. 校驗信息 3. 發送微信服 ...


最近幾年想必大家一聽到哪裡有搶紅包可以搶，馬上會拿起手機點去~~~~然後問題來了。。。

如何控制在同一時間保證資料庫中扣減紅包餘額不會出錯。之前我們的做法是直接鎖程式，這樣子帶來的壞處就是等待時間太長，每當一個線程進去之後要經過以下幾個過程。

過程分別是

1. 查表

2. 校驗信息

3. 發送微信伺服器

4. 等待反饋

5. 更新表

等這些過程結束之後才輪到下麵這個過程。想必這樣要等到花兒都謝了~

另外發送微信伺服器這個過程時間在0s至9s時間不等。會產生大量的空閑時間，這裡CPU會產生大量的空閑。而且這種情況也無法繼續做負載均衡，如果有多個站點部署必定會產生資料庫併發問題。

若在查表之前加鎖更新後釋放掉，雖然說不會產生資料庫併發。但是在第二個線程進入查詢的時候他會一直在等待，其耗時則與更鎖程式差不多。


改進

這個想法源於分散式事務的設計，採用預扣紅包餘額的方式來保證無需等待微信伺服器反饋，讓下一個線程可繼續執行相關任務。當微信伺服器反饋回來時，才開始另外一個事務去更改交易狀態。若反饋結果為FAIL則需要預扣的紅包餘額進行還原操作。

粗略寫了模擬實際環境的測試代碼，模擬搶紅包動作

private void task()
{
    for (int i = 0; i < 50; i++)
    {
        string tradeNo = Qxun.Framework.Utility.CreateOrderNo.DateTimeAndNumber();
        try
        {
            using (var trans = new TransactionScope())
            {
                using (var dbContext = new ActivityDbContext())
                {
                    //加鎖
                    var model = dbContext.Database.SqlQuery<Qxun.Activity.Contract.VIPPassRedBag013>(@"select * from VIPPassRedBag013 with(updlock) where ActivitySceneID=199").FirstOrDefault();
                    var mode = dbContext.Database.SqlQuery<Qxun.Activity.Contract.VIPPassRedBag013Mode>(@"select * from VIPPassRedBag013Mode with(updlock) where ActivitySceneID=199").ToList();
                    //模擬校驗延遲
                    Thread.Sleep(5);
                    //得到領取紅包的金額
                    VIPPassRedBag013Mode currentMode = null;
                    foreach (var modeItem in mode)
                    {
                        if (modeItem.RemainCount > 0)
                        {
                            currentMode = modeItem;
                            break;
                        }
                    }
                    //判斷是否領完
                    if (currentMode != null && model != null && model.RedBagBalance >= currentMode.Money)
                    {
                        VIPPassRedBag013Play currentPlayModel = new VIPPassRedBag013Play();//本次的參與記錄對象
                        currentPlayModel.VIPPassRedBag013ModeID = currentMode.ID;
                        currentPlayModel.WeixinUserID = Thread.CurrentThread.ManagedThreadId;
                        currentPlayModel.Money = Convert.ToInt32(currentMode.Money * 100);//要支付的金額（存入到表的）
                        currentPlayModel.TradeNumber = tradeNo;
                        currentPlayModel.Status = (int)TradeStatus.Trading;
                        currentPlayModel.VIPPassRedBag013ModeID = currentMode.ID;
                        currentPlayModel.ActivitySceneID = 199;
                        dbContext.Insert<VIPPassRedBag013Play>(currentPlayModel);
                        currentMode.RemainCount -= 1;
                        dbContext.Update<VIPPassRedBag013Mode>(currentMode);
                        model.RedBagBalance -= currentMode.Money;
                        dbContext.Update<Qxun.Activity.Contract.VIPPassRedBag013>(model);
                        trans.Complete();

                    }
                    else
                    {
                        trans.Complete();
                    }
                }
            }
        }
        catch (Exception ex){}
        //提交至微信           
        string returnCode = "SUCCESS";
        Random ran = new Random();
        int time = ran.Next(100);
        if (time <= 1)
        {
            returnCode = "FAIL";
        }
        //模擬網路延遲
        Thread.Sleep(time * 100);
        //設置重新嘗試次數
        bool retry = true;
        int retryCount = 0;
        do
        {
            Qxun.Activity.Contract.VIPPassRedBag013 model = null;
            VIPPassRedBag013Play playModel = null;
            VIPPassRedBag013Mode mode = null;
            try
            {
                using (var trans = new TransactionScope())
                {
                    using (var dbContext = new ActivityDbContext())
                    {
                        //這裡獲取很容易異常
                        model = dbContext.Database.SqlQuery<Qxun.Activity.Contract.VIPPassRedBag013>(@"select * from VIPPassRedBag013 with(updlock) where ActivitySceneID=199").FirstOrDefault();
                        playModel = dbContext.Database.SqlQuery<Qxun.Activity.Contract.VIPPassRedBag013Play>(@"select * from VIPPassRedBag013Play with(updlock) where TradeNumber='" + tradeNo + "'").FirstOrDefault();
                        mode = dbContext.Database.SqlQuery<Qxun.Activity.Contract.VIPPassRedBag013Mode>(@"select * from VIPPassRedBag013Mode with(updlock) where ID=" + playModel.VIPPassRedBag013ModeID).FirstOrDefault();
                        if (returnCode == "SUCCESS")
                        {
                            playModel.Status = (int)TradeStatus.Success;
                            playModel.Remark = "retry=" + retryCount + ",success;time=" + DateTime.Now.ToString();
                            playModel.FinishTime = DateTime.Now;
                            dbContext.Update<VIPPassRedBag013Play>(playModel);
                            trans.Complete();
                            retry = false;
                        }
                        else
                        {
                            model.RedBagBalance += mode.Money;
                            dbContext.Update<Qxun.Activity.Contract.VIPPassRedBag013>(model);
                            playModel.Status = (int)TradeStatus.Fail;
                            playModel.Remark = "retry=" + retryCount + ",fail;time=" + DateTime.Now.ToString();
                            playModel.FinishTime = DateTime.Now;
                            dbContext.Update<VIPPassRedBag013Play>(playModel);
                            mode.RemainCount += 1;
                            dbContext.Update<VIPPassRedBag013Mode>(mode);
                            trans.Complete();
                            retry = false;
                        }
                    }
                }
            }
            catch (Exception ex)
            {
                //如果之前的線程請求資料庫時阻塞
                //如果執行失敗
                retryCount++;
                retry = true;
            }
            if (retryCount > 5)
            {
                break;
            }
        } while (retry);
    }
}

 
模擬100個人併發搶紅包

public ActionResult Excute()
{
    for (int i = 0; i < 100; i++)
    {
        Thread thread = new Thread(new ThreadStart(task));
        thread.Start();
    }
    return Content("完成！");
}

 

上面代碼還用了一個retry變數控制防止由於長等待產生的超時，好讓每個訂單都能夠處理的到。但是實際上當線程數量為100-200時候，會有10至20個VIPPassRedBag013Play訂單狀態一直為Trading。當線程數量大於200的時候就變得及不穩定，目前一直沒有找到是什麼原因。希望有緣人指點一二。

為瞭解決這種現象，我在Global寫了周期去查找10分鐘前的VIPPassRedBag013Play，且訂單狀態為Trading的單子（都10分鐘了還沒有處理，那就是處理不到了）。得到訂單號，去反查微信的紅包交易記錄。通過微信紅包反饋的結果去更新資料庫的交易狀態。

public ActionResult Check()
{
    using (var dbContext = new ActivityDbContext())
    {
        //查詢十分鐘之前狀態仍為交易中的訂單
        var playModel = dbContext.Database
            .SqlQuery<Qxun.Activity.Contract.VIPPassRedBag013Play>(@"select * from VIPPassRedBag013Play with(nolock) where ActivitySceneID=199
                            and[status] = 2 and DATEDIFF(MINUTE, CreateTime, GETDATE()) > 10").ToList();
        if (playModel != null && playModel.Count > 0)
        {
            foreach (var item in playModel)
            {
                using (var trans = new TransactionScope())
                {
                    //提交至微信查詢       
                    string returnCode = "SUCCESS";
                    Random ran = new Random();
                    int time = ran.Next(100);
                    if (time <= 1)
                    {
                        returnCode = "FAIL";
                    }
                    //去查詢微信紅包的信息
                    //模擬網路延遲
                    Thread.Sleep(time * 100);
                    if (returnCode == "SUCCESS")
                    {
                        item.Status = (int)TradeStatus.Success;
                        item.Remark = "success;time=" + DateTime.Now.ToString();
                        item.FinishTime = DateTime.Now;
                        dbContext.Update<VIPPassRedBag013Play>(item);
                        trans.Complete();
                    }
                    else
                    {
                        Qxun.Activity.Contract.VIPPassRedBag013 model = dbContext.Database
                            .SqlQuery<Qxun.Activity.Contract.VIPPassRedBag013>(@"select * from VIPPassRedBag013 with(updlock) where ActivitySceneID=199")
                            .FirstOrDefault();
                        VIPPassRedBag013Mode mode = dbContext.Database
                            .SqlQuery<Qxun.Activity.Contract.VIPPassRedBag013Mode>(@"select * from VIPPassRedBag013Mode with(updlock) where ID=" + item.VIPPassRedBag013ModeID).FirstOrDefault();
                        model.RedBagBalance += item.Money;
                        dbContext.Update<Qxun.Activity.Contract.VIPPassRedBag013>(model);
                        item.Status = (int)TradeStatus.Fail;
                        item.Remark = "fail;time=" + DateTime.Now.ToString();
                        item.FinishTime = DateTime.Now;
                        dbContext.Update<VIPPassRedBag013Play>(item);
                        mode.RemainCount += 1;
                        dbContext.Update<VIPPassRedBag013Mode>(mode);
                        trans.Complete();
                    }
                }
            }
        }
    }
    return View();
}


PS:經過這樣改進，應該比之前的好多了。當然這樣還是很遠遠不夠的。希望各位路過的大神能夠指點一二，甚是感謝！


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • crontab的定時任務實例
    實例1：每1分鐘執行一次myCommand * * * * * myCommand 實例2：每小時的第3和第15分鐘執行 3,15 * * * * myCommand 實例3：在上午8點到11點的第3和第15分鐘執行 3,15 8-11 * * * myCommand 實例4：每隔兩天的上午8點到1 ...
  • shell編程其實真的很簡單（四）
    上篇我們學習了shell中條件選擇語句的用法。接下來本篇就來學習迴圈語句。在shell中，迴圈是通過for, while, until命令來實現的。下麵就分別來看看吧。 for for迴圈有兩種形式： for in語句 基本格式如下： for var in list do commands done ...
  • windows包管理器chocolatey
    1.安裝chocolatey打開cmd.exe執行@powershell -NoProfile -ExecutionPolicy Bypass -Command "iex ((New-Object System.Net.WebClient).DownloadString('https://choco ...
  • Linux編程之從零開始搭建RPC分散式系統
    我一畢業進公司就接觸到了RPC，主要是使用前輩們搭建好的RPC框架以及封裝好的RPC函數進行業務開發，雖說使用RPC框架開發已經近半年了，但一直想知道如何從零開始搭建起這麼一個好用的分散式通信系統框架，近日心血來潮，雖說沒人教怎麼搭建，但自己在網上查閱了大量資料後，開始自己一手一腳從零搭建這麼一個R ...
  • npm全局執行update、outdated出現npm-debug.log 404錯誤的問題
    想要執行一次全局更新，發現屢次報錯： 提示的錯誤信息包含如下內容： 尋找解決方案未果。後來看到一個不相關的回答： ，腦洞大開想到可能是npm的modules文件夾下多出了一個npm debug.log的文件，導致查詢倉庫時把這個文件名也拿去查詢了。locate一下發現果真如此： 將這個文件刪掉後再次 ...
  • WPF DEV CellTemplateSelector(一個正確使用DevExpress CellTemplateSelector的Demo)
    說明 我在項目中根據需求需要用到WPF Dev CellTemplateSelector時，遇到不少坑。曾一度想要放棄使用模板轉換器，但又心有不甘，終於在不斷努力下，達到了需求的要求。所以寫下來和大家分享。如果有同樣困惑的人，可以少走些彎路。筆者第一次寫博客，文筆不好，還請見諒。 需求 需求很簡單， ...
  • window nfs 服務端配置安裝
    windows7下麵安裝nfs客戶端命令(首先開啟windows客戶端mount掛載命令)： windows7下麵安裝nfs客戶端命令(首先開啟windows客戶端mount掛載命令)： 打開或關閉windows功能>nfs服務(勾選上)重啟 windows nfs共用有兩種方式分別是如下hanew ...
  • OSS.Common獲取枚舉字典列表標準庫支持
    上篇（.Net Standard擴展支持實例分享）介紹了OSS.Common的標準庫支持擴展，也列舉了可能遇到問題的解決方案。由於時間有限，同時.net standard暫時還沒有提供對DescriptionAttribute的支持，所以其中的轉化枚舉到字典列表的擴展當時按照第一種處理方式先行屏蔽， ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類