OkHttp 3.14.10源码分析(1)- 总体框架介绍

2024-01-22 16:08

本文主要是介绍OkHttp 3.14.10源码分析(1)- 总体框架介绍,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

OkHttp源码版本:

OkHttp-3.14.10

OkHttp总体框架介绍

对于OkHttp整体框架的介绍,网上的文章有很多,同时也配有一些图解(当然很多都是一样的就是了),总体上我和大家的理解也是相近的。但是呢,我觉得还不够具体也不够完善,因为我想知道,如果我自己要实现一个HttpClient到底要做到什么程度?所以我希望能更加详细地去理解OKHttp的设计和实现。
下面这幅是我自己描绘的OkHttp框架层次图(图比较大可能需要鼠标左键图片才能看清楚):
 

下面先来简单介绍一下OkHttp的各个层次,后面会有更加详细的文章专门去解读它们。

OkHttpClient
OkHttpClient在一个应用往往只会创建一个单例。
对外主要是两个功能:一个是可配置,比如你可以设置超时时间,配置自定义的CookieJar实现,配置多个自定义的Interceptor实现,添加事件监听等等;另外一个是提供newCall API,我们用的最多也是这个API。
对内它的配置会被全局范围内使用,同时也负责创建和管理一些全局单例对象,比如Dispatcher、ConnectionPool等。
所以OkHttpClient有点类似一个全局的应用上下文。

Dispatcher
Dispatcher主要管理异步请求任务策略,负责分配异步线程资源,控制异步连接数,只覆盖线程资源层面的逻辑,往下的执行过程对其来说是透明的。
而对于同步任务,Dispatcher只是简单记录当前运行的任务实体(RealCall),并且是由RealCall主动注册和注销。
Dispatcher是final类,不提供扩展接口,但是Dispatcher存在两个构造方法:Dispatcher()和Dispatcher(ExecutorService)。OkHttpClient默认会使用无参构造函数创建一个全局的单例对象,该对象使用内置的线程池来执行异步任务,如果用户想使用自定义线程池,那么可以通过使用有参构造函数创建一个新的Dispatcher对象,并且通过OkHttpClient.Builder设置进去。

Call
OkHttp一次用户请求任务的接口定义,有两个实现:RealCall和AsyncCall,前者是同步任务,后者是异步任务。
这里我之所以把Call称作为“一次用户请求”,是因为一次OkHttp请求和响应,中间可能夹着多个请求和响应,比如代理服务的认证、失败重试、重定向等等,但是这些对于OkHttp的使用者来说都是透明的,他们很多时候只需要感知最初的请求和最后的结果即可,而Call是包含中间这些所有的过程的,因此我把Call称为“一次用户请求”。

