.Net Core缓存组件(MemoryCache)【缓存篇（二）】

时间 2020-07-23

标签 core 缓存组件 memorycache 缓存篇（二）繁體版

原文原文链接

1、前言html

　　一、上篇.NET Core ResponseCache【缓存篇（一）】中咱们提到了使用客户端缓存、和服务端缓存。本文咱们介绍MemoryCache缓存组件，说到服务端缓存咱们通常都会想到MemoryCache、Redis等等优秀的缓存组件，各自有各自使用的场景。MemoryCache的类型比较单一是Object对象存储、Redis的数据类型就相对比较多 String（字符串），List（列表），set（去重集合），zset（去重排序集合），hash（哈希）。还有HyperLogLog，bitMap，GeoHash，BloomFilter这四种尚未详细了解，等下篇讲解Redis的时候详细给各位姥爷供上。github

2、MemoryCache缓存组件使用缓存

　　一、首先咱们须要将MemoryCache组件注入到程序中。安全

 public void ConfigureServices(IServiceCollection services)
        {
            //添加内存缓存
            services.AddMemoryCache();
        }

　　二、使用的方法也比较简单和咱们日常写代码差很少。在控制其中注入基类IMemoryCache，看到下面这个基类，我还觉得会只有两个方法。多线程

 #region 注入缓存
        private readonly IMemoryCache Cache;
        public MemoryCacheController(IMemoryCache cache)
        {
            Cache = cache;
        }
        #endregion

　　三、当我正常使用的时候发现方法原来使用推展方法写在这里。使用起来很简单我就直接代码了。函数

　　四、设置缓存主要是四种过时时间。post

　　　　　　1:永久不过时就是老子就是不过时气死你。this

　　　　　　2:绝对过时时间这个就比如咱们买的安眠药，2020年07月22日过时。那你今天就要好好利用这个时间了。url

　　　　　　3:相对过时时间这个比如你吃饭三个小时，肚子就呱呱叫了，相对于当前时间延长。

　　　　　　4:滑动过时时间这个就是相对过时时间的升级版，咱们每隔三个小时就会肚子饿，那么咱们是否是能够等到两个半小时就是吃饭，肚子就不会叫了。这样在必定时间内使用这个缓存就会在你最后使用缓存的时间上延长。

            //设置缓存  当咱们没有指定过时时间，理论是永久的（后面会说到不理论的）
            Cache.Set("key", "value");
            Console.WriteLine(Cache.Get("key"));

            //设置缓存绝对过时时间
            Cache.Set("key1", "value", new DateTimeOffset(new DateTime(2020, 7, 22)));
            Console.WriteLine(Cache.Get("key1"));

            //设置相对过时时间
            Cache.Set("key2", "value", new TimeSpan(0, 0, 10));
            Console.WriteLine(Cache.Get("key2"));

            //设置滑动过时时间
            Cache.Set("key3", "value", new MemoryCacheEntryOptions()
            {
                //设置滑动过时
                SlidingExpiration = new TimeSpan(0, 0, 5),
                //设置缓存的优先级，当咱们缓存空间不足的时候会移除等级低的缓存，以此类推（清除的时候不会管是否过时）
                //Low,    低的意思
                //Normal, 正常模式  默认模式
                //High,   高
                //NeverRemove 毫不回收，这个就算内存满了也不会清除。
                Priority = CacheItemPriority.NeverRemove
            });
            Console.WriteLine(Cache.Get("key3"));

　　五、这里咱们还要讲一下缓存失效机制，这里它不是主动失效的，只有当咱们再次对缓存MemoryCache组件进行增删查改的时候才会扫描里面的内存是否存在过时的，进行垃圾回收。这里咱们使用GetOrCreate方法建立咱们的缓存证明咱们的说法。这个能够设置过时回调函数。图下咱们能够看到当咱们的缓存过时以后，就没有对缓存进行操做了就不会有回调函数触发。

Cache.GetOrCreate("key4", cacheEntry =>
            {
                //设置滑动过时
                cacheEntry.SlidingExpiration= new TimeSpan(0, 0, 5);
                //设置删除回调函数
                cacheEntry.RegisterPostEvictionCallback(CallbackFunction);
                //设置内存
                return cacheEntry.Value = "滑动过时时间带删除回调";
            });
            Thread.Sleep(2000);
            Console.WriteLine(Cache.Get("key4"));
            Thread.Sleep(4000);
            Console.WriteLine(Cache.Get("key4"));
            Thread.Sleep(5000);

　　六、可是咱们将最后一句代码解开封印。这里有一个问题，当咱们执行等待了5秒钟按道理过时了，可是没有触发删除回调，我截图上的是我将代码块拉到了以前执行的最后一行代码才有，这个我也蒙了。可是当我第二次进来访问就有回调函数了。

