处理加载慢问题

吴奎庆
1 parent 7eb626e7
Showing 6 changed files with 139 additions and 163 deletions
app/src/main/java/com/cnlive/strike/debug/MainActivity.java
lib_media/src/main/java/com/cnlive/media/frame/view/MediaPickerFragmentView.java
lib_media/src/main/java/com/cnlive/media/utils/GlideCacheUtil.java
lib_media/src/main/java/com/cnlive/media/utils/ThumbnailsUtils.java
lib_media/src/main/java/com/cnlive/media/utils/glide/DataCacheKey.java
lib_media/src/main/res/drawable-xhdpi/iv_new_media_zw.png
@@ -71,7 +71,7 @@ public class MainActivity extends AppCompatActivity implements View.OnClickListe
                         .maxImageSize(25 * 1024 * 1024)
                         .maxVideoSize(100*1024*1024)
                         .isReturnUri(AndroidQUtil.isAndroidQ())
-                        .selectMode(PickerConfig.PICKER_VIDEO)
+                        .selectMode(PickerConfig.PICKER_IMAGE_VIDEO)
                         .defaultSelectList(new ArrayList<Media>())
                         .needCamera(true)
                         .builder()
@@ -60,18 +60,18 @@ public class MediaPickerFragmentView implements MvpView {
         //如果可以确定每个item的高度是固定的，设置这个选项可以提高性能
         mFragment.binding.rv.setHasFixedSize(true);
-        mFragment.binding.rv.addOnScrollListener(new RecyclerView.OnScrollListener() {
-            @RequiresApi(api = Build.VERSION_CODES.JELLY_BEAN_MR1)
-            @Override
-            public void onScrollStateChanged(RecyclerView recyclerView, int newState) {
-                super.onScrollStateChanged(recyclerView, newState);
-                if (RecyclerView.SCROLL_STATE_IDLE == newState) {
-                    Glide.with(recyclerView).resumeRequests();
-                } else {
-                    Glide.with(recyclerView).pauseRequests();
-                }
-            }
-        });
+//        mFragment.binding.rv.addOnScrollListener(new RecyclerView.OnScrollListener() {
+//            @RequiresApi(api = Build.VERSION_CODES.JELLY_BEAN_MR1)
+//            @Override
+//            public void onScrollStateChanged(RecyclerView recyclerView, int newState) {
+//                super.onScrollStateChanged(recyclerView, newState);
+//                if (RecyclerView.SCROLL_STATE_IDLE == newState) {
+//                    Glide.with(recyclerView).resumeRequests();
+//                } else {
+//                    Glide.with(recyclerView).pauseRequests();
+//                }
+//            }
+//        });
         mFragment.mMediaAdapter = new MediaAdapter(mFragment.getActivity(), mActivity.showTime, mActivity.mOptions);
         mFragment.binding.rv.setAdapter(mFragment.mMediaAdapter);
@@ -31,8 +31,8 @@ import com.bumptech.glide.load.engine.cache.InternalCacheDiskCacheFactory;
 import com.bumptech.glide.request.RequestListener;
 import com.bumptech.glide.request.RequestOptions;
 import com.bumptech.glide.request.target.Target;
-import com.cnlive.media.media.entity.Media;
 import com.cnlive.media.R;
+import com.cnlive.media.media.entity.Media;
 import org.reactivestreams.Subscriber;
 import org.reactivestreams.Subscription;
@@ -291,15 +291,11 @@ public class GlideCacheUtil {
                         .centerCrop()
                         .dontAnimate();
             }
-
             if (media.mediaType == 1) {
-                option = option
-                        .error(R.drawable.iv_imgload_full_err);
+                option = option.error(R.drawable.iv_imgload_full_err);
                 view.setScaleType(ImageView.ScaleType.CENTER_CROP);
             } else if (media.mediaType == 3) {
-                option = option
-                        .error(R.drawable.iv_imgload_full_err);
-
+                option = option.error(R.drawable.iv_imgload_full_err);
             }
             if (AndroidQUtil.isAndroidQ()) {
@@ -307,7 +303,6 @@ public class GlideCacheUtil {
             } else {
                 rb = rb == null ? rm.load(media.path) : rb.load(media.path);
             }
-
             rb.listener(listener).apply(option).into(view);
         } catch (Exception e) {
         }
@@ -328,28 +323,24 @@ public class GlideCacheUtil {
                         .dontAnimate();
             }
             if (media.mediaType == 1) {
-                option = option.error(R.drawable.iv_imgload_full_err);
-            }else {
-                option = option.error(R.drawable.iv_imgload_full_err).placeholder(R.drawable.iv_imgload_full_err);
+                option = option.error(R.drawable.iv_imgload_full_err).placeholder(R.drawable.iv_new_media_zw);
+            } else {
+                option = option.error(R.drawable.iv_imgload_full_err).placeholder(R.drawable.iv_new_media_zw);
             }
-
             if (AndroidQUtil.isAndroidQ()) {
+                view.setTag(mediaUri.toString());
                 showAndroidQ(context, media.mediaType, mediaUri, view, loading, option);
             } else {
                 if (media.mediaType == 1) {
-                    showNoAndroidQ(context, media.mediaType, media.path, view, loading, option);
-//                    showImageThumbnail(context, media.mediaType, media.id, media.path, view, loading, option);
+                    showNoAndroidQ(context, media.mediaType, media.fileUri, view, loading, option);
                 } else if (media.mediaType == 3) {
                     if (ThumbnailsUtils.thumbnails.containsKey(media.id + "")) {
-                        Log.e("包含:",ThumbnailsUtils.thumbnails.get(media.id + ""));
                         showVideoNoAndroidQ(context, media.mediaType, ThumbnailsUtils.thumbnails.get(media.id + ""), view, loading, option);
                     } else {
+                        view.setTag(media.id);
                         showVideoThumbnail(context, media.mediaType, media.id, media.path, view, loading, option);
-//                        showVideoNoAndroidQ(context, media.mediaType, media.path, view, loading, option);
                     }
-//
                 }
-
             }
@@ -358,50 +349,57 @@ public class GlideCacheUtil {
         }
     }
