OkHttpClient client = new OkHttpClient();

咦,怎么不见 builder?莫急,且看其构造函数:

public OkHttpClient() {
this(new Builder());
}

原来是方便我们使用,提供了一个“快捷操作”,全部使用了默认的配 置。 OkHttpClient.Builder 类成员很多,后面我们再慢慢分析,这里先暂时略 过:

public Builder() {
dispatcher = new Dispatcher();
protocols = DEFAULT_PROTOCOLS;
connectionSpecs = DEFAULT_CONNECTION_SPECS;
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;
}

2.2.发起 HTTP 请求

String run(String url) throws IOException {
Request request = new Request.Builder()
.url(url)
.build();
Response response = client.newCall(request).execute();
return response.body().string();
}

OkHttpClient 实现了 Call.Factory ,负责根据请求创建新的 Call 。
那我们现在就来看看它是如何创建 Call 的:

/**

  • Prepares the {@code request} to be executed at some point in the future.
    */
    @Override public Call newCall(Request request) {
    return new RealCall(this, request);
    }

如此看来功劳全在 RealCall 类了,下面我们一边分析同步网络请求的过程,一边 了解 RealCall 的具体内容。

2.2.1.同步网络请求

我们首先看 RealCall#execute

@Override public Response execute() throws IOException {
synchronized (this) {
if (executed) throw new IllegalStateException(“Already Execu ted”);
// (1)
executed = true;
}
try {
client.dispatcher().executed(this);
// (2)
Response result = getResponseWithInterceptorChain();
// (3)
if (result == null) throw new IOException(“Canceled”);
return result;
} finally {
client.dispatcher().finished(this);
// (4)
}
}

这里我们做了 4 件事:

  1. 检查这个 call 是否已经被执行了,每个 call 只能被执行一次,如果想要一个完 全一样的 call,可以利用 call#clone 方法进行克隆。
  2. 利用 client.dispatcher().executed(this) 来进行实际执 行 dispatcher 是刚才看到的 OkHttpClient.Builder 的成员之一,它的文 档说自己是异步 HTTP 请求的执行策略,现在看来,同步请求它也有掺和。
  3. 调用 getResponseWithInterceptorChain() 函数获取 HTTP 返回结果,从 函数名可以看出,这一步还会进行一系列“拦截”操作。
  4. 最后还要通知 dispatcher 自己已经执行完毕。

dispatcher 这里我们不过度关注,在同步执行的流程中,涉及到 dispatcher 的内容 只不过是告知它我们的执行状态,比如开始执行了(调用 executed ),比如执行 完毕了(调用 finished ),在异步执行流程中它会有更多的参与。

真正发出网络请求,解析返回结果的,还 是 getResponseWithInterceptorChain

private Response getResponseWithInterceptorChain() throws IOExce ption {
// Build a full stack of interceptors.
List interceptors = new ArrayList<>();
interceptors.addAll(client.interceptors());
interceptors.add(retryAndFollowUpInterceptor);
interceptors.add(new BridgeInterceptor(client.cookieJar()));
interceptors.add(new CacheInterceptor(client.internalCache())) ;
interceptors.add(new ConnectInterceptor(client));
if (!retryAndFollowUpInterceptor.isForWebSocket()) {
interceptors.addAll(client.networkInterceptors());
}
interceptors.add(new CallServerInterceptor(
retryAndFollowUpInterceptor.isForWebSocket()));
Interceptor.Chain chain = new RealInterceptorChain(
interceptors, null, null, null, 0, originalRequest);
return chain.proceed(originalRequest);
}

InterceptorOkHttp 最核心的一个东西,不要误以为它只负责拦截请求 进行一些额外的处理(例如 cookie),实际上它把实际的网络请求、缓存、透明压 缩等功能都统一了起来,每一个功能都只是一个 Interceptor ,它们再连接成一 个 Interceptor.Chain ,环环相扣,最终圆满完成一次网络请求。

