StackExchange.Redis 之 List隊列 類型示例

来源:https://www.cnblogs.com/peterzhang123/archive/2020/02/17/12322353.html

//從第1個開始,依次向左插入值。如果鍵不存在,先創建再插入值 隊列形式 先進後出,後進先出 //插入後形式 <-- 10,9,8,7,6,5,4,3,2,1 <-- 方向向左依次進行 stopwatch.Start(); for (int i = 0; i < 10; i++) { var get ...


            //從第1個開始,依次向左插入值。如果鍵不存在,先創建再插入值  隊列形式 先進後出,後進先出
//插入後形式  <-- 10,9,8,7,6,5,4,3,2,1 <-- 方向向左依次進行
stopwatch.Start(); for (int i = 0; i < 10; i++) { var getobjlist = RedisCacheHelper.Instance.ListLeftPush("leftlistkey", (i + 1).ToString()); } stopwatch.Stop(); Console.WriteLine("在列表頭部插入值消耗時間:" + stopwatch.ElapsedMilliseconds.ToString()); //從第1個開始,依次向右插入值。如果鍵不存在,先創建再插入值 先進先出,後進後出
//插入後形式  1,2,3,4,5,6,7,8,9,10 --> 方向向右依次進行
stopwatch.Start(); for (int i = 0; i < 10; i++) { var getobjlist = RedisCacheHelper.Instance.ListRightPush("rightlistkey", (i + 1).ToString()); } stopwatch.Stop(); Console.WriteLine("在列表尾部插入值消耗時間:" + stopwatch.ElapsedMilliseconds.ToString());

 

 

            //獲取Left列表中的隊列元素  從列表頭部開始讀取
            var getleftvalue = RedisCacheHelper.Instance.ListRange("leftlistkey");
            Console.WriteLine(string.Join(",", getleftvalue));


            //獲取Right列表中的隊列元素   從列表頭部開始讀取
            var getrightvalue = RedisCacheHelper.Instance.ListRange("rightlistkey");
            Console.WriteLine(string.Join(",", getrightvalue));

            //從左邊第一個元素開始  迴圈移除並返回該移除的值
            Console.WriteLine("從左邊開始");
            while (true)
            {
                var getleftvalue = RedisCacheHelper.Instance.ListLeftPop("leftlistkey");
                if (!string.IsNullOrEmpty(getleftvalue))
                {
                    Console.WriteLine("移除:" + getleftvalue);
                }
                else
                {
                    break;
                }
            }

            //從右邊第一個元素開始  迴圈移除並返回該移除的值  
            Console.WriteLine("從右邊開始");
            while (true)
            {
                var getrightvalue = RedisCacheHelper.Instance.ListRightPop("rightlistkey");
                if (!string.IsNullOrEmpty(getrightvalue))
                {
                    Console.WriteLine("移除:" + getrightvalue);
                }
                else
                {
                    break;
                }
            }

            //從左邊第一個元素開始  迴圈移除並返回該移除的值  替換一下Key後
            Console.WriteLine("從左邊開始");
            while (true)
            {
                var getleftvalue = RedisCacheHelper.Instance.ListLeftPop("rightlistkey");
                if (!string.IsNullOrEmpty(getleftvalue))
                {
                    Console.WriteLine("移除:" + getleftvalue);
                }
                else
                {
                    break;
                }
            }


            //從右邊第一個元素開始  迴圈移除並返回該移除的值  替換一下Key後
            Console.WriteLine("從右邊開始");
            while (true)
            {
                var getrightvalue = RedisCacheHelper.Instance.ListRightPop("leftlistkey");
                if (!string.IsNullOrEmpty(getrightvalue))
                {
                    Console.WriteLine("移除:" + getrightvalue);
                }
                else
                {
                    break;
                }
            }

            //列表長度  不存在則返回0
            var getlength = RedisCacheHelper.Instance.ListLength("leftlistkey");
            Console.WriteLine("列表長度:" + getlength);

            //刪除List中的元素 並返回刪除的個數    不存在則返回0
            var getlong = RedisCacheHelper.Instance.ListDelRange("leftlistkey", "6");
            Console.WriteLine("刪除List中的元素,並返回刪除的個數:" + getlong);

            //清空列表
            RedisCacheHelper.Instance.ListClear("leftlistkey");

使用List類型 模擬用戶併發搶購商品

