zoukankan      html  css  js  c++  java
  • C# Redis 帮助类

    总结下,后期会陆续更新

    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
    
        }
    }
    Top
    收藏
    关注
    评论
  • 相关阅读:
    安卓模拟器genimotion安装过程
    python3安装过程
    python基础数据类型数字和字符串
    genimotion模拟器和appium环境配置
    ArcEngine中的ICommand和ITool
    BM.AE介绍
    地图数据和版式数据联动
    BM.AE中的命令工具体系
    2021年1月1日 AutoCAD.Net/C#.Net QQ群:193522571获取任意路径dwg文件内所有块在控件中显示并能选择插入当前模型空间
    2021年1月1日 AutoCAD.Net/C#.Net QQ群:193522571用acedGrRead()函数实现一拖多
  • 原文地址:https://www.cnblogs.com/for917157ever/p/14288307.html
Copyright © 2011-2022 走看看