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);//註意這裡多了個^符號 ...
一周排行
  • 一、引言 按照專用隊列解釋: MachineName\Private$\QueueName,只針對於本機的程式才可以調用的隊列,有些情況下為了安全起見定義為私有隊列。所以剛開始的時候認為,要想訪問遠程消息隊列,只能使用公共隊列。但是後來發現,公共隊列依賴Domain Controller(域控),在 ...
  • 本文只對api介面,header請求參數進行簡單驗證,起到拋磚引玉使用,需要深入驗證,請自行擴展 項目目錄結構如圖 中間件類 using ApiMiddleware.Common.DataEnityModel; using ApiMiddleware.Common.DbContext; using ...
  • 前言:由於公司占時沒有運維,出於微服務的需要,Apollo只能先裝在windows 阿裡雲上跑起來,由於環境及網路等問題,在安裝過程中遇到很多坑,算是一個個坑填完後,最終實現。 一. java jdk環境 java jdk 1.8下載地址: https://www.oracle.com/java/t ...
  • 前言 nuget 是 .net 的常用包管理器,目前已經內置到 Visual Studio 2012 以後的版本。大多數 .net 包都托管在 nuget.org,包括 .net core 框架基礎包,得益於 .net core 的模塊化設計,很多非核心包都可以進行一定程度的獨立升級。 製作並上傳 ...
  • 簡單的介紹一下集合,通俗來講就是用來保管多個數據的方案。比如說我們是一個公司的倉庫管理,公司有一堆貨物需要管理,有同類的,有不同類的,總而言之就是很多、很亂。我們對照集合的概念對倉庫進行管理的話,那麼 數組就是將一堆貨整整齊齊的碼在倉庫的某個地方,普通列表也是如此;Set就是在倉庫里有這麼一個貨架, ...
  • 中間件分類 ASP.NET Core 中間件的配置方法可以分為以上三種,對應的Helper方法分別是:Run(), Use(), Map()。 Run(),使用Run調用中間件的時候,會直接返回一個響應,所以後續的中間件將不會被執行了。 Use(),它會對請求做一些工作或處理,例如添加一些請求的上下 ...
  • 字元串的常用操作 很好理解 字元串可以用 ' + ' 連接,或者乘一個常數重覆輸出字元串 字元串的索引操作 通過一對中括弧可以找到字元串中的某個字元 可以通過正負數雙向操作噢 用一個中括弧來實現 為什麼沒有-0??去清醒腦子想想 -0 和 0 有差嗎? 還有一個切片操作 就像切菜那樣簡單,同樣是中括 ...
  • title: Java基礎語法(3) 運算符 blog: "CSDN" data: "Java學習路線及視頻" 1.算術運算符 算術運算符的註意問題 如果對負數取模,可以把模數負號忽略不記,如:5% 2=1。 但被模數是負數則不可忽略。此外,取模運算的結果不一定總是整數。 對於除號“/”,它的整數除 ...
  • 下麵是互相轉換的代碼: 有想要瞭解更多關於python知識的請在下方評論或私信小編 ...
  • 引言 構建分散式系統並不容易。然而,人們日常所使用的應用大多基於分散式系統,在短時間內依賴於分散式系統的現狀並不會改變。ApacheZooKeeper旨在減輕構建健壯的分散式系統的任務。ZooKeeper基於 分散式計算的核心概念而設計,主要目的是給開發人員提供一套容易理解和開發的介面,從而簡化分佈 ...
x