1、OkHttp使用流程:
OkHttpClient:
OkHttpClient client = new OkHttpClient();
Request request = new Request.Builder().url("http://wwww.baidu.com").build();
//同步请求
Response syncResponse = client.newCall(request).execute();
//异步请求
client.newCall(request).enqueue(new Callback() {
@Override
public void onFailure(@NotNull Call call, @NotNull IOException e) { }
@Override
public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException { }
});
首先创建一个OkHttpClient实例,然后调用调用OkhttpClient的newCall方法,传入Request请求参数,返回一个Call,实际返回的是RealCall,再调用RealCall的execute或enqueue发起请求。
OkHttpClient可以直接创建或者通过Builder方式创建。里面没什么代码,只是根据建造者模式传入的Builder进行赋值,初始化操作都是在Builder里进行,参数具体意义见下文。
Request:
open class Builder {
internal var url: HttpUrl? = null
internal var method: String
internal var headers: Headers.Builder
internal var body: RequestBody? = null
/** A mutable map of tags, or an immutable empty map if we don't have any. */
internal var tags: MutableMap<Class<*>, Any> = mutableMapOf()
constructor() {
this.method = "GET"
this.headers = Headers.Builder()
}
}
Request里默认请求方式为get,通过建造者模式配置请求地址、请求方式、请求头等参数。
2、分析Okhttp工作流程:
首先我们可以看到,在OkHttp的实际使用中,最后是调用了enqueue()方法发起请求的
client.newCall(request).enqueue
我们跟踪enqueue进去,可以发现该方法在 接口 interface Call 里面,是个抽象方法。所以我们断定,client .newCall()继承了Call 。再追踪newCall(),看看有没有抽象方法enqueue()方法的实现。
我们发现newCall()实例了一个RealCall(),这也是我们前文提到的"返回一个Call,实际返回的是RealCall”。
紧接着,我们在RealCall()中可以发现 enqueue()方法的实现。
由一个client.dispatcher的enqueue()实现,传进了一个AsyncCall()参数。AsyncCall我们之后分析,现在先进入dispatcher的enqueue()看看里面的具体业务。PS:client就是OkHttpClient的实例。
可以看到 enqueue把AsyncCall放入一个readyAsyncCalls的集合之后,最后调用了promoteAndExecute();我们接着追
可以发现,promoteAndExecute对异步操作做了一系列的检查,是否是未执行,执行是否会超负载等。接着将所有的asyncCall遍历并却执行asyncCall.executeOn();如此可见,我们再追executeOn()就能进一步接近答案。
可以发现,该方法中,调用了JAVA原生的线程调度类
executorService.execute(this),会将参数中的runnable送至后台执行(所以此时,线程发生切换)
断定this为AsyncCall里面的一个runnable方法,现在,我们回到最开始的
client.dispatcher的enqueue()实现,里面传进了一个AsyncCall()参数,看看这个AsyncCall()里面的runnable具体干了什么。
可以发现 AsyncCall是RealCall的内部类,并却继承了Runnable接口。
核心业务就是其run()方法;
可见最后的response 由getResponseWithInterceptorChain()来返回。
目前,这就是OkHttp异步请求唤起责任链的全过程
PS:责任链是OkHttp最核心的东西包括报文封装TCP连接,TLS连接等等工作全部由责任链完成。
cilent.newCall(requset).execute();
在看同步请求,同样的,去到RealCall里面寻找execute()
可以看见,直接就在execute()里面getResponseWithInterceptorChain()了。