getResponseWithInterceptorChain 函数我们可以看 到 Interceptor.Chain 的分布依次是:

  1. 在配置 OkHttpClient 时设置的 interceptors
  2. 负责失败重试以及重定向的 RetryAndFollowUpInterceptor
  3. 负责把用户构造的请求转换为发送到服务器的请求、把服务器返回的响应转换 为用户友好的响应的 BridgeInterceptor
  4. 负责读取缓存直接返回、更新缓存的 CacheInterceptor
  5. 负责和服务器建立连接的 ConnectInterceptor
  6. 配置 OkHttpClient 时设置的 networkInterceptors
  7. 负责向服务器发送请求数据、从服务器读取响应数 据 CallServerInterceptor

在这里,位置决定了功能,最后一个 Interceptor 一定是负责和服务器实际通讯的, 重定向、缓存等一定是在实际通讯之前的。 责任链模式在这个 Interceptor 链条中得到了很好的实践。

它包含了一些命令对象和一系列的处理对象,每一个处理对象决定它能处理哪 些命令对象,它也知道如何将它不能处理的命令对象传递给该链中的下一个处 理对象。该模式还描述了往该处理链的末尾添加新的处理对象的方法。

对于把 Request 变成 Response 这件事来说,每个 Interceptor 都可能完成这 件事,所以我们循着链条让每个 Interceptor 自行决定能否完成任务以及怎么完 成任务(自力更生或者交给下一个 Interceptor )。这样一来,完成网络请求这 件事就彻底从 RealCall 类中剥离了出来,简化了各自的责任和逻辑。两个字:优 雅!

责任链模式在安卓系统中也有比较典型的实践,例如 view 系统对点击事件 (TouchEvent)的处理。

回到 OkHttp,在这里我们先简单分析一 下 ConnectInterceptorCallServerInterceptor ,看看 OkHttp 是怎么进 行和服务器的实际通信的。

2.2.1.1.建立连接: ConnectInterceptor

@Override public Response intercept(Chain chain) throws IOExcept ion {
RealInterceptorChain realChain = (RealInterceptorChain) chain;
Request request = realChain.request();
StreamAllocation streamAllocation = realChain.streamAllocation ();
// We need the network to satisfy this request. Possibly for v alidating a conditional GET. boolean doExtensiveHealthChecks = !request.method().equals(“GE T”);
HttpCodec httpCodec = streamAllocation.newStream(client, doExt ensiveHealthChecks);
RealConnection connection = streamAllocation.connection();
return realChain.proceed(request, streamAllocation, httpCodec, connection);
}

实际上建立连接就是创建了一个 HttpCodec 对象,它将在后面的步骤中被使用, 那它又是何方神圣呢?它是对 HTTP 协议操作的抽象,有两个实 现: Http1CodecHttp2Codec ,顾名思义,它们分别对应 HTTP/1.1 和 HTTP/2 版本的实现。

Http1Codec 中,它利用Okio对 Socket 的读写操作进行封装,Okio 以后有机 会再进行分析,现在让我们对它们保持一个简单地认识:它 对 java.iojava.nio 进行了封装,让我们更便捷高效的进行 IO 操作。

而创建 HttpCodec 对象的过程涉及 到 StreamAllocation RealConnection ,代码较长,这里就不展开,这个过 程概括来说,就是找到一个可用的 RealConnection ,再利 用 RealConnection 的输入输出( BufferedSourceBufferedSink )创 建 HttpCodec 对象,供后续步骤使用。

2.2.1.2.发送和接收数据: CallServerInterceptor

@Override public Response intercept(Chain chain) throws IOExcept ion {
HttpCodec httpCodec = ((RealInterceptorChain) chain).httpStrea m();
StreamAllocation streamAllocation = ((RealInterceptorChain) ch ain).streamAllocation();
Request request = chain.request();
long sentRequestMillis = System.currentTimeMillis(); httpCodec.writeRequestHeaders(request);
if (HttpMethod.permitsRequestBody(request.method()) && request .body() != null) {
Sink requestBodyOut = httpCodec.createRequestBody(request, r equest.body().contentLength());
BufferedSink bufferedRequestBody = Okio.buffer(requestBodyOut);
request.body().writeTo(bufferedRequestBody);
bufferedRequestBody.close();
}

// 省略部分检查代码
return response;
}

