using Newtonsoft.Json;
using StackExchange.Redis;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;

namespace learun.cache
{
	/// <summary>
	/// 版 本 EasyCode EC管理后台
	/// Copyright (c) 2019-present EC管理有限公司
	/// 创建人：tobin
	/// 日 期：2019.09.09
	/// 描 述：Redis缓存
	/// </summary>
	public class RedisCache
	{
		private int DbNum { get; set; }

		/// <summary>
		/// Redis连接
		/// </summary>
		private readonly ConnectionMultiplexer _conn;

		/// <summary>
		/// 设置自定义键
		/// </summary>
		public string CustomKey;

		#region 构造函数

		/// <summary>
		/// 构造函数
		/// </summary>
		/// <param name="dbNum"></param>
		public RedisCache(int dbNum = 0)
			: this(dbNum, null)
		{
		}

		/// <summary>
		/// 构造函数
		/// </summary>
		/// <param name="dbNum"></param>
		/// <param name="readWriteHosts"></param>
		public RedisCache(int dbNum, string readWriteHosts)
		{
			DbNum = dbNum;
			_conn = string.IsNullOrWhiteSpace(readWriteHosts) ?
					RedisConnectionHelp.Instance :
					RedisConnectionHelp.GetConnectionMultiplexer(readWriteHosts);
		}

		#endregion 构造函数

		#region String

		#region 同步方法

		/// <summary>
		/// 保存单个key value
		/// </summary>
		/// <param name="key">Redis Key</param>
		/// <param name="value">保存的值</param>
		/// <param name="expiry">过期时间</param>
		/// <returns></returns>
		public bool StringSet(string key, string value, TimeSpan? expiry = default)
		{
			key = AddSysCustomKey(key);
			return Do(db => db.StringSet(key, value, expiry));
		}

		/// <summary>
		/// 保存多个key value
		/// </summary>
		/// <param name="keyValues">键值对</param>
		/// <returns></returns>
		public bool StringSet(List<KeyValuePair<RedisKey, RedisValue>> keyValues)
		{
			List<KeyValuePair<RedisKey, RedisValue>> newkeyValues = keyValues.Select(p => new KeyValuePair<RedisKey, RedisValue>(AddSysCustomKey(p.Key), p.Value)).ToList();
			return Do(db => db.StringSet(newkeyValues.ToArray()));
		}

		/// <summary>
		/// 保存一个对象
		/// </summary>
		/// <typeparam name="T"></typeparam>
		/// <param name="key"></param>
		/// <param name="obj"></param>
		/// <param name="expiry"></param>
		/// <returns></returns>
		public bool StringSet<T>(string key, T obj, TimeSpan? expiry = default)
		{
			key = AddSysCustomKey(key);
			string json = ConvertJson(obj);
			return Do(db => db.StringSet(key, json, expiry));
		}

		/// <summary>
		/// 获取单个key的值
		/// </summary>
		/// <param name="key">Redis Key</param>
		/// <returns></returns>
		public string StringGet(string key)
		{
			key = AddSysCustomKey(key);
			return Do(db => db.StringGet(key));
		}

		/// <summary>
		/// 获取多个Key
		/// </summary>
		/// <param name="listKey">Redis Key集合</param>
		/// <returns></returns>
		public RedisValue[] StringGet(List<string> listKey)
		{
			List<string> newKeys = listKey.Select(AddSysCustomKey).ToList();
			return Do(db => db.StringGet(ConvertRedisKeys(newKeys)));
		}

		/// <summary>
		/// 获取一个key的对象
		/// </summary>
		/// <typeparam name="T"></typeparam>
		/// <param name="key"></param>
		/// <returns></returns>
		public T StringGet<T>(string key)
		{
			key = AddSysCustomKey(key);
			return Do(db => ConvertObj<T>(db.StringGet(key)));
		}