//模擬數據  想List類型表中加入一定數量的庫存   50個商品
            for (int i = 1; i <= 50; i++)
            {
                var getvalue = RedisCacheHelper.Instance.ListRightPush("orderlist", i.ToString());
                //Console.WriteLine("返回結果:" + getvalue);
            }

            //模擬創建多個用戶  100個用戶
            List<TestRedis> testlist = new List<TestRedis>();
            for (int i = 0; i < 100; i++)
            {
                testlist.Add(new TestRedis() { Uid = (i + 1) });
            }

            //先清空
            RedisCacheHelper.Instance.ListClear("orderSuccessList");

            //使用List類型模擬併發情況  不用擔心庫存為負的情況
            //模擬多個用戶搶購限時商品   100個用戶搶50個商品
            stopwatch.Start();
            List<Task> taskList = new List<Task>();
            foreach (var item in testlist)
            {
                var task = Task.Run(() =>
                {
                    try
                    {
                        //先自減,獲取自減後的值
                        long order_Num = -1;
                        long.TryParse(RedisCacheHelper.Instance.ListRightPop("orderlist"), out order_Num);
                        if (order_Num > 0)
                        {
                            //下麵執行訂單邏輯(這裡不考慮業務出錯的情況)

                            RedisCacheHelper.Instance.ListLeftPush("orderSuccessList", item.Uid.ToString());  //記錄下單成功的用戶

                            //操作資料庫相關邏輯 可以使用“消息隊列”或“服務”進行資料庫同步操作

                            Console.WriteLine("用戶:" + item.Uid + ",搶到了商品:" + order_Num);
                        }
                        else
                        {
                            Console.WriteLine("商品已經被搶光了,用戶" + item.Uid + "未搶到");
                        }

                    }
                    catch (Exception ex)
                    {
                        Console.WriteLine(ex.Message);
                        throw;
                    }
                });
                taskList.Add(task);
            }
            Task.WaitAll(taskList.ToArray());
            stopwatch.Stop();
            Console.WriteLine("模擬併發場景消耗時間:" + stopwatch.ElapsedMilliseconds.ToString());

 