我们抓住主干部分:

  1. 向服务器发送 request header;
  2. 如果有 request body,就向服务器发送;
  3. 读取 response header,先构造一个 Response 对象;
  4. 如果有 response body,就在 3 的基础上加上 body 构造一个新 的 Response 对象;

这里我们可以看到,核心工作都由 HttpCodec 对象完成,而 HttpCodec 实际上 利用的是 Okio,而 Okio 实际上还是用的 Socket ,所以没什么神秘的,只不过一 层套一层,层数有点多。

其实 Interceptor 的设计也是一种分层的思想,每个 Interceptor 就是一层。 为什么要套这么多层呢?分层的思想在 TCP/IP 协议中就体现得淋漓尽致,分层简 化了每一层的逻辑,每层只需要关注自己的责任(单一原则思想也在此体现),而 各层之间通过约定的接口/协议进行合作(面向接口编程思想),共同完成复杂的任 务

简单应该是我们的终极追求之一,尽管有时为了达成目标不得不复杂,但如果有另 一种更简单的方式,我想应该没有人不愿意替换。

2.2.2.发起异步网络请求

client.newCall(request).enqueue(new Callback() {
@Override
自我介绍一下,小编13年上海交大毕业,曾经在小公司待过,也去过华为、OPPO等大厂,18年进入阿里一直到现在。

深知大多数初中级Android工程师,想要提升技能,往往是自己摸索成长或者是报班学习,但对于培训机构动则近万的学费,着实压力不小。自己不成体系的自学效果低效又漫长,而且极易碰到天花板技术停滞不前!

因此收集整理了一份《2024年Android移动开发全套学习资料》,初衷也很简单,就是希望能够帮助到想自学提升又不知道该从何学起的朋友,同时减轻大家的负担。

img

img

img

img

既有适合小白学习的零基础资料,也有适合3年以上经验的小伙伴深入学习提升的进阶课程,基本涵盖了95%以上Android开发知识点,真正体系化!

由于文件比较大,这里只是将部分目录截图出来,每个节点里面都包含大厂面经、学习笔记、源码讲义、实战项目、讲解视频,并且会持续更新!

如果你觉得这些内容对你有帮助,可以扫码获取!!(备注:Android)

总结

可以看出,笔者的工作学习模式便是由以下 「六个要点」 组成:

❝ 多层次的工作/学习计划 + 番茄工作法 + 定额工作法 + 批处理 + 多任务并行 + 图层工作法❞

希望大家能将这些要点融入自己的工作学习当中,我相信一定会工作与学习地更富有成效。

下面是我学习用到的一些书籍学习导图,以及系统的学习资料。每一个知识点,都有对应的导图,学习的资料,视频,面试题目。

**如:我需要学习 **Flutter的知识。(大家可以参考我的学习方法)

  • Flutter 的思维导图(无论学习什么,有学习路线都会事半功倍)

  • Flutter进阶学习全套手册

  • Flutter进阶学习全套视频

大概就上面这几个步骤,这样学习不仅高效,而且能系统的学习新的知识。

《Android学习笔记总结+移动架构视频+大厂面试真题+项目实战源码》,点击传送门即可获取!

z-1712419383817)]

  • Flutter进阶学习全套视频

[外链图片转存中…(img-2TyYPxP9-1712419383817)]

大概就上面这几个步骤,这样学习不仅高效,而且能系统的学习新的知识。

《Android学习笔记总结+移动架构视频+大厂面试真题+项目实战源码》,点击传送门即可获取!
Logo

旨在为数千万中国开发者提供一个无缝且高效的云端环境,以支持学习、使用和贡献开源项目。

更多推荐