		/// <summary>
		/// 为数字增长val
		/// </summary>
		/// <param name="key"></param>
		/// <param name="val">可以为负</param>
		/// <returns>增长后的值</returns>
		public double StringIncrement(string key, double val = 1)
		{
			key = AddSysCustomKey(key);
			return Do(db => db.StringIncrement(key, val));
		}

		/// <summary>
		/// 为数字减少val
		/// </summary>
		/// <param name="key"></param>
		/// <param name="val">可以为负</param>
		/// <returns>减少后的值</returns>
		public double StringDecrement(string key, double val = 1)
		{
			key = AddSysCustomKey(key);
			return Do(db => db.StringDecrement(key, val));
		}

		#endregion 同步方法

		#region 异步方法

		/// <summary>
		/// 保存单个key value
		/// </summary>
		/// <param name="key">Redis Key</param>
		/// <param name="value">保存的值</param>
		/// <param name="expiry">过期时间</param>
		/// <returns></returns>
		public async Task<bool> StringSetAsync(string key, string value, TimeSpan? expiry = default)
		{
			key = AddSysCustomKey(key);
			return await Do(db => db.StringSetAsync(key, value, expiry));
		}

		/// <summary>
		/// 保存多个key value
		/// </summary>
		/// <param name="keyValues">键值对</param>
		/// <returns></returns>
		public async Task<bool> StringSetAsync(List<KeyValuePair<RedisKey, RedisValue>> keyValues)
		{
			List<KeyValuePair<RedisKey, RedisValue>> newkeyValues =
				keyValues.Select(p => new KeyValuePair<RedisKey, RedisValue>(AddSysCustomKey(p.Key), p.Value)).ToList();
			return await Do(db => db.StringSetAsync(newkeyValues.ToArray()));
		}

		/// <summary>
		/// 保存一个对象
		/// </summary>
		/// <typeparam name="T"></typeparam>
		/// <param name="key"></param>
		/// <param name="obj"></param>
		/// <param name="expiry"></param>
		/// <returns></returns>
		public async Task<bool> StringSetAsync<T>(string key, T obj, TimeSpan? expiry = default)
		{
			key = AddSysCustomKey(key);
			string json = ConvertJson(obj);
			return await Do(db => db.StringSetAsync(key, json, expiry));
		}

		/// <summary>
		/// 获取单个key的值
		/// </summary>
		/// <param name="key">Redis Key</param>
		/// <returns></returns>
		public async Task<string> StringGetAsync(string key)
		{
			key = AddSysCustomKey(key);
			return await Do(db => db.StringGetAsync(key));
		}

		/// <summary>
		/// 获取多个Key
		/// </summary>
		/// <param name="listKey">Redis Key集合</param>
		/// <returns></returns>
		public async Task<RedisValue[]> StringGetAsync(List<string> listKey)
		{
			List<string> newKeys = listKey.Select(AddSysCustomKey).ToList();
			return await Do(db => db.StringGetAsync(ConvertRedisKeys(newKeys)));
		}

		/// <summary>
		/// 获取一个key的对象
		/// </summary>
		/// <typeparam name="T"></typeparam>
		/// <param name="key"></param>
		/// <returns></returns>
		public async Task<T> StringGetAsync<T>(string key)
		{
			key = AddSysCustomKey(key);
			string result = await Do(db => db.StringGetAsync(key));
			return ConvertObj<T>(result);
		}

		/// <summary>
		/// 为数字增长val
		/// </summary>
		/// <param name="key"></param>
		/// <param name="val">可以为负</param>
		/// <returns>增长后的值</returns>
		public async Task<double> StringIncrementAsync(string key, double val = 1)
		{
			key = AddSysCustomKey(key);
			return await Do(db => db.StringIncrementAsync(key, val));
		}

		/// <summary>
		/// 为数字减少val
		/// </summary>
		/// <param name="key"></param>
		/// <param name="val">可以为负</param>
		/// <returns>减少后的值</returns>
		public async Task<double> StringDecrementAsync(string key, double val = 1)
		{
			key = AddSysCustomKey(key);
			return await Do(db => db.StringDecrementAsync(key, val));
		}

