.net core 的缓存方案

发布于:2024-06-30 ⋅ 阅读:(20) ⋅ 点赞:(0)

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


网站公告

今日签到

点亮在社区的每一天
去签到