Interceptor调用链
Interceptor接口在OKHttp包下有5个内置实现,也就是上图中最大的那一个框。它们通过责任链的方式调用,实现了Http协议的整个流程,当然这个流程指的是应用层协议的流程,不包括底下传输层的实现。
Interceptor是可扩展可配置的,用户可以自定义实现Interceptor接口,并且通过OkHttpClient添加到Http流程的实现中去。
OKHttpClient有两个可配置的Interceptor集合(它们默认都是空的):interceptors和networkInterceptors。interceptors会被添加到调用链的最前面;而networkInterceptors则会被添加到Socket连接之后,Socket读写数据之前。但是如果是WebSocket请求,networkInterceptors集合则不会被添加到调用链中去。
 

 Response getResponseWithInterceptorChain() throws IOException {// Build a full stack of interceptors.List<Interceptor> interceptors = new ArrayList<>();//用户自定义的拦截器会在请求最开始被调用,也就是递归的最上层interceptors.addAll(client.interceptors());//失败重试,代理认证、重定向等interceptors.add(new RetryAndFollowUpInterceptor(client));//重写请求和响应头,Cookie存储interceptors.add(new BridgeInterceptor(client.cookieJar()));//Http缓存流程实现interceptors.add(new CacheInterceptor(client.internalCache()));//发起Socket连接interceptors.add(new ConnectInterceptor(client));//Socket连接和数据读写之间,但是WebSocket请求不会添加这个拦截器集合//可能WebSocket,数据通信走的是传输层,而Interceptor是应用层协议的接口?if (!forWebSocket) {interceptors.addAll(client.networkInterceptors());}//数据的读写,真正的网络I/Ointerceptors.add(new CallServerInterceptor(forWebSocket));...}

Transmitter
Transmitter翻译过来有“传输者、传播者”的意思,所以在这里我还是用上下文来称呼它,作用域是整个Call任务。
Transmitter会在Interceptor调用链中相互传递,Interceptor会通过Transmitter对象的属性或者方法对底下的传输层进行操作,Transmitter对调用者屏蔽了传输层的实现细节,让Interceptor调用链专注于应用层协议的实现。
Transmitter管理着Call任务的很多状态(比如请求开始、请求结束、失败、取消等等),调用者随时可以获取Call的状态从而实现相应的逻辑处理,也可以根据处理的结果更新其状态。
Transmitter还持有用户配置,实现了超时回调机制等等。
Transmitter往下的代码耦合性挺强的,层次之间其实没有上面那图那么清晰,它直接会存在一些交叉,彼此之间相互调用,个人觉得这部分代码可读性是挺差的 - -!。同时多数类都是final类,并不向上提供接口,也就是这部分代码是不可扩展的,只是留有一些可配置的参数属性(比如:连接池最大空闲连接数),我不知道这是OkHttp历史版本迭代的原因,还是作者有意这样设计,如果有小伙伴对这方面有了解的话,希望可以留言跟大家分享一下。

Exchange层
这个名字是我直接根据它几个主要实现类的名称前缀来取的,可能不能很好表明这一层的具体功能。总的来说这一层主要负责连接应用层和传输层,例如:Http协议作为应用层协议,它的主要流程由上面的Interceptor调用链来实现,但是Interceptor不会直接和传输层的实现类打交道,而是通过Exchange提供的API去实现数据的读写。
Exchange层主要有三个类:Exchange、ExchangeFinder和ExchangeCodec,前两个都是Transmitter的属性,第三个有ExchangeFinder创建。

  • Exchange:Exchange代表着一次Request和Response,里面封装了应用层的读写方法,Interceptor调用链就是通过Transmitter获取的Exchange对象来进行读写操作。一次Request和Response,也即是上面的Interceptor调用链从RetryAndFollowUpInterceptor到CallServerInterceptor绕了一圈,但是一个Call任务并不代表仅仅只会绕一圈,比如你访问百度之前需要通过你公司的代理服务器,那么就可能在发送请求到百度之前,先发送一次Http请求到代理服务认证,认证通过了才会继续发送请求到百度,这样就绕了两圈了,也就是发送了两次Http请求,同理还有重定向也是一样。简单来说一次用户请求是一个Call,一个Call可能会发生多次Exchange,但是对于用户来说Exchange是透明的,只需要感知Call即可。
  • ExchangeCodec:OkHttp的编解码器,这是一个接口,具体实现有Http1ExchangeCodec和Http2ExchangeCodec。下面这图展示的是Exchange、ExchangeCodec、Okio和网络I/O,在读写操作上的层次关系。

  • ExchangeFinder:ExchangeFinder类似一个工厂类,对外只提供一个方法,就是返回一个ExchangeCodec对象,下面这段代码能比较清楚展示Exchange、ExchangeCodec和ExchangeFinder三者之间的关系。
 /** Returns a new exchange to carry a new request and response. */Exchange newExchange(Interceptor.Chain chain, boolean doExtensiveHealthChecks) {...ExchangeCodec codec = exchangeFinder.find(client, chain, doExtensiveHealthChecks);Exchange result = new Exchange(this, call, eventListener, exchangeFinder, codec);...}

同时ExchangeFinder还负责获取和创建RealConnection,ExchangeFinder和RealConnectionPool也有比较强的耦合关系,这个后面的文章会详细介绍。

链接

  • Connection:Connection封装了Socket的连接操作,包括TCP连接,TLS连接,在代理隧道上构建Https连接等。一个连接创建成功后可以在存活时间内被反复使用,但是不能同时处理多个Call任务。获取Connection后,就可以通过Connection#socket()方法获取Socket对象进行读写操作。Connection是一个接口,只有一个实现类RealConnection,但是Transmitter声明Connection属性的时候,并没有使用Connection而是直接使用RealConnection,所以实际上我们也无法对其进行扩展。
  • RealConnectionPool:RealConnectionPool是一个finnal类,管理RealConnection的链接池。
  • Route:路由,例如一个Url可能通过DNS能解析出2个Host,而这2个Host是需要通过代理才能访问的,而这个代理又有两台机器组成负载均衡,那这样就会产生4条线路,每条线路就会被封装成一个Route。
  • RouteSelector:Route选择器,会对Route的选择上做一些优化,比如记录最近连接失败的Route,把它放到重试队列最底端,优先使用上次连接成功的Route等。

java.net
这一部分就是Java网络编程的内容,主要是Socket编程。主要类的类包括:Socket、SocketFactory、SSLSocketFactory、Proxy、ProxySelector、CertificateChainCleaner等,后面会有内容对这一部分进行分析。


总结

到这里,我就大体把OkHttp的层次设计概括了一遍,这些内容都是我自己读源码的理解,因此总会有不对的地方。其实读源码是必须自己打开编辑器去读的,你可以参考网上的文章,但是你如果不亲自去研读的话,是挺难理解的,也无法确定它的正确性。所以我也希望小伙伴能看了我的文章之后能够亲自去研读相关的源码,然后对比我的理解,大家相互交流,后面我也会继续带来这个系列的其他文章。

 

这篇关于OkHttp 3.14.10源码分析(1)- 总体框架介绍的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/633489

相关文章

性能测试介绍

性能测试是一种测试方法,旨在评估系统、应用程序或组件在现实场景中的性能表现和可靠性。它通常用于衡量系统在不同负载条件下的响应时间、吞吐量、资源利用率、稳定性和可扩展性等关键指标。 为什么要进行性能测试 通过性能测试,可以确定系统是否能够满足预期的性能要求,找出性能瓶颈和潜在的问题,并进行优化和调整。 发现性能瓶颈:性能测试可以帮助发现系统的性能瓶颈,即系统在高负载或高并发情况下可能出现的问题

水位雨量在线监测系统概述及应用介绍

在当今社会,随着科技的飞速发展,各种智能监测系统已成为保障公共安全、促进资源管理和环境保护的重要工具。其中,水位雨量在线监测系统作为自然灾害预警、水资源管理及水利工程运行的关键技术,其重要性不言而喻。 一、水位雨量在线监测系统的基本原理 水位雨量在线监测系统主要由数据采集单元、数据传输网络、数据处理中心及用户终端四大部分构成,形成了一个完整的闭环系统。 数据采集单元:这是系统的“眼睛”,

Hadoop数据压缩使用介绍

一、压缩原则 (1)运算密集型的Job,少用压缩 (2)IO密集型的Job,多用压缩 二、压缩算法比较 三、压缩位置选择 四、压缩参数配置 1)为了支持多种压缩/解压缩算法,Hadoop引入了编码/解码器 2)要在Hadoop中启用压缩,可以配置如下参数