		#endregion 异步方法

		#endregion String

		#region Hash

		#region 同步方法

		/// <summary>
		/// 判断某个数据是否已经被缓存
		/// </summary>
		/// <param name="key"></param>
		/// <param name="dataKey"></param>
		/// <returns></returns>
		public bool HashExists(string key, string dataKey)
		{
			key = AddSysCustomKey(key);
			return Do(db => db.HashExists(key, dataKey));
		}

		/// <summary>
		/// 存储数据到hash表
		/// </summary>
		/// <typeparam name="T"></typeparam>
		/// <param name="key"></param>
		/// <param name="dataKey"></param>
		/// <param name="t"></param>
		/// <returns></returns>
		public bool HashSet<T>(string key, string dataKey, T t)
		{
			key = AddSysCustomKey(key);
			return Do(db =>
			{
				string json = ConvertJson(t);
				return db.HashSet(key, dataKey, json);
			});
		}

		/// <summary>
		/// 移除hash中的某值
		/// </summary>
		/// <param name="key"></param>
		/// <param name="dataKey"></param>
		/// <returns></returns>
		public bool HashDelete(string key, string dataKey)
		{
			key = AddSysCustomKey(key);
			return Do(db => db.HashDelete(key, dataKey));
		}

		/// <summary>
		/// 移除hash中的多个值
		/// </summary>
		/// <param name="key"></param>
		/// <param name="dataKeys"></param>
		/// <returns></returns>
		public long HashDelete(string key, List<RedisValue> dataKeys)
		{
			key = AddSysCustomKey(key);
			//List<RedisValue> dataKeys1 = new List<RedisValue>() {"1","2"};
			return Do(db => db.HashDelete(key, dataKeys.ToArray()));
		}

		/// <summary>
		/// 从hash表获取某个值
		/// </summary>
		/// <param name="key"></param>
		/// <param name="dataKey"></param>
		/// <returns></returns>
		public string HashGet(string key, string dataKey)
		{
			key = AddSysCustomKey(key);
			return Do(db =>
			{
				string value = db.HashGet(key, dataKey);
				return value;
			});
		}

		/// <summary>
		/// 从hash表获取Model
		/// </summary>
		/// <typeparam name="T"></typeparam>
		/// <param name="key"></param>
		/// <param name="dataKey"></param>
		/// <returns></returns>
		public T HashGet<T>(string key, string dataKey)
		{
			key = AddSysCustomKey(key);
			return Do(db =>
			{
				string value = db.HashGet(key, dataKey);
				return ConvertObj<T>(value);
			});
		}

		/// <summary>
		/// 从hash表获取List
		/// </summary>
		/// <typeparam name="T"></typeparam>
		/// <param name="key"></param>
		/// <returns></returns>
		public IList<T> HashGetList<T>(string key)
		{
			key = AddSysCustomKey(key);
			return Do(db =>
			{
				RedisValue[] values = db.HashValues(key);
				return ConvetList<T>(values);
			});
		}

		/// <summary>
		/// 为数字增长val
		/// </summary>
		/// <param name="key"></param>
		/// <param name="dataKey"></param>
		/// <param name="val">可以为负</param>
		/// <returns>增长后的值</returns>
		public double HashIncrement(string key, string dataKey, double val = 1)
		{
			key = AddSysCustomKey(key);
			return Do(db => db.HashIncrement(key, dataKey, val));
		}

		/// <summary>
		/// 为数字减少val
		/// </summary>
		/// <param name="key"></param>
		/// <param name="dataKey"></param>
		/// <param name="val">可以为负</param>
		/// <returns>减少后的值</returns>
		public double HashDecrement(string key, string dataKey, double val = 1)
		{
			key = AddSysCustomKey(key);
			return Do(db => db.HashDecrement(key, dataKey, val));
		}

