tnblog
首页
精品
资源
登录

.net core 缓存

811人阅读 2021/7/23 16:12 总访问:8654 评论:2 收藏:0 手机
分类: .net core

这里主要讲两个缓存的使用,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一模一样,先注入,然后直接用就行了

Good

评价
新手码农
排名
6
文章
6
粉丝
16
评论
8
{{item.articleTitle}}
{{item.blogName}} : {{item.content}}
ICP备案 :渝ICP备18016597号-1
网站信息:2018-2021TNBLOG.NET
技术交流:群号677373950
欢迎加群交流技术