当前位置：首页 > news >正文

.net core 的缓存方案

news 来源：原创 2024/7/4 17:57:44

这里主要讲两个缓存的使用，MemoryCache和Redis
先讲讲常见的缓存
1、.net framework web中自带有Cache缓存，这种缓存属于粘性缓存，是缓存到项目中的，项目从服务器迁移的时候缓存的内容也能够随着服务器一起迁移
2、MemoryCache缓存则需要引用NuGet包 Microsoft.Extensions.Caching.Memory
3、Redis，Redis也有多种，我使用过ServiceStack.Redis和StackExchange.Reids，这两个的区别也是很大的ServiceStack.Redis是商用的，不给钱每个小时的使用是有限的，好像是六千次，但是速度稍微比StackExchange.Reids快一点点，毕竟是收费的，但是StackExchange.Reids没有使用限制，所以这里主要讲一下StackExchange.Reids怎么用

先讲MemoryCache怎么用吧
一、引用Microsoft.Extensions.Caching.Memory NuGet包
二、开写

private static IMemoryCache _memoryCache = null;public Cache(){_memoryCache = new MemoryCache(new MemoryCacheOptions());}/// <summary>/// 缓存绝对过期时间/// </summary>///<param name="key">Cache键值</param>///<param name="value">给Cache[key]赋的值</param>///<param name="minute">minute分钟后绝对过期</param>public void CacheInsert(string key, object value, int minute){if (value == null) return;_memoryCache.Set(key, value, new MemoryCacheEntryOptions().SetAbsoluteExpiration(TimeSpan.FromMinutes(minute)));}/// <summary>/// 缓存相对过期，最后一次访问后minute分钟后过期/// </summary>///<param name="key">Cache键值</param>///<param name="value">给Cache[key]赋的值</param>///<param name="minute">滑动过期分钟</param>public void CacheInsertFromMinutes(string key, object value, int minute){if (value == null) return;_memoryCache.Set(key, value, new MemoryCacheEntryOptions().SetSlidingExpiration(TimeSpan.FromMinutes(minute)));}/// <summary>///写入缓存/// </summary>///<param name="key">Cache键值</param>///<param name="value">给Cache[key]赋的值</param>public void CacheInsert(string key, object value){_memoryCache.Set(key, value);}/// <summary>///清除指定缓存/// </summary>///<param name="key"></param>public void RemoveCache(string key){_memoryCache.Remove(key);}/// <summary>///读取缓存/// </summary>///<param name="key"></param>public object GetCache(string key){return _memoryCache.Get(key);}

三、在要使用缓存的项目中的Startup类的ConfigureServices方法注入这个服务

services.AddSingleton(new CUE.Cache.Cache());

四、使用的页面就直接拿来用就好了
接收这个注入就可以用了，就像这样，完美

private readonly CUE.Cache.Cache _cache;public HomeController(CUE.Cache.Cache cache){_cache = cache;}public IActionResult Index(){_cache.CacheInsert("Key","vaule",10);return View();}

一、现在用StackExchange.Redis
1,应为我们是把缓存封装到类库里面的，然而类库不能直接读取配置文件，redis又需要稍微配置已下连接地址，所以我有一篇文章讲怎么用类库读取配置文件的，有空可以去看一下
2.先引用StackExchange.Redis NuGet包
二、写配置文件
写到需要使用缓存的项目的appsettings.json里面

"Redis": {"Default": {"Connection": "127.0.0.1:6379","InstanceName": "local","DefaultDB": 8}}

三、读取配置文件

public class RedisConfigInfo{/// <summary>/// 读取Redis:Default 配置文件/// </summary>/// <returns></returns>public static IConfigurationSection GetConfig(){return ConfigHelper.GetSection("Redis:Default");}/// <summary>/// 读取Redis:Default下指定的值/// </summary>/// <param name="Key"></param>/// <returns></returns>public static string GetConfigValue(string Key){return GetConfig().GetSection(Key).Value;}}

三、写连接字符串

public class RedisCathe{//连接字符串private string _connectionString;//实例名称private string _instanceName;//数据库private int _defaultDB;private ConcurrentDictionary<string, ConnectionMultiplexer> _connections;public RedisCathe(){_connectionString = RedisConfigInfo.GetConfigValue("Connection");_instanceName = RedisConfigInfo.GetConfigValue("InstanceName");//给定默认数据库，默认为0_defaultDB = int.Parse(RedisConfigInfo.GetConfigValue("DefaultDB") ?? "0");_connections = new ConcurrentDictionary<string, ConnectionMultiplexer>();}/// <summary>/// 获取ConnectionMultiplexer/// </summary>/// <returns></returns>private ConnectionMultiplexer GetConnect(){return _connections.GetOrAdd(_instanceName, p => ConnectionMultiplexer.Connect(_connectionString));}/// <summary>/// 获取数据库/// </summary>/// <param name="configName"></param>/// <param name="db">默认为0：优先代码的db配置，其次config中的配置</param>/// <returns></returns>public IDatabase GetDatabase(){return GetConnect().GetDatabase(_defaultDB);}public IServer GetServer(string configName = null, int endPointsIndex = 0){var confOption = ConfigurationOptions.Parse(_connectionString);return GetConnect().GetServer(confOption.EndPoints[endPointsIndex]);}public ISubscriber GetSubscriber(string configName = null){return GetConnect().GetSubscriber();}public void Dispose(){if (_connections != null && _connections.Count > 0){foreach (var item in _connections.Values){item.Close();}}}}

三、封装方法

public class Cache{private readonly IDatabase _redis;public Cache(){_redis = new RedisCathe().GetDatabase();}/// <summary>///写入缓存/// </summary>///<param name="key">Cache键值</param>///<param name="value">给Cache[key]赋的值</param>public void CacheInsert(string key, string value){_redis.StringSet(key, value);}/// <summary>/// 缓存过期时间/// </summary>///<param name="key">Cache键值</param>///<param name="value">给Cache[key]赋的值</param>///<param name="minute">minute分钟后绝对过期</param>public void CacheInsert(string key, string value, int minute){_redis.StringSet(key, value, TimeSpan.FromMinutes(minute));}/// <summary>///读取缓存/// </summary>///<param name="key"></param>public string GetCache(string key){return _redis.StringGet(key);}/// <summary>///清除指定缓存/// </summary>///<param name="key"></param>public void RemoveCache(string key){_redis.KeyDelete(key);}}

四、用法就和上面的Cache一模一样，先注入，然后直接用就行了