2. 程式人生 > >OKHttp原始碼分析-BridgeInterceptor

OKHttp原始碼分析-BridgeInterceptor

阿新 • • 發佈：2019-02-14

在上一篇部落格中我們介紹了一下RetryAndFollowUpInterceptor攔截器內容也是比較多的這次我們先介紹個簡單的攔截器BridgeInterceptor，這個攔截器的主要作用就是對請求引數做一下處理內容也是很簡單我們直接上原始碼。
BridgeInterceptor三步走策略

1. 取出請求頭判斷標頭檔案缺失內容如果沒有則補充上
2. 呼叫 chain.proceed方法吧請求交給下一個攔截器去處理
3. 取出響應體對返回資料進行簡單封裝返回給上一級攔截器

@Override public Response intercept(Chain chain) throws IOException {
    Request userRequest =
 
 chain.request();
    Request.Builder requestBuilder = userRequest.newBuilder();

    RequestBody body = userRequest.body();
    if (body != null) {
      MediaType contentType = body.contentType();
      if (contentType != null) {
        requestBuilder.header("Content-Type", contentType.toString());
      }

      long contentLength =
 
 body.contentLength();
      if (contentLength != -1) {
        requestBuilder.header("Content-Length", Long.toString(contentLength));
        requestBuilder.removeHeader("Transfer-Encoding");
      } else {
        requestBuilder.header("Transfer-Encoding", "chunked");
        requestBuilder.removeHeader("Content-Length"
 
);
      }
    }

    if (userRequest.header("Host") == null) {
      requestBuilder.header("Host", hostHeader(userRequest.url(), false));
    }
    // 這個頭資訊必須要，但是使用者不一定會自己設定
    if (userRequest.header("Connection") == null) {
      requestBuilder.header("Connection", "Keep-Alive");
    }

    // If we add an "Accept-Encoding: gzip" header field we're responsible for also decompressing
    // the transfer stream.
    boolean transparentGzip = false;
    if (userRequest.header("Accept-Encoding") == null && userRequest.header("Range") == null) {
      transparentGzip = true;
      requestBuilder.header("Accept-Encoding", "gzip");
    }

    List<Cookie> cookies = cookieJar.loadForRequest(userRequest.url());
    if (!cookies.isEmpty()) {
      requestBuilder.header("Cookie", cookieHeader(cookies));
    }

    if (userRequest.header("User-Agent") == null) {
      requestBuilder.header("User-Agent", Version.userAgent());
    }
    // 下一級給我們的 Response
    Response networkResponse = chain.proceed(requestBuilder.build());
    // 處理儲存 Cookie
    HttpHeaders.receiveHeaders(cookieJar, userRequest.url(), networkResponse.headers());

    Response.Builder responseBuilder = networkResponse.newBuilder()
        .request(userRequest);
    // 如果後臺返回的資料採用 gzip 壓縮了
    if (transparentGzip
        && "gzip".equalsIgnoreCase(networkResponse.header("Content-Encoding"))
        && HttpHeaders.hasBody(networkResponse)) {
      // GzipSource okio 的輸入流
      GzipSource responseBody = new GzipSource(networkResponse.body().source());
      Headers strippedHeaders = networkResponse.headers().newBuilder()
          .removeAll("Content-Encoding")
          .removeAll("Content-Length")
          .build();
      responseBuilder.headers(strippedHeaders);
      String contentType = networkResponse.header("Content-Type");
      responseBuilder.body(new RealResponseBody(contentType, -1L, Okio.buffer(responseBody)));
    }
    // 我們這個攔截器處理的 Response 返回回去
    return responseBuilder.build();
  }

這塊的邏輯比起上一個攔截器來說要簡化了不少啊，我們依然逐行分析

    Request userRequest = chain.request();
    Request.Builder requestBuilder = userRequest.newBuilder();
    RequestBody body = userRequest.body();

這段程式碼意思是從我們的攔截器裡面取出請求然後從請求中取出請求體RequestBody 然後對RequestBody 進行校驗。

