在.Net下使用redis基于StackExchange.Redis

2024-02-23 21:30
文章标签 使用 redis net stackexchange

本文主要是介绍在.Net下使用redis基于StackExchange.Redis，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

研究了下redis在.net下的使用，因为以前在java上用redis用的是jedis操作，在.net不是很熟悉，在网站上也看了一部分的.net下redis的使用，大部分都是ServiceStack.Redis听说ServiceStack.Redis4.0版本都是收费的，这个我不是很清楚，但是我确实有项目再用ServiceStack.Redis。

这里就不讨论ServiceStack.Redis的使用今天带来的是StackExchange.Redis的封装版。

代码参考

DDD领域驱动之干货（三）完结篇！

下面是干货

RedisCaching里面放着的是Redis的基本5个方法分别如下图所示：

RedisCommon里面放着的是redis的帮助类和初始化类如下图所示：

现在举了例子就以DoRedisStringCache为例：

实现了接口IRedisCaching，当然这里这个接口是标识接口意思就是用来约束的。

StackExchange.Redis是初始化是单列模式，内部有一套自己的方法，这里我就放一下代码

 

这里面还有6个事件如下图：

代码贴出来：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using StackExchange.Redis;
using KuRuMi.Mio.DoMain.Infrastructure.Logger;namespace KuRuMi.Mio.DoMain.RedisCache.RedisCommon
{public class RedisManager{private static string Constring = RedisConfig.Config();private static readonly object locker = new object();private static ConnectionMultiplexer instance;private static readonly Dictionary<string, ConnectionMultiplexer> Concache = new Dictionary<string, ConnectionMultiplexer>();/// <summary>/// 单例模式获取redis连接实例/// </summary>public static ConnectionMultiplexer Instance{get{if (instance == null){lock (locker){if (instance == null)instance = GetManager();}}return instance;}}/// <summary>/// 从缓存中获取/// </summary>/// <param name="constr"></param>/// <returns></returns>public static ConnectionMultiplexer GetConForMap(string constr) {if (!Concache.ContainsKey(constr))Concache[constr] = GetManager(constr);return Concache[constr];}private static ConnectionMultiplexer GetManager(string constr = null){constr = constr ?? Constring;var connect = ConnectionMultiplexer.Connect(constr);#region 注册事件connect.ConnectionFailed += MuxerConnectionFailed;connect.ConnectionRestored += MuxerConnectionRestored;connect.ErrorMessage += MuxerErrorMessage;connect.ConfigurationChanged += MuxerConfigurationChanged;connect.HashSlotMoved += MuxerHashSlotMoved;connect.InternalError += MuxerInternalError;#endregionreturn connect;}#region Redis事件/// <summary>/// 内部异常/// </summary>/// <param name="sender"></param>/// <param name="e"></param>private static void MuxerInternalError(object sender, InternalErrorEventArgs e){Units.Log("内部异常：" + e.Exception.Message);}/// <summary>/// 集群更改/// </summary>/// <param name="sender"></param>/// <param name="e"></param>private static void MuxerHashSlotMoved(object sender, HashSlotMovedEventArgs e){Units.Log("新集群：" + e.NewEndPoint + "旧集群：" + e.OldEndPoint);}/// <summary>/// 配置更改事件/// </summary>/// <param name="sender"></param>/// <param name="e"></param>private static void MuxerConfigurationChanged(object sender, EndPointEventArgs e){Units.Log("配置更改：" + e.EndPoint);}/// <summary>/// 错误事件/// </summary>/// <param name="sender"></param>/// <param name="e"></param>private static void MuxerErrorMessage(object sender, RedisErrorEventArgs e){Units.Log("异常信息：" + e.Message);}/// <summary>/// 重连错误事件/// </summary>/// <param name="sender"></param>/// <param name="e"></param>private static void MuxerConnectionRestored(object sender, ConnectionFailedEventArgs e){Units.Log("重连错误" + e.EndPoint);}/// <summary>/// 连接失败事件/// </summary>/// <param name="sender"></param>/// <param name="e"></param>private static void MuxerConnectionFailed(object sender, ConnectionFailedEventArgs e){Units.Log("连接异常" + e.EndPoint + "，类型为" + e.FailureType + (e.Exception == null ? "" : ("，异常信息是" + e.Exception.Message)));}#endregion}
}

下面是redis的config：

using System;
using System.Collections.Generic;
using System.Configuration;
using System.Linq;
using System.Text;
using System.Threading.Tasks;namespace KuRuMi.Mio.DoMain.RedisCache.RedisCommon
{public sealed class RedisConfig{public static readonly string config = ConfigurationManager.AppSettings["RedisConfig"];public static readonly string redisKey = ConfigurationManager.AppSettings["RedisKey"] ?? "";public static string Config() {return config;}public static string Key() {return redisKey;}}
}

下面是redis的helper：

using Newtonsoft.Json;
using StackExchange.Redis;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;namespace KuRuMi.Mio.DoMain.RedisCache.RedisCommon
{public class RedisBase{private static ConnectionMultiplexer db = null;private static string key = string.Empty;private int DbNumber { get; }public RedisBase(int dbnum = 0) : this(dbnum, null){}public RedisBase(int dbnum, string connectionString){DbNumber = dbnum;db = string.IsNullOrWhiteSpace(connectionString) ? RedisManager.Instance : RedisManager.GetConForMap(connectionString);}#region 辅助方法/// <summary>/// 添加名称/// </summary>/// <param name="old"></param>/// <returns></returns>public string AddKey(string old){var fixkey = key ?? RedisConfig.Key();return fixkey + old;}/// <summary>/// 执行保存/// </summary>/// <typeparam name="T"></typeparam>/// <param name="func"></param>/// <returns></returns>public T DoSave<T>(Func<IDatabase, T> func){return func(db.GetDatabase(DbNumber));}public string ConvertJson<T>(T val){return val is string ? val.ToString() : JsonConvert.SerializeObject(val);}public T ConvertObj<T>(RedisValue val){return JsonConvert.DeserializeObject<T>(val);}public List<T> ConvertList<T>(RedisValue[] val){List<T> result = new List<T>();foreach (var item in val){var model = ConvertObj<T>(item);result.Add(model);}return result;}public RedisKey[] ConvertRedisKeys(List<string> val){return val.Select(k => (RedisKey)k).ToArray();}#endregion}
}

下面是我的string封装方法：

using KuRuMi.Mio.DoMain.RedisCache.RedisCommon;
using StackExchange.Redis;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;namespace KuRuMi.Mio.DoMain.RedisCache.RedisCaching
{/// <summary>/// 表示string的操作/// </summary>public class DoRedisStringCache : IRedisCaching{private RedisBase redis = null;public DoRedisStringCache(){redis = new RedisBase();}#region 同步执行/// <summary>/// 单个保存/// </summary>/// <param name="key"></param>/// <param name="val">值</param>/// <param name="exp">过期时间</param>/// <returns></returns>public bool StringSet(string key, string val, TimeSpan? exp = default(TimeSpan?)){key = redis.AddKey(key);return redis.DoSave(db => db.StringSet(key, val, exp));}/// <summary>/// 保存多个key value/// </summary>/// <param name="keyValues">键值对</param>/// <returns></returns>public bool StringSet(List<KeyValuePair<RedisKey, RedisValue>> KeyVal){List<KeyValuePair<RedisKey, RedisValue>> newkey = KeyVal.Select(k => new KeyValuePair<RedisKey, RedisValue>(redis.AddKey(k.Key), k.Value)).ToList();return redis.DoSave(db => db.StringSet(newkey.ToArray()));}/// <summary>/// 保存一个对象/// </summary>/// <typeparam name="T"></typeparam>/// <param name="key"></param>/// <param name="obj"></param>/// <param name="exp"></param>/// <returns></returns>public bool StringSet<T>(string key, T obj, TimeSpan? exp = default(TimeSpan?)){key = redis.AddKey(key);string json = redis.ConvertJson(obj);return redis.DoSave(db => db.StringSet(key, json, exp));}/// <summary>/// 获取单个/// </summary>/// <param name="key"></param>/// <returns></returns>public string StringGet(string key){key = redis.AddKey(key);return redis.DoSave(db => db.StringGet(key));}/// <summary>/// 获取单个对象/// </summary>/// <typeparam name="T"></typeparam>/// <param name="key"></param>/// <returns></returns>public T StringGet<T>(string key) {key = redis.AddKey(key);var val = redis.DoSave(db => db.StringGet(key));return redis.ConvertObj<T>(val);}/// <summary>/// 为数字增长val/// </summary>/// <param name="key"></param>/// <param name="val">可以为负数</param>/// <returns>增长后的值</returns>public double StringIncrement(string key, double val = 1){key = redis.AddKey(key);return redis.DoSave(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 = redis.AddKey(key);return redis.DoSave(db => db.StringDecrement(key, val));}#endregion#region 异步执行/// <summary>/// 异步保存单个/// </summary>/// <param name="key"></param>/// <param name="val"></param>/// <param name="exp"></param>/// <returns></returns>public async Task<bool> StringSetAsync(string key, string val, TimeSpan? exp = default(TimeSpan?)){key = redis.AddKey(key);return await redis.DoSave(db => db.StringSetAsync(key, val, exp));}/// <summary>/// 异步保存多个key value/// </summary>/// <param name="keyValues">键值对</param>/// <returns></returns>public async Task<bool> StringSetAsync(List<KeyValuePair<RedisKey, RedisValue>> KeyVal){List<KeyValuePair<RedisKey, RedisValue>> newkey = KeyVal.Select(k => new KeyValuePair<RedisKey, RedisValue>(redis.AddKey(k.Key), k.Value)).ToList();return await redis.DoSave(db => db.StringSetAsync(newkey.ToArray()));}/// <summary>/// 异步保存一个对象/// </summary>/// <typeparam name="T"></typeparam>/// <param name="key"></param>/// <param name="obj"></param>/// <param name="exp"></param>/// <returns></returns>public async Task<bool> StringSetAsync<T>(string key, T obj, TimeSpan? exp = default(TimeSpan?)){key = redis.AddKey(key);string json = redis.ConvertJson(obj);return await redis.DoSave(db => db.StringSetAsync(key, json, exp));}/// <summary>/// 异步获取单个/// </summary>/// <param name="key"></param>/// <returns></returns>public async Task<string> StringGetAsync(string key){key = redis.AddKey(key);return await redis.DoSave(db => db.StringGetAsync(key));}/// <summary>/// 异步获取单个/// </summary>/// <param name="key"></param>/// <returns></returns>public async Task<T> StringGetAsync<T>(string key){key = redis.AddKey(key);var val = await redis.DoSave(db => db.StringGetAsync(key));return redis.ConvertObj<T>(val);}/// <summary>/// 异步为数字增长val/// </summary>/// <param name="key"></param>/// <param name="val">可以为负数</param>/// <returns>增长后的值</returns>public async Task<double> StringIncrementAsync(string key, double val = 1){key = redis.AddKey(key);return await redis.DoSave(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 = redis.AddKey(key);return await redis.DoSave(db => db.StringDecrementAsync(key, val));}#endregion}
}

StackExchange.Redis本身提供了一套异步的方法这个我比较喜欢。至于其他的和string的同理，我这里就不放出封装方法，需要的留言。

最后是测试：

这是我的redis然后是我的数据库

这里是我登录的测试代码：

 

转载于:https://www.cnblogs.com/edna-lzh/p/6932948.html

这篇关于在.Net下使用redis基于StackExchange.Redis的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/739974。

相关文章

鸿蒙中@State的原理使用详解(HarmonyOS 5)

鸿蒙中@State的原理使用详解(HarmonyOS 5)

《鸿蒙中@State的原理使用详解(HarmonyOS5)》@State是HarmonyOSArkTS框架中用于管理组件状态的核心装饰器,其核心作用是实现数据驱动UI的响应式编程模式,本文给大家介绍... 目录一、@State在鸿蒙中是做什么的？二、@Spythontate的基本原理1. 依赖关系的收集2.
阅读更多...
Python基础语法中defaultdict的使用小结

Python基础语法中defaultdict的使用小结

《Python基础语法中defaultdict的使用小结》Python的defaultdict是collections模块中提供的一种特殊的字典类型,它与普通的字典（dict）有着相似的功能,本文主要... 目录示例1示例2python的defaultdict是collections模块中提供的一种特殊的字
阅读更多...
C++ Sort函数使用场景分析

C++ Sort函数使用场景分析

《C++Sort函数使用场景分析》sort函数是algorithm库下的一个函数,sort函数是不稳定的,即大小相同的元素在排序后相对顺序可能发生改变,如果某些场景需要保持相同元素间的相对顺序,可使... 目录C++ Sort函数详解一、sort函数调用的两种方式二、sort函数使用场景三、sort函数排序
阅读更多...
Redis实现延迟任务的三种方法详解

Redis实现延迟任务的三种方法详解

《Redis实现延迟任务的三种方法详解》延迟任务（DelayedTask）是指在未来的某个时间点,执行相应的任务,本文为大家整理了三种常见的实现方法,感兴趣的小伙伴可以参考一下... 目录1.前言2.Redis如何实现延迟任务3.代码实现3.1. 过期键通知事件实现3.2. 使用ZSet实现延迟任务3.3
阅读更多...
Java String字符串的常用使用方法

Java String字符串的常用使用方法

《JavaString字符串的常用使用方法》String是JDK提供的一个类,是引用类型,并不是基本的数据类型,String用于字符串操作,在之前学习c语言的时候,对于一些字符串,会初始化字符数组表... 目录一、什么是String二、如何定义一个String1. 用双引号定义2. 通过构造函数定义三、St
阅读更多...
Pydantic中Optional 和Union类型的使用

Pydantic中Optional 和Union类型的使用

《Pydantic中Optional和Union类型的使用》本文主要介绍了Pydantic中Optional和Union类型的使用,这两者在处理可选字段和多类型字段时尤为重要,文中通过示例代码介绍的... 目录简介Optional 类型Union 类型Optional 和 Union 的组合总结简介Pyd
阅读更多...
Vue3使用router,params传参为空问题

Vue3使用router,params传参为空问题

《Vue3使用router,params传参为空问题》：本文主要介绍Vue3使用router,params传参为空问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐... 目录vue3使用China编程router,params传参为空1.使用query方式传参2.使用 Histo
阅读更多...
使用Python自建轻量级的HTTP调试工具

使用Python自建轻量级的HTTP调试工具

《使用Python自建轻量级的HTTP调试工具》这篇文章主要为大家详细介绍了如何使用Python自建一个轻量级的HTTP调试工具,文中的示例代码讲解详细,感兴趣的小伙伴可以参考一下... 目录一、为什么需要自建工具二、核心功能设计三、技术选型四、分步实现五、进阶优化技巧六、使用示例七、性能对比八、扩展方向建
阅读更多...
Redis分片集群的实现

Redis分片集群的实现

《Redis分片集群的实现》Redis分片集群是一种将Redis数据库分散到多个节点上的方式,以提供更高的性能和可伸缩性,本文主要介绍了Redis分片集群的实现,具有一定的参考价值,感兴趣的可以了解一... 目录1. Redis Cluster的核心概念哈希槽（Hash Slots）主从复制与故障转移2.
阅读更多...
使用Python实现一键隐藏屏幕并锁定输入

使用Python实现一键隐藏屏幕并锁定输入

《使用Python实现一键隐藏屏幕并锁定输入》本文主要介绍了使用Python编写一个一键隐藏屏幕并锁定输入的黑科技程序,能够在指定热键触发后立即遮挡屏幕,并禁止一切键盘鼠标输入,这样就再也不用担心自己... 目录1. 概述2. 功能亮点3.代码实现4.使用方法5. 展示效果6. 代码优化与拓展7. 总结1.
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2