+    private static void showAndroidQUri(Context context, Uri path, ImageView view, ProgressBar loading, RequestOptions option) {
+        RequestBuilder rb = Glide.with(context).load(path);
+        rb.listener(new RequestListener() {
+            @Override
+            public boolean onLoadFailed(@Nullable GlideException e, Object model, Target target, boolean isFirstResource) {
+                view.setScaleType(ImageView.ScaleType.CENTER);
+                if (loading != null) loading.setVisibility(View.GONE);
+                return false;
+            }
+
+            @Override
+            public boolean onResourceReady(Object resource, Object model, Target target, DataSource dataSource, boolean isFirstResource) {
+                if (loading != null) loading.setVisibility(View.GONE);
+                return false;
+            }
+        });
+
+        rb.apply(option).into(view);
+    }
+
     private static void showAndroidQ(Context context, int mediaType, Uri mediaUri, ImageView view, ProgressBar loading, RequestOptions option) {
+
         Observable.create(new ObservableOnSubscribe<Bitmap>() {
             @RequiresApi(api = Build.VERSION_CODES.LOLLIPOP)
             @Override
             public void subscribe(ObservableEmitter<Bitmap> emitter) throws Exception {
                 ContentResolver contentResolver = context.getContentResolver();
                 Bitmap bm = contentResolver.loadThumbnail(mediaUri, new Size(100, 100), null);
-                if (bm!=null){
+                if (bm != null) {
                     emitter.onNext(bm);
-                }else {
+                } else {
                     emitter.onError(new Throwable(""));
                 }
-
             }
         }).subscribeOn(Schedulers.computation()).observeOn(AndroidSchedulers.mainThread()).subscribe(new Observer<Bitmap>() {
             @Override
             public void onSubscribe(Disposable d) {
-
             }
             @Override
-            public void onNext(Bitmap bm) {
-
-                RequestBuilder rb = Glide.with(context).load(bm);
-                rb.listener(new RequestListener() {
-                    @Override
-                    public boolean onLoadFailed(@Nullable GlideException e, Object model, Target target, boolean isFirstResource) {
-                        view.setScaleType(ImageView.ScaleType.CENTER);
-                        if (loading != null) loading.setVisibility(View.GONE);
-                        return false;
-                    }
-
-                    @Override
-                    public boolean onResourceReady(Object resource, Object model, Target target, DataSource dataSource, boolean isFirstResource) {
-                        if (loading != null) loading.setVisibility(View.GONE);
-                        return false;
-                    }
-                });
-
-                rb.apply(option).into(view);
+            public void onNext(Bitmap bean) {
+                if (view.getTag() != null && mediaUri.toString().equals(view.getTag())) {
+                    showThumbnail(context, bean, view, loading, option);
+                }
             }
             @Override
             public void onError(Throwable e) {
+                if (view.getTag() != null && mediaUri.toString().equals(view.getTag())) {
+                    showAndroidQUri(context, mediaUri, view, loading, option);
+                }
                 if (loading != null) loading.setVisibility(View.GONE);
             }
@@ -452,11 +450,8 @@ public class GlideCacheUtil {
         rb.thumbnail(0.3f).apply(option).into(view);
     }
-    public static int count = 0;
     private static void showVideoThumbnail(Context context, int mediaType, long id, String path, ImageView view, ProgressBar loading, RequestOptions option) {
-//        Bitmap bm = getVideoThumbnail(context, id + "");
-//        showThumbnail(context, bm, view, loading, option);
 //        // 步骤1：创建被观察者 =  Flowable
         Flowable.create(new FlowableOnSubscribe<Bitmap>() {
             @Override
@@ -467,21 +462,17 @@ public class GlideCacheUtil {
                 } else {
                     emitter.onError(new Throwable(""));
                 }
-
-//                emitter.onComplete();
             }
         }, BackpressureStrategy.LATEST)
                 .subscribe(new Subscriber<Bitmap>() {
-                    // 步骤2：创建观察者 =  Subscriber & 建立订阅关系
-
                     @Override
                     public void onSubscribe(Subscription s) {
-//                        s.request(150);
                     }
                     @Override
                     public void onNext(Bitmap thumbnails) {
-                        showThumbnail(context, thumbnails, view, loading, option);
+                        if (view.getTag() != null && view.getTag().toString().equals(id + ""))
+                            showThumbnail(context, thumbnails, view, loading, option);
                     }
                     @Override
@@ -494,100 +485,9 @@ public class GlideCacheUtil {
                     public void onComplete() {
                     }
                 });
-
-
-        Observable.create(new ObservableOnSubscribe<Bitmap>() {
-            @Override
-            public void subscribe(ObservableEmitter<Bitmap> emitter) throws Exception {
-                count += 1;
-                Log.e("显示测试:", count + "");
-                Bitmap bitmap = getVideoThumbnail(context, id + "");
-                emitter.onNext(bitmap);
-//
-//                Cursor thumbCursor = null;
-//                Bitmap bitmap = null;
-//                    thumbCursor = context.getContentResolver().query(
-//                            MediaStore.Video.Thumbnails.EXTERNAL_CONTENT_URI,
-//                            null, MediaStore.Video.Thumbnails.VIDEO_ID
-//                                    + "=" + id, null, null);
-//                    if (thumbCursor.moveToFirst()) {
-//                        String albumPath = thumbCursor.getString(thumbCursor.getColumnIndex(MediaStore.Video.Thumbnails.DATA));
-//                        Log.e("显示测试地址:", albumPath);
-//                        bitmap = BitmapFactory.decodeFile(albumPath);
-//                        emitter.onNext(bitmap);
-//                    }else {
-//                        emitter.onNext(Bitmap.createBitmap(1,1,Bitmap.Config.RGB_565));
-//                    }
-
-
-            }
-        }).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(new Observer<Bitmap>() {
-            @Override
-            public void onSubscribe(Disposable d) {
-                Log.e("显示测试:--->", "onSubscribe:" + count + "");
-            }
-
-            @Override
-            public void onNext(Bitmap thumbnails) {
-                Log.e("显示测试:--->", "onNext:" + count + "");
-                showThumbnail(context, thumbnails, view, loading, option);
-
-            }
-
-            @Override
-            public void onError(Throwable e) {
-                showNoAndroidQ(context, mediaType, path, view, loading, option);
-                if (loading != null) loading.setVisibility(View.GONE);
-            }
-
-            @Override
-            public void onComplete() {
-                Log.e("显示测试:--->", "onComplete:" + count + "");
-            }
-        });
     }
-    private static void showImageThumbnail(Context context, int mediaType, int id, String path, ImageView view, ProgressBar loading, RequestOptions option) {
-        Observable.create(new ObservableOnSubscribe<Bitmap>() {
-            @Override
-            public void subscribe(ObservableEmitter<Bitmap> emitter) throws Exception {
-                Bitmap bm = null;
-                if (mediaType == 1) {
-                    bm = getImageThumbnail(context, id + "");
-                    emitter.onNext(bm);
-                }
-
-
-            }
-        }).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(new Observer<Bitmap>() {
-            @Override
-            public void onSubscribe(Disposable d) {
-
-            }
-
-            @Override
-            public void onNext(Bitmap thumbnails) {
-                if (thumbnails != null) {
-                    showThumbnail(context, thumbnails, view, loading, option);
-                } else {
-                    showNoAndroidQ(context, mediaType, path, view, loading, option);
-                }
-
-            }
-
-            @Override
-            public void onError(Throwable e) {
-                if (loading != null) loading.setVisibility(View.GONE);
-            }
-
-            @Override
-            public void onComplete() {
-
-            }
-        });
-    }
-
     private static void showThumbnail(Context context, Bitmap bm, ImageView view, ProgressBar loading, RequestOptions option) {
         RequestBuilder rb = Glide.with(context).load(bm);
         rb.listener(new RequestListener() {
@@ -619,7 +519,7 @@ public class GlideCacheUtil {
                             + "=" + videoId, null, null);
             if (thumbCursor.moveToFirst()) {
                 String albumPath = thumbCursor.getString(thumbCursor.getColumnIndex(MediaStore.Video.Thumbnails.DATA));
-                Log.d("缩略图----------------->:","id:"+videoId+"地址:"+ albumPath);
+                Log.d("缩略图----------------->:", "id:" + videoId + "地址:" + albumPath);
                 bitmap = BitmapFactory.decodeFile(albumPath);
                 return bitmap;
             }
@@ -635,14 +535,6 @@ public class GlideCacheUtil {
     public static Bitmap getImageThumbnail(Context context, String videoId) {
         Bitmap bitmap = null;
         Cursor thumbCursor = null;
-
-
-//        String[] projection = {MediaStore.Images.Thumbnails._ID, MediaStore.Images.Thumbnails.IMAGE_ID,
-//                MediaStore.Images.Thumbnails.DATA};
-//
-//        Cursor cursor = context.getContentResolver().query(MediaStore.Images.Thumbnails.EXTERNAL_CONTENT_URI, projection, null, null, null);
-//
-
         try {
             thumbCursor = context.getApplicationContext().getContentResolver().query(
                     MediaStore.Images.Thumbnails.EXTERNAL_CONTENT_URI,
@@ -36,10 +36,31 @@ public class ThumbnailsUtils {
             _id = cursor.getInt(_idColumn);
             image_id = cursor.getInt(image_idColumn);
             image_path = cursor.getString(dataColumn);
+            Log.e("缩略图视频:","--->videoId:"+image_id+" videoPath:"+image_path);
             thumbnails.put(image_id + "", image_path);
         }
+        getImageThumbnails(context);
+    }
+    public static void getImageThumbnails(Context context) {
+        String[] projection = {MediaStore.Images.Thumbnails._ID, MediaStore.Images.Thumbnails.IMAGE_ID,
+                MediaStore.Images.Thumbnails.DATA};
+        Cursor cursor = context.getContentResolver().query(MediaStore.Images.Thumbnails.EXTERNAL_CONTENT_URI, projection, null, null, null);
+        if (cursor == null) return;
+        while (cursor.moveToNext()) {
+            int _id;
+            int image_id;
+            String image_path;
+            int _idColumn = cursor.getColumnIndex(MediaStore.Images.Thumbnails._ID);
+            int image_idColumn = cursor.getColumnIndex(MediaStore.Images.Thumbnails.IMAGE_ID);
+            int dataColumn = cursor.getColumnIndex(MediaStore.Images.Thumbnails.DATA);
+            _id = cursor.getInt(_idColumn);
+            image_id = cursor.getInt(image_idColumn);
+            image_path = cursor.getString(dataColumn);
+            Log.e("缩略图图片:","--->image_id:"+image_id+" image_path:"+image_path);
+            thumbnails.put(image_id + "", image_path);
+        }
     }
+package com.cnlive.media.utils.glide;
+
+/**
+ * 作 者 : wkq
+ * <p>
+ * 时 间 : 2021/2/1 11:05
+ * <p>
+ * 名 字 : DataCacheKey
+ * <p>
+ * 简 介 :
+ */
+
+import com.bumptech.glide.load.Key;
+
+import java.security.MessageDigest;
+
+/**
+ * A cache key for original source data + any requested signature.
+ */
+public class DataCacheKey implements Key {
+
+    private final Key sourceKey;
+    private final Key signature;
+
+    public DataCacheKey(Key sourceKey, Key signature) {
+        this.sourceKey = sourceKey;
+        this.signature = signature;
+    }
+
+    public Key getSourceKey() {
+        return sourceKey;
+    }
+
+    @Override
+    public boolean equals(Object o) {
+        if (o instanceof DataCacheKey) {
+            DataCacheKey other = (DataCacheKey) o;
+            return sourceKey.equals(other.sourceKey) && signature.equals(other.signature);
+        }
+        return false;
+    }
+
+    @Override
+    public int hashCode() {
+        int result = sourceKey.hashCode();
+        result = 31 * result + signature.hashCode();
+        return result;
+    }
+
+    @Override
+    public String toString() {
+        return "DataCacheKey{"
+                + "sourceKey=" + sourceKey
+                + ", signature=" + signature
+                + '}';
+    }
+
+    @Override
+    public void updateDiskCacheKey(MessageDigest messageDigest) {
+        sourceKey.updateDiskCacheKey(messageDigest);
+        signature.updateDiskCacheKey(messageDigest);
+    }
+}