OkHttpClient 解剖
源码地址:https://github.com/square/okhttp
上一篇对整体的流程,有了窥探,这次就对另外一个重要的类进行学习分析——OkHttpCilent。
OkHttpClient结构上比较简单,使用了Bulider模式来进行构建。
这个类大体分了三部分:
- 提供内部使用的静态块;
- 提供给外部调用读取信息的方法,以及实现了某些接口,如之前的说到的newCall;
- Builder,构建相应的后续需要的变量等。(重点)
静态块
通过代码注析的方式,对每个方法进行了解学习。参考中文注析。
提供的方法都是给内部使用。
static { Internal.instance = new Internal() { //提供静态方法对头部信息进行处理 @Override public void addLenient(Headers.Builder builder, String line) { builder.addLenient(line); } @Override public void addLenient(Headers.Builder builder, String name, String value) { builder.addLenient(name, value); } //写入缓存(响应数据缓存) @Override public void setCache(OkHttpClient.Builder builder, InternalCache internalCache) { builder.setInternalCache(internalCache); } //把连接变成空闲状态 @Override public boolean connectionBecameIdle( ConnectionPool pool, RealConnection connection) { return pool.connectionBecameIdle(connection); } //从缓存中获取有效的连接, 从内存的ConnectiongPool中的Deque读取 @Override public RealConnection get(ConnectionPool pool, Address address, StreamAllocation streamAllocation, Route route) { return pool.get(address, streamAllocation, route); } //对地址进行校验 @Override public boolean equalsNonHost(Address a, Address b) { return a.equalsNonHost(b); } //多路复用?(待研究 StreamAllocation 类) @Override public Socket deduplicate( ConnectionPool pool, Address address, StreamAllocation streamAllocation) { return pool.deduplicate(address, streamAllocation); } //把连接添加到连接池当中,缓存起来 @Override public void put(ConnectionPool pool, RealConnection connection) { pool.put(connection); } //获取连接池里面的连接,可以有效剔除黑名单的线路,用于优化连接效果。 @Override public RouteDatabase routeDatabase(ConnectionPool connectionPool) { return connectionPool.routeDatabase; } //获取response 的 code @Override public int code(Response.Builder responseBuilder) { return responseBuilder.code; } //sslSocket 的连接协议,规范 @Override public void apply(ConnectionSpec tlsConfiguration, SSLSocket sslSocket, boolean isFallback) { tlsConfiguration.apply(sslSocket, isFallback); } //检查 Url 正确性,可用性 @Override public HttpUrl getHttpUrlChecked(String url) throws MalformedURLException, UnknownHostException { return HttpUrl.getChecked(url); } //获取到的 StreamAllocation(待研究) ,主要处理 Connections,Streams, Calls之间的关系 @Override public StreamAllocation streamAllocation(Call call) { return ((RealCall) call).streamAllocation(); } //新建web 相关的 Call @Override public Call newWebSocketCall(OkHttpClient client, Request originalRequest) { return new RealCall(client, originalRequest, true); }};}
提供给外部调用的方法
略(提供的方法,大多都是获取或者设置后面Bulider中变量。此处不做过多的解析)
Builder
在Builder里面,你会发现很多的变量,而这些变量都是可以提供给你设置的,提供给后面逻辑调用的。
下面是变量:
Dispatcher dispatcher;Proxy proxy;List<Protocol> protocols;List<ConnectionSpec> connectionSpecs;final List<Interceptor> interceptors = new ArrayList<>();final List<Interceptor> networkInterceptors = new ArrayList<>();ProxySelector proxySelector;CookieJar cookieJar;Cache cache;InternalCache internalCache;SocketFactory socketFactory;SSLSocketFactory sslSocketFactory;CertificateChainCleaner certificateChainCleaner;HostnameVerifier hostnameVerifier;CertificatePinner certificatePinner;Authenticator proxyAuthenticator;Authenticator authenticator;ConnectionPool connectionPool;Dns dns;boolean followSslRedirects;boolean followRedirects;boolean retryOnConnectionFailure;int connectTimeout;int readTimeout;int writeTimeout;int pingInterval;
设置的默认数据:
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; pingInterval = 0;}
-
Dispatcher, 分发请求,内部是有一个ThreadPoolExecutor
-
Proxy, 代理连接,分三种类型直接(DIRECT)、Http(http)、SOCKS。
-
ProxySelector,线路选择器,对应Okhttp的一大特点,自行线路选择,找到合适的连接
-
Cache, 真正的缓存实现
-
SSLSocketFactory, Https的支持
-
ConnectionPool, 连接池
-
Dns,dns解析(Java实现)
-
其他,如超时时间等
总结:
OkhttpClient 类以Bulider的模式,构建了相关的数据变量,提供后面使用。内部结构比较简单,主要还是初始化每个变量提供给后面的使用。在后面的学习分析中,你会发现这个okHttpClient会无处不在,所以这里提前对其进行学习分析。
系列:
OKhttp源码学习(一)—— 基本请求流程
OKhttp源码学习(三)—— Request, RealCall
OKhttp源码学习(四)——RetryAndFollowUpInterceptor拦截器分析
OKhttp源码学习(五)—— BridgeInterceptor
OKhttp源码学习(六)—— CacheInterceptor拦截器
OKhttp源码学习(七)—— ConnectInterceptor拦截器
OKhttp源码学习(八)——CallServerInterceptor拦截器
OKhttp源码学习(九)—— 任务管理(Dispatcher)
原著是一个有趣的人,若有侵权,请通知删除
还没有人抢沙发呢~