性能分析之MySQL索引实战案例

文章目录 一、前言二、准备三、MySQL索引优化四、MySQL 索引知识回顾五、总结 一、前言 在上一讲性能工具之 JProfiler 简单登录案例分析实战中已经发现SQL没有建立索引问题,本文将一起从代码层去分析为什么没有建立索引? 开源ERP项目地址:https://gitee.com/jishenghua/JSH_ERP 二、准备 打开IDEA找到登录请求资源路径位置

JAVA智听未来一站式有声阅读平台听书系统小程序源码

智听未来,一站式有声阅读平台听书系统 🌟&nbsp;开篇:遇见未来,从“智听”开始 在这个快节奏的时代,你是否渴望在忙碌的间隙,找到一片属于自己的宁静角落?是否梦想着能随时随地,沉浸在知识的海洋,或是故事的奇幻世界里?今天,就让我带你一起探索“智听未来”——这一站式有声阅读平台听书系统,它正悄悄改变着我们的阅读方式,让未来触手可及! 📚&nbsp;第一站:海量资源,应有尽有 走进“智听

图神经网络模型介绍(1)

我们将图神经网络分为基于谱域的模型和基于空域的模型,并按照发展顺序详解每个类别中的重要模型。 1.1基于谱域的图神经网络         谱域上的图卷积在图学习迈向深度学习的发展历程中起到了关键的作用。本节主要介绍三个具有代表性的谱域图神经网络:谱图卷积网络、切比雪夫网络和图卷积网络。 (1)谱图卷积网络 卷积定理:函数卷积的傅里叶变换是函数傅里叶变换的乘积,即F{f*g}

Java ArrayList扩容机制 (源码解读)

结论:初始长度为10,若所需长度小于1.5倍原长度,则按照1.5倍扩容。若不够用则按照所需长度扩容。 一. 明确类内部重要变量含义         1:数组默认长度         2:这是一个共享的空数组实例,用于明确创建长度为0时的ArrayList ,比如通过 new ArrayList<>(0),ArrayList 内部的数组 elementData 会指向这个 EMPTY_EL

如何在Visual Studio中调试.NET源码

今天偶然在看别人代码时,发现在他的代码里使用了Any判断List<T>是否为空。 我一般的做法是先判断是否为null,再判断Count。 看了一下Count的源码如下: 1 [__DynamicallyInvokable]2 public int Count3 {4 [__DynamicallyInvokable]5 get

poj 2976 分数规划二分贪心(部分对总体的贡献度) poj 3111

poj 2976: 题意: 在n场考试中,每场考试共有b题,答对的题目有a题。 允许去掉k场考试,求能达到的最高正确率是多少。 解析: 假设已知准确率为x,则每场考试对于准确率的贡献值为: a - b * x,将贡献值大的排序排在前面舍弃掉后k个。 然后二分x就行了。 代码: #include <iostream>#include <cstdio>#incl

SWAP作物生长模型安装教程、数据制备、敏感性分析、气候变化影响、R模型敏感性分析与贝叶斯优化、Fortran源代码分析、气候数据降尺度与变化影响分析

查看原文>>>全流程SWAP农业模型数据制备、敏感性分析及气候变化影响实践技术应用 SWAP模型是由荷兰瓦赫宁根大学开发的先进农作物模型,它综合考虑了土壤-水分-大气以及植被间的相互作用;是一种描述作物生长过程的一种机理性作物生长模型。它不但运用Richard方程,使其能够精确的模拟土壤中水分的运动,而且耦合了WOFOST作物模型使作物的生长描述更为科学。 本文让更多的科研人员和农业工作者