		/// <summary>
		/// 获取hashkey所有Redis key
		/// </summary>
		/// <typeparam name="T"></typeparam>
		/// <param name="key"></param>
		/// <returns></returns>
		public List<T> HashKeys<T>(string key)
		{
			key = AddSysCustomKey(key);
			return Do(db =>
			{
				RedisValue[] values = db.HashKeys(key);
				return ConvetList<T>(values);
			});
		}

		#endregion 同步方法

		#region 异步方法

		/// <summary>
		/// 判断某个数据是否已经被缓存
		/// </summary>
		/// <param name="key"></param>
		/// <param name="dataKey"></param>
		/// <returns></returns>
		public async Task<bool> HashExistsAsync(string key, string dataKey)
		{
			key = AddSysCustomKey(key);
			return await Do(db => db.HashExistsAsync(key, dataKey));
		}

		/// <summary>
		/// 存储数据到hash表
		/// </summary>
		/// <typeparam name="T"></typeparam>
		/// <param name="key"></param>
		/// <param name="dataKey"></param>
		/// <param name="t"></param>
		/// <returns></returns>
		public async Task<bool> HashSetAsync<T>(string key, string dataKey, T t)
		{
			key = AddSysCustomKey(key);
			return await Do(db =>
			{
				string json = ConvertJson(t);
				return db.HashSetAsync(key, dataKey, json);
			});
		}

		/// <summary>
		/// 移除hash中的某值
		/// </summary>
		/// <param name="key"></param>
		/// <param name="dataKey"></param>
		/// <returns></returns>
		public async Task<bool> HashDeleteAsync(string key, string dataKey)
		{
			key = AddSysCustomKey(key);
			return await Do(db => db.HashDeleteAsync(key, dataKey));
		}

		/// <summary>
		/// 移除hash中的多个值
		/// </summary>
		/// <param name="key"></param>
		/// <param name="dataKeys"></param>
		/// <returns></returns>
		public async Task<long> HashDeleteAsync(string key, List<RedisValue> dataKeys)
		{
			key = AddSysCustomKey(key);
			//List<RedisValue> dataKeys1 = new List<RedisValue>() {"1","2"};
			return await Do(db => db.HashDeleteAsync(key, dataKeys.ToArray()));
		}

		/// <summary>
		/// 从hash表获取数据
		/// </summary>
		/// <typeparam name="T"></typeparam>
		/// <param name="key"></param>
		/// <param name="dataKey"></param>
		/// <returns></returns>
		public async Task<T> HashGeAsync<T>(string key, string dataKey)
		{
			key = AddSysCustomKey(key);
			string value = await Do(db => db.HashGetAsync(key, dataKey));
			return ConvertObj<T>(value);
		}

		/// <summary>
		/// 为数字增长val
		/// </summary>
		/// <param name="key"></param>
		/// <param name="dataKey"></param>
		/// <param name="val">可以为负</param>
		/// <returns>增长后的值</returns>
		public async Task<double> HashIncrementAsync(string key, string dataKey, double val = 1)
		{
			key = AddSysCustomKey(key);
			return await Do(db => db.HashIncrementAsync(key, dataKey, val));
		}

		/// <summary>
		/// 为数字减少val
		/// </summary>
		/// <param name="key"></param>
		/// <param name="dataKey"></param>
		/// <param name="val">可以为负</param>
		/// <returns>减少后的值</returns>
		public async Task<double> HashDecrementAsync(string key, string dataKey, double val = 1)
		{
			key = AddSysCustomKey(key);
			return await Do(db => db.HashDecrementAsync(key, dataKey, val));
		}

		/// <summary>
		/// 获取hashkey所有Redis key
		/// </summary>
		/// <typeparam name="T"></typeparam>
		/// <param name="key"></param>
		/// <returns></returns>
		public async Task<List<T>> HashKeysAsync<T>(string key)
		{
			key = AddSysCustomKey(key);
			RedisValue[] values = await Do(db => db.HashKeysAsync(key));
			return ConvetList<T>(values);
		}

