MemoryCache AbsoluteExpiration表现奇怪

Question

我正在尝试使用MemoryCache.net 4.5跟踪并自动更新各种项目,但似乎无论我设置什么,AbsoluteExpiration它总是只会在15秒或更长时间内到期.

我希望缓存项目每5秒到期,但它总是在至少15秒内到期,如果我将到期时间移出,它最终将达到15秒+我的刷新间隔,但绝不会少于15秒.

是否有一些内部定时器分辨率,我没有看到？我查看了一些反映的System.Runtime.Caching.MemoryCache代码,并没有什么突出的我,我没有找到任何其他人在互联网上有这个问题.

我在下面有一个非常基本的例子来说明问题.

我想要的是CacheEntryUpdate每5秒左右被击中并用新数据更新,但是,正如我所说,它只会在15秒内被击中.

static MemoryCache MemCache;
static int RefreshInterval = 5000;

protected void Page_Load(object sender, EventArgs e)
{
    if (MemCache == null)
        MemCache = new MemoryCache("MemCache");

    if (!MemCache.Contains("cacheItem"))
    {
        var cacheObj = new object();
        var policy = new CacheItemPolicy
        {
            UpdateCallback = new CacheEntryUpdateCallback(CacheEntryUpdate),
            AbsoluteExpiration = DateTimeOffset.UtcNow.AddMilliseconds(RefreshInterval)
        };
        var cacheItem = new CacheItem("cacheItem", cacheObj);
        MemCache.Set("cacheItem", cacheItem, policy);
    }
}

private void CacheEntryUpdate(CacheEntryUpdateArguments args)
{
    var cacheItem = MemCache.GetCacheItem(args.Key);
    var cacheObj = cacheItem.Value;

    cacheItem.Value = cacheObj;
    args.UpdatedCacheItem = cacheItem;
    var policy = new CacheItemPolicy
    {
        UpdateCallback = new CacheEntryUpdateCallback(CacheEntryUpdate),
        AbsoluteExpiration = DateTimeOffset.UtcNow.AddMilliseconds(RefreshInterval)
    };
    args.UpdatedCacheItemPolicy = policy;
}

Answer 1

我已经明白了.internal static readonly TimeSpanSystem.Runtime.Caching.CacheExpires上有一个名为_tsPerBucket的文件,它在20秒内被硬编码.

显然,此字段用于运行的内部计时器,并检查缓存项是否已过期.

我正在解决这个问题,方法是使用反射覆盖值并清除默认的MemoryCache实例以重置所有内容.它似乎有效,即使它是一个巨大的黑客.

这是更新的代码:

static MemoryCache MemCache;
static int RefreshInterval = 1000;

protected void Page_Load(object sender, EventArgs e)
{
    if (MemCache == null)
    {
        const string assembly = "System.Runtime.Caching, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a";
        var type = Type.GetType("System.Runtime.Caching.CacheExpires, " + assembly, true, true);
        var field = type.GetField("_tsPerBucket", BindingFlags.Static | BindingFlags.NonPublic);
        field.SetValue(null, TimeSpan.FromSeconds(1));

        type = typeof(MemoryCache);
        field = type.GetField("s_defaultCache", BindingFlags.Static | BindingFlags.NonPublic);
        field.SetValue(null, null);

        MemCache = new MemoryCache("MemCache");
    }

    if (!MemCache.Contains("cacheItem"))
    {
        var cacheObj = new object();
        var policy = new CacheItemPolicy
        {
            UpdateCallback = new CacheEntryUpdateCallback(CacheEntryUpdate),
            AbsoluteExpiration = DateTimeOffset.UtcNow.AddMilliseconds(RefreshInterval)
        };
        var cacheItem = new CacheItem("cacheItem", cacheObj);
        MemCache.Set("cacheItem", cacheItem, policy);
    }
}

private void CacheEntryUpdate(CacheEntryUpdateArguments args)
{
    var cacheItem = MemCache.GetCacheItem(args.Key);
    var cacheObj = cacheItem.Value;

    cacheItem.Value = cacheObj;
    args.UpdatedCacheItem = cacheItem;
    var policy = new CacheItemPolicy
    {
        UpdateCallback = new CacheEntryUpdateCallback(CacheEntryUpdate),
        AbsoluteExpiration = DateTimeOffset.UtcNow.AddMilliseconds(RefreshInterval)
    };
    args.UpdatedCacheItemPolicy = policy;
}

Answer 2

您愿意/能够从旧的 System.Runtime.Caching 更改为新的Microsft.Extensions.Caching吗？1.x 版支持 netstandard 1.3 和 net451。如果是这样，那么改进的 API 将支持您描述的用法，而无需通过反射进行黑客攻击。

MemoryCacheOptions 对象有一个属性 ExpirationScanFrequency 允许您控制缓存清理的扫描频率，请参阅https://docs.microsoft.com/en-us/dotnet/api/microsoft.extensions.caching.memory.memorycacheoptions.expirationscanfrequency ?view=aspnetcore-2.0

请注意，不再有基于计时器的过期（这是性能设计决策），因此现在内存压力或为缓存项调用基于 Get() 的方法之一现在是过期的触发器。但是，您可以使用取消令牌强制基于时间的到期，请参阅此 SO 答案以获取示例/sf/answers/3356437801/。