最後附上Helper

        /// <summary>
        /// 在列表頭部插入值。如果鍵不存在,先創建再插入值
        /// </summary>
        /// <param name="redisKey"></param>
        /// <param name="redisValue"></param>
        /// <returns></returns>
        public long ListLeftPush(string redisKey, string redisValue, int db = -1)
        {
            var _db = GetDatabase(db);
            return _db.ListLeftPush(redisKey, redisValue);
        }
        /// <summary>
        /// 在列表尾部插入值。如果鍵不存在,先創建再插入值
        /// </summary>
        /// <param name="redisKey"></param>
        /// <param name="redisValue"></param>
        /// <returns></returns>
        public long ListRightPush(string redisKey, string redisValue, int db = -1)
        {
            var _db = GetDatabase(db);
            return _db.ListRightPush(redisKey, redisValue);
        }

        /// <summary>
        /// 在列表尾部插入數組集合。如果鍵不存在,先創建再插入值
        /// </summary>
        /// <param name="redisKey"></param>
        /// <param name="redisValue"></param>
        /// <returns></returns>
        public long ListRightPush(string redisKey, IEnumerable<string> redisValue, int db = -1)
        {
            var _db = GetDatabase(db);
            var redislist = new List<RedisValue>();
            foreach (var item in redisValue)
            {
                redislist.Add(item);
            }
            return _db.ListRightPush(redisKey, redislist.ToArray());
        }


        /// <summary>
        /// 移除並返回存儲在該鍵列表的第一個元素  反序列化
        /// </summary>
        /// <param name="redisKey"></param>
        /// <returns></returns>
        public T ListLeftPop<T>(string redisKey, int db = -1) where T : class
        {
            var _db = GetDatabase(db);
            return JsonConvert.DeserializeObject<T>(_db.ListLeftPop(redisKey));
        }

        /// <summary>
        /// 移除並返回存儲在該鍵列表的最後一個元素   反序列化
        /// 只能是對象集合
        /// </summary>
        /// <param name="redisKey"></param>
        /// <returns></returns>
        public T ListRightPop<T>(string redisKey, int db = -1) where T : class
        {
            var _db = GetDatabase(db);
            return JsonConvert.DeserializeObject<T>(_db.ListRightPop(redisKey));
        }

        /// <summary>
        /// 移除並返回存儲在該鍵列表的第一個元素   
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="redisKey"></param>
        /// <param name="db"></param>
        /// <returns></returns>
        public string ListLeftPop(string redisKey, int db = -1)
        {
            var _db = GetDatabase(db);
            return _db.ListLeftPop(redisKey);
        }

        /// <summary>
        /// 移除並返回存儲在該鍵列表的最後一個元素   
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="redisKey"></param>
        /// <param name="db"></param>
        /// <returns></returns>
        public string ListRightPop(string redisKey, int db = -1)
        {
            var _db = GetDatabase(db);
            return _db.ListRightPop(redisKey);
        }

        /// <summary>
        /// 列表長度
        /// </summary>
        /// <param name="redisKey"></param>
        /// <param name="db"></param>
        /// <returns></returns>
        public long ListLength(string redisKey, int db = -1)
        {
            var _db = GetDatabase(db);
            return _db.ListLength(redisKey);
        }

        /// <summary>
        /// 返回在該列表上鍵所對應的元素
        /// </summary>
        /// <param name="redisKey"></param>
        /// <returns></returns>
        public IEnumerable<string> ListRange(string redisKey, int db = -1)
        {
            var _db = GetDatabase(db);
            var result = _db.ListRange(redisKey);
            return result.Select(o => o.ToString());
        }

        /// <summary>
        /// 根據索引獲取指定位置數據
        /// </summary>
        /// <param name="redisKey"></param>
        /// <param name="start"></param>
        /// <param name="stop"></param>
        /// <param name="db"></param>
        /// <returns></returns>
        public IEnumerable<string> ListRange(string redisKey, int start, int stop, int db = -1)
        {
            var _db = GetDatabase(db);
            var result = _db.ListRange(redisKey, start, stop);
            return result.Select(o => o.ToString());
        }

        /// <summary>
        /// 刪除List中的元素 並返回刪除的個數
        /// </summary>
        /// <param name="redisKey">key</param>
        /// <param name="redisValue">元素</param>
        /// <param name="type">大於零 : 從表頭開始向表尾搜索,小於零 : 從表尾開始向表頭搜索,等於零:移除表中所有與 VALUE 相等的值</param>
        /// <param name="db"></param>
        /// <returns></returns>
        public long ListDelRange(string redisKey, string redisValue, long type = 0, int db = -1)
        {
            var _db = GetDatabase(db);
            return _db.ListRemove(redisKey, redisValue, type);
        }

        /// <summary>
        /// 清空List
        /// </summary>
        /// <param name="redisKey"></param>
        /// <param name="db"></param>
        public void ListClear(string redisKey, int db = -1)
        {
            var _db = GetDatabase(db);
            _db.ListTrim(redisKey, 1, 0);
        }
View Code

 


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

