最近有个需求需要定时清理服务器上所有的缓存 。本来以为很简单的调用一下 MemoryCache.Clear 方法就完事了 。谁知道 MemoryCache 类以及 IMemoryCache 扩展方法都没有 Clear 方法 。这可给难住了,于是想找到所有的 Keys 来一个个 Remove,谁知道居然也没有获取所有 Key 的方法 。于是研究了一下,找到一些方法,下面介绍两个方法:
自定义 CacheWrApper 包装类MemoryCache 构造 Entry 的时候支持传入 CancellationChangeToken 对象,当 CancellationChangeToken.Cancel 触发的时候会自动使该对象过期 。那么我们只要对 MemoryCache 类包装一下很容易实现一个自己的 Cache 类 。
public class CacheWrapper{private readonly IMemoryCache _memoryCache;private CancellationTokenSource _resetCacheToken = new();public CacheWrapper(IMemoryCache memoryCache){_memoryCache = memoryCache;}public void Add(object key, object value, MemoryCacheEntryOptions memoryCacheEntryOptions){using var entry = _memoryCache.CreateEntry(key);entry.SetOptions(memoryCacheEntryOptions);entry.Value = https://www.isolves.com/it/cxkf/yy/C/2021-12-30/value;// add an expiration token that allows us to clear the entire cache with a single method callentry.AddExpirationToken(new CancellationChangeToken(_resetCacheToken.Token));}public object Get(object key){return _memoryCache.Get(key);}public void Remove(object key){_memoryCache.Remove(key);}public void Clear(){_resetCacheToken.Cancel(); // this triggers the CancellationChangeToken to expire every item from cache_resetCacheToken.Dispose(); // dispose the current cancellation token source and create a new one_resetCacheToken = new CancellationTokenSource();}}
然后单元测试测试一下:
[TestMethod()]public void ClearTest(){var memCache = new MemoryCache(new MemoryCacheOptions());var wrapper = new CacheWrapper(memCache);for (int i = 0; i < 10; i++){wrapper.Add(i.ToString(), new object(), new MemoryCacheEntryOptions());}Assert.IsNotNull(wrapper.Get("1"));Assert.IsNotNull(wrapper.Get("9"));wrapper.Clear();for (int i = 0; i < 10; i++){Assert.IsNull(wrapper.Get(i.ToString()));}for (int i = 0; i < 10; i++){wrapper.Add(i.ToString(), new object(), new MemoryCacheEntryOptions());}Assert.IsNotNull(wrapper.Get("1"));Assert.IsNotNull(wrapper.Get("9"));wrapper.Clear();for (int i = 0; i < 10; i++){Assert.IsNull(wrapper.Get(i.ToString()));}}
测试通过 。
Compact 方法以上 CacheWrapper 类虽然可以实现我们想要的功能,但是对于原来的程序有侵入,需要使用 CacheWrapper 类替换默认的 MemoryCache 类,不是太好 。于是不死心继续研究,后来直接看了 MemoryCache 的代码(源码在这),开源真香 。发现 MemoryCache 有个 Compact 方法好像在干删除的勾当 。也怪我英文不好,这单词是压缩的意思,居然才发现 。。。。于是我们的清除所有对象的需求不就轻而易举了么?
/// Remove at least the given percentage (0.10 for 10%) of the total entries (or estimated memory?), according to the following policy:/// 1. Remove all expired items./// 2. Bucket by CacheItemPriority./// 3. Least recently used objects./// ?. Items with the soonest absolute expiration./// ?. Items with the soonest sliding expiration./// ?. Larger objects - estimated by object graph size, inaccurate.MemoryCache.Compact(double percentage);
Compact 方法会对缓存的对象进行压缩,参数是个double,0.1 表示压缩 10%,那么传 1.0 就是压缩 100%,那不就是 Clear All 么 。所以我可以使用 Compact(1.0) 来清除所有的缓存对象 。单元测试一下:
【C# MemoryCache 如何清除全部缓存】[TestMethod()]public void CompactTest(){var memCache = new MemoryCache(new MemoryCacheOptions());for (int i = 0; i < 10; i++){memCache.Set(i.ToString(), new object(), new MemoryCacheEntryOptions());}Assert.IsNotNull(memCache.Get("1"));Assert.IsNotNull(memCache.Get("9"));memCache.Compact(1);for (int i = 0; i < 10; i++){Assert.IsNull(memCache.Get(i.ToString()));}for (int i = 0; i < 10; i++){memCache.Set(i.ToString(), new object(), new MemoryCacheEntryOptions());}Assert.IsNotNull(memCache.Get("1"));Assert.IsNotNull(memCache.Get("9"));memCache.Compact(1);for (int i = 0; i < 10; i++){Assert.IsNull(memCache.Get(i.ToString()));}}
完美通过 。
这里简单介绍下 Compact 方法 。根据注释它会按照以下优先级删除对象:
- 过期的对象
- CacheItemPriority 设置的优先级,等级越高越不容易被删除
- 最近最少被使用过的对象
- 绝对过期时间
- 滑动过期时间
- 大对象
- 评论区有人提到 main 分支的代码上微软已经加上了 Clear 方法 。https://github.com/dotnet/runtime/blob/main/src/libraries/Microsoft.Extensions.Caching.Memory/src/MemoryCache.cs#L272 感谢 @yi念之间 兄弟指出 。
推荐阅读
- 如何远程连接软件加密狗
- 什么是微服务,如何构建微服务
- 鸿蒙APP开发:如何实现“百度地图”的显示?需要3项认真操作才行
- 全网连夜修复的Log4j漏洞,如何做到一行代码都不改?
- 祁门红茶如何鉴别好坏,祁门红茶多少年历史
- 英国红茶历史起源,遵义红茶的起源
- 如何选购优质红茶,红茶的种类和图片大全
- 如何选择耐磨陶瓷
- Win10如何连接手机摄像头?Win10连接手机摄像头的方法
- 没有爱快路由如何进行组网?