		#endregion 异步方法

		#endregion Hash

		#region List

		#region 同步方法

		/// <summary>
		/// 移除指定ListId的内部List的值
		/// </summary>
		/// <param name="key"></param>
		/// <param name="value"></param>
		public void ListRemove<T>(string key, T value)
		{
			key = AddSysCustomKey(key);
			Do(db => db.ListRemove(key, ConvertJson(value)));
		}

		/// <summary>
		/// 获取指定key的List
		/// </summary>
		/// <param name="key"></param>
		/// <returns></returns>
		public List<T> ListRange<T>(string key)
		{
			key = AddSysCustomKey(key);
			return Do(redis =>
			{
				var values = redis.ListRange(key);
				return ConvetList<T>(values);
			});
		}

		/// <summary>
		/// 入队
		/// </summary>
		/// <param name="key"></param>
		/// <param name="value"></param>
		public void ListRightPush<T>(string key, T value)
		{
			key = AddSysCustomKey(key);
			Do(db => db.ListRightPush(key, ConvertJson(value)));
		}

		/// <summary>
		/// 出队
		/// </summary>
		/// <typeparam name="T"></typeparam>
		/// <param name="key"></param>
		/// <returns></returns>
		public T ListRightPop<T>(string key)
		{
			key = AddSysCustomKey(key);
			return Do(db =>
			{
				var value = db.ListRightPop(key);
				return ConvertObj<T>(value);
			});
		}

		/// <summary>
		/// 入栈
		/// </summary>
		/// <typeparam name="T"></typeparam>
		/// <param name="key"></param>
		/// <param name="value"></param>
		public void ListLeftPush<T>(string key, T value)
		{
			key = AddSysCustomKey(key);
			Do(db => db.ListLeftPush(key, ConvertJson(value)));
		}

		/// <summary>
		/// 出栈
		/// </summary>
		/// <typeparam name="T"></typeparam>
		/// <param name="key"></param>
		/// <returns></returns>
		public T ListLeftPop<T>(string key)
		{
			key = AddSysCustomKey(key);
			return Do(db =>
			{
				var value = db.ListLeftPop(key);
				return ConvertObj<T>(value);
			});
		}

		/// <summary>
		/// 获取集合中的数量
		/// </summary>
		/// <param name="key"></param>
		/// <returns></returns>
		public long ListLength(string key)
		{
			key = AddSysCustomKey(key);
			return Do(redis => redis.ListLength(key));
		}

		#endregion 同步方法

		#region 异步方法

		/// <summary>
		/// 移除指定ListId的内部List的值
		/// </summary>
		/// <param name="key"></param>
		/// <param name="value"></param>
		public async Task<long> ListRemoveAsync<T>(string key, T value)
		{
			key = AddSysCustomKey(key);
			return await Do(db => db.ListRemoveAsync(key, ConvertJson(value)));
		}

		/// <summary>
		/// 获取指定key的List
		/// </summary>
		/// <param name="key"></param>
		/// <returns></returns>
		public async Task<List<T>> ListRangeAsync<T>(string key)
		{
			key = AddSysCustomKey(key);
			var values = await Do(redis => redis.ListRangeAsync(key));
			return ConvetList<T>(values);
		}

		/// <summary>
		/// 入队
		/// </summary>
		/// <param name="key"></param>
		/// <param name="value"></param>
		public async Task<long> ListRightPushAsync<T>(string key, T value)
		{
			key = AddSysCustomKey(key);
			return await Do(db => db.ListRightPushAsync(key, ConvertJson(value)));
		}

		/// <summary>
		/// 出队
		/// </summary>
		/// <typeparam name="T"></typeparam>
		/// <param name="key"></param>
		/// <returns></returns>
		public async Task<T> ListRightPopAsync<T>(string key)
		{
			key = AddSysCustomKey(key);
			var value = await Do(db => db.ListRightPopAsync(key));
			return ConvertObj<T>(value);
		}

