Redis使用记录

1.安装及部署参考 https://www.cnblogs.com/888888CN/p/9519590.html

2.使用Redis类库，我这里使用的是 StackExchange.Redis;

3.标准使用Set/Get，自己封装一个标准使用的类库

public class RedisService
    {
        private static string DefaultKey { get; set; }
        private ConnectionMultiplexer redis { get; set; }
        private IDatabase db { get; set; }

        public RedisService(string connection, string defaultKey)
        {
            DefaultKey = defaultKey;
            redis = ConnectionMultiplexer.Connect(connection);
            db = redis.GetDatabase();
        }

        /// <summary>
        /// 添加 key 的前缀
        /// </summary>
        /// <param name="key"></param>
        /// <returns></returns>
        private static string AddKeyPrefix(string key)
        {
            return $"{DefaultKey}:{key}";
        }


        /// <summary>
        /// 保存单个key value 
        /// </summary>
        /// <param name="key"></param>
        /// <param name="value"></param>
        /// <returns></returns>
        public bool Set(string key, string value)
        {
            key = AddKeyPrefix(key);
            return db.StringSet(key, value);
        }

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

        /// <summary>
        /// 保存多个key-value
        /// </summary>
        /// <param name="keyValuePairs"></param>
        /// <returns></returns>
        public bool Set(IEnumerable<KeyValuePair<RedisKey, RedisValue>> keyValuePairs)
        {
            keyValuePairs =
                keyValuePairs.Select(x => new KeyValuePair<RedisKey, RedisValue>(AddKeyPrefix(x.Key), x.Value));
            return db.StringSet(keyValuePairs.ToArray());
        }

        /// <summary>
        /// 获取一个key的value
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="key"></param>
        /// <returns></returns>
        public string Get(string key)
        {
            key = AddKeyPrefix(key);
            return db.StringGet(key);
        }

        /// <summary>
        /// 删除key
        /// </summary>
        /// <param name="key"></param>
        /// <returns></returns>
        public bool Delete(string key)
        {
            key = AddKeyPrefix(key);
            return db.KeyDelete(key);
        }

        /// <summary>
        /// 删除keys
        /// </summary>
        /// <param name="redisKeys"></param>
        /// <returns></returns>
        public long Delete(IEnumerable<string> keys)
        {
            var redisKeys = keys.Select(x => (RedisKey)AddKeyPrefix(x));
            return db.KeyDelete(redisKeys.ToArray());
        }


        /// <summary>
        /// 判断key是否存在
        /// </summary>
        /// <param name="key"></param>
        /// <returns></returns>
        public bool Exists(string key)
        {
            key = AddKeyPrefix(key);
            return db.KeyExists(key);
        }

        /// <summary>
        /// 重命名key
        /// </summary>
        /// <param name="oldKeyName"></param>
        /// <param name="newKeyName"></param>
        /// <returns></returns>
        public bool ReName(string oldKeyName, string newKeyName)
        {
            oldKeyName = AddKeyPrefix(oldKeyName);
            return db.KeyRename(oldKeyName, newKeyName);
        }

        /// <summary>
        /// 设置key 的过期时间
        /// </summary>
        /// <param name="redisKey"></param>
        /// <param name="expired"></param>
        /// <returns></returns>
        public bool Expire(string redisKey, TimeSpan? expired = null)
        {
            redisKey = AddKeyPrefix(redisKey);
            return db.KeyExpire(redisKey, expired);
        }

        /// <summary>
        /// 发布消息
        /// </summary>
        /// <param name="panel"></param>
        /// <param name="message"></param>
        public void Publish(string channel, string message)
        {
            ISubscriber sub = redis.GetSubscriber();
            sub.Publish(channel, message);
        }


        public void Subscribe(string panel, Action<string, string> handle)
        {
            ISubscriber sub = redis.GetSubscriber();
            sub.Subscribe(panel, (channel, message) =>
            {
                handle(channel, message);
            });
        }

        /// <summary>
        /// 在列表头部插入值，如果键不存在，先创建再插入值
        /// </summary>
        /// <param name="redisKey">不区分项目</param>
        /// <param name="redisValue"></param>
        /// <returns></returns>
        public long ListLeftPush(string key, string value)
        {
            //var redisKey = AddKeyPrefix(key);
            return db.ListLeftPush(key, value);
        }

        /// <summary>
        /// 移除并返回key所对应列表的第一个元素
        /// </summary>
        /// <param name="redisKey">不区分项目</param>
        /// <returns></returns>
        public string ListLeftPop(string key, Action<string> handle)
        {
            //var redisKey = AddKeyPrefix(key);
            string value = db.ListLeftPop(key);
            handle(value);
            return value; 
        }


        public string ListRightPop(string key, Action<string> handle)
        {
            string value = db.ListRightPop(key);
            handle(value);
            return value;

        }


    }

测试结果：