Picasso源碼解析

来源:https://www.cnblogs.com/huangjialin/archive/2018/09/11/9626526.html
-Advertisement-
Play Games

本來這一篇文章，早就應該寫了，但是最近一直在研究項目的安全性，就一直耽擱了。研究了一段時間的安全性，收穫頗豐，下一篇文章，將總結一下最近的收穫。好了，先把Picasso捋一遍。老規矩，先上流程圖。這張圖，從網上找來的。 Picasso的簡單使用 build.gradle依賴 載入圖片 就一句代碼，就 ...


本來這一篇文章，早就應該寫了，但是最近一直在研究項目的安全性，就一直耽擱了。研究了一段時間的安全性，收穫頗豐，下一篇文章，將總結一下最近的收穫。好了，先把Picasso捋一遍。
老規矩，先上流程圖。這張圖，從網上找來的。

 

Picasso的簡單使用

build.gradle依賴

1 implementation 'com.squareup.picasso:picasso:2.71828'

載入圖片

1 Picasso.get().load(url).into(imageView);

就一句代碼，就實現了整個圖片的載入。簡單，明瞭。當然以前的版本是這樣使用的 Picasso.with(this).load(url).into(imageView);

Picasso的源碼解析

get()

我們先看看get()方法做了哪些操作

 1 public static Picasso get() {
 2 if (singleton == null) {
 3 synchronized (Picasso.class) {
 4 if (singleton == null) {
 5 if (PicassoProvider.context == null) {
 6 throw new IllegalStateException("context == null");
 7 }
 8 singleton = new Builder(PicassoProvider.context).build();
 9 }
10 }
11 }
12 return singleton;
13 }

直接就通過一個雙重判斷形式的單例來獲取到這個Picasso實例對象，我們看看singleton = new Builder(PicassoProvider.context).build();中的Builder做了什麼。

1 /** Start building a new {@link Picasso} instance. */
2 public Builder(@NonNull Context context) {
3 if (context == null) {
4 throw new IllegalArgumentException("Context must not be null.");
5 }
6 this.context = context.getApplicationContext();
7 }

Building中所的操作不多，判斷一下這個上下文環境，並且對上下文環境賦值為context.getApplicationContext();也就是說，Picasso的生命周期是和整個項目的生命周期是一致的，

當項目退出後，Picasso才會銷毀。

build()

接著我們看看build()方法中做了哪些操作

 1 /** Create the {@link Picasso} instance. */
 2 public Picasso build() {
 3 Context context = this.context;
 4 
 5 if (downloader == null) {
 6 downloader = new OkHttp3Downloader(context);
 7 }
 8 if (cache == null) {
 9 cache = new LruCache(context);
10 }
11 if (service == null) {
12 service = new PicassoExecutorService();
13 }
14 if (transformer == null) {
15 transformer = RequestTransformer.IDENTITY;
16 }
17 
18 Stats stats = new Stats(cache);
19 
20 Dispatcher dispatcher = new Dispatcher(context, service, HANDLER, downloader, cache, stats);
21 
22 return new Picasso(context, dispatcher, cache, listener, transformer, requestHandlers, stats,
23 defaultBitmapConfig, indicatorsEnabled, loggingEnabled);
24 }
25 }

build()方法中，主要是對這個下載器downloader，緩存cache，線程池PicassoExecutorService，事務分發器Dispatcher這幾個對象的實例化。這幾個對象，等會我們都會有介紹。

我們先看看Dispatcher這個事務分發器看看，先看看構造方法

 1 Dispatcher(Context context, ExecutorService service, Handler mainThreadHandler,
 2 Downloader downloader, Cache cache, Stats stats) {
 3 this.dispatcherThread = new DispatcherThread();
 4 this.dispatcherThread.start();
 5 Utils.flushStackLocalLeaks(dispatcherThread.getLooper());
 6 this.context = context;
 7 this.service = service;
 8 this.hunterMap = new LinkedHashMap<>();
 9 this.failedActions = new WeakHashMap<>();
10 this.pausedActions = new WeakHashMap<>();
11 this.pausedTags = new LinkedHashSet<>();
12 this.handler = new DispatcherHandler(dispatcherThread.getLooper(), this);
13 this.downloader = downloader;
14 this.mainThreadHandler = mainThreadHandler;
15 this.cache = cache;
16 this.stats = stats;
17 this.batch = new ArrayList<>(4);
18 this.airplaneMode = Utils.isAirplaneModeOn(this.context);
19 this.scansNetworkChanges = hasPermission(context, Manifest.permission.ACCESS_NETWORK_STATE);
20 this.receiver = new NetworkBroadcastReceiver(this);
21 receiver.register();
22 }

