主页 / coding / 问题 / 78821057
Accepted
Wouter Vandenputte
Asked: 2024-08-01 20:49:10 +0800 CST

.NET 8：无需访问 MemoryCache SlidingExpiration

  • 772

我的问题与这个类似，但答案只解释了为什么事情会这样发生，而不是如何真正实现期望的解决方案。

现在，在定义

var options = new MemoryCacheEntryOptions()
{
    // After x minutes of non-access, remove
    SlidingExpiration = TimeSpan.FromMinutes(x),
}
.RegisterPostEvictionCallback(OnCacheItemRemoved);

仅在某个时间点>访问时才会删除 cacheItem 。这意味着，如果我在此之后不再访问该项目，它也不会从缓存中删除。t1t0 + x'

是的，我可以设置绝对过期时间，但这会推翻滑动窗口。如果我希望它在仍被访问时留在内存中，那么它会因绝对过期而被驱逐。我想要的是一个简单的滑动窗口，一旦项目在x几分钟内没有被访问，它就会自动被驱逐。我希望有一个内部计时器来处理这个问题。出于性能原因，它不需要每秒运行一次，一分钟一次对我来说就足够了。

我也没有看到任何关于如何检查驱逐的配置。

编辑 在为 DI 添加 MemoryCache 时，实际上有一个选项ExpirationScanFrequency

services.AddMemoryCache(options => {
    // Check for expired cache items once a minute
    options.ExpirationScanFrequency = TimeSpan.FromMinutes(1);
});

但这似乎不起作用。几分钟后，即使没有任何内容访问我的回调，它仍然没有被调用。1目前 X 设置为。

c#

2 个回答

  1. 仅在某个时间点访问时才会删除 cacheItem t1 > t0 + x'。这意味着，如果我在该时间点之后不再访问该项目，它也永远不会从缓存中删除。

    这不是完全正确的表述。正如其中一个答案中的链接所解释的那样，缓存上的任何活动都可能导致驱逐，例如向缓存中添加新项目，甚至读取另一个键：

    我们不希望计时器总是在空闲的网站上运行。缓存上的任何活动（Get、Set、Remove）都可能触发对过期项目的后台扫描。CancellationTokenSource（CancelAfter）上的计时器也会删除条目并触发对过期项目的扫描。

    查看源代码中的用法StartScanForExpiredItemsIfNeeded- 它在几种方法中被调用，例如Remove、SetEntry和。TryGetValueEntryExpired

    例如你可以玩以下游戏：

    // some setup
var sc = new ServiceCollection();
sc.AddMemoryCache(opts =>
{
    opts.ExpirationScanFrequency = TimeSpan.FromMilliseconds(200);
});
var sp = sc.BuildServiceProvider();
var cache = sp.GetRequiredService<IMemoryCache>();
// eviction "debugger"
PostEvictionDelegate OnCacheItemRemoved = (key, value, reason, state) => Console.WriteLine($"{key} {value} {reason} {state}");
// entry to be evicted
var options = new MemoryCacheEntryOptions()
    {
        SlidingExpiration = TimeSpan.FromMilliseconds(100),
    }
    .RegisterPostEvictionCallback(OnCacheItemRemoved);
cache.Set("1", 1, options);
// some other entry
cache.Set("not1", 1);

for (int i = 0; i < 20; i++)
{
    await Task.Delay(50);
    Console.WriteLine(i);
    // uncommenting any of the following lines 
    // triggers expiration in the Release mode:

    // cache.Set("1" + i, 1, options);
    // cache.Get<int>("not1");
    // cache.TryGetValue("notPresent", out _);
}

    除了一些像下面这样的技巧之外，你在这里能做的事情不多：

    • 创建一个计时器，并在计时器结束时访问某个键（例如虚拟键）或MemoryCache.Compact手动调用（例如(cache as MemoryCache)?.Compact(0.01)
    • 添加一些具有绝对过期时间的虚拟缓存条目（并在过期时重新添加）。
    • 2
  2. Best Answer

    下面是启动计时器检查过期物品的代码示例，可能适合您的需要。

    每 5 秒缓存中的项目就会过期一次 - 您可以通过更改以下两行来更改时间长度：

    cache_opts.ExpirationScanFrequency = TimeSpan.FromSeconds( 5 );

cache_check_timer = new System.Timers.Timer( 5000 );

    在示例中，创建了一个内存缓存，并添加了 3 个项目，每个项目如果在滑动过期时间范围内未访问，则会过期：

    using Microsoft.Extensions.Caching.Memory;
using System;
using System.Threading;
using System.Threading.Tasks;
using System.Timers;

namespace InMemoryNetCore
{

   class Program
   {

      private static System.Timers.Timer? cache_check_timer;

      private static IMemoryCache? cache;

      public static void Main( string[] args )
      {

         String in_str;


         // Create a memory cache ...
         // Important - set the minimum length of time between successive scans for expired items (default is one minute) ...

         var cache_opts = new MemoryCacheOptions();

         cache_opts.ExpirationScanFrequency = TimeSpan.FromSeconds( 5 );

         cache = new MemoryCache( cache_opts );


         // Create a timer with a five second interval ...

         cache_check_timer = new System.Timers.Timer( 5000 );

         cache_check_timer.AutoReset = true;

         cache_check_timer.Elapsed += cache_check;

         cache_check_timer.Start();


         // Create cache item which executes call back function

         var cacheEntryOptions = new MemoryCacheEntryOptions()
             .SetPriority( Microsoft.Extensions.Caching.Memory.CacheItemPriority.Normal )
             .SetSlidingExpiration( TimeSpan.FromSeconds( 5 ) )
             .RegisterPostEvictionCallback( callback: cache_item_removed );


         // add cache Item with options of callback

         cache.Set( 1, "Cache Item 1", cacheEntryOptions );

         cache.Set( 2, "Cache Item 2", cacheEntryOptions );

         cache.Set( 3, "Cache Item 3", cacheEntryOptions );


         // Get user input to terminate program ...

         in_str = String.Empty;

         while ( !"QUIT".Equals( in_str ) )
         {

            Console.Write( "Enter QUIT to end: " );

            in_str = Console.ReadLine();

         }


         // Stop and dispose of timer ...

         cache_check_timer.Stop();
         
         cache_check_timer.Dispose();


         Console.WriteLine( "\nProgram ended" );

      }

      // Used to issue a Get request to the cache using a key value that we
      // know does not exist - only to invoke the internal scan for expired items ...
      private static void cache_check( object? sender, ElapsedEventArgs e )
      {

         //Console.WriteLine( "Here in cache_check" );
         //Console.WriteLine( "Timer event was raised at {0:HH:mm:ss.fff}", e.SignalTime );

         if ( cache is not null )
         {

            // Issue a Get for a key that does not exist ...

           _ = cache.Get( -1 );

         }

      }


      // Callback when cached items are removed ...
      private static void cache_item_removed( object key, object? value, EvictionReason reason, object? state )
      {

         Console.Write( "\nCache key: " + key + " removed from cache due to: " + reason );

      }

   }

}
    • 1

相关问题