		/// <summary>
		/// 入栈
		/// </summary>
		/// <typeparam name="T"></typeparam>
		/// <param name="key"></param>
		/// <param name="value"></param>
		public async Task<long> ListLeftPushAsync<T>(string key, T value)
		{
			key = AddSysCustomKey(key);
			return await Do(db => db.ListLeftPushAsync(key, ConvertJson(value)));
		}

		/// <summary>
		/// 出栈
		/// </summary>
		/// <typeparam name="T"></typeparam>
		/// <param name="key"></param>
		/// <returns></returns>
		public async Task<T> ListLeftPopAsync<T>(string key)
		{
			key = AddSysCustomKey(key);
			var value = await Do(db => db.ListLeftPopAsync(key));
			return ConvertObj<T>(value);
		}

		/// <summary>
		/// 获取集合中的数量
		/// </summary>
		/// <param name="key"></param>
		/// <returns></returns>
		public async Task<long> ListLengthAsync(string key)
		{
			key = AddSysCustomKey(key);
			return await Do(redis => redis.ListLengthAsync(key));
		}

		#endregion 异步方法

		#endregion List

		#region SortedSet 有序集合

		#region 同步方法

		/// <summary>
		/// 添加
		/// </summary>
		/// <param name="key"></param>
		/// <param name="value"></param>
		/// <param name="score"></param>
		public bool SortedSetAdd<T>(string key, T value, double score)
		{
			key = AddSysCustomKey(key);
			return Do(redis => redis.SortedSetAdd(key, ConvertJson<T>(value), score));
		}

		/// <summary>
		/// 删除
		/// </summary>
		/// <param name="key"></param>
		/// <param name="value"></param>
		public bool SortedSetRemove<T>(string key, T value)
		{
			key = AddSysCustomKey(key);
			return Do(redis => redis.SortedSetRemove(key, ConvertJson(value)));
		}

		/// <summary>
		/// 获取全部
		/// </summary>
		/// <param name="key"></param>
		/// <returns></returns>
		public List<T> SortedSetRangeByRank<T>(string key)
		{
			key = AddSysCustomKey(key);
			return Do(redis =>
			{
				var values = redis.SortedSetRangeByRank(key);
				return ConvetList<T>(values);
			});
		}

		/// <summary>
		/// 获取集合中的数量
		/// </summary>
		/// <param name="key"></param>
		/// <returns></returns>
		public long SortedSetLength(string key)
		{
			key = AddSysCustomKey(key);
			return Do(redis => redis.SortedSetLength(key));
		}

		#endregion 同步方法

		#region 异步方法

		/// <summary>
		/// 添加
		/// </summary>
		/// <param name="key"></param>
		/// <param name="value"></param>
		/// <param name="score"></param>
		public async Task<bool> SortedSetAddAsync<T>(string key, T value, double score)
		{
			key = AddSysCustomKey(key);
			return await Do(redis => redis.SortedSetAddAsync(key, ConvertJson<T>(value), score));
		}

		/// <summary>
		/// 删除
		/// </summary>
		/// <param name="key"></param>
		/// <param name="value"></param>
		public async Task<bool> SortedSetRemoveAsync<T>(string key, T value)
		{
			key = AddSysCustomKey(key);
			return await Do(redis => redis.SortedSetRemoveAsync(key, ConvertJson(value)));
		}

		/// <summary>
		/// 获取全部
		/// </summary>
		/// <param name="key"></param>
		/// <returns></returns>
		public async Task<List<T>> SortedSetRangeByRankAsync<T>(string key)
		{
			key = AddSysCustomKey(key);
			var values = await Do(redis => redis.SortedSetRangeByRankAsync(key));
			return ConvetList<T>(values);
		}

		/// <summary>
		/// 获取集合中的数量
		/// </summary>
		/// <param name="key"></param>
		/// <returns></returns>
		public async Task<long> SortedSetLengthAsync(string key)
		{
			key = AddSysCustomKey(key);
			return await Do(redis => redis.SortedSetLengthAsync(key));
		}

