源码系列--OkHttp（CallServerInterceptor）
2021-03-14 14:28
标签：github eal 发送 end throw http inf 头信息 左右 Github下载源码地址https://github.com/square/okhttp 我们今天来看看拦截器里的CallServerInterceptor 来看CallServerInterceptor类的intercept方法 1）源码： RealInterceptorChain类分别返回Exchange和Request对象 2）源码 进到Exchange类 进到ExchangeCodec的实现类Http1ExchangeCodec（Http1.1版本）的writeRequestHeaders方法 进到RequestLine的get方法 这里是一些字符串的拼接和请求的判断 紧接着是Http1ExchangeCodec的writeRequest方法 可以看到是通过Okio的BufferedSink实现的 Exchange类的writeRequestHeaders方法的catch中的trackFailure会走失败流程，输出ErrorCode 3）源码 进到Exchange类的readResponseHeaders方法，然后再进到Http1ExchangeCodec类的readResponseHeaders方法 看名字都知道是读响应头信息，进到StatusLine的parse方法里 4）源码 最终进到Http1ExchangeCodec类的createRequestBody方法中 5）CallServerInterceptor类的intercept方法最后是生成response 源码： 总的来说，还是比较简单的，150行左右的代码。先写请求头，然后发送请求，最后得到响应 而且有两个类Http1ExchangeCodec和Http2ExchangeCodec，很好的适配了不同的http版本 欢迎关注我的微信公众号：安卓圈 源码系列--OkHttp（CallServerInterceptor） 标签：github eal 发送 end throw http inf 头信息 左右 原文地址：https://www.cnblogs.com/anni-qianqian/p/12810703.htmlExchange exchange = realChain.exchange();
Request request = realChain.request();
exchange.writeRequestHeaders(request)
public void writeRequestHeaders(Request request) throws IOException {
try {
eventListener.requestHeadersStart(call);
codec.writeRequestHeaders(request);
eventListener.requestHeadersEnd(call, request);
} catch (IOException e) {
eventListener.requestFailed(call, e);
trackFailure(e);
throw e;
}
}
@Override public void writeRequestHeaders(Request request) throws IOException {
String requestLine = RequestLine.get(
request, realConnection.route().proxy().type());
writeRequest(request.headers(), requestLine);
}
public static String get(Request request, Proxy.Type proxyType) {
StringBuilder result = new StringBuilder();
result.append(request.method());
result.append(‘ ‘);
if (includeAuthorityInRequestLine(request, proxyType)) {
result.append(request.url());
} else {
result.append(requestPath(request.url()));
}
result.append(" HTTP/1.1");
return result.toString();
}
public void writeRequest(Headers headers, String requestLine) throws IOException {
if (state != STATE_IDLE) throw new IllegalStateException("state: " + state);
sink.writeUtf8(requestLine).writeUtf8("\r\n");
for (int i = 0, size = headers.size(); i ) {
sink.writeUtf8(headers.name(i))
.writeUtf8(": ")
.writeUtf8(headers.value(i))
.writeUtf8("\r\n");
}
sink.writeUtf8("\r\n");
state = STATE_OPEN_REQUEST_BODY;
}
responseBuilder = exchange.readResponseHeaders(true);
BufferedSink bufferedRequestBody = Okio.buffer(
exchange.createRequestBody(request, true));
Response response = responseBuilder
.request(request)
.handshake(exchange.connection().handshake())
.sentRequestAtMillis(sentRequestMillis)
.receivedResponseAtMillis(System.currentTimeMillis())
.build();
int code = response.code();
if (code == 100) {
// server sent a 100-continue even though we did not request one.
// try again to read the actual response
response = exchange.readResponseHeaders(false)
.request(request)
.handshake(exchange.connection().handshake())
.sentRequestAtMillis(sentRequestMillis)
.receivedResponseAtMillis(System.currentTimeMillis())
.build();
code = response.code();
}
exchange.responseHeadersEnd(response);
if (forWebSocket && code == 101) {
// Connection is upgrading, but we need to ensure interceptors see a non-null response body.
response = response.newBuilder()
.body(Util.EMPTY_RESPONSE)
.build();
} else {
response = response.newBuilder()
.body(exchange.openResponseBody(response))
.build();
}
上一篇：02 css3
文章标题：源码系列--OkHttp（CallServerInterceptor）
文章链接：http://soscw.com/index.php/essay/64585.html