终于到了OKHttp最终发起请求的地方,在上个拦截器中找到了一个连接,客户端与服务端已经建立起了连接,连接之后我们自然是要从服务器获取到我们想要的数据了,这时候就是客户端与服务端进行数据交换操作了;首先呢,在这个拦截器中拿到上一个连接拦截器中获取到的 HttpCodec 和 RealConnection,然后将客户端的请求头信息写入到服务端:
// 写入请求头信息
httpCodec.writeRequestHeaders(request);
realChain.eventListener().requestHeadersEnd(realChain.call(), request);
紧接着会判断一下是否有请求体,有的话同样也会将请求体也写入服务器:
if (HttpMethod.permitsRequestBody(request.method()) && request.body() != null) {
if ("100-continue".equalsIgnoreCase(request.header("Expect"))) {
httpCodec.flushRequest();
realChain.eventListener().responseHeadersStart(realChain.call());
// 读取服务器头部信息
responseBuilder = httpCodec.readResponseHeaders(true);
}
}
这个地方有一个特殊的判断,“100-continue” 协议的判断,这个是什么东西呢?这个是客户端来询问服务端是否接受较大的数据上传,比如说大图,文件之类的,那么为什么要这么做呢?举个很简单的例子,如果客户端想上传一张很大的图片,这时候如果他先问服务端支不支持,那如果不支持的话,那么客户端就不会传了,也没有这个动作,但是如果没有事先知道服务端不支持,那么客户端就直接传过来了,但是服务端不会处理,因为不支持,处理不了,这个时候就浪费了上传的资源,所以这一步就避免了浪费资源。然后就是写入请求体的操作了:
if (responseBuilder == null) {
// Write the request body if the "Expect: 100-continue" expectation was met.
// 写入请求体
realChain.eventListener().requestBodyStart(realChain.call());
long contentLength = request.body().contentLength();
CountingSink requestBodyOut =
new CountingSink(httpCodec.createRequestBody(request, contentLength));
BufferedSink bufferedRequestBody = Okio.buffer(requestBodyOut);
request.body().writeTo(bufferedRequestBody);
bufferedRequestBody.close();
realChain.eventListener().requestBodyEnd(realChain.call(), requestBodyOut.successfulCount);
}
然后一次请求就结束了,后面就是读取响应头的信息以及服务器返回的数据:
// 结束请求
httpCodec.finishRequest();
if (responseBuilder == null) {
// 读取响应头
realChain.eventListener().responseHeadersStart(realChain.call());
responseBuilder = httpCodec.readResponseHeaders(false);
}
// 构建Response对象
Response response = responseBuilder
.request(request)
.handshake(streamAllocation.connection().handshake())
.sentRequestAtMillis(sentRequestMillis)
.receivedResponseAtMillis(System.currentTimeMillis())
.build();
这里所有的数据交换操作都在 HttpCodec 中的 Source 和 Sink 中进行,然后就会构造一个 Response 进行返回,具体是怎么读取数据流的这个在Okio框架里面实现,这里不进行展开,后面会专门讲。