图片加载框架Picasso解析

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了图片加载框架Picasso解析相关的知识,希望对你有一定的参考价值。

picasso是Square公司开源的一个android图形缓存库

主要有以下一些特性:

在adapter中回收和取消当前的下载;

使用最少的内存完成复杂的图形转换操作;

自动的内存和硬盘缓存;

图形转换操作,如变换大小,旋转等,提供了接口来让用户可以自定义转换操作;

加载载网络或本地资源;

Picasso.class

他有一个内部类,一般是通过他来创建实例的:

技术分享

downloader(Downloader downloader) :

容许使用自定义的下载器,可以用okhttp或者volley,必须实现Downloader接口。

executor(ExecutorService executorService):

容许使用自己的线程池来进行下载

memoryCache(Cache memoryCache):

容许使用自己的缓存类,必须实现Cache接口。

requestTransformer(RequestTransformer transformer):

listener(Listener listener):

addRequestHandler(RequestHandler requestHandler):

indicatorsEnabled(boolean enabled):设置图片来源的指示器。

loggingEnabled(boolean enabled):

再来看build()方法:

 

[html] view plain copy
 
  1. /** Create the {@link Picasso} instance. */  
  2.    public Picasso build() {  
  3.      Context context = this.context;  
  4.   
  5.      if (downloader == null) {  
  6.        downloader = Utils.createDefaultDownloader(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,  
  23.          requestHandlers, stats, indicatorsEnabled, loggingEnabled);  
  24.    }  

这里会使用默认的下载器,缓存类,线程池,并将这些对象封装到了分发器Dispatcher里。然后在返回一个Picasso对象。

 

一般情况下,如果不需要自定义bulid里的这些方法,可以使用Picasso.with(context)默认方法来获得单例对象:

 

[html] view plain copy
 
  1. public static Picasso with(Context context) {  
  2.     if (singleton == null) {  
  3.       synchronized (Picasso.class) {  
  4.         if (singleton == null) {  
  5.           singleton = new Builder(context).build();  
  6.         }  
  7.       }  
  8.     }  
  9.     return singleton;  
  10.   }  

如果需要自定义一些对象:

 

 

[html] view plain copy
 
  1. public class SamplePicassoFactory {  
  2.   
  3.   private static Picasso sPicasso;  
  4.   
  5.   public static Picasso getPicasso(Context context) {  
  6.     if (sPicasso == null) {  
  7.         sPicasso = new Picasso.Builder(context)  
  8.             .downloader(new OkHttpDownloader(context, ConfigConstants.MAX_DISK_CACHE_SIZE))  
  9.             .memoryCache(new LruCache(ConfigConstants.MAX_MEMORY_CACHE_SIZE))  
  10.             .build();  
  11.     }  
  12.     return sPicasso;  
  13.   }  
  14. }  

通过上面的方法,获得sPicasso对象后就设置成了单例,但是最好设置成双重校验锁模式。

 

如果通过以上方法获得对象后,还可以通过Picasso.setSingletonInstance(Picasso picasso)方法设置对象到Picasso中,这样以后还是通过Picasso.with(context)来调用。

接着就可以通过以下方式设置加载源:

技术分享

可以是uri地址,file文件,res资源drawable。

最终都是通过以下方法来创建一个RequestCreator对象:

 

[html] view plain copy
 
  1. public RequestCreator load(Uri uri) {  
  2.     return new RequestCreator(this, uri, 0);  
  3.   }  
[html] view plain copy
 
  1. RequestCreator(Picasso picasso, Uri uri, int resourceId) {  
  2.     if (picasso.shutdown) {  
  3.       throw new IllegalStateException(  
  4.           "Picasso instance already shut down. Cannot submit new requests.");  
  5.     }  
  6.     this.picasso = picasso;  
  7.     this.data = new Request.Builder(uri, resourceId);   
  8.   }  

RequestCreator对象是用来设置一系列属性的,如:

 

技术分享
noPlaceholder():设置没有加载等待图片

placeholder(int placeholderResId):设置加载等待图片

placeholder(Drawable placeholderDrawable):设置加载等待图片

error(int errorResId):设置加载出错的图片。

error(Drawable errorDrawable):设置加载出错的图片。

tag(Object tag):设置标记

fit():自适应,下载的图片有多少像素就显示多少像素

resizeDimen(int targetWidthResId, int targetHeightResId):设置图片显示的像素。

resize(int targetWidth, int targetHeight):设置图片显示的像素。

centerCrop():设置ImageView的ScaleType属性.

centerInside():设置ImageView的ScaleType属性.

rotate(float degrees):设置旋转角度。

rotate(float degrees, float pivotX, float pivotY):设置以某个中心点设置某个旋转角度。

config(Bitmap.Config config):设置Bitmap的Config属性

priority(Priority priority):设置请求的优先级。

transform(Transformation transformation):

skipMemoryCache():跳过内存缓存

memoryPolicy(MemoryPolicy policy, MemoryPolicy... additional):

networkPolicy(NetworkPolicy policy, NetworkPolicy... additional):

noFade():没有淡入淡出效果

get():获得bitmap对象

fetch():

设置完以上一系列属性之后,最关键的就是into方法,现在以into(ImageView target)举例:

 

[html] view plain copy
 
  1. public void into(ImageView target) {  
  2.     into(target, null);  
  3.   }  

他实际调用的是:

 

 

[html] view plain copy
 
  1. public void into(ImageView target, Callback callback) {  
  2.    long started = System.nanoTime();  
  3.    checkMain();  
  4.   
  5.    if (target == null) {  
  6.      throw new IllegalArgumentException("Target must not be null.");  
  7.    }  
  8.   
  9.    if (!data.hasImage()) {  
  10.      picasso.cancelRequest(target);  
  11.      if (setPlaceholder) {  
  12.        setPlaceholder(target, getPlaceholderDrawable());  
  13.      }  
  14.      return;  
  15.    }  
  16.   
  17.    if (deferred) {  
  18.      if (data.hasSize()) {  
  19.        throw new IllegalStateException("Fit cannot be used with resize.");  
  20.      }  
  21.      int width = target.getWidth();  
  22.      int height = target.getHeight();  
  23.      if (width == 0 || height == 0) {  
  24.        if (setPlaceholder) {  
  25.          setPlaceholder(target, getPlaceholderDrawable());  
  26.        }  
  27.        picasso.defer(target, new DeferredRequestCreator(this, target, callback));  
  28.        return;  
  29.      }  
  30.      data.resize(width, height);  
  31.    }  
  32.   
  33.    Request request = createRequest(started);  
  34.    String requestKey = createKey(request);  
  35.   
  36.    if (shouldReadFromMemoryCache(memoryPolicy)) {  
  37.      Bitmap bitmap = picasso.quickMemoryCacheCheck(requestKey);  
  38.      if (bitmap != null) {  
  39.        picasso.cancelRequest(target);  
  40.        setBitmap(target, picasso.context, bitmap, MEMORY, noFade, picasso.indicatorsEnabled);  
  41.        if (picasso.loggingEnabled) {  
  42.          log(OWNER_MAIN, VERB_COMPLETED, request.plainId(), "from " + MEMORY);  
  43.        }  
  44.        if (callback != null) {  
  45.          callback.onSuccess();  
  46.        }  
  47.        return;  
  48.      }  
  49.    }  
  50.   
  51.    if (setPlaceholder) {  
  52.      setPlaceholder(target, getPlaceholderDrawable());  
  53.    }  
  54.   
  55.    Action action =  
  56.        new ImageViewAction(picasso, target, request, memoryPolicy, networkPolicy, errorResId,  
  57.            errorDrawable, requestKey, tag, callback, noFade);  
  58.   
  59.    picasso.enqueueAndSubmit(action);  
  60.  }  
[html] view plain copy
 
  1. checkMain();  

首先检查是否是主线程

 

[html] view plain copy
 
  1. if (target == null) {  
  2.       throw new IllegalArgumentException("Target must not be null.");  
  3.     }  

检查目标view是否存在

 

 

[html] view plain copy
 
  1. if (!data.hasImage()) {  
  2.       picasso.cancelRequest(target);  
  3.       if (setPlaceholder) {  
  4.         setPlaceholder(target, getPlaceholderDrawable());  
  5.       }  
  6.       return;  
  7.     }  

如果没有设置uri或者resDrawable,就停止请求,如果设置了加载等待的图片就设置,然后就return

 

 

[html] view plain copy
 
  1. if (deferred) {  
  2.       if (data.hasSize()) {  
  3.         throw new IllegalStateException("Fit cannot be used with resize.");  
  4.       }  
  5.       int width = target.getWidth();  
  6.       int height = target.getHeight();  
  7.       if (width == 0 || height == 0) {  
  8.         if (setPlaceholder) {  
  9.           setPlaceholder(target, getPlaceholderDrawable());  
  10.         }  
  11.         picasso.defer(target, new DeferredRequestCreator(this, target, callback));  
  12.         return;  
  13.       }  
  14.       data.resize(width, height);  
  15.     }  

如果设置fit自适应:如果已经设置了图片像素大小就抛异常,如果目标view的长宽等于0,就在设置等待图片后延期处理,如果不等于0就设置size到Request.Builder的data里。

 

 

[html] view plain copy
 
  1. Request request = createRequest(started);  
  2.  String requestKey = createKey(request);  

接着就创建Request,并生成一个String类型的requestKey。

 

 

[html] view plain copy
 
  1. /** Create the request optionally passing it through the request transformer. */  
  2.   private Request createRequest(long started) {  
  3.     int id = nextId.getAndIncrement();  
  4.   
  5.     Request request = data.build();  
  6.     request.id = id;  
  7.     request.started = started;  
  8.   
  9.     boolean loggingEnabled = picasso.loggingEnabled;  
  10.     if (loggingEnabled) {  
  11.       log(OWNER_MAIN, VERB_CREATED, request.plainId(), request.toString());  
  12.     }  
  13.   
  14.     Request transformed = picasso.transformRequest(request);  
  15.     if (transformed != request) {  
  16.       // If the request was changed, copy over the id and timestamp from the original.  
  17.       transformed.id = id;  
  18.       transformed.started = started;  
  19.   
  20.       if (loggingEnabled) {  
  21.         log(OWNER_MAIN, VERB_CHANGED, transformed.logId(), "into " + transformed);  
  22.       }  
  23.     }  
  24.   
  25.     return transformed;  
  26.   }  

在以上代码可以看出,这里调用picasso.transformRequest(request);来给使用者提供一个可以更改request的机会,他最终调用的是Picasso.Build里面的通过requestTransformer(RequestTransformer transformer)方法传进去的RequestTransformer 接口:

 

 

[html] view plain copy
 
  1. public interface RequestTransformer {  
  2.    /**  
  3.     * Transform a request before it is submitted to be processed.  
  4.     *  
  5.     * @return The original request or a new request to replace it. Must not be null.  
  6.     */  
  7.    Request transformRequest(Request request);  
  8.   
  9.    /** A {@link RequestTransformer} which returns the original request. */  
  10.    RequestTransformer IDENTITY = new RequestTransformer() {  
  11.      @Override public Request transformRequest(Request request) {  
  12.        return request;  
  13.      }  
  14.    };  
  15.  }  

默认使用的是IDENTITY。这里没有做任何的修改,如果有需要可以自己设置接口以达到修改Request的目的。

 

 

[html] view plain copy
 
  1. if (shouldReadFromMemoryCache(memoryPolicy)) {  
  2.       Bitmap bitmap = picasso.quickMemoryCacheCheck(requestKey);  
  3.       if (bitmap != null) {  
  4.         picasso.cancelRequest(target);  
  5.         setBitmap(target, picasso.context, bitmap, MEMORY, noFade, picasso.indicatorsEnabled);  
  6.         if (picasso.loggingEnabled) {  
  7.           log(OWNER_MAIN, VERB_COMPLETED, request.plainId(), "from " + MEMORY);  
  8.         }  
  9.         if (callback != null) {  
  10.           callback.onSuccess();  
  11.         }  
  12.         return;  
  13.       }  
  14.     }  

接着要判断是否需要从缓存中读取图片,如果需要,就要根据requestKey从缓存中读取:

 

 

[html] view plain copy
 
  1. Bitmap quickMemoryCacheCheck(String key) {  
  2.     Bitmap cached = cache.get(key);  
  3.     if (cached != null) {  
  4.       stats.dispatchCacheHit();  
  5.     } else {  
  6.       stats.dispatchCacheMiss();  
  7.     }  
  8.     return cached;  
  9.   }  

这里的cache用的是LruCache内存缓存类,这个内存缓存类,实现了Cache接口,最后调用的是:

 

 

[html] view plain copy
 
  1. @Override public Bitmap get(String key) {  
  2.    if (key == null) {  
  3.      throw new NullPointerException("key == null");  
  4.    }  
  5.   
  6.    Bitmap mapValue;  
  7.    synchronized (this) {  
  8.      mapValue = map.get(key);  
  9.      if (mapValue != null) {  
  10.        hitCount++;  
  11.        return mapValue;  
  12.      }  
  13.      missCount++;  
  14.    }  
  15.   
  16.    return null;  
  17.  }  

这里的map是LinkedHashMap<String, Bitmap>:

 

 

[html] view plain copy
 
  1. this.map = new LinkedHashMap<String, Bitmap>(0, 0.75f, true);  

缓存的策略稍后分析,现在先回到前面,如果从缓存中拿到的bitmap不等于null,就调用picasso.cancelRequest(target)来删除请求,然后通过

 

 

[html] view plain copy
 
  1. setBitmap(target, picasso.context, bitmap, MEMORY, noFade, picasso.indicatorsEnabled);  

设置图片,然后如果设置了callback回调,再回掉callback.onSuccess();方法,然后就return。

 

 

如果没有设置内存缓存,或者缓存中的图片已经不存在:

 

[html] view plain copy
 
  1. if (setPlaceholder) {  
  2.      setPlaceholder(target, getPlaceholderDrawable());  
  3.    }  
  4.   
  5.    Action action =  
  6.        new ImageViewAction(picasso, target, request, memoryPolicy, networkPolicy, errorResId,  
  7.            errorDrawable, requestKey, tag, callback, noFade);  
  8.   
  9.    picasso.enqueueAndSubmit(action);  

接着就设置等待加载图片,然后封装一个action,然后将action加入到分发器中:

 

 

[html] view plain copy
 
  1. void enqueueAndSubmit(Action action) {  
  2.     Object target = action.getTarget();  
  3.     if (target != null && targetToAction.get(target) != action) {  
  4.       // This will also check we are on the main thread.  
  5.       cancelExistingRequest(target);  
  6.       targetToAction.put(target, action);  
  7.     }  
  8.     submit(action);  
  9.   }  
  10.   
  11.   void submit(Action action) {  
  12.     dispatcher.dispatchSubmit(action);  
  13.   }  

然后调用了dispatcher的performSubmit()方法:

 

 

[html] view plain copy
 
  1. void performSubmit(Action action) {  
  2.    performSubmit(action, true);  
  3.  }  
  4.   
  5.  void performSubmit(Action action, boolean dismissFailed) {  
  6.    if (pausedTags.contains(action.getTag())) {  
  7.      pausedActions.put(action.getTarget(), action);  
  8.      if (action.getPicasso().loggingEnabled) {  
  9.        log(OWNER_DISPATCHER, VERB_PAUSED, action.request.logId(),  
  10.            "because tag ‘" + action.getTag() + "‘ is paused");  
  11.      }  
  12.      return;  
  13.    }  
  14.   
  15.    BitmapHunter hunter = hunterMap.get(action.getKey());  
  16.    if (hunter != null) {  
  17.      hunter.attach(action);  
  18.      return;  
  19.    }  
  20.   
  21.    if (service.isShutdown()) {  
  22.      if (action.getPicasso().loggingEnabled) {  
  23.        log(OWNER_DISPATCHER, VERB_IGNORED, action.request.logId(), "because shut down");  
  24.      }  
  25.      return;  
  26.    }  
  27.   
  28.    hunter = forRequest(action.getPicasso(), this, cache, stats, action);  
  29.    hunter.future = service.submit(hunter);  
  30.    hunterMap.put(action.getKey(), hunter);  
  31.    if (dismissFailed) {  
  32.      failedActions.remove(action.getTarget());  
  33.    }  
  34.   
  35.    if (action.getPicasso().loggingEnabled) {  
  36.      log(OWNER_DISPATCHER, VERB_ENQUEUED, action.request.logId());  
  37.    }  
  38.  }  

这里通过 hunter = forRequest(action.getPicasso(), this, cache, stats, action);获得一个BitmapHunter对象,接着就提交到线程池中 hunter.future = service.submit(hunter);:

 

接着线程池就会调用hunter 的run方法,因为这实现了Runnable对象:

[html] view plain copy
 
  1. @Override public void run() {  
  2.    try {  
  3.      updateThreadName(data);  
  4.   
  5.      if (picasso.loggingEnabled) {  
  6.        log(OWNER_HUNTER, VERB_EXECUTING, getLogIdsForHunter(this));  
  7.      }  
  8.   
  9.      result = hunt();  
  10.   
  11.      if (result == null) {  
  12.        dispatcher.dispatchFailed(this);  
  13.      } else {  
  14.        dispatcher.dispatchComplete(this);  
  15.      }  
  16.    } catch (Downloader.ResponseException e) {  
  17.      if (!e.localCacheOnly || e.responseCode != 504) {  
  18.        exception = e;  
  19.      }  
  20.      dispatcher.dispatchFailed(this);  
  21.    } catch (NetworkRequestHandler.ContentLengthException e) {  
  22.      exception = e;  
  23.      dispatcher.dispatchRetry(this);  
  24.    } catch (IOException e) {  
  25.      exception = e;  
  26.      dispatcher.dispatchRetry(this);  
  27.    } catch (OutOfMemoryError e) {  
  28.      StringWriter writer = new StringWriter();  
  29.      stats.createSnapshot().dump(new PrintWriter(writer));  
  30.      exception = new RuntimeException(writer.toString(), e);  
  31.      dispatcher.dispatchFailed(this);  
  32.    } catch (Exception e) {  
  33.      exception = e;  
  34.      dispatcher.dispatchFailed(this);  
  35.    } finally {  
  36.      Thread.currentThread().setName(Utils.THREAD_IDLE_NAME);  
  37.    }  
  38.  }  

接着调用hunt()方法:

 

 

[html] view plain copy
 
  1. Bitmap hunt() throws IOException {  
  2.     Bitmap bitmap = null;  
  3.   
  4.     if (shouldReadFromMemoryCache(memoryPolicy)) {  
  5.       bitmap = cache.get(key);  
  6.       if (bitmap != null) {  
  7.         stats.dispatchCacheHit();  
  8.         loadedFrom = MEMORY;  
  9.         if (picasso.loggingEnabled) {  
  10.           log(OWNER_HUNTER, VERB_DECODED, data.logId(), "from cache");  
  11.         }  
  12.         return bitmap;  
  13.       }  
  14.     }  
  15.   
  16.     data.networkPolicy = retryCount == 0 ? NetworkPolicy.OFFLINE.index : networkPolicy;  
  17.     RequestHandler.Result result = requestHandler.load(data, networkPolicy);  
  18.     if (result != null) {  
  19.       loadedFrom = result.getLoadedFrom();  
  20.       exifRotation = result.getExifOrientation();  
  21.   
  22.       bitmap = result.getBitmap();  
  23.   
  24.       // If there was no Bitmap then we need to decode it from the stream.  
  25.       if (bitmap == null) {  
  26.         InputStream is = result.getStream();  
  27.         try {  
  28.           bitmap = decodeStream(is, data);  
  29.         } finally {  
  30.           Utils.closeQuietly(is);  
  31.         }  
  32.       }  
  33.     }  
  34.   
  35.     if (bitmap != null) {  
  36.       if (picasso.loggingEnabled) {  
  37.         log(OWNER_HUNTER, VERB_DECODED, data.logId());  
  38.       }  
  39.       stats.dispatchBitmapDecoded(bitmap);  
  40.       if (data.needsTransformation() || exifRotation != 0) {  
  41.         synchronized (DECODE_LOCK) {  
  42.           if (data.needsMatrixTransform() || exifRotation != 0) {  
  43.             bitmap = transformResult(data, bitmap, exifRotation);  
  44.             if (picasso.loggingEnabled) {  
  45.               log(OWNER_HUNTER, VERB_TRANSFORMED, data.logId());  
  46.             }  
  47.           }  
  48.           if (data.hasCustomTransformations()) {  
  49.             bitmap = applyCustomTransformations(data.transformations, bitmap);  
  50.             if (picasso.loggingEnabled) {  
  51.               log(OWNER_HUNTER, VERB_TRANSFORMED, data.logId(), "from custom transformations");  
  52.             }  
  53.           }  
  54.         }  
  55.         if (bitmap != null) {  
  56.           stats.dispatchBitmapTransformed(bitmap);  
  57.         }  
  58.       }  
  59.     }  
  60.   
  61.     return bitmap;  
  62.   }  

这里如果从内存缓存中渠道bitmap对象,就直接返回了;否则通过requestHandler.load(data, networkPolicy);来发起网络请求(这个是NetworkRequestHandler类型的):

 

 

[html] view plain copy
 
  1. @Override public Result load(Request request, int networkPolicy) throws IOException {  
  2.     Response response = downloader.load(request.uri, request.networkPolicy);  
  3.     if (response == null) {  
  4.       return null;  
  5.     }  
  6.   
  7.     Picasso.LoadedFrom loadedFrom = response.cached ? DISK : NETWORK;  
  8.   
  9.     Bitmap bitmap = response.getBitmap();  
  10.     if (bitmap != null) {  
  11.       return new Result(bitmap, loadedFrom);  
  12.     }  
  13.   
  14.     InputStream is = response.getInputStream();  
  15.     if (is == null) {  
  16.       return null;  
  17.     }  
  18.     // Sometimes response content length is zero when requests are being replayed. Haven‘t found  
  19.     // root cause to this but retrying the request seems safe to do so.  
  20.     if (loadedFrom == DISK && response.getContentLength() == 0) {  
  21.       Utils.closeQuietly(is);  
  22.       throw new ContentLengthException("Received response with 0 content-length header.");  
  23.     }  
  24.     if (loadedFrom == NETWORK && response.getContentLength() > 0) {  
  25.       stats.dispatchDownloadFinished(response.getContentLength());  
  26.     }  
  27.     return new Result(is, loadedFrom);  
  28.   }  

这里调用了downloader.load(request.uri, request.networkPolicy)方法,这是一个UrlConnectionDownloader类型的对象,调用的是UrlConnectionDownloader的load()方法:

 

 

[html] view plain copy
 
  1. @Override public Response load(Uri uri, int networkPolicy) throws IOException {  
  2.    if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.ICE_CREAM_SANDWICH) {  
  3.      installCacheIfNeeded(context);  
  4.    }  
  5.   
  6.    HttpURLConnection connection = openConnection(uri);  
  7.    connection.setUseCaches(true);  
  8.   
  9.    if (networkPolicy != 0) {  
  10.      String headerValue;  
  11.   
  12.      if (NetworkPolicy.isOfflineOnly(networkPolicy)) {  
  13.        headerValue = FORCE_CACHE;  
  14.      } else {  
  15.        StringBuilder builder = CACHE_HEADER_BUILDER.get();  
  16.        builder.setLength(0);  
  17.   
  18.        

以上是关于图片加载框架Picasso解析的主要内容,如果未能解决你的问题,请参考以下文章

Picasso源码解析

Picasso源码解析

Picasso源码解析

Android图片加载框架Picasso最全使用教程 三

Android图片加载框架Picasso最全使用教程 一

图片加载框架之Glide和Picasso