Redis学习系列三List列表

        /// <summary>
        /// 异步在指定索引处,添加一个值
        /// </summary>
        /// <param name="key"></param>
        /// <param name="value"></param>
        /// <param name="index">目标索引</param>
        /// <returns></returns>
        public static async Task ListSetByIndexAsync(RedisKey key, RedisValue value,long index)
        {
            var db = GetDatabase();
            await db.ListSetByIndexAsync(key, index, value);
        }

        /// <summary>
        /// 异步向列表的右边追加多个值
        /// </summary>
        /// <param name="key"></param>
        /// <param name=""></param>
        /// <param name="index"></param>
        /// <returns></returns>
        public static async Task<long> ListRightPushAsync(RedisKey key, RedisValue[] value)
        {
            var db = GetDatabase();
            return await db.ListRightPushAsync(key, value);
        }

        /// <summary>
        /// 异步获取列表最左边的值
        /// </summary>
        /// <param name="key"></param>
        /// <param name="value"></param>
        /// <returns></returns>
        public static async Task<RedisValue> ListLeftPopAsync(RedisKey key)
        {
            var db = GetDatabase();
            return await db.ListLeftPopAsync(key);
        }

        /// <summary>
        /// 异步获取链表的长度
        /// </summary>
        /// <param name="key"></param>
        /// <returns></returns>
        public static async Task<long> ListLengthAsync(RedisKey key)
        {
            var db = GetDatabase();
            return await db.ListLengthAsync(key);
        }

    class Program
    {
        static Program()
        {
            //链式配置Redis
            AppConfiguration.Current.ConfigureRedis<RedisConfig>();
        }

        static void Main(string[] args)
        {
            StringSetGetAsync();
            Console.ReadKey();
        }

        static async void StringSetGetAsync()
        {
            try
            {
                var key = "列表键值";
                var count=await RedisClient.ListRightPushAsync(key, new RedisValue[] {"C#",".Net","TPL",".Net Core2.0" });
                Console.WriteLine("向键为'列表键值'的列表成功添加了{0}条记录", count);

                //模拟消费者,每次取左边一个消费
                var listLength =await RedisClient.ListLengthAsync(key);

                //不存在线程安全问题,注意这里如果使用Parallel去消费list会存在线程安全问题,我这边已经重现了这个问题
                for (var i = 0; i < listLength; i++)
                {
                    var item = await RedisClient.ListLeftPopAsync(key);
                    Console.WriteLine(item);
                }
            }
            catch (Exception)
            {
                //记录日志
                Console.WriteLine("Redis,使用异常");
            }
                
        }
    }