} @Override public void onResponse(Call call, Response response) throws IOException { Log.d(“OkHttp”, “Call succeeded:” + response.message()); } });
2. 发起请求
OkHttpClient.newCall
实际是创建一个RealCall
实例:
@Override public Call newCall(Request request) { return new RealCall(this, request, false /* for web socket */); }
RealCall.enqueue
实际就是讲一个RealCall
放入到任务队列中,等待合适的机会执行:
@Override public void enqueue(Callback responseCallback) { synchronized (this) { if (executed) throw new IllegalStateException(“Already Executed”); executed = true; } captureCallStackTrace(); client.dispatcher().enqueue(new AsyncCall(responseCallback)); }
从代码中可以看到最终RealCall
被转化成一个AsyncCall
并被放入到任务队列中,任务队列中的分发逻辑这里先不说,相关实现会放在OkHttp源码分析——任务队列疑问进行介绍。这里只需要知道AsyncCall的excute方法最终将会被执行:
[RealCall.java] @Override protected void execute() { boolean signalledCallback = false; try { Response response = getResponseWithInterceptorChain(); if (retryAndFollowUpInterceptor.isCanceled()) { signalledCallback = true; responseCallback.onFailure(RealCall.this, new IOException(“Canceled”)); } else { signalledCallback = true; responseCallback.onResponse(RealCall.this, response); } } catch (IOException e) { if (signalledCallback) { // Do not signal the callback twice! Platform.get().log(INFO, "Callback failure for " + toLoggableString(), e); } else { responseCallback.onFailure(RealCall.this, e); } } finally { client.dispatcher().finished(this); } } }
execute方法的逻辑并不复杂,简单的说就是:
调用getResponseWithInterceptorChain获取服务器返回
通知任务分发器(client.dispatcher)该任务已结束
getResponseWithInterceptorChain构建了一个拦截器链,通过依次执行该拦截器链中的每一个拦截器最终得到服务器返回。
3. 构建拦截器链
首先来看下getResponseWithInterceptorChain的实现:
源码路径:okhttp3/RealCall.java
// 开始执行整个请求 Response getResponseWithInterceptorChain() throws IOException { // Build a full stack of interceptors. // 拦截器栈 List interceptors = new ArrayList<>(); // 前文说过的 普通拦截器 interceptors.addAll(client.interceptors()); // 重试拦截器,网络错误、请求失败等 interceptors.add(retryAndFollowUpInterceptor); // 桥接拦截器,主要是重构请求头即header interceptors.add(new BridgeInterceptor(client.cookieJar())); // 缓存拦截器 interceptors.add(newCacheInterceptor(client.internalCache())); // 连接拦截器,连接服务器,https包装 interceptors.add(new ConnectInterceptor(client)); // 网络拦截器,websockt不支持,同样是自定义 if (!forWebSocket) { interceptors.addAll(client.networkInterceptors()); } // 服务拦截器,主要是发送(write、input)、读取(read、output)数据