最近这段时间的确有点忙，要处理的事情比较多，发现好久没有更新文章了，以后尽量一周更新一篇，这周要视频的人也特多，希望我们看了要多花点时间消化，最好我们自己能写一下总结，千万别又还给我了。那位替我打广告的哥们，虽然我不知道你是谁，但是打心底里说声谢谢。
OkHttp 我们总共花了四次去分析源码，花那么多时间去看源码到底是为了啥？其实每个人想的都不一样，有人觉得会用就很不错了，对于我来说我就是喜欢琢磨琢磨而已。但是开发过程中分析源码，对于我们其实会有很多好处，比如现在我想要监听文件上传的进度，又或者是我想要自定义缓存，又或者说我想要断点下载等等。当然这些网上都有，大家也都基本一个模板，但关键我们是否明白为什么要这么写？是否能够看得懂人家的代码？而这一切的一切在分析源码之后，我们不光能看懂别人为什么这么写，还能从源码的角度自己去分析扩展。
这里分析开发中最常见的几个扩展：
- 文件上传进度监听
- 自定义缓存（要求：有网 30s 内请求读缓存，无网直接读缓存）
- 多线程断点下载
1.文件上传进度监听
我们先看下 OkHttp 上传文件是怎么写的，至于 OkHttp 怎么使用？这里不做过多的介绍，而且对于文件上传我们之前自己动手写过，直接贴代码：
File file = new File(Environment.getExternalStorageDirectory(), "test.png");
OkHttpClient httpClient = new OkHttpClient();
// 构建请求 Body , 这个我们之前自己动手写过
MultipartBody.Builder builder = new MultipartBody.Builder()
.setType(MultipartBody.FORM);
builder.addFormDataPart("platform", "android");
builder.addFormDataPart("file", file.getName(),
RequestBody.create(MediaType.parse(guessMimeType(file.getAbsolutePath())), file));
// 构建一个请求
final Request request = new Request.Builder()
.url("https://www.easyjoke.com/xxxxx")
.post(builder.build()).build();
// new RealCall 发起请求
Call call = httpClient.newCall(request);
call.enqueue(new Callback() {
@Override
public void onFailure(Call call, IOException e) {
e.printStackTrace();
}
@Override
public void onResponse(Call call, Response response) throws IOException {
Log.e("TAG", response.body().string());
}
});
怎么去添加进度？这个时候尽可能运用所有的脑细胞。先跑到源码中 CallServerInterceptor 这个拦截器，之前分析源码的时候说过，所有的读写操作都在这里，有这么一行向服务器写数据的代码：
BufferedSink bufferedRequestBody = Okio.buffer(requestBodyOut);
// 调用 RequestBody的writeTo方法向服务器去写数据
request.body().writeTo(bufferedRequestBody);
看到上面这行代码，我们能够分析出，最终肯定会来到 MultipartBody 中的 writeTo 的方法。那么我们在这个方法里面去做处理不就行了，我们自己扩展一个 ExRequestBody 去继承 MultipartBody 然后复写 writeTo 方法做处理，但是发现 MultipartBody 是一个 final 类，不能继承这个时候怎么办？嗨，醒醒，不能继承怎么办？还好之前学了设计模式，设计模式学了就是要用的，用 静态代理 不就刚好能解决这个问题？
/**
* description: RequestBody代理
* author: Darren on 2017/11/24 10:16
* email: 240336124@qq.com
* version: 1.0
*/
public class ExRequestBody extends RequestBody {
// 被代理的对象
private RequestBody mOriginalBody;
// 总的长度
private long mTotalLength = -1;
// 当前上传的长度
private long mCurrentLength = -1;
public ExRequestBody(RequestBody requestBody) {
this.mOriginalBody = requestBody;
}
@Nullable
@Override
public MediaType contentType() {
return mOriginalBody.contentType();
}
@Override
public long contentLength() throws IOException {
return mOriginalBody.contentLength();
}
@Override
public void writeTo(BufferedSink sink) throws IOException {
// Log.e("TAG", "进来了");
// 获取总的长度
mTotalLength = contentLength();
// 这里又是一个代理模式
ForwardingSink forwardingSink = new ForwardingSink(sink) {
@Override
public void write(Buffer source, long byteCount) throws IOException {
super.write(source, byteCount);
// 写了多少数据叠加起来
mCurrentLength += byteCount;
// 我们要自己写一个接口回调出去
// Log.e("TAG", "-> " + mCurrentLength + " -> " + mContentLength);
}
};
sink = Okio.buffer(forwardingSink);
// 最终调用者还是被代理对象的方法
mOriginalBody.writeTo(sink);
// 一定要刷新，之前说过的连接池，复用等等
sink.flush();
}
}
2. 自定义缓存（要求：有网 30s 内请求读缓存，无网直接读缓存）
关于缓存的处理，我们需要了解我们之前所讲的缓存策略，熟读 CacheInterceptor 这个拦截器的源码就可以了，网上我看了很多例子，虽说效果都达到了，但准确的说应该分为两个部分去处理：
CacheRequestInterceptor
public class CacheRequestInterceptor implements Interceptor {
private Context context;
public CacheRequestInterceptor(Context context) {
this.context = context;
}
@Override
public Response intercept(Chain chain) throws IOException {
Request request = chain.request();
if(!NetworkUtil.isNetworkAvailable(context)){
// 直接读缓存
request = request.newBuilder()
.cacheControl(CacheControl.FORCE_CACHE)
.build();
}
Response response = chain.proceed(request);
return response;
}
}
CacheResponseInterceptor
public class CacheResponseInterceptor implements Interceptor {
@Override
public Response intercept(Chain chain) throws IOException {
// 有网的情况下 30s 之内访问同一接口，会直接读缓存，不会重复访问
Request request = chain.request();
Response response = chain.proceed(request);
int maxAge = 30;
return response.newBuilder()
.removeHeader("Pragma")
.removeHeader("Cache-Control")
// max-age 是一种特例，既包含缓存策略又包含缓存过期时间
.header("Cache-Control", "max-age=" + maxAge)
.build();
}
}
使用
.cache(cache)//开启缓存
// 一个添加在前
.addInterceptor(new CacheRequestInterceptor(MainActivity.this))
// 一个添加在后
.addNetworkInterceptor(new CacheResponseInterceptor())
OkHttp 自带的这种缓存的扩展还是会有一些坑的，比如不支持 post 数据缓存，某些特定接口也不应该这样去处理，所以我们还得会自己管理缓存，当然如果你对源码已经足够了解，什么事干不出来？
所有分享大纲：Android进阶之旅 - 系统架构篇
