C# Redis 帮助类

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了C# Redis 帮助类，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含3882字，纯文字阅读大概需要6分钟。

内容图文

总结下，后期会陆续更新

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using StackExchange.Redis;
using System.Threading;
using System.Data;
using System.Configuration;

namespace WebCommon
{
    public class RedisHelper
    {
        private static string connectStr = ConfigurationManager.AppSettings["RedisServer"];
        private static ConfigurationOptions configurationOptions = ConfigurationOptions.Parse(connectStr);
        //the lock for singleton
        private static readonly object Locker = new object();
        //singleton
        private static ConnectionMultiplexer redisConn;

        /// <summary>
        /// 连接redis
        /// </summary>
        /// <returns></returns>
        public static ConnectionMultiplexer getRedisConn()
        {
            if (redisConn == null)
            {
                lock (Locker)
                {
                    if (redisConn == null || !redisConn.IsConnected)
                    {
                        redisConn = ConnectionMultiplexer.Connect(configurationOptions);
                    }
                }
            }
            return redisConn;
        }

        #region Redis 字符串操作

        /// <summary>
        ///      设置一个key的值
        /// </summary>
        /// <param name="strKey"></param>
        /// <param name="strValue"></param>
        public void InsertStr(string strKey, string strValue)
        {
            redisConn = getRedisConn();
            var db = redisConn.GetDatabase();
            //set get
            bool setResult = db.StringSet(strKey, strValue);
        }
        /// <summary>
        ///    设置一个key的值并设定过期时间
        /// </summary>
        /// <param name="strKey">key</param>
        /// <param name="strValue">values</param>
        /// <param name="expirytime">过期时间</param>
        /// <param name="databasenum"></param>
        public void InsertStr(string strKey, string strValue, DateTime expirytime, int databasenum)
        {
            redisConn = getRedisConn();
            var db = redisConn.GetDatabase(databasenum);
            bool setResult = db.StringSet(strKey, strValue);
            db.KeyExpire(strKey, expirytime.ToUniversalTime());
        }

        
        /// <summary>
        /// 读取一个key值
        /// </summary>
        /// <param name="strKey"></param>
        /// <returns></returns>
        public string ReadStr(string strKey)
        {
            redisConn = getRedisConn();
            var db = redisConn.GetDatabase();
            return db.StringGet(strKey);
        }

        /// <summary>
        /// 删除一个key值
        /// </summary>
        /// <param name="strKey"></param>
        public void DeleteStr(string strKey)
        {
            redisConn = getRedisConn();
            var db = redisConn.GetDatabase();
            //set get
            bool setResult = db.KeyDelete(strKey);
        }
        /// <summary>
        /// 删除一个key值
        /// </summary>
        /// <param name="strKey"></param>
        /// <param name="databasenum"></param>
        /// <returns></returns>
        public bool DeleteStr(string strKey, int databasenum)
        {
            redisConn = getRedisConn();
            var db = redisConn.GetDatabase(databasenum);
            return db.KeyDelete(strKey);
        }

        /// <summary>
        ///  判断key是否存在
        /// </summary>
        /// <param name="strKey"></param>
        /// <returns></returns>
        public bool Exist(string strKey)
        {
            redisConn = getRedisConn();
            var db = redisConn.GetDatabase();
            return db.KeyExists(strKey);
        }
        #endregion

        #region Redis哈希操作 

        
        /// <summary>
        /// 添加一个key值
        /// </summary>
        /// <param name="tablename"></param>
        /// <param name="strKey"></param>
        /// <param name="strValue"></param>
        public void InsertHash(string tablename, string strKey, string strValue)
        {
            redisConn = getRedisConn();
            var db = redisConn.GetDatabase();

            //set get
            bool setResult = db.HashSet(tablename, strKey, strValue);
        }

        /// <summary>
        /// 读取一个key值
        /// </summary>
        /// <param name="tablename"></param>
        /// <param name="strKey"></param>
        /// <returns></returns>
        public string ReadHash(string tablename, string strKey)
        {
            redisConn = getRedisConn();
            var db = redisConn.GetDatabase();
            
            return db.HashGet(tablename, strKey);
        }

        /// <summary>
        /// 判断一个key值是否存在
        /// </summary>
        /// <param name="tablename"></param>
        /// <param name="strKey"></param>
        /// <returns></returns>
        public bool ExistHash(string tablename, string strKey)
        {
            redisConn = getRedisConn();
            var db = redisConn.GetDatabase();
            return db.HashExists(tablename, strKey);
        }

        /// <summary>
        /// 
        /// </summary>
        /// <param name="tablename"></param>
        /// <param name="strKey"></param>
        public void DeleteHash(string tablename, string strKey)
        {
            redisConn = getRedisConn();
            var db = redisConn.GetDatabase();
            //set get
            bool setResult = db.HashDelete(tablename,strKey);
        } 

        #endregion

    }
}

内容总结

以上是互联网集市为您收集整理的C# Redis 帮助类全部内容，希望文章能够帮你解决C# Redis 帮助类所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端