RequestBody body = userRequest.body();
    if (body != null) {
      MediaType contentType = body.contentType();
      if (contentType != null) {
        requestBuilder.header("Content-Type", contentType.toString());
      }

      long contentLength = body.contentLength();
      if (contentLength != -1) {
        requestBuilder.header("Content-Length", Long.toString(contentLength));
        requestBuilder.removeHeader("Transfer-Encoding");
      } else {
        requestBuilder.header("Transfer-Encoding", "chunked");
        requestBuilder.removeHeader("Content-Length");
      }
    }

    if (userRequest.header("Host") == null) {
      requestBuilder.header("Host", hostHeader(userRequest.url(), false));
    }
    // 這個頭資訊必須要，但是使用者不一定會自己設定
    if (userRequest.header("Connection") == null) {
      requestBuilder.header("Connection", "Keep-Alive");
    }

    // If we add an "Accept-Encoding: gzip" header field we're responsible for also decompressing
    // the transfer stream.
    boolean transparentGzip = false;
    if (userRequest.header("Accept-Encoding") == null && userRequest.header("Range") == null) {
      transparentGzip = true;
      requestBuilder.header("Accept-Encoding", "gzip");
    }

    List<Cookie> cookies = cookieJar.loadForRequest(userRequest.url());
    if (!cookies.isEmpty()) {
      requestBuilder.header("Cookie", cookieHeader(cookies));
    }

    if (userRequest.header("User-Agent") == null) {
      requestBuilder.header("User-Agent", Version.userAgent());
    }

上面一大段都是校驗判斷我們的請求頭有沒有必須要有的資訊如果沒有則在requestBuilder中新增header，這麼做的目的是為了防止我們沒有設定某些請求頭而報錯。

    // 下一級給我們的 Response
    Response networkResponse = chain.proceed(requestBuilder.build());

接下來還是呼叫了 chain.proceed方法將任務交給下一級去處理等處理完了之後再繼續處理下面的內容

// 處理儲存 Cookie
    HttpHeaders.receiveHeaders(cookieJar, userRequest.url(), networkResponse.headers());

    Response.Builder responseBuilder = networkResponse.newBuilder()
        .request(userRequest);
    // 如果後臺返回的資料採用 gzip 壓縮了
    if (transparentGzip
        && "gzip".equalsIgnoreCase(networkResponse.header("Content-Encoding"))
        && HttpHeaders.hasBody(networkResponse)) {
      // GzipSource okio 的輸入流
      GzipSource responseBody = new GzipSource(networkResponse.body().source());
      Headers strippedHeaders = networkResponse.headers().newBuilder()
          .removeAll("Content-Encoding")
          .removeAll("Content-Length")
          .build();
      responseBuilder.headers(strippedHeaders);
      String contentType = networkResponse.header("Content-Type");
      responseBuilder.body(new RealResponseBody(contentType, -1L, Okio.buffer(responseBody)));
    }
    // 我們這個攔截器處理的 Response 返回回去
    return responseBuilder.build();

HttpHeaders.receiveHeaders這一段沒啥好解釋的就是將請求處理好的cookie儲存到本地，後面的處理時如果後臺返回的資料被採用GZIP壓縮了那麼使用OKIO將responseBody解壓轉換為流封裝到RealResponseBody中去，最後呼叫responseBuilder.build()將請求返回。

相關推薦

OKHttp原始碼分析-BridgeInterceptor

在上一篇部落格中我們介紹了一下RetryAndFollowUpInterceptor攔截器內容也是比較多的這次我們先介紹個簡單的攔截器BridgeInterceptor，這個攔截器的主要作用就是對請求引數做一下處理內容也是很簡單我們直接上原始碼。 Bridge

【Android】OkHttp原始碼分析

Android為我們提供了兩種HTTP互動的方式：HttpURLConnection 和 Apache HttpClient，雖然兩者都支援HTTPS，流的上傳和下載，配置超時，IPv6和連線池，已足夠滿足我們各種HTTP請求的需求。但更高效的使用HTTP 可以讓您的應用執行更快、更節省

android okhttp原始碼分析

okhttp是Square公司開發貢獻的，其功能強大，現在是安卓主流網路框架。 現在我們就看看這個框架牛逼之處，探究其原始碼。 compile 'com.squareup.okhttp3:okhttp:3.8.0' 我們分析的版本是3.8.0. public class

WebSocket學習——結合OkHttp原始碼分析

轉自：https://www.jianshu.com/p/ba0f45aa7457 前言 最近公司有專案需要用WebSocket完成及時通訊的需求，這裡來學習一下。 WebScoket簡介 在以前的web應用中，雙向通訊機制往往藉助輪詢或是長輪詢來實現，但是這兩種方式都會或多或少的造

okhttp原始碼分析（一）——基本流程（超詳細）

1.okhttp原始碼分析（一）——基本流程（超詳細） 2.okhttp原始碼分析（二）——RetryAndFollowUpInterceptor過濾器 3.okhttp原始碼分析（三）——CacheInterceptor過濾器 4.okhttp原始碼分析（四）——Conn

OkHttp 原始碼分析(五)——ConnectInterceptor

