1. 缓存操作流程
对一些写低频,读高频的数据操作我们经常需要用到缓存,通常的缓存操作流程如下:
2. 通常的缓存处理方式
通常我们对上面流程的实现,伪代码如下:
public Object getObject(String key) {
//1. 尝试从缓存读取
Object obj = readFromCache(key);
//缓存命中直接返回
if (obj != null) {
return obj;
}
//2.如果缓存未命中,读数据库
obj = readFromDB();
//3. 回写入缓存,并返回
saveToCache(key,obj);
return obj;
}
对于不同缓存的处理上面步骤1、3是重复的,步骤2是取决于缓存内容变化的,我们无法使用普通方法将上面的流程提取出一个工具函数,而不得不在每一次缓存操作时重复上面步骤1、3的代码。
3. 使用Lambda表达式与回调函数简化缓存操作
这种场景可以利用回调函数的方式将步骤2做为回调函数参数传入,即可将步骤1、3提取成一个工具函数消除这部分重复,并利用Lambda表达式将整个缓存操作简化到一行代码。
这里我使用jdk8自带的java.util.function.Supplier 类做为回调接口类(较低jdk版本的话也可以自己写一个类似接口),利用该类实现java的回调函数,在这个接口类函数实现中进行读DB操作。
利用回调函数方式完成的缓存操作工具类伪代码如下:
public Object getObjectUtil(String key, Supplier<T> supplier) {
//1. 尝试从缓存读取
Object obj = readFromCache(key);
if (obj == null) {
//2.如果缓存未命中,调用回调函数读数据库
obj = supplier.get();
//3. 回写入缓存,并返回
saveToCache(key,obj);
}
return obj;
}
通过上面的工具类,进行缓存操作时,我们只需要关心读DB的回调函数接口实现,不需要重复手动判断缓存是否存在等操作。
利用上面的工具类进行缓存操作伪代码如下:
public Object getObject() {
return getObjectUtil("key",new Supplier() {
@Override
public SerializeObject get() {
return readFromDB();
}
});
}
//使用Lambda表达式简化语法:
public Object getObject() {
return getObjectUtil("key",() -> readFromDB());
}
这样,利用Lambda表达式以及回调函数的方式,我们增加一个业务的缓存操作只需要一行代码即可实现。