前言
OkHttp是目前很流行的网络请求框架。源码也设计很优秀的思想。有必要去探究一下源码。
由于篇幅较长，分为五篇文章。本篇文章将讨论OkHttp的执行流程分析
文章目录
一、OkHttp执行流程分析
二、同步请求流程分析
三、异步请求流程分析
四、任务调度核心dispatcher
五、OkHttp中五大拦截器源码与功能分析
OkHttp执行流程分析
流程图
流程图.png
流程分析
1、创建OkHttpClient
OkHttpClient是一个通过build模式去构建的。
public Builder() {
dispatcher = new Dispatcher();
protocols = DEFAULT_PROTOCOLS;
connectionSpecs = DEFAULT_CONNECTION_SPECS;
eventListenerFactory = EventListener.factory(EventListener.NONE);
proxySelector = ProxySelector.getDefault();
cookieJar = CookieJar.NO_COOKIES;
socketFactory = SocketFactory.getDefault();
hostnameVerifier = OkHostnameVerifier.INSTANCE;
certificatePinner = CertificatePinner.DEFAULT;
proxyAuthenticator = Authenticator.NONE;
authenticator = Authenticator.NONE;
connectionPool = new ConnectionPool();
dns = Dns.SYSTEM;
followSslRedirects = true;
followRedirects = true;
retryOnConnectionFailure = true;
connectTimeout = 10_000;
readTimeout = 10_000;
writeTimeout = 10_000;
pingInterval = 0;
}
然后通过build的build方法构建
public OkHttpClient build() {
return new OkHttpClient(this);
}
这里主要是通过build设计模式配置一些常用的参数信息，如超时时间等。
2、创建Request
public Builder() {
this.method = "GET";
this.headers = new Headers.Builder();
}
Builder(Request request) {
this.url = request.url;
this.method = request.method;
this.body = request.body;
this.tag = request.tag;
this.headers = request.headers.newBuilder();
}
Request也是通过build模式配置一些请求信息等，如url,请求方法，请求体，请求头等。
3、创建Call
Call call = client.newCall(request);
主要是通过client.newCall然后传入一个request来进行创建。
@Override
public Call newCall(Request request) {
return RealCall.newRealCall(this, request, false);
}
这里其实是创建了一个RealCall，RealCall也是OkHttp框架主要流程的一部分，主要是链接request和Response的桥梁，通过call进行同步和异步方法的执行。在同步和异步的执行方法里会返回response。例如：
@Override public Response execute() throws IOException {
synchronized (this) {
if (executed) throw new IllegalStateException("Already Executed");
executed = true;
}
captureCallStackTrace();
eventListener.callStart(this);
try {
client.dispatcher().executed(this);
Response result = getResponseWithInterceptorChain();
if (result == null) throw new IOException("Canceled");
return result;
} catch (IOException e) {
eventListener.callFailed(this, e);
throw e;
} finally {
client.dispatcher().finished(this);
}
}
4、通过Call执行同步或者异步请求，获取response
Response response = call.execute();
System.out.println(response.body().string());
上面已经说过通过call的execute可以进行同步请求，然后获取response，这个response就是我们想要的返回的信息。
也可以通过call.enqueue方法传入也一个监听器，进行异步请求。
call.enqueue(new Callback() {
@Override
public void onFailure(Call call, IOException e) {
//返回失败的情况
}
@Override
public void onResponse(Call call, Response response) throws IOException {
//调用成功的情况
}
});
5、完整的get请求，和post请求示例
get
OkHttpClient client = new OkHttpClient();
String run(String url) throws IOException {
Request request = new Request.Builder()
.url(url)
.build();
Response response = client.newCall(request).execute();
return response.body().string();
}
post
public static final MediaType JSON
= MediaType.parse("application/json; charset=utf-8");
OkHttpClient client = new OkHttpClient();
String post(String url, String json) throws IOException {
RequestBody body = RequestBody.create(JSON, json);
Request request = new Request.Builder()
.url(url)
.post(body)
.build();
Response response = client.newCall(request).execute();
return response.body().string();
}
6、总结
这篇只是简单分析OkHttp的使用流程，其实还有一部分核心的流程是在源码中体现的比如dispatcher调度器的使用流程，与拦截器的核心功能等，这一部分将在后面的总结中进行单独分析。
