c#redis使用

時間 2019-11-20

原文原文鏈接

redis是一個key-value存儲系統。和Memcached相似，它支持存儲的value類型相對更多，包括string(字符串)、list(鏈表)、set(集合)和zset(有序集合)。這些數據類型都支持push/pop、add/remove及取交集並集和差集及更豐富的操做，並且這些操做都是原子性的。在此基礎上，redis支持各類不一樣方式的排序。與memcached同樣，爲了保證效率，數據都是緩存在內存中。區別的是redis會週期性的把更新的數據寫入磁盤或者把修改操做寫入追加的記錄文件，而且在此基礎上實現了master-slave(主從)同步。html

主要用於數據存儲（緩存）、發佈訂閱、消息隊列以及分佈式鎖等。linux

1.redis安裝能夠使用 window安裝還有 linux安裝以及docker安裝redis

官網 https://redis.io/docker

中文 http://www.redis.cn/c#

2.可視化工具緩存

RedisDesktopManager服務器

3. c# 驅動併發

比較知名的c#驅動是 ServiceStack.Redis 和 StackExchange.Redis分佈式

因爲ServiceStack.Redis，提供了默認的線程池是收費的，主要是須要付費解除併發數量的限制，ide

而StackExchange.Redis沒有提供默認的線程池沒有併發量的限制，是免費的。

StackExchange.Redis封裝類方便使用。

 public class RedisManager
    {
        /// <summary>
        /// 鎖對象
        /// </summary>
        private static object _locker = new object();
        /// <summary>
        /// StackExchange.Redis對象
        /// </summary>
        private static ConnectionMultiplexer _redis;

        /// <summary>
        /// 代理類型
        /// None = 0,
        /// Twemproxy = 1,
        /// </summary>
        private static int proxy = int.Parse(ConfigurationManager.AppSettings["Redis_Proxy"] ?? "0");

        /// <summary>
        /// 是否爲sentinel服務器
        /// yes=1,
        /// no=0,
        /// </summary>
        private static int issentinel = int.Parse(ConfigurationManager.AppSettings["Redis_RedisIssentinel"] ?? "0");

        /// <summary>
        /// sentinel模式下,redis主數據服務器的密碼
        /// </summary>
        private static string authPassword = ConfigurationManager.AppSettings["Redis_RedisIssentinel"];

        /// <summary>
        /// serverName
        /// </summary>
        private static string serviceName = ConfigurationManager.AppSettings["Redis_ServiceName"];

        /// <summary>
        /// 獲得StackExchange.Redis單例對象
        /// </summary>
        public static ConnectionMultiplexer Instance
        {
            get
            {
                if (_redis == null || !_redis.IsConnected)
                {
                    lock (_locker)
                    {
                        if (_redis == null || !_redis.IsConnected)
                        {

                            _redis = GetManager();
                            return _redis;
                        }
                    }
                }

                return _redis;
            }
        }

        /// <summary>
        /// 構建連接
        /// </summary>
        /// <param name="connectionString"></param>
        /// <returns></returns>
        private static ConnectionMultiplexer GetManager()
        {
            return GetCurrentRedis();
        }

        /// <summary>
        /// 每一個鏈接串用逗號分開,sentinel不支持密碼
        /// </summary>
        /// <returns></returns>
        static ConnectionMultiplexer GetCurrentRedis()
        {
            var connectionString = ConfigurationManager.AppSettings["Redis_Host"];
            ConnectionMultiplexer conn;
            var option = new ConfigurationOptions();
            option.Proxy = (Proxy)proxy;//代理模式,目前支持TW


            //sentinel模式下自動鏈接主redis
            if (issentinel == 1)
            {
                var configArr = connectionString.Split(new char[] { ',' }, StringSplitOptions.RemoveEmptyEntries);
                configArr.ToList().ForEach(i =>
                {
                    option.EndPoints.Add(i);
                });

                option.TieBreaker = "";//這行在sentinel模式必須加上
                option.CommandMap = CommandMap.Sentinel;
                conn = ConnectionMultiplexer.Connect(option);

                for (int i = 0; i < option.EndPoints.Count; i++)
                {

                    try
                    {
                        connectionString = conn.GetServer(option.EndPoints[i]).SentinelGetMasterAddressByName(serviceName).ToString();
                        Console.WriteLine("當前主master[{0}]:{1}", i, connectionString);
                        break;
                    }
                    catch (RedisConnectionException ex)//超時
                    {
                        continue;
                    }
                    catch (Exception ex)
                    {
                        continue;
                    }
                }

            }

            return ConnectionMultiplexer.Connect(connectionString + ",password=" + authPassword);
        }

    }

View Code

消息隊列：
入隊

/// <summary>
       /// 消息隊列-入隊
       /// </summary>
        static void ListLeftPush()
        {
            while (true)
            {
                string msg = $"{DateTime.Now:HH:mm}-{globaxId}-{Thread.CurrentThread.ManagedThreadId}-{StringExtend.GetRanString(8)}";
                RedisManager.Instance.GetDatabase(RedisConfig.DemoDb).ListLeftPush(RedisConfig.DemoKey, msg);
                globaxId++;
                Console.WriteLine($"LeftPush:{msg}");
                Task.Delay(500);
                Thread.Sleep(500);
            }
        }

View Code

出隊：

 /// <summary>
        /// 消息隊列-出隊
        /// </summary>
        static void ListLeftPush()
        {
            while (true)
            {
                //ListLeftPush
                var msg = RedisManager.Instance.GetDatabase(RedisConfig.DemoDb).ListLeftPop(RedisConfig.DemoKey);
                if (!msg.IsNullOrEmpty)
                {
                    Console.WriteLine($"出隊:{msg}");
                    Task.Delay(200);
                }
                else
                {   
                    Thread.Sleep(1000);
                }
            }
        }

View Code

效果：

4.2發佈訂閱：

發佈

  /// <summary>
        /// 發佈
        /// </summary>
        static void Publish()
        {
            while (true)
            {
                lock (lockObj)
                {
                    string msg = $"{DateTime.Now:HH:mm}-{globaxId}-{StringExtend.GetRanString(8)}";
                    var sub = RedisManager.Instance.GetSubscriber();
                    sub.Publish(RedisConfig.DemoChannel1, msg);
                    Console.WriteLine($"Publish:{msg}");
                    globaxId++;
                   
                }

                Task.Delay(200);
                Thread.Sleep(500);
            }
        }

View Code

   /// <summary>
        /// 訂閱
        /// </summary>
        static void Subscribe()
        {
            while (true)
            {
                lock (lockObj)
                {
                    // string msg = $"Publish:{DateTime.Now:HH:mm}-{globaxId}-{StringExtend.GetRanString(8)}";
                    var sub = RedisManager.Instance.GetSubscriber();
                    sub.Subscribe(RedisConfig.DemoChannel1, SubHandel);
                }

                Task.Delay(200);
                Thread.Sleep(500);
            }
        }

        static void SubHandel(RedisChannel cnl, RedisValue val)
        {
            if (!val.IsNullOrEmpty)
            {
                Console.WriteLine($"Subscribe{val},線程:{Thread.CurrentThread.ManagedThreadId},是否線程池:{Thread.CurrentThread.IsThreadPoolThread}");
            }
            else
            {
                Thread.Sleep(1000);
            }
        }