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
    收藏
    关注
    评论
  • 相关阅读:
    [安装程序配置服务器失败]解决SQL Server2000安装失败
    C# 操作 XML 增 删 改 查
    批量修改文件的编码格式
    获取SqlServer2005表结构(字段,主键,外键,递增,描述)
    .NET 特性Attribute[一]
    windows2003远程桌面退出后系统自动注销的解决方法
    SqlServer 无日志文件附加
    接受来自服务器的数据连接时发生超时(30000 毫秒)问题原因及解决方法
    .net中数据集合导出为Excel(支持泛型及显示字段顺序,可自定义显示列名)
    EF中自编写SQL脚本查询结果(适用于复杂SQL逻辑提高查询效率)
  • 原文地址:https://www.cnblogs.com/for917157ever/p/14288307.html
Copyright © 2011-2022 走看看