Picasso源码
Picasso源码
Picasso.java
单例,几乎是所有操作步骤的中转站,中南海。
Picasso.with()
调用 Builder 创建这个单例,主要初始化了这些:
- Downloader (默认
Utils.createDefaultDownloader(context);
然后返回 OkHttpDownloader) - Cache (默认LruCache)
- ExecutorService (默认 PicassoExecutorService)
- RequestTransformer(默认不做任何处理)
- Stats 记录整个 Picasso 的网络请求次数,缓存命中次数,图像转换次数等状态
- Dispatcher
- 创建清理线程 CleanupThread 并启动,清理通过 ReferenceQueue 实现,CleanupThread 的成员变量 referenceQueue 里存的是 Action 里面不同类型 Target 的 WeakReference。
- requestHandlers 在 Picasso 的构造函数中,会初始化这个变量,放上一堆 RequestHandler
load 这个常用方法,会 new 一个 RequestCreator
submit ,把一个 Action 放进 dispatcher
一个请求大概会经过 RequestCreator - Request - Action 这几个包装
RequestHandler.java
请求处理类,获取图片资源,通过创建不同的子类(override 两个方法:load canHandleRequest)来处理不同的图片来源。
RequestCreator.java
构造方法会调用 Request 的 Builder,创建一个 Request.Builder 的成员变量。
还有 get() / fetch() / into() 几个方法,这几个作用类似,都是 调用 createRequest() 创建 Request ,再创建一个Action 开始获取图片。
get() 直接调用 BitmapHunter 的 forRequest() 创建 BitmapHunter,然后调用这个 bitmapHunter 的 hunt() 同步返回 bitmap。
fetch() 调用 picasso 实例的 submit() 把 action 扔进 dispatcher 。
into() 调用 picasso 实例的 enqueueAndSubmit() :把这个 action 放进 picasso.targetToAction,再调用 submit() 把 action 扔进 dispatcher 。
fetch() 和 into() 会通过 picasso.quickMemoryCacheCheck(key) 尝试从缓存读取
Request.java
请求封装类,对图形的操作都会记录在这里,供之后图形的创建使用,如重新计算大小,旋转角度,也可以自定义变换,只需要实现 Transformation
Action / ImageViewAction / Target
都可以看作图片下载的任务单元 / 回调接口。代表了一个具体的加载任务,主要用于图片加载后的结果回调,有两个抽象方法: complete() 和 error() 来通知上层。 其中会使用弱引用 RequestWeakReference来包装 ImageView 或者 Target 。所以要注意使用 Target 时,不要用匿名内部类,存一个 Activity / Fragment 的 filed,或者让 Activity / Fragement 去 Implement Target。
BitmapHunter.java
网络下载工作线程。一个 runnable 线程,
hunt()是具体的图片获取过程:检查缓存,stats跟踪图片处理过程的各个状态去记录缓存相关的数量。使用相关的 RequestHandler 调用 load 获取到 RequestHandler.Result,再调用 decodeStream() 获取到 bitmap,如果有 Transformation 操作(有目标 width 和 height 的,比如 resize ,fit 本质也是 resize 操作),则同步进行 bitmap 的 transform 操作。
在自己的 run 方法里,也就是作为一个 线程任务 执行的时候,主要操作是:
hunt() 拿到 bitmap 之后,通过dispatcher.dispatchComplete(this);
或者dispatcher.dispatchFailed(this);
,扔进 dispatcher.
在 performComplete 中,会把获取到的 hunter 放进 cache 中。
Dispatcher.java
任务调度器,创建单独的线程 DispatcherThread ,创建使用这个线程的 Handler :DispatcherHandler 。在构造方法中启动 DispatcherThread。
通过这个 handler ,向下把新建的任务 bitmapHunter 传给 ExecutorService ,向上通过 mainThreadHandler(Picasso 实例中的 HANDLER) 把 bitmapHunter 传给主线程。( dispatcher 会调用自己线程的 handler ,来执行 performComplete,然后 performBatchComplete,这里会 mainThreadHandler.sendMessage(mainThreadHandler.obtainMessage(HUNTER_BATCH_COMPLETE, copy));
)
PicassoExecutorService.java
获取图片任务的线程池,根据网络状态设置线程数量。将 bitmapHunter 包装成 FutureTask 方便控制优先级。 默认 3 个核心线程,最大线程数也是 3 个。线程池线程总数大于 最大线程数时,终止多余的空闲线程的时间是0,也就是超过线程数就直接执行超时策略。使用的 PriorityBlockingQueue , 也就是任务带优先级。
核心线程数会根据当前网络状态(WIFI,4G,3G,2G)来修改。
任务使用 PicassoFutureTask,有成员变量 hunter(BitmapHunter),使用 BitmapHunter 的 getPriority方法来比较优先级。
Downloader.java
一个下载接口,用来封装不同的Http库,子类可以选择各种不同的库来实现下载功能。
Cache.java
内存缓存,子类 LruCache 采用 Least Recently Used 算法,使用 LinkedHashMap 作为数据结构,LinkedHashMap 自带 LRU 策略,只需根据配置的缓存大小调用 trimToSize。配合 Stats 计数 实现缓存大小的管理
本地文件缓存,Picasso 并没有,需要 Downloader 的子类自己实现,如果使用 OkHttpDownloader 或者 UrlConnectionDownloader 的话,已经实现了文件缓存。