0、前言 在前面的文章中，我們分析了http的快取策略和Okhttp快取攔截器的快取機制，我們知道，在沒有快取命中的情況下，需要對網路資源進行請求，這時候攔截鏈就來到ConnectInterceptor。 ConnectInterceptor的主要作用是和伺服器建立連線，

OKHttp原始碼分析3

1 概述 上篇文章，我們詳細分析了OKHttp中Request的建立和傳送過程。其中sendRequest(), readResponse(), followUpRequest()三個關鍵方法在底層HttpEngine中實現。革命尚未成功，我們接下來在這篇文章

OKHttp原始碼分析1 - 框架

1 OKHttp介紹 網路庫一直是Android APP開發中至關重要的庫，關係到載入速度，流量消耗等諸多問題。Android系統提供了HttpClient和HttpURLConnection兩個網路庫。相比HttpClient，OKHttp效能更好，且API設計更加易用。相比Htt

okhttp原始碼分析（三）

接著上一章分析request.body().writeTo(); public @Nullable RequestBody body() { return body; }public abstract class RequestBody { ........

OKHttp原始碼分析(二)之RequestBody

一，概述 在上篇blog中以get請求為例分析了OKHttp框架的表層原始碼，具體參見：OKHttp原始碼分析（一） 在post請求中用到的API很大部分與get請求中用到的API相同，最大的不同就是Request.Builder類的post方法，這個方法的

Okhttp原始碼分析--基本使用流程分析

Okhttp原始碼分析--基本使用流程分析 一、 使用 同步請求 OkHttpClient okHttpClient=new OkHttpClient(); Request request=new Request.Builder() .get() .url("w

OkHttp原始碼流程分析

OkHttpClient okHttpClient = new OkHttpClient.Builder().build(); Request request = new Request.Builder().build(); Call newCall = okHttpClient.new

OkHttp深入分析——原始碼分析部分

一、前言 在《OkHttp深入分析——基礎認知部分》對 OkHttp 原始碼的工程已經有一個大致的瞭解了，這篇文章裡就來分析下核心模組 OkHttp。首先看看程式碼結構的框架圖。 框架圖中可以看到涉及到的東西非常多，也看到了很多協議相關的東西。前面的文章中有分析過 Volley——《Vo

OkHttp 3.7原始碼分析（三）——任務佇列

前面的部落格已經提到過，OkHttp的一個高效之處在於在內部維護了一個執行緒池，方便高效地執行非同步請求。本篇部落格將詳細介紹OkHttp的任務佇列機制。 1. 執行緒池的優點 OkHttp的任務佇列在內部維護了一個執行緒池用於執行具體的網路請求。而執行緒池

OkHttp 3.7原始碼分析（四）——快取策略

合理地利用本地快取可以有效地減少網路開銷，減少響應延遲。HTTP報頭也定義了很多與快取有關的域來控制快取。今天就來講講OkHttp中關於快取部分的實現細節。 1. HTTP快取策略 首先來了解下HTTP協議中快取部分的相關域。 1.1 Expires

原始碼分析：Android Okhttp原始碼淺析（一）

Okhttp的呼叫 分析原始碼，我們都需要通過呼叫來檢視原始碼的每一步都做了什麼事情。 看下非同步呼叫 OkHttpClient client = new OkHttpClient(); Request request = n

Okhttp使用和原始碼分析二(OkHttp3.x用法)

上一篇介紹了OkHttp2.x的用法，這一篇文章我們來對照OkHttp2.x版本來看看，OkHttp3使用起來有那些變化？ 1.使用前準備,Android Studio 配置gradle： compile 'com.squareup.okhttp3:okht

OkHttp 3.7原始碼分析（一）——整體架構

OkHttp是一個處理網路請求的開源專案,是Android端最火熱的輕量級框架,由移動支付Square公司貢獻用於替代HttpUrlConnection和Apache HttpClient。隨著OkHttp的不斷成熟，越來越多的Android開發者使用OkHtt

Okhttp檔案上傳原始碼分析

     一直搞開發，也使用各種框架，但是基本上也從來沒研究過這些框架的底層是如何實現的。像我們客戶端，一般重要的事情就是：網路請求、圖片處理、操作資料庫、展現View介面，剛好今天哥們有問我一個okhttp網路請求的問題，幫他看完了之後，就詳細的走了一遍okhttp框架實

mybatis原理，配置介紹及原始碼分析

前言 mybatis核心元件有哪些？它是工作原理是什麼？ mybatis配置檔案各個引數是什麼含義？ mybatis只添加了介面類，沒有實現類，為什麼可以直接查詢呢？ mybatis的mapper對映檔案各個引數又是什麼含義？ mybatis-spring提供哪些機制簡化了原生mybatis？ m