书接着上文，如果没有看过上一篇，传送门 ，应为篇幅和必要性，并没有分析GreenDao 数据级别的缓存优化。本篇幅补充上。
GreenDao一些基础知识，也可以看这里，了解一下，他是个什么东西，为什么用GreenDao，那么多基于ORM解决方案，真想只有一个，原作者用的，我懒得改。
好了先看代码 HttpManager 类--->doHttpDeal方法,在创建网络处理的时候有一段代码 这里用到了一个缓冲拦截器，没错他就是今天主角。
// 添加拦截器 仅仅是打印，为了例子简单，我吧元项目的 db持久化数据存储删除了。暂时删除了。
builder.addInterceptor(new CookieInterceptor(basePar.isCache(), basePar.getUrl()));
CookieInterceptor 重点代码
public class CookieInterceptor implements Interceptor
//数据的一个工具类 稍后会说明
private CookieDbUtil dbUtil;
/*是否缓存标识*/
private boolean cache;
/*url*/
private String url;
@Override
public Response intercept(Chain chain) throws IOException {
// 获取请求
Request request = chain.request();
// 获取相应
Response response = chain.proceed(request);
if (cache) {
// 后去主体内容
ResponseBody body = response.body();
// 这句话很明显多内容进行分解 存入缓存区中 [学习链接](http://blog.csdn.net/io_field/article/details/51812054)
BufferedSource source = body.source();
source.request(Long.MAX_VALUE); //修改缓冲区大小 最大
Buffer buffer = source.buffer();
Charset charset = Charset.defaultCharset();
MediaType contentType = body.contentType();
if (contentType != null) {
charset = contentType.charset(charset);
}
// 克隆一个缓冲器，并填入值
String bodyString = buffer.clone().readString(charset);
// 这里有个工具，方法的意思是获取整个url之前的备份
CookieResulte resulte = dbUtil.queryCookieBy(url);
long time = System.currentTimeMillis();
/*保存和更新本地数据*/
// 如果没有这个url的存储，就新建一个，如果有则更新内容
if (resulte == null) {
resulte = new CookieResulte(url, bodyString, time);
dbUtil.saveCookie(resulte);
} else {
resulte.setResulte(bodyString);
resulte.setTime(time);
dbUtil.updateCookie(resulte);
}
}
return response;
}
CookieDbUtil 类的主体代码，一个很普通的类 不普通的是， DaoMaster、简单说明一下，DaoMaster是GreenDao建立了@Entity 文件刷新自己生成的文件 为什么会这样，请去看帖子，我唠叨半天可能你看一眼就Ok了。 RxRetrofitApp.getApplication() 则是实体类不过他和Application又很美妙的关系，稍后会说明。
public class CookieDbUtil
// 一个单例的名字
private static CookieDbUtil db;
// 数据库名字
private final static String dbName = "tests_db";
// 看名字就知道是sqlite的操作文件
private DaoMaster.DevOpenHelper openHelper;
// 上下文，，不说多
private Context context;
public CookieDbUtil() {
context = RxRetrofitApp.getApplication();
// 实例化了数据的操作对象
openHelper = new DaoMaster.DevOpenHelper(context, dbName);
}
/**
* 获取可读数据库
*/
private SQLiteDatabase getReadableDatabase() {
.......不是重点代码省略
SQLiteDatabase db = openHelper.getReadableDatabase();
return db;
}
/**
* 获取可写数据库
*/
private SQLiteDatabase getWritableDatabase() {
.......不是重点代码省略
SQLiteDatabase db = openHelper.getWritableDatabase();
return db;
}
//是个方法，就是存储 删除 查询 更新 重点：CookieResulte
public void saveCookie(CookieResulte info) {
.......不是重点代码省略
}
public void updateCookie(CookieResulte info) {
.......不是重点代码省略
}
public void deleteCookie(CookieResulte info) {
.......不是重点代码省略
}
public CookieResulte queryCookieBy(String url) {
.......不是重点代码省略
}
CookieResulte 核心代码 就是这几个属性，ORM一个标准的方法注入数据的对象。很多大型数据的数据框架也这样，思路都是一样的。
@Entity
public class CookieResulte {
@Id
private Long id;
private String url;
private String resulte;
private long time;
RxRetrofitApp 介绍一下，很简单一个 application的初始化，一个是debug模式的开启，这个debug哪里用了？httpManager拦截器哪里用了。debug的时候直接打印到控制台。那么init方法哪里使用了？下面👇解释
public class RxRetrofitApp {
private static Application application;
private static boolean debug;
public static void init(Application app) {
setApplication(app);
setDebug(true);
}
public static void init(Application app, boolean debug) {
setApplication(app);
setDebug(debug);
}
public static Application getApplication() {
return application;
}
private static void setApplication(Application application) {
RxRetrofitApp.application = application;
}
public static boolean isDebug() {
return debug;
}
public static void setDebug(boolean debug) {
RxRetrofitApp.debug = debug;
}
}
MyApplication 集成了这个app的最重要的类，android入口类
public class MyApplication extends Application {
public static Context app;
@Override
public void onCreate() {
super.onCreate();
app = getApplicationContext();
RxRetrofitApp.init(this, BuildConfig.DEBUG);
}
}
其实以上方法都是用于存储，那什么取出来，缓存就是要用才有意义。其实最终重要的一个思路就是，网络操作异常的时候。所有。。必定是上一篇介绍的 继承 观察者的 ProgressSubscriber 类
/**
* 订阅开始
* 显示ProgressDialog
*/
@Override
public void onStart() {
showProgressDialog();
/*缓存并且有网*/
if (api.isCache() && AppUtil.isNetworkAvailable(RxRetrofitApp.getApplication())) {
/*获取缓存数据*/
CookieResulte cookieResulte = CookieDbUtil.getInstance().queryCookieBy(api.getUrl());
if (cookieResulte != null) {
long time = (System.currentTimeMillis() - cookieResulte.getTime()) / 1000;
if (time < api.getCookieNetWorkTime()) {
if (mSubscriberOnNextListener.get() != null) {
mSubscriberOnNextListener.get().onCacheNext(cookieResulte.getResulte());
}
onCompleted();
unsubscribe();
}
}
}
}
@Override
public void onError(Throwable e) {
dismissProgressDialog();
/*需要緩存并且本地有缓存才返回*/
if (api.isCache()) {
//这里比较有意思，使用的是一个发送url的观察者静态方法。我理解就是为了让他在io线程中处理的原因。
Observable.just(api.getUrl()).subscribe(new Subscriber<String>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
errorDo(e);
}
@Override
public void onNext(String s) {
/*获取缓存数据*/
CookieResulte cookieResulte = CookieDbUtil.getInstance().queryCookieBy(s);
if (cookieResulte == null) {
throw new HttpTimeException("网络错误");
}
long time = (System.currentTimeMillis() - cookieResulte.getTime()) / 1000;
if (time < api.getCookieNoNetWorkTime()) {
if (mSubscriberOnNextListener.get() != null) {
mSubscriberOnNextListener.get().onCacheNext(cookieResulte.getResulte());
}
} else {
CookieDbUtil.getInstance().deleteCookie(cookieResulte);
throw new HttpTimeException("网络错误");
}
}
});
} else {
errorDo(e);
}
}
以上就分析完毕·~其实原作者的思路还是非常严谨的。很多学习地方。下一篇应该还是这个作者利用整合下载分析，下面的分析就会快很多因为，已经有基础了。跑的会很快，我要飙车了。。
我的源码
