简介
提供Android缓存功能,包括对SD卡
,内存
、Sharedpreference
以及同时存储SD卡
和内存
的双层缓存操作,缓存对象包括:实现序列化的对象
,Bitmap
以及字符数组
。下载项目https://github.com/homeven/RxCache。
1.使用
导入项目依赖
implementation "io.reactivex:rxandroid:1.2.1"
implementation "io.reactivex:rxjava:1.1.6"
在调用缓存API之前需要初始化缓存配置,推荐在Application当中进行初始化.
//初始化缓存配置,包括磁盘缓存路径,缓存大小,内存缓存大小,加密策略等。
// 最后调用.install(this)方法完成初始化
CacheInstaller.get()
.configDiskCache("TestCache", 50 * 1024 * 1024, 1)
.install(this);
完成初始化之后就可以正常使用缓存操作了。
存储
项目本身一共两种缓存的调用方式:
- 直接在项目当中进行链式的调用。
- 一种是类似于retrofit的接口调用方式。
存储的对象可以是实现序列化的对象
,Bitmap
以及字符数组
。以缓存bitmap
为例,看一下调用实例:
调用方式一
/**
* 定义接口
*/
public interface TestInerface {
//注解标明请求方式,超时时间等等
//method设置当前操作为put,调用缓存到SD卡以及内存当中的双层缓存
@Method(methodType = MethodType.PUT,cacheType = CacheType.TWO_LAYER)
//设置过期时间为1天
@Lifecycle(time = 1,unit = TimeUnit.DAYS)
<T> Observable<Boolean> putData( @CacheKey String key,@CacheValue T value, @CacheClass Class<T> clazz);
}
//调用缓存存储bitmap
TestInerface testInerface = RetrofitCache.create(TestInerface.class);
testInerface.putData("testKey", bitmap, Bitmap.class).observeOn(AndroidSchedulers.mainThread())
.subscribe(new Action1<Boolean>() {
@Override
public void call(Boolean aBoolean) {
Toast.makeText(TestActivity.this, aBoolean + "", Toast.LENGTH_SHORT).show();
}
});
整个存储过程可分为两步:
- 定义接口,并通过注解标明请求方式,请求参数等。
- 在项目中调用缓存API。
整个API的调用过程与Retrofit很相似,在定义接口时的注解说明如下:
注解 | 类型 | 说明 |
---|---|---|
@Lifecycle | 方法注解 | 设置过期时间,包括时长和单位,存储时调用 |
@Method | 方法注解 | 设置缓存方法以及存储方式 |
@ShareName | 方法注解 | sharedPreference缓存时的文件名 |
@Strategy | 方法注解 | 设置超时策略,读取缓存时调用 |
@CacheClass | 参数注解 | 设置缓存类,标注一个Class对象 |
@CacheKey | 参数注解 | 设置缓存的key值,标注一个String对象 |
@CacheValue | 参数注解 | 设置缓存内容 |
调用方式二
直接通过链式调用
//调用put方法存储数据
RxCache.get().setTimeout(1, TimeUnit.DAYS)
.putData2TwoLayer("diskKey", bitmap).observeOn(AndroidSchedulers.mainThread())
.subscribe(new Action1<Boolean>() {
@Override
public void call(Boolean aBoolean) {
Toast.makeText(TestActivity.this, aBoolean + "", Toast.LENGTH_SHORT).show();
}
});
//setTimeout方法设置超时时间
//putData2TwoLayer调用双层缓存,参数为缓存的key值以及缓存内容
调用存储方法putXX
后返回一个Observable<Boolean>
对象,当返回true时代表缓存成功,返回false代表缓存失败。
两种方法各有利弊
- 方式一方便对缓存的管理,并省去在项目中对缓存策略等的配置内容。
- 方式二调用方式更直接,代码也相对更少一些。
注意:无论哪种调用方式,都需要先初始化配置信息。
读取
读取方式和存储类似,也分为两种,详细调用内容不再赘述,直接看代码。
//----------------------方式一------------------------------
//定义接口
public interface TestInerface {
//注解标明请求方式,超时策略等等
//请求方式为get,读取对象为从SD卡中读取
@Method(methodType = MethodType.GET,cacheType = CacheType.DISK)
//设置超时策略,当数据超时时返回null
@Strategy(key = ExpirationPolicies.ReturnNull)
<T> Observable<T> getData(@CacheKey String key, @CacheClass Class<T> clazz);
}
testInerface.getData("testKey",Bitmap.class).observeOn(AndroidSchedulers.mainThread())
.subscribe(new Action1<Bitmap>() {
@Override
public void call(Bitmap s) {
if (s != null) {
testImage.setImageBitmap(s);
} else {
Toast.makeText(TestActivity.this, "数据为null", Toast.LENGTH_SHORT).show();
}
}
});
//----------------------方式二------------------------------
RxCache.get().getDataTwoLayer("diskKey", Bitmap.class).observeOn(AndroidSchedulers.mainThread())
.subscribe(new Action1<Bitmap>() {
@Override
public void call(Bitmap s) {
if (s != null) {
testImage.setImageBitmap(s);
} else {
Toast.makeText(TestActivity.this, "数据为null", Toast.LENGTH_SHORT).show();
}
}
});
读取缓存会返回一个Observable对象,通过subscribe()订阅后可以拿到返回的数据,并进行操作。
注意:默认执行subscribe()的线程为调用时所在线程,如果需要修改线程,需自行调用observeOn()方法修改调用线程。
另外还有删除
和清空缓存
等API,调用方式与存储
、读取
类似,省略这部分内容,感兴趣的可以自己下载试一下。https://github.com/bh4614910/RxCache
2.架构设计
说完对整个API的使用,再来详细看一下整个缓存的项目结构。
image整个项目可以大体分为三层
- 基础层:主要负责存储的基础操作,包括对
SD卡
、内存
以SharedPreference
的基础操作。 - 控制层:负责根据对不同的事务类型进行分发。
- API:对外暴露的API,目前提供两种API调用方式。
3.基础层实现
基础操作分为三种:sharedPreference
、memory
以及disk
。对于三种存储方式,提供统一的供上层调用的API接口CacheWrapper
。
/**
* 缓存控制类接口
*/
public interface CacheWrapper {
/**
* 读取缓存类
*
* @param <T> 缓存值类型,需要实现Parcelable接口
* @param key 缓存的key值
* @return 返回CacheResult<T>类型
*/
<T> CacheResource<T> get(String key, Class<T> clazz);
/**
* 存储缓存类
*
* @param key 缓存的key值
* @param value 缓存值
* @param <T> 缓存值类型,需要实现Parcelable接口
* @return 返回true或者false表示缓存是否成功
*/
<T> boolean put(String key, CacheResource<T> value);
/**
* 清空缓存
*/
void clear();
/**
* 删除某个值
*
* @param key 需要删除的缓存值对应key
* @return 返回true或者false表示删除是否成功
*/
boolean remove(String key);
/**
* 构造用工厂接口
*/
interface Factory {
}
interface Factory2 {
CacheWrapper create(Context context, CacheType type, String shareName);
}
}
各个存储方法再各自实现对应的存储内容。
sharedPreference
是我们在项目当中经常用到的,为了让它也满足上层API的调用,我们对它的基础操作进行封装PreferenceProvider
,之后再对接口进行具体实现DiskCacheWrapper
。
memory
也就是我们的内存缓存,我们选用LruCache
作为基础操作类型,LruCache
的核心思想就是要维护一个缓存对象列表,其中对象列表的排列方式是按照访问顺序实现的,即一直没访问的对象,将放在队尾,即将被淘汰。而最近访问的对象将放在队头,最后被淘汰。有兴趣的可以去了解一下LruCache
的具体实现。
使用时我们先初始化LruCache
并重写sizeOf
方法,计算存储数据的大小,这里我提供了一个SizeUtil
方便大小的计算,之后的调用方式非常简单,直接看代码
/**
* 内存缓存控制类
*/
public class MemoryCacheWrapper implements CacheWrapper {
private LruCache<String, Object> memoryCache;
private static final int DEFAULT_MEMORY_CACHE_SIZE = (int) (Runtime.getRuntime().maxMemory() / 8);
public static MemoryCacheWrapper get(){
return MemoryCacheHolder.mInstance;
}
private MemoryCacheWrapper() {
memoryCache = new LruCache<String, Object>(getCacheSize()) {
@Override
protected int sizeOf(String key, Object value) {
if (Bitmap.class.isAssignableFrom(value.getClass())) {
return (int)SizeUtil.getBitmapSize((Bitmap) value);
} else {
return (int) SizeUtil.getValueSize(value);
}
}
};
}
/**
* 获取缓存大小
*
* @return
*/
private int getCacheSize() {
int cacheSize = CacheInstaller.get().getMemorySize();
if (cacheSize <= 0) {
cacheSize = DEFAULT_MEMORY_CACHE_SIZE;
}
return cacheSize;
}
@Override
public <T> CacheResource<T> get(String key, Class<T> clazz) {
CacheResource<T> value = (CacheResource<T>) memoryCache.get(key);
if (value != null) {
return value;
}
return null;
}
@Override
public <T> boolean put(String key, CacheResource<T> value) {
if (value != null && memoryCache.get(key) == null) {
memoryCache.put(key, value);
return true;
} else {
LogUtil.log("value值为空或key值以及存在");
}
return false;
}
@Override
public void clear() {
memoryCache.evictAll();
}
@Override
public boolean remove(String key) {
Object object = memoryCache.remove(key);
if (object == null) {
return false;
} else {
return true;
}
}
private static class MemoryCacheHolder {
public static MemoryCacheWrapper mInstance = new MemoryCacheWrapper();
private MemoryCacheHolder() {
}
}
}
有些缓存模块没有使用LruCache
,而是使用HashMap
作为存储结构,两种方案都是可行的,这里使用LruCache
主要是为了方便图片的存储。
细心的朋友会发现这里put
的参数和get
返回的数据都是CacheResource
类型,我们把存储的数据,以及超时时间等统一的存储进这个数据结构,也就是说CacheResource
作为控制层和基础层传递的介质。
之后就是disk
也就是SD卡的存储。这一部分使用DiskLruCache
作为基础操作类型,和sharedPreference一样,首先我们对DiskLruCache
的操作进行封装,以统一对上层调用的API。
/**
* Created by liubohua on 2018/7/24.
* 提供本地缓存基础操作。
*/
public class DiskCacheProvider {
private DiskLruCache diskLruCache;
private Converter objectConverter;
private Converter bitmapConverter;
private Converter byteArrayConverter;
public DiskCacheProvider(File directory, int appVersion, long maxSize) {
objectConverter = new ObjectConverter();
bitmapConverter = new BitmapConverter();
byteArrayConverter = new ByteArrayConverter();
try {
diskLruCache = DiskLruCache.open(directory, appVersion, 1, maxSize);
} catch (IOException e) {
e.printStackTrace();
}
}
public CacheResource<Bitmap> getBitmap(String key) {
DiskLruCache.Snapshot snapShot = null;
try {
snapShot = diskLruCache.get(key);
if (snapShot != null) {
InputStream is = snapShot.getInputStream(0);
CacheResource<Bitmap> value = null;
value = bitmapConverter.read(is);
if (value != null) {
return value;
}
}
} catch (IOException e) {
e.printStackTrace();
} finally {
snapShot.close();
}
return null;
}
public CacheResource<Object> getObject(String key) {
DiskLruCache.Snapshot snapShot = null;
try {
snapShot = diskLruCache.get(key);
if (snapShot != null) {
InputStream is = snapShot.getInputStream(0);
CacheResource<Object> value = null;
value = objectConverter.read(is);
if (value != null) {
return value;
}
}
} catch (IOException e) {
e.printStackTrace();
} finally {
if(snapShot!=null){
snapShot.close();
}
}
return null;
}
public CacheResource<byte[]> getBytes(String key) {
DiskLruCache.Snapshot snapShot = null;
try {
snapShot = diskLruCache.get(key);
if (snapShot != null) {
InputStream is = snapShot.getInputStream(0);
CacheResource<byte[]> value = null;
value = byteArrayConverter.read(is);
if (value != null) {
return value;
}
}
} catch (IOException e) {
e.printStackTrace();
} finally {
if (snapShot != null) {
snapShot.close();
}
}
return null;
}
public boolean putObject(String key, CacheResource<Object> value) {
try {
DiskLruCache.Editor editor = diskLruCache.edit(key);
OutputStream outputStream = editor.newOutputStream(0);
boolean result = false;
result = objectConverter.write(value, outputStream);
if (result) {
editor.commit();
} else {
editor.abort();
}
return result;
} catch (IOException e) {
LogUtil.error("存储报错", e);
}
return false;
}
public boolean putBitmap(String key, CacheResource<Bitmap> value) {
try {
DiskLruCache.Editor editor = diskLruCache.edit(key);
OutputStream outputStream = editor.newOutputStream(0);
boolean result = false;
result = bitmapConverter.write(value, outputStream);
if (result) {
editor.commit();
} else {
editor.abort();
}
return result;
} catch (IOException e) {
LogUtil.error("存储报错", e);
}
return false;
}
public boolean putBytes(String key, CacheResource<byte[]> value) {
try {
DiskLruCache.Editor editor = diskLruCache.edit(key);
OutputStream outputStream = editor.newOutputStream(0);
boolean result = false;
result = byteArrayConverter.write(value, outputStream);
if (result) {
editor.commit();
} else {
editor.abort();
}
return result;
} catch (IOException e) {
LogUtil.error("存储报错", e);
}
return false;
}
public boolean remove(String key) {
try {
return diskLruCache.remove(key);
} catch (IOException e) {
e.printStackTrace();
}
return false;
}
public void clear() {
try {
diskLruCache.delete();
} catch (IOException e) {
e.printStackTrace();
}
}
}
在这个类当中除了对DiskLruCache
的封装外,还有三个转换器ObjectConverter
、BitmapConverter
、ByteArrayConverter
分别用于将三种存储的数据类型转换成对应的流进行存储。以ObjectConverter
为例,我们看一下这部分代码。
/**
* 类与流的转换器,需要实现序列化的对象
*/
public class ObjectConverter extends Converter<Object> {
public boolean write(CacheResource<Object> value, OutputStream outputStream) {
ObjectOutputStream oos = null;
try {
oos = new ObjectOutputStream(outputStream);
writeHeader(outputStream,value);
oos.writeObject(value.getData());
oos.flush();
return true;
} catch (IOException e) {
LogUtil.error("ObjectConverter数据解析出错", e);
} finally {
try {
oos.close();
} catch (IOException e) {
e.printStackTrace();
}
}
return false;
}
public CacheResource<Object> read(InputStream inputStream) {
ObjectInputStream ois = null;
CacheResource<Object> cacheObject = new CacheResource<>();
try {
ois = new ObjectInputStream(inputStream);
readHeader(inputStream,cacheObject);
cacheObject.setData(ois.readObject());
return cacheObject;
} catch (IOException e) {
LogUtil.error("ObjectConverter数据解析出错", e);
} catch (ClassNotFoundException e) {
LogUtil.error("ObjectConverter数据解析出错", e);
} finally {
try {
ois.close();
} catch (IOException e) {
e.printStackTrace();
}
}
return null;
}
}
这个类继承自Converter
方法,这个类提供了readHeader(inputStream,cacheObject)
和writeHeader(outputStream,value)
方法,以魔法数字的形式存储超时时间等除存储内容之外的数据。
之后把DiskCacheProvider
封装为DiskCacheWrapper
供控制层调用。
4.控制层
控制层的工作主要有
- 根据不同的操作类型分发事务。
- 对超时时间加以判断,触发超时策略。
- 对
CacheResource
的封装和解析。 - 对
key
值进行加密
/**
* Cache管理类
*/
public class CacheManager {
private CacheWrapper wrapper;
private Encrypt encrypt;
public CacheManager(CacheWrapper wrapper, Encrypt encrypt) {
this.wrapper = wrapper;
this.encrypt = encrypt;
}
/**
* 获取缓存内容
*
*/
public <T> Observable<T> get(final String key, final CacheType type, final Class<T> clazz, final ExpirationPolicies policies) {
Observable<T> observable = Observable.create(new Observable.OnSubscribe<CacheResource<T>>() {
@Override
public void call(Subscriber<? super CacheResource<T>> subscriber) {
String cacheKey = encrypt.getEncryptKey(key);
CacheResource<T> cacheResource = null;
if(wrapper!=null){
cacheResource = wrapper.get(cacheKey,clazz);
}
subscriber.onNext(cacheResource);
subscriber.onCompleted();
}
}).filter(new Func1<CacheResource<T>, Boolean>() {
@Override
public Boolean call(CacheResource<T> resource) {
if (resource != null) {
if (resource.isExpired()) {
if (policies == ExpirationPolicies.ReturnNull) {
resource.setData(null);
}
remove(key).subscribe();
}
}
return true;
}
}).map(new Func1<CacheResource<T>, T>() {
public T call(CacheResource<T> resource) {
if (resource != null) {
return resource.getData();
} else {
return null;
}
}
}).subscribeOn(Schedulers.io());
return observable;
}
/**
* 添加缓存
*/
public <T> Observable<Boolean> put(final String key, final T value, final long timeout, final TimeUnit unit) {
Observable<Boolean> observable = Observable.create(new Observable.OnSubscribe<Boolean>() {
@Override
public void call(Subscriber<? super Boolean> subscriber) {
String cacheKey = encrypt.getEncryptKey(key);
CacheResource<T> cacheResource = new CacheResource<>(value, System.currentTimeMillis(), timeout, unit);
boolean result = false;
if (wrapper != null) {
result = wrapper.put(cacheKey, cacheResource);
}
subscriber.onNext(result);
subscriber.onCompleted();
}
}).subscribeOn(Schedulers.io());
return observable;
}
/**
* 移除缓存内容
*
*/
public Observable<Boolean> remove(final String key) {
Observable<Boolean> observable = Observable.create(new Observable.OnSubscribe<Boolean>() {
@Override
public void call(Subscriber<? super Boolean> subscriber) {
boolean result = false;
String cacheKey = encrypt.getEncryptKey(key);
if (wrapper != null) {
wrapper.remove(cacheKey);
}
subscriber.onNext(result);
subscriber.onCompleted();
}
}).subscribeOn(Schedulers.io());
return observable;
}
/**
* 清空缓存
*/
public void clear() {
if (wrapper != null) {
wrapper.clear();
}
}
public static class CacheWrapperFactory implements CacheWrapper.Factory2 {
@Override
public CacheWrapper create(Context context, CacheType type, String shareName) {
if (type == CacheType.DISK) {
return new DiskCacheWrapper();
} else if (type == CacheType.MEMORY) {
return MemoryCacheWrapper.get();
} else if (type == CacheType.SHARED) {
return new ShareCacheWrapper(context, shareName);
} else if (type == CacheType.TWO_LAYER) {
return new TwoLayerWrapper();
}
return null;
}
}
}
对外提供加密接口Encrypt
,用户可以实现这个接口并实现自己的加密方式,默认使用MD5
加密。
5.封装api
封装的API主要有三部分:
-
CacheInstaller
缓存的配置类 -
RxCache
对外提供的存取操作API -
RetrofitCache
以Retrofit
的形式调用API
CacheInstaller
以单例的形式对外提供,在一个项目当中,该类应该之初始化一次,简单看一下这部分代码。
public class CacheInstaller {
private static final long MAX_DISK_CACHE_SIZE = 50 * 1024 * 1024; // 50MB
private static final int DEFAULT_VERSION = 1;
private static final String DEFAULT_PATH = "cache";
private String diskPath;
private int memorySize;
private long diskSize =0l;
private int diskVersion = -1;
private boolean isInstall = false;
private Context context;
private Encrypt encrypt;
private CacheInstaller() {
}
private static class SingleTon {
private static CacheInstaller INSTANCE = new CacheInstaller();
}
public static CacheInstaller get() {
return SingleTon.INSTANCE;
}
/**
* 配置磁盘缓存配置
*/
public CacheInstaller configDiskCache(String diskPath, long diskSize, int diskVersion) {
if (isInstall) {
return this;
}
this.diskPath = diskPath;
this.diskSize = diskSize;
this.diskVersion = diskVersion;
return this;
}
/**
* 配置内存缓存配置
*
*/
public CacheInstaller configMemoryCache(int memorySize) {
if (isInstall) {
return this;
}
this.memorySize = memorySize;
return this;
}
/**
* 配置全局加密方式
*
*/
public CacheInstaller encryptFactory(Encrypt.Factory factory) {
if (isInstall) {
return this;
}
if(factory!=null){
encrypt = factory.create();
}
return this;
}
/**
* 完成装填工作
*/
public void install(Context context) {
this.isInstall = true;
this.diskPath = getDirectory(context);
this.diskVersion = getVersion();
this.diskSize = getCacheSize(context);
this.encrypt = createEncrypt();
this.context = context.getApplicationContext();
}
/**
* 重置装填状态
* 慎用
*/
public void resume() {
this.isInstall = false;
}
}
RxCache
的代码只是对外提供API,没有逻辑代码。
RetrofitCache
使用动态代理的方式。
public static <T> T create(Class<T> clazz) {
RetrofitProxy proxy = new RetrofitProxy();
try {
return (T) Proxy.newProxyInstance(RetrofitCache.class.getClassLoader(), new Class[]{clazz}, proxy);
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
public class RetrofitProxy implements InvocationHandler {
RxCache rxCache;
@Override
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
car.wuba.saas.cache.retrofit.annotation.Method method1 = method.getAnnotation(car.wuba.saas.cache.retrofit.annotation.Method.class);
Strategy strategy = method.getAnnotation(Strategy.class);
Lifecycle lifecycle = method.getAnnotation(Lifecycle.class);
ShareName shareName = method.getAnnotation(ShareName.class);
Class CacheClazz = null;
Object CacheValue = null;
String CacheKey = null;
Annotation[][] allParamsAnnotations = method.getParameterAnnotations();
//获取key、value等注解对应的参数
if (allParamsAnnotations != null) {
for (int i = 0; i < allParamsAnnotations.length; i++) {
Annotation[] paramAnnotations = allParamsAnnotations[I];
if (paramAnnotations != null) {
for (Annotation annotation : paramAnnotations) {
if (annotation instanceof CacheClass) {
CacheClazz = (Class) args[I];
}
if (annotation instanceof CacheKey) {
CacheKey = (String) args[I];
}
if (annotation instanceof CacheValue) {
CacheValue = args[I];
}
}
}
}
}
//初始化各项参数
if (method1 != null) {
MethodType methodKey = method1.methodType();
CacheType typeValue = method1.cacheType();
long time = 0;
TimeUnit unit = null;
if (lifecycle != null) {
time = lifecycle.time();
unit = lifecycle.unit();
}
ExpirationPolicies policies = ExpirationPolicies.ReturnNull;
if (strategy != null) {
policies = strategy.key();
}
String name = "";
if (shareName != null) {
name = shareName.name();
}
rxCache = RxCache.get();
if (methodKey == MethodType.PUT) {
return putMethod(typeValue, time, unit, CacheKey, CacheValue, name);
} else if (methodKey == MethodType.GET) {
return getMethod(typeValue, policies, CacheKey, CacheClazz, name);
} else if (methodKey == MethodType.REMOVE) {
return removeMethod(typeValue, CacheKey, name);
} else if (methodKey == MethodType.CLEAR) {
clearMethod(typeValue, name);
}
}
return null;
}
总结
缓存SDK参考了Glide
以及okHttp
等内部的缓存形式,并结合我们当前的项目结构和需求进行构建,本人还是个新手,有什么问题还希望大神们多多指教。感兴趣的小伙伴也可以自己下载,修改来试试。下载链接https://github.com/homeven/RxCache
作者:銀灬楓
链接:https://www.jianshu.com/p/a16ee1ff4da1
来源:简书
简书著作权归作者所有,任何形式的转载都请联系作者获得授权并注明出处。
网友评论