在構造方法中，除了將剛剛傳入的下載器downloader，緩存cache，線程池PicassoExecutorService以外，還有幾個比較重要的的一個是DispatcherHandler，NetworkBroadcastReceiver這兩個對象
我們分別看看。

downloader下載器

1 if (downloader == null) {
2         downloader = new OkHttp3Downloader(context);
3       }
4 
5 
6       
7 public OkHttpClient build() {
8       return new OkHttpClient(this);
9     }

我看了Picasso以前的版本，以前的版本下載器中，它會通過反射來獲取OKhttp，如果項目中有使用OKhttp，則下載器就是使用OKhttp，否則的話，它會使用內嵌的UrlConnectionDownloader
下載器。但是新的版本以後（具體哪個版本開始，我沒有深究）直接就是使用OKhttp了。

LruCache 緩存

1  /** Create a cache with a given maximum size in bytes. */
2   public LruCache(int maxByteCount) {
3     cache = new android.util.LruCache<String, LruCache.BitmapAndSize>(maxByteCount) {
4       @Override protected int sizeOf(String key, BitmapAndSize value) {
5         return value.byteCount;
6       }
7     };
8   }

這個緩存相當於給了一個具有給定最大位元組大小的緩存。

PicassoExecutorService 線程池

 1 class PicassoExecutorService extends ThreadPoolExecutor {
 2   private static final int DEFAULT_THREAD_COUNT = 3;
 3 
 4   PicassoExecutorService() {
 5     super(DEFAULT_THREAD_COUNT, DEFAULT_THREAD_COUNT, 0, TimeUnit.MILLISECONDS,
 6         new PriorityBlockingQueue<Runnable>(), new Utils.PicassoThreadFactory());
 7   }
 8 
 9   void adjustThreadCount(NetworkInfo info) {
10     if (info == null || !info.isConnectedOrConnecting()) {
11       setThreadCount(DEFAULT_THREAD_COUNT);
12       return;
13     }
14     switch (info.getType()) {
15       case ConnectivityManager.TYPE_WIFI:
16       case ConnectivityManager.TYPE_WIMAX:
17       case ConnectivityManager.TYPE_ETHERNET:
18         setThreadCount(4);
19         break;
20       case ConnectivityManager.TYPE_MOBILE:
21         switch (info.getSubtype()) {
22           case TelephonyManager.NETWORK_TYPE_LTE:  // 4G
23           case TelephonyManager.NETWORK_TYPE_HSPAP:
24           case TelephonyManager.NETWORK_TYPE_EHRPD:
25             setThreadCount(3);
26             break;
27           case TelephonyManager.NETWORK_TYPE_UMTS: // 3G
28           case TelephonyManager.NETWORK_TYPE_CDMA:
29           case TelephonyManager.NETWORK_TYPE_EVDO_0:
30           case TelephonyManager.NETWORK_TYPE_EVDO_A:
31           case TelephonyManager.NETWORK_TYPE_EVDO_B:
32             setThreadCount(2);
33             break;
34           case TelephonyManager.NETWORK_TYPE_GPRS: // 2G
35           case TelephonyManager.NETWORK_TYPE_EDGE:
36             setThreadCount(1);
37             break;
38           default:
39             setThreadCount(DEFAULT_THREAD_COUNT);
40         }
41         break;
42       default:
43         setThreadCount(DEFAULT_THREAD_COUNT);
44     }
45   }

這個線程池直接就繼承ThreadPoolExecutor，預設的線程數是3個，而線程數的數量隨著網路的變化而改變，WiFi的為4,4G的為3,3G的為2,2G的為1，其他情況都是使用預設的。

DispatcherHandler

 1 private static class DispatcherHandler extends Handler {
 2     private final Dispatcher dispatcher;
 3 
 4     DispatcherHandler(Looper looper, Dispatcher dispatcher) {
 5       super(looper);
 6       this.dispatcher = dispatcher;
 7     }
 8 
 9     @Override public void handleMessage(final Message msg) {
10       switch (msg.what) {
11         case REQUEST_SUBMIT: {
12           Action action = (Action) msg.obj;
13           dispatcher.performSubmit(action);
14           break;
15         }
16         case REQUEST_CANCEL: {
17           Action action = (Action) msg.obj;
18           dispatcher.performCancel(action);
19           break;
20         }
21         case TAG_PAUSE: {
22           Object tag = msg.obj;
23           dispatcher.performPauseTag(tag);
24           break;
25         }
26         case TAG_RESUME: {
27           Object tag = msg.obj;
28           dispatcher.performResumeTag(tag);
29           break;
30         }
31         case HUNTER_COMPLETE: {
32           BitmapHunter hunter = (BitmapHunter) msg.obj;
33           dispatcher.performComplete(hunter);
34           break;
35         }
36         case HUNTER_RETRY: {
37           BitmapHunter hunter = (BitmapHunter) msg.obj;
38           dispatcher.performRetry(hunter);
39           break;
40         }
41         case HUNTER_DECODE_FAILED: {
42           BitmapHunter hunter = (BitmapHunter) msg.obj;
43           dispatcher.performError(hunter, false);
44           break;
45         }
46         case HUNTER_DELAY_NEXT_BATCH: {
47           dispatcher.performBatchComplete();
48           break;
49         }
50         case NETWORK_STATE_CHANGE: {
51           NetworkInfo info = (NetworkInfo) msg.obj;
52           dispatcher.performNetworkStateChange(info);
53           break;
54         }
55         case AIRPLANE_MODE_CHANGE: {
56           dispatcher.performAirplaneModeChange(msg.arg1 == AIRPLANE_MODE_ON);
57           break;
58         }
59         default:
60           Picasso.HANDLER.post(new Runnable() {
61             @Override public void run() {
62               throw new AssertionError("Unknown handler message received: " + msg.what);
63             }
64           });
65       }
66     }
67   }

這個DispatcherHandler直接Handler，並且是作用在dispatcherThread線程中的Handler，它用於把在dispatcherThread子線程的操作轉到到Dispatcher中去，通過handleMessage()方法可以知道
如，請求取消，暫停，網路的變化，飛行模式的改變等等，都是通過Handler來切換處理的。

NetworkBroadcastReceiver

 1 static class NetworkBroadcastReceiver extends BroadcastReceiver {
 2     static final String EXTRA_AIRPLANE_STATE = "state";
 3 
 4     private final Dispatcher dispatcher;
 5 
 6     NetworkBroadcastReceiver(Dispatcher dispatcher) {
 7       this.dispatcher = dispatcher;
 8     }
 9 
10     void register() {
11       IntentFilter filter = new IntentFilter();
12       filter.addAction(ACTION_AIRPLANE_MODE_CHANGED);
13       if (dispatcher.scansNetworkChanges) {
14         filter.addAction(CONNECTIVITY_ACTION);
15       }
16       dispatcher.context.registerReceiver(this, filter);
17     }
18 
19     void unregister() {
20       dispatcher.context.unregisterReceiver(this);
21     }
22 
23     @SuppressLint("MissingPermission")
24     @Override public void onReceive(Context context, Intent intent) {
25       // On some versions of Android this may be called with a null Intent,
26       // also without extras (getExtras() == null), in such case we use defaults.
27       if (intent == null) {
28         return;
29       }
30       final String action = intent.getAction();
31       if (ACTION_AIRPLANE_MODE_CHANGED.equals(action)) {
32         if (!intent.hasExtra(EXTRA_AIRPLANE_STATE)) {
33           return; // No airplane state, ignore it. Should we query Utils.isAirplaneModeOn?
34         }
35         dispatcher.dispatchAirplaneModeChange(intent.getBooleanExtra(EXTRA_AIRPLANE_STATE, false));
36       } else if (CONNECTIVITY_ACTION.equals(action)) {
37         ConnectivityManager connectivityManager = getService(context, CONNECTIVITY_SERVICE);
38         dispatcher.dispatchNetworkStateChange(connectivityManager.getActiveNetworkInfo());
39       }
40     }
41   }

這是一個廣播，他的主要作用就是監聽網路的變化，一旦網路發生了變化，則通過廣播來接收到，並且通知相應的操作，比如更改線程的數量。
以上就是get()的所做的一些操作。

load()

 1 public RequestCreator load(@Nullable String path) {
 2     if (path == null) {
 3       return new RequestCreator(this, null, 0);
 4     }
 5     if (path.trim().length() == 0) {
 6       throw new IllegalArgumentException("Path must not be empty.");
 7     }
 8     return load(Uri.parse(path));
 9   }
10 
11  RequestCreator(Picasso picasso, Uri uri, int resourceId) {
12     if (picasso.shutdown) {
13       throw new IllegalStateException(
14           "Picasso instance already shut down. Cannot submit new requests.");
15     }
16     this.picasso = picasso;
17     this.data = new Request.Builder(uri, resourceId, picasso.defaultBitmapConfig);
18   }

load()中所做的操作不多，主要通過path，來獲得一個請求構造器RequestCreator

into()

 public void into(ImageView target, Callback callback) {
    long started = System.nanoTime();
    checkMain(); //判斷是否在主線程

    if (target == null) {
      throw new IllegalArgumentException("Target must not be null.");
    }

    if (!data.hasImage()) { //這裡主要是判斷uri是否為空，或者是resourceId是否為0，如果是的話，Picasso就會取消這個imageView的請求。並且將占點陣圖顯示
      picasso.cancelRequest(target);
      if (setPlaceholder) {
        setPlaceholder(target, getPlaceholderDrawable());
      }
      return;
    }

    if (deferred) {
      if (data.hasSize()) { //如果我們在代碼中設置了fit()這個屬性，也就是調整圖像的大小，使其完全適合目標，但是又設置圖片的寬高的話，就會拋異常了...
        throw new IllegalStateException("Fit cannot be used with resize.");
      }
      int width = target.getWidth();
      int height = target.getHeight();
      if (width == 0 || height == 0) { //如果我們設置的寬高中有一個為0的話，就會展示這個占點陣圖
        if (setPlaceholder) {
          setPlaceholder(target, getPlaceholderDrawable());
        }
        picasso.defer(target, new DeferredRequestCreator(this, target, callback));
        return;
      }
      data.resize(width, height);
    }

    Request request = createRequest(started);
    String requestKey = createKey(request);

    if (shouldReadFromMemoryCache(memoryPolicy)) { //先判斷緩存中是否有數據，如果緩存中有數據的話則直接從緩存中取出來
      Bitmap bitmap = picasso.quickMemoryCacheCheck(requestKey);
      if (bitmap != null) {
        picasso.cancelRequest(target);
        setBitmap(target, picasso.context, bitmap, MEMORY, noFade, picasso.indicatorsEnabled);
        if (picasso.loggingEnabled) {
          log(OWNER_MAIN, VERB_COMPLETED, request.plainId(), "from " + MEMORY);
        }
        if (callback != null) {
          callback.onSuccess();
        }
        return;
      }
    }

    if (setPlaceholder) { //先展示占點陣圖
      setPlaceholder(target, getPlaceholderDrawable());
    }

    Action action =
        new ImageViewAction(picasso, target, request, memoryPolicy, networkPolicy, errorResId,
            errorDrawable, requestKey, tag, callback, noFade);

    picasso.enqueueAndSubmit(action); //將請求事件添加到隊列中，然後通過handler將請求事件發送出去。
  }

基本Picasso的基本流程就是這樣的了，如果有哪些錯誤，麻煩請指出，一起學習，一起進步

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • MySQL關鍵字大全
    轉載自：https://blog.csdn.net/benxiaohai888/article/details/77803090 在使用MySQL的時候，一般儘量避免用關鍵字作為表名，如使用關鍵字做表名，需要按標準寫法給SQL語句加[](或是“)區分欄位名和表名。 下麵列出MySQL所有關鍵字，希望 ...
  • mssql sqlserver null數據類型專題
    摘要: 下文將詳細講述sql server NULL(空值)的相關知識，如下所示: 實驗環境: sql server 2008 R2 NULL(空值)簡介: mssql sqlserver null數據值簡介-1 mssql sqlserver null值詳細說明-2 mssql sqlserver ...
  • Android Studio移除模塊
    一、打開文件菜單下的項目結構 二、在項目結構中選中模塊，點擊－號，然後刪除 三、刪除本地文件，移除模塊成功 ...
  • JVM vs DVM
    JVM vs DVM ...
  • Android architecture
    Android四層架構 ...
  • 支持scrollTo的RecycleView
    RecycleView內部沒有幫我們實現ScrollTo的方法，不過幫我們實現了ScrollBy，我們可以通過ScrollBy自定義一個支持scrollTo的RecycleView。 ...
  • TextView走馬燈
    設置textView走馬燈形式顯示： 給Textview設置以上的屬性，android:ellipsize="marquee"便是指定超出範圍的時候以跑馬的形式顯示（註意上面的屬性是只有在內容超出TextView寬度時候才有效果）。 不能用max_line屬性，要用singleLine屬性。 別忘了 ...
  • 【轉載】Android RecyclerView 使用完全解析 體驗藝術般的控制項
    崇拜下鴻洋大神，原文地址：http://blog.csdn.net/lmj623565791/article/details/45059587 概述 RecyclerView出現已經有一段時間了，相信大家肯定不陌生了，大家可以通過導入support-v7對其進行使用。 據官方的介紹，該控制項用於在有限 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類