本文共 1345 字,大约阅读时间需要 4 分钟。
对一些写低频,读高频的数据操作我们经常需要用到缓存,通常的缓存操作流程如下:
通常我们对上面流程的实现,伪代码如下:
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的代码。
这种场景可以利用回调函数的方式将步骤2做为回调函数参数传入,即可将步骤1、3提取成一个工具函数消除这部分重复,并利用Lambda表达式将整个缓存操作简化到一行代码。
这里我使用jdk8自带的java.util.function.Supplier 类做为回调接口类(较低jdk版本的话也可以自己写一个类似接口),利用该类实现java的回调函数,在这个接口类函数实现中进行读DB操作。
利用回调函数方式完成的缓存操作工具类伪代码如下:
public Object getObjectUtil(String key, Suppliersupplier) { //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表达式以及回调函数的方式,我们增加一个业务的缓存操作只需要一行代码即可实现。
转载地址:http://jtfll.baihongyu.com/