Redis安装使用

Redis下载地址：https://github.com/MicrosoftArchive/redis/releases

安装参考步骤参考：https://www.cnblogs.com/jaign/articles/7920588.html

Redis初始化类RedisUtils：

public class RedisUtils
    {
        private ConnectionMultiplexer _conn;
        private IDatabase _db;

        public RedisUtils(int dbNum)
        {
            _conn = RedisConnection.Current;
            _db = _conn.GetDatabase(dbNum);
        }

        public bool Exit(string key)
        {
            return _db.KeyExists(key);
        }

        public bool Exit(string haskKey, string key)
        {
            return _db.HashExists(haskKey, key);
        }

        public bool Set(string key, string value, int min = 0)
        {
            TimeSpan? time = null;
            if (min > 0) time = new TimeSpan(0, min, 0);
            return _db.StringSet(key, value, time);
        }

        public bool Set<T>(string key, T value, int min = 0)
        {
            TimeSpan? time = null;
            if (min > 0) time = new TimeSpan(0, min, 0);
            return _db.StringSet(key, Serialize(value), time);
        }

        public bool Set<T>(string hashKey, string key, T value)
        {
            return _db.HashSet(hashKey, key, Serialize(value));
        }
        /// <summary>
        /// 原始值存入 不自动转换
        /// </summary>
        /// <param name="hashKey"></param>
        /// <param name="key"></param>
        /// <param name="value"></param>
        /// <returns></returns>
        public bool Set(string hashKey, string key, string value)
        {
            return _db.HashSet(hashKey, key, value);
        }

        public string Get(string key)
        {
            if(string.IsNullOrEmpty(key)) return "";

            if (!Exit(key)) return "";
            return _db.StringGet(key);
        }

        public string Get(string hashKey, string key)
        {
            if (string.IsNullOrEmpty(hashKey)) return "";
            if (string.IsNullOrEmpty(key)) return "";

            if (!Exit(hashKey, key)) return "";
            return _db.HashGet(hashKey, key);
        }

        public T Get<T>(string key)
        {
            if (string.IsNullOrEmpty(key)) return default(T);

            if (!Exit(key)) return default(T);
            return Deserialize<T>(_db.StringGet(key));
        }

        public T Get<T>(string hashKey, string key)
        {
            if (string.IsNullOrEmpty(hashKey) || string.IsNullOrEmpty(key)) return default(T);

            if (!Exit(hashKey, key)) return default(T);
            return Deserialize<T>(_db.HashGet(hashKey, key));
        }

        public bool Remove(string key)
        { 
            if(string.IsNullOrEmpty(key)) return false;

            if (!Exit(key)) return true;
            return _db.KeyDelete(key);
        }

        public bool Remove(string HashKey, string key)
        {
            if (string.IsNullOrEmpty(HashKey) || string.IsNullOrEmpty(key)) return false;

            if (!Exit(HashKey, key)) return true;
            return _db.HashDelete(HashKey, key);
        }

        public void MultiRemove(string like)
        {
            _db.ScriptEvaluate(LuaScript.Prepare(
                @"
                    local ks = redis.call('KEYS', @keyPara) 
                    for i=1,#ks,5000 do 
                    redis.call('del', unpack(ks, i, math.min(i+4999, #ks))) 
                    end 
                    return true 
                "), new { keyPara = like }
            );
        }

        public void MultiRemove(string hashKey, string like)
        { 
            _db.ScriptEvaluate(LuaScript.Prepare(
                @"
                    local ks = redis.call('hkeys', @hKey) 
                    local fkeys = {} 
                    for i=1,#ks do 
                    if string.find(ks[i], @keyPara) then 
                    fkeys[#fkeys + 1] = ks[i] 
                    end 
                    end 
                    for i=1,#fkeys,5000 do 
                    redis.call('hdel', @hKey, unpack(fkeys, i, math.min(i+4999, #fkeys))) 
                    end 
                    return true 
                "
                ), new { hKey = hashKey, keyPara = like }
            );
        }

        /// <summary>
        /// 序列化对象
        /// </summary>
        /// <param name="o"></param>
        /// <returns></returns>
        private byte[] Serialize(object o)
        {
            if (o == null)
            {
                return null;
            }
            BinaryFormatter binaryFormatter = new BinaryFormatter();
            binaryFormatter.Binder = new UBinder();
            using (MemoryStream memoryStream = new MemoryStream())
            {
                binaryFormatter.Serialize(memoryStream, o);
                byte[] objectDataAsStream = memoryStream.ToArray();
                return objectDataAsStream;
            }
        }

        /// <summary>
        /// 反序列化对象
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="stream"></param>
        /// <returns></returns>
        private T Deserialize<T>(byte[] stream) 
        {
            if (stream == null)
            {
                return default(T);
            }
            BinaryFormatter binaryFormatter = new BinaryFormatter();
            binaryFormatter.Binder = new UBinder();
            using (MemoryStream memoryStream = new MemoryStream(stream))
            {
                T result = (T)binaryFormatter.Deserialize(memoryStream);
                return result;
            }
        }

        private class UBinder : SerializationBinder
        {
            public override Type BindToType(string assemblyName, string typeName)
            {
                if (typeName.Contains("International.Web"))
                {
                    typeName = typeName.Replace("Web", "PolicyUpload");
                    assemblyName = assemblyName.Replace("Web", "PolicyUpload");
                }
                else if (typeName.Contains("Models"))
                {
                    typeName = typeName.Replace("International.Models", "PolicyUpload");
                    assemblyName = assemblyName.Replace("International.Models", "PolicyUpload");
                }

                return Type.GetType(string.Format("{0}, {1}", typeName, assemblyName));
            }
        }
    }

RedisConnection类：

 public class RedisConnection
    {
        private static string _conn = ConfigurationManager.AppSettings["RedisConn"]; //连接字符串

        private static Lazy<ConnectionMultiplexer> lazyCon = new Lazy<ConnectionMultiplexer>(() =>
        {
            return ConnectionMultiplexer.Connect(_conn);
        });

        public static ConnectionMultiplexer Current
        {
            get
            {
                return lazyCon.Value;
            }
        }
    }

Redis可视化工具Redis Desktop Manager下载地址：https://github.com/uglide/RedisDesktopManager （参考资料：https://www.cnblogs.com/lbky/p/9861270.html）

 免费工具：https://gitee.com/qishibo/AnotherRedisDesktopManager

Windows 下安装多个Redis 实例

https://www.cnblogs.com/wangxingjian/p/12601592.html