內(nèi)存不夠用還要速度快，終于找到可以基于 File 的 Cache 了
一、背景
1. 講故事
18年的時(shí)候在做純內(nèi)存項(xiàng)目的過程中遇到了這么一個(gè)問題，因?yàn)橐恍┖诵臄?shù)據(jù)都是飄在內(nèi)存中，所以內(nèi)存空間對我們來說額外寶貴，但偏偏項(xiàng)目中有些數(shù)據(jù)需要緩存，比如說需要下鉆的報(bào)表上的點(diǎn)，基于性能的考慮，不希望采用獨(dú)立的緩存中間件，比如 redis, mongodb，畢竟再怎么滴還是要走網(wǎng)絡(luò)io，但直接放在本機(jī)內(nèi)存中也不現(xiàn)實(shí)，那有沒有均衡于 native cache 和 cache server 之間的方案呢？對的，就是 disk cache，畢竟 磁盤IO 的讀寫要遠(yuǎn)大于網(wǎng)絡(luò)IO，更何況配的是 SSD 呢。
二、尋找解決方案
1. 檢索 github
有了 disk cache 這個(gè)大方向就可以去 github 上檢索關(guān)鍵詞，看看有沒有類似的中間件，說實(shí)話，java的倒不少，比如著名的 guava，ehcache，不僅有cache的簡單操作，還附帶各種統(tǒng)計(jì)信息，刷新了對緩存認(rèn)知的三觀哈，尤其是 ehcache 太????了，堆內(nèi)，堆外，磁盤，分布式通通支持，用 C# 寫的好不容易找到一個(gè) disk cache 還不幸是收費(fèi)的，氣人哈，用 C# 調(diào)用 Java 肯定不現(xiàn)實(shí)了哈。
2. 使用sqlite作為 disk cache
既然開源社區(qū)沒什么好的東西，看來只能自己封裝一下了，像 ehcache 那種高階的 diskcache 搞不定，用簡單的 sqlite 作為本機(jī)的 diskcahe 還是可以的，接下來試試看。
class DiskCache
{
private static readonly string dbFile = $@"{Environment.CurrentDirectory}\mysqlite1.db";
private static readonly string connectionString = $@"Data Source={dbFile};Version=3";
//過期數(shù)據(jù)監(jiān)測:【一分鐘來一次】
private static Timer timer = new Timer((arg) =>
{
}, null, 1000, 1000 * 60);
static DiskCache()
{
if (!File.Exists(dbFile))
{
var schema = @"CREATE TABLE Cache (
cachekey VARCHAR (1000) PRIMARY KEY NOT NULL,
cachevalue TEXT NOT NULL,
created DATE NOT NULL,
expried DATE NOT NULL
);";
using (SQLiteConnection connection = new SQLiteConnection(connectionString))
{
connection.Execute(schema);
}
}
}
public static void Set<T>(string key, T value, int expiredMinutes)
{
using (SQLiteConnection connection = new SQLiteConnection(connectionString))
{
var sql = $"delete from Cache where cachekey =@key;" +
$"insert into Cache(cachekey,cachevalue,created,expried) values (@cachekey,@cachevalue,@created,@expried)";
connection.Execute(sql, new
{
key = key,
cachekey = key,
cachevalue = Newtonsoft.Json.JsonConvert.SerializeObject(value),
created = DateTime.Now,
expried = DateTime.Now.AddMinutes(expiredMinutes)
});
}
}
public static T Get<T>(string key)
{
using (SQLiteConnection connection = new SQLiteConnection(connectionString))
{
var sql = $"select cachevalue from Cache where cachekey=@cachekey and expried > @expried";
var query = connection.QueryFirstOrDefault(sql, new { cachekey = key, expried = DateTime.Now });
var json = JsonConvert.DeserializeObject<T>(query.cachevalue);
return json;
}
}
}這里有二個(gè)注意點(diǎn)：
- 因?yàn)槭亲鼍彺?，所以?shù)據(jù)庫和表的創(chuàng)建都要通過程序自動(dòng)化，數(shù)據(jù)庫是否存在判斷 file 文件是否存在即可。
- 過期數(shù)據(jù)的問題，因?yàn)槲矣?nbsp;expried 字段，這一點(diǎn)可以學(xué)習(xí)GC思想，使用 Timer 在后臺(tái)定期清理。
有了這些基礎(chǔ)之后，原子化的緩存就實(shí)現(xiàn)好了，接下來試一下基本的 Get / Set 方法。
圖片
這個(gè)方案很好的節(jié)省了我寶貴的內(nèi)存，同時(shí)速度又是 networkio 和 native 之間的一個(gè)平衡，算是個(gè)不錯(cuò)的解決辦法吧。
三、aspnetcore 的 EasyCaching
EasyCaching 是園子里 @Catcher Wong 的作品 [https://www.cnblogs.com/catcher1994/p/10806607.html]，點(diǎn)贊~~~ 看了下提供了很多種 provider，如下圖：
圖片
我想后面肯定還會(huì)有更多的 provider 出現(xiàn)，如：leveldb，Cassandra，接下來看看這玩意怎么玩。
1. 安裝使用
在 nuget 上 搜一下 EasyCaching.SQLite 安裝即可，接下來就是使用文檔：https://easycaching.readthedocs.io/en/latest/SQLite/#2-config-in-startup-class 如下圖：
圖片
文檔中是采用依賴注入的方式，而我的程序是 console 模式的后端服務(wù)，并沒有 ServiceCollection，先模擬著試試看。
static void Main(string[] args)
{
IServiceCollection services = new ServiceCollection();
services.AddEasyCaching(option =>
{
option.UseSQLite(c =>
{
c.DBConfig = new SQLiteDBOptions
{
FileName = "demo.db",
CacheMode = SqliteCacheMode.Default,
OpenMode = SqliteOpenMode.ReadWriteCreate,
};
}, "m1");
});
IServiceProvider serviceProvider = services.BuildServiceProvider();
var factory = serviceProvider.GetService<IEasyCachingProviderFactory>();
var cache = factory.GetCachingProvider("m1");
cache.Set("user", "hello world!", TimeSpan.FromSeconds(20));
var info = cache.Get<string>("user");
Console.WriteLine(info);
}
圖片
接下來用 SQLiteStudio 打開 demo.db 看一下數(shù)據(jù)呈現(xiàn)，如下圖：
圖片
可以看到人家的框架比我的多了一個(gè) name 字段，看樣子是給 多個(gè) cache 做隔離用的，不過這里貌似有三個(gè)需要優(yōu)化的地方。
- 并不是每一個(gè)程序都要使用 依賴注入 的方式 ，提供更便捷的方式初始化就更好了。
- 看了下源碼，并沒有找到可以定期刪除過期數(shù)據(jù)的業(yè)務(wù)邏輯。
- 建議提供一些 cache 的統(tǒng)計(jì)信息，如命中次數(shù)，某一個(gè)key最后命中時(shí)間等等時(shí)分統(tǒng)計(jì)圖。