更多相關文章
  • 前言 也許,有的人看到上邊這個標題,首先會覺得這肯定是一篇廣告文吧。確實,我們可能見過有很多號主用類似於“你的同齡人已經XXX了,而你還在XXX”這種風格,來寫軟文。 但是,我可以明確的告訴你,這篇文章不是廣告,只是記錄我的一些感想而已。再說了,也沒有廣告主來找我合作呀(手動捂臉)。 正文 今天,無 ...
  • 值傳遞與對象拷貝 值傳遞和引用傳遞 調用一個有參函數的時候,會把實際參數傳遞給形式參數。但是,在程式語言中,這個傳遞過程中傳遞的兩種情況,即值傳遞和引用傳遞 兩者區別 1. 值傳遞(pass by value)是指在調用函數時將實際參數複製一份傳遞到函數中,這樣在函數中如果對參數進行修改,將不會影響 ...
  • 目標網站:古詩文網 登錄界面顯示: 打開控制台工具,輸入賬號密碼,在ALL欄目中進行抓包 數據如下: 登錄請求的url和請求方式 登錄所需參數 參數分析: __VIEWSTATE和__VIEWSTATEGENERATOR可以在登錄界面獲取,code為驗證碼,email為賬號,pwd為密碼,from為 ...
  • 一. insert 首先看一下 insert.java 的代碼: /** * <p> * 根據 ID 刪除 * </p> * * @author hubin * @since 2018-04-06 */ public class Insert extends AbstractMethod { @Ov ...
  • 以控台的形式,運行.net core mvc 代碼, Host.CreateDefaultBuilder(args) .ConfigureWebHostDefaults(webBuilder => { webBuilder.UseStartup<Startup>();//指定網路主機要使用的啟動類型 ...
  • 通過上一章的學習,Geometry抽象類表示形狀或路徑。Drawing抽象類扮演了互補的角色,它表示2D圖畫(Drawing)——換句話說,它包含了顯示矢量圖像或點陣圖需要的所有信息。 儘管有幾類畫圖類,但只有GeometryDrawing類能使用已經學習過的幾何圖形。它增加了決定如何繪製圖形的畫筆和 ...
  • String類型很簡單,就不做示例演示了,這裡只貼出Helper類 /// <summary> /// 判斷key是否存在 /// </summary> /// <param name="key"></param> /// <param name="db"></param> /// <returns ...
  • 過濾漢字 Regex.Replace(inputStr,@"[\u4e00-\u9fa5]",string.Empty); 提取漢字: Regex.Replace(inputStr,@"[^\u4e00-\u9fa5]",string.Empty);//註意這裡多了個^符號 ...
一周排行
  • 上一篇文章(https://www.cnblogs.com/meowv/p/12943699.html)完成了項目的全局異常處理和日誌記錄。 在日誌記錄中使用的靜態方法有人指出寫法不是很優雅,遂優化一下上一篇中日誌記錄的方法,具體操作如下: 在.ToolKits層中新建擴展方法Log4NetExte ...
  • 先安裝幾個包 獲取地址如下https://www.nuget.org/packages/QRCoder/https://www.nuget.org/packages/SixLabors.Fonts/https://www.nuget.org/packages/SixLabors.ImageSharp ...
  • 0. 前言 前一篇我們詳細的介紹了SqlSugar的增刪改查,那些已經滿足我們在日常工程開發中的使用了。但是還有一點點在開發中並不常用,但是卻非常有用的方法。接下來讓我們一起來看看還有哪些有意思的內容。 1. 不同尋常的查詢 之前介紹了針對單個表的查詢,同樣也是相對簡單的查詢模式。雖然開發完全夠用, ...
  • 最新.net core 圖片合併生成二維碼合成圖片 圖片添加文字 先安裝幾個包 獲取地址如下 https://www.nuget.org/packages/QRCoder/ https://www.nuget.org/packages/SixLabors.Fonts/ https://www.nug ...
  • 前言 之前我寫過一篇關於 Blazor WebAssembly 的文章瀏覽器中的 .Net Core —— Blazor WebAssembly 初體驗,如今已經更新到 RC-1,與預覽版有著較大的差異,為此補充這篇文章。 正文 與預覽版的主要差異 1、這次的候選版修改了大部分包名和命名空間,因此無 ...
  • 藍牙設置相關界面,以下是通過C#方式打開的幾個方式,記錄一下 藍牙設置界面 1.控制面板命令bthprops.cpl 可以用控制面板 control+bthprops.cpl,也可以直接bthprops.cpl。更多的命令見:所有運行命令指令大全、CMD & CPL:快捷系統命令和控制面板命令 bt ...
  • 一:背景 1. 講故事 去年阿裡聚石塔上的所有isv簡訊通道全部對接阿裡通信,我們就做了對接改造,使用阿裡提供的.net sdk。 網址:https://help.aliyun.com/document_detail/114480.html 同事當時使用的是ons-.net v1.1.3版本,程式上 ...
  • 一.相關介紹 Dockerfile:關於Dockerfile的使用說明,我在文章《讓.NetCore程式跑在任何有docker的地方》中有說到,這裡不在贅述,需要的可以先看下,本文主要介紹Jenkinsfile結合dockerfile配合使用,自動構建.NetCore應用程式。 Jenkinsfil ...
  • 當用戶嚮應用程式發出請求時,伺服器將解析該請求,生成響應,然後將結果發送給客戶端。用戶可能會在伺服器處理請求的時候中止請求。就比如說用戶跳轉到另一個頁面中獲取說關閉頁面。在這種情況下,我們希望停止所有正在進行的工作,以浪費不必要的資源。例如我們可能要取消SQL請求、http調用請求、CPU密集型操作 ...
  • 在.NET中,我們可以通過Task.WhenAll用來等待多個任務。任務完成之後,我們可以使用await等待他們來獲取結果。 Task<int> task1 = Task.Run(() => 1); Task<string> task2 = Task.Run(() => "hello"); awai ...