		#endregion 异步方法

		#endregion SortedSet 有序集合

		#region key

		/// <summary>
		/// 删除单个key
		/// </summary>
		/// <param name="key">redis key</param>
		/// <returns>是否删除成功</returns>
		public bool KeyDelete(string key)
		{
			key = AddSysCustomKey(key);
			return Do(db => db.KeyDelete(key));
		}

		/// <summary>
		/// 删除单个key
		/// </summary>
		/// <param name="key"></param>
		/// <returns></returns>
		public Task<bool> KeyDeleteAsync(string key)
		{
			key = AddSysCustomKey(key);
			return Do(db => db.KeyDeleteAsync(key));
		}

		/// <summary>
		/// 删除多个key
		/// </summary>
		/// <param name="keys">rediskey</param>
		/// <returns>成功删除的个数</returns>
		public long KeyDelete(List<string> keys)
		{
			List<string> newKeys = keys.Select(AddSysCustomKey).ToList();
			return Do(db => db.KeyDelete(ConvertRedisKeys(newKeys)));
		}

		/// <summary>
		/// 判断key是否存储
		/// </summary>
		/// <param name="key">redis key</param>
		/// <returns></returns>
		public bool KeyExists(string key)
		{
			key = AddSysCustomKey(key);
			return Do(db => db.KeyExists(key));
		}

		/// <summary>
		/// 重新命名key
		/// </summary>
		/// <param name="key">就的redis key</param>
		/// <param name="newKey">新的redis key</param>
		/// <returns></returns>
		public bool KeyRename(string key, string newKey)
		{
			key = AddSysCustomKey(key);
			return Do(db => db.KeyRename(key, newKey));
		}

		/// <summary>
		/// 设置Key的时间
		/// </summary>
		/// <param name="key">redis key</param>
		/// <param name="expiry"></param>
		/// <returns></returns>
		public bool KeyExpire(string key, TimeSpan? expiry = default)
		{
			key = AddSysCustomKey(key);
			return Do(db => db.KeyExpire(key, expiry));
		}

		#endregion key

		#region 发布订阅

		/// <summary>
		/// Redis发布订阅  订阅
		/// </summary>
		/// <param name="subChannel"></param>
		/// <param name="handler"></param>
		public void Subscribe(string subChannel, Action<RedisChannel, RedisValue> handler = null)
		{
			ISubscriber sub = _conn.GetSubscriber();
			sub.Subscribe(subChannel, (channel, message) =>
			{
				//接收订阅消息，处理逻辑
				if (handler == null)
				{
					Console.WriteLine(subChannel + " 订阅收到消息：" + message);
				}
				else
				{
					handler(channel, message);
				}
			});
			//写法二
			sub.Subscribe(subChannel, new Action<RedisChannel, RedisValue>((channel, message) =>
			{
				Console.WriteLine(subChannel + " 订阅收到消息：" + message);
			}));
			//写法三
			sub.Subscribe(subChannel, new Action<RedisChannel, RedisValue>(GetMessage));
		}

		/// <summary>
		/// 获取订阅消息（写法三）
		/// </summary>
		/// <param name="channel"></param>
		/// <param name="message"></param>
		private static void GetMessage(RedisChannel channel, RedisValue message)
		{
			Console.WriteLine(channel + " 订阅收到消息：" + message);
		}

		/// <summary>
		/// Redis发布订阅  发布
		/// </summary>
		/// <typeparam name="T"></typeparam>
		/// <param name="channel"></param>
		/// <param name="msg"></param>
		/// <returns></returns>
		public long Publish<T>(string channel, T msg)
		{
			ISubscriber sub = _conn.GetSubscriber();
			return sub.Publish(channel, ConvertJson(msg));
		}

		/// <summary>
		/// Redis发布订阅  取消订阅
		/// </summary>
		/// <param name="channel"></param>
		public void Unsubscribe(string channel)
		{
			ISubscriber sub = _conn.GetSubscriber();
			sub.Unsubscribe(channel);
		}

		/// <summary>
		/// Redis发布订阅  取消全部订阅
		/// </summary>
		public void UnsubscribeAll()
		{
			ISubscriber sub = _conn.GetSubscriber();
			sub.UnsubscribeAll();
		}

		#endregion 发布订阅

		#region 其他

		/// <summary>
		/// 获取事物
		/// </summary>
		/// <returns></returns>
		public ITransaction CreateTransaction()
		{
			return GetDatabase().CreateTransaction();
		}

		/// <summary>
		/// 获取批处理（管道模式）
		/// </summary>
		/// <returns></returns>
		public IBatch CreateBatch()
		{
			return GetDatabase().CreateBatch();
		}

		/// <summary>
		///
		/// </summary>
		/// <returns></returns>
		public IDatabase GetDatabase()
		{
			return _conn.GetDatabase(DbNum);
		}

		/// <summary>
		///
		/// </summary>
		/// <param name="hostAndPort"></param>
		/// <returns></returns>
		public IServer GetServer(string hostAndPort)
		{
			return _conn.GetServer(hostAndPort);
		}

		/// <summary>
		///
		/// </summary>
		/// <param name="dbNum"></param>
		public void FlushDatabase(int dbNum)
		{
			var list = _conn.GetEndPoints();
			foreach (var item in list)
			{
				_conn.GetServer(item).FlushDatabase(dbNum);
			}
		}

		/// <summary>
		///
		/// </summary>
		/// <param name="dbNum"></param>
		/// <returns></returns>
		public async Task FlushDatabaseAsync(int dbNum)
		{
			var list = _conn.GetEndPoints();
			foreach (var item in list)
			{
				await _conn.GetServer(item).FlushDatabaseAsync(dbNum);
			}
		}

		/// <summary>
		/// 设置前缀
		/// </summary>
		/// <param name="customKey">自定义键</param>
		public void SetSysCustomKey(string customKey)
		{
			CustomKey = customKey;
		}

		#endregion 其他

		#region 辅助方法

		/// <summary>
		/// 添加自定义键
		/// </summary>
		/// <param name="oldKey"></param>
		/// <returns></returns>
		private string AddSysCustomKey(string oldKey)
		{
			var prefixKey = CustomKey ?? RedisConnectionHelp.SysCustomKey;
			return prefixKey + oldKey;
		}

		private T Do<T>(Func<IDatabase, T> func)
		{
			var database = _conn.GetDatabase(DbNum);
			return func(database);
		}

		/// <summary>
		/// 序列化
		/// </summary>
		/// <typeparam name="T">类</typeparam>
		/// <param name="value">值</param>
		/// <returns></returns>
		private string ConvertJson<T>(T value)
		{
			string result = value is string ? value.ToString() : JsonConvert.SerializeObject(value);
			return result;
		}

		/// <summary>
		/// 反序列化
		/// </summary>
		/// <typeparam name="T"></typeparam>
		/// <param name="value"></param>
		/// <returns></returns>
		private T ConvertObj<T>(RedisValue value)
		{
			if (value.IsNullOrEmpty)
			{
				return default;
			}
			if (typeof(T) == typeof(string))
			{
				return (T)Convert.ChangeType(value, typeof(T));
			}
			return JsonConvert.DeserializeObject<T>(value);
		}

		private List<T> ConvetList<T>(RedisValue[] values)
		{
			List<T> result = new List<T>();
			foreach (var item in values)
			{
				if (!item.IsNullOrEmpty)
				{
					var model = ConvertObj<T>(item);
					result.Add(model);
				}
			}
			return result;
		}

		private RedisKey[] ConvertRedisKeys(List<string> redisKeys)
		{
			return redisKeys.Select(redisKey => (RedisKey)redisKey).ToArray();
		}

		#endregion 辅助方法
	}
}