/// <summary>
        /// 删除回调函数
        /// </summary>
        /// <param name="key"></param>
        /// <param name="value"></param>
        /// <param name="reason"></param>
        /// <param name="state"></param>
        public void CallbackFunction(object key, object value, EvictionReason reason, object state)
        {
            Console.WriteLine($"你被删除了key：{key},value：{value}回调函数");
        }

　　七、CreateEntry设置缓存，有一点特殊正常设置缓存的时候，获取的时候是null,只有当咱们执行Dispose或者using的时候才成功。带着这个疑问咱们决定看看源码。

            ////CreateEntry设置缓存
            var entity = Cache.CreateEntry("key5");
            entity.Value = "5555";
            Console.WriteLine("CreateEntry 获取信息：" + Cache.Get("key5"));  //结果null

 //方法1
            var entity = Cache.CreateEntry("key5");
            entity.Value = "5555";
            entity.Dispose();
            Console.WriteLine("CreateEntry 获取信息：" + Cache.Get("key5"));  //结果5555

            //方法2
            using (var entity = Cache.CreateEntry("key5"))
            {
                entity.Value = "5555";
                Console.WriteLine("CreateEntry 获取信息：" + Cache.Get("key5"));  //结果5555
            }

　　八、CacheEntry有一个重要的方法Dispose()，由于它继承IDisposable，在Dispost方法中调用了_notifyCacheEntryDisposed委托。

public void Dispose()
{
      if (!_added)
      {
          _added = true;
          _scope.Dispose();
          _notifyCacheEntryDisposed(this);//在此调用委托，而此委托是被MemoryCache类中的SetEntry赋值。目的是将CacheEntry实体放入MemoryCache类的字典中，也就是放入缓存中。
          PropagateOptions(CacheEntryHelper.Current);

3、MemoryCache组件源码

　　一、首先看咱们在Startup中声明添加的内存缓存的对应的源码。 services.AddMemoryCache();能够看到这里是将缓存组件使用单例模式注入咱们程序中。

        /// <summary>
        /// Adds a non distributed in memory implementation of <see cref="IMemoryCache"/> to the
        /// <see cref="IServiceCollection" />.
        /// </summary>
        /// <param name="services">The <see cref="IServiceCollection" /> to add services to.</param>
        /// <returns>The <see cref="IServiceCollection"/> so that additional calls can be chained.</returns>
        public static IServiceCollection AddMemoryCache(this IServiceCollection services)
        {
            if (services == null)
            {
                throw new ArgumentNullException(nameof(services));
            }

            services.AddOptions();
            services.TryAdd(ServiceDescriptor.Singleton<IMemoryCache, MemoryCache>());

            return services;
        }

　　二、MemoryCacheOptions类：主要是配置一些参数

　　　　ExpirationScanFrequency：此字段代表隔一段时间扫描缓存，移除过时缓存，默认频率为一分钟。

　　　　SizeLimit：设置缓存的大小。

　　　　CompactionPercentage：压缩比例默认为百分之五。

            //添加内存缓存
            services.AddMemoryCache(x=> {
                x.CompactionPercentage = 0.05;//缓存压缩大小
                x.ExpirationScanFrequency= new TimeSpan(0, 0, 1); //默认自动扫描时间为三分钟
                x.SizeLimit = 500 * 1024 * 1024; //大小为500M
            });

　　三、MemoryCache类

　　　　1：ConcurrentDictionary<object, CacheEntry> _entries：一个多线程安全的字典类型，其实缓存的本质就是这个字典，将全部缓存都放入这个字典中，而后经过字典的key(字典的key其实和缓存实体CacheEntry的key值同样)获取CacheEntry实体(CacheEntry实体包含key和value，也就是咱们代码中设置的key和value)。

　　　　2：_expirationScanFrequency：Span类型，表示扫描过时缓存的频率时间，此字段的值来自MemoryCacheOptions类的ExpirationScanFrequency。须要注意的是：假如设置为一分钟扫描一次缓存集合，这个扫描不是主动扫描的，只有当对缓存集合操做时才会扫描。好比增删改查缓存集合的时候，会判断上一次扫描的时间离如今过去多久了，若是超过扫描设置的时间，才会扫描。

private void StartScanForExpiredItems()//扫描函数。在添加、查找、删除、修改缓存的时候，会调用此方法扫描过滤过时缓存，并非主动隔一段时间执行
        {
            var now = _clock.UtcNow;
            if (_expirationScanFrequency < now - _lastExpirationScan)//判断如今的时间和最后一次扫描时间，是否是大于设置的时间段
            {
                _lastExpirationScan = now;
                Task.Factory.StartNew(state => ScanForExpiredItems((MemoryCache)state), this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
            }
        }
        private static void ScanForExpiredItems(MemoryCache cache)
        {
            var now = cache._clock.UtcNow;
            foreach (var entry in cache._entries.Values)//而后遍历字典集合，移除过时缓存
            {
                if (entry.CheckExpired(now))
                {
                    cache.RemoveEntry(entry);
                }
            }
        }