RxAndroid和RxJava结合OkGo示例请求网络图片加载到不同ImageView

缺乏、安全感 2023-10-17 11:59 23阅读 0赞

**RxAndroid和RxJava结合OkGo示例请求网络图片加载到不同ImageView**

代码：

package zhangphil.app;
    
    import android.app.Activity;
    import android.graphics.Bitmap;
    import android.graphics.BitmapFactory;
    import android.os.Bundle;
    import android.support.annotation.Nullable;
    import android.util.Log;
    import android.widget.ImageView;
    import android.widget.TextView;
    
    import com.lzy.okgo.OkGo;
    
    import java.util.ArrayList;
    import java.util.List;
    import java.util.UUID;
    
    import io.reactivex.Observable;
    import io.reactivex.android.schedulers.AndroidSchedulers;
    import io.reactivex.functions.Function;
    import io.reactivex.observers.DisposableObserver;
    import io.reactivex.schedulers.Schedulers;
    import okhttp3.Response;
    
    
    /**
     * 本例使用RxAndroid和RxJava，结合Okgo，在一个最普遍的应用场景，
     * 比如有两个ImageView，给每个ImageView请求给定的url，请求回Bitmap后，分别装载到相应的ImageView。
     * 这种情况在实际的开发中十分常见，本利给出一个基本用法，由此可以举一反三变化出更多更复杂的用法。
     *
     */
    
    
    public class MainActivity extends Activity {
    
        private final String TAG = String.valueOf(UUID.randomUUID());
    
        private DisposableObserver<MyItem> mObserver = new DisposableObserver<MyItem>() {
    
            @Override
            public void onNext(MyItem item) {
                item.image.setImageBitmap(item.bitmap);
                item.text.setText(item.url);
            }
    
            @Override
            public void onComplete() {
                Log.d(TAG, "onComplete");
            }
    
            @Override
            public void onError(Throwable e) {
                Log.e(TAG, e.toString(), e);
            }
        };
    
    
        @Override
        public void onCreate(@Nullable Bundle savedInstanceState) {
            super.onCreate(savedInstanceState);
            setContentView(R.layout.activity_main);
            ImageView image1 = (ImageView) findViewById(R.id.image1);
            ImageView image2 = (ImageView) findViewById(R.id.image2);
    
            TextView text1 = (TextView) findViewById(R.id.text1);
            TextView text2 = (TextView) findViewById(R.id.text2);
    
            String url1 = "http://avatar.csdn.net/9/7/A/1_zhangphil.jpg";
            String url2 = "http://avatar.csdn.net/9/7/A/2_zhangphil.jpg";
    
            List<MyItem> lists = new ArrayList<>();
    
            MyItem i1 = new MyItem();
            i1.image = image1;
            i1.url = url1;
            i1.text = text1;
            lists.add(i1);
    
            MyItem i2 = new MyItem();
            i2.image = image2;
            i2.url = url2;
            i2.text = text2;
            lists.add(i2);
    
            Observable mObservable = Observable
                    .just(lists)
                    .flatMap(function)
                    .map(getBitmap)
                    .subscribeOn(Schedulers.io()) //执行任务的线程
                    .observeOn(AndroidSchedulers.mainThread()); //回调发生的线程
    
            //建立订阅关系
            mObservable.subscribe(mObserver);
    
            //mObservable.subscribe(mConsumer);
        }
    
        private class MyItem {
            public ImageView image;
            public Bitmap bitmap;
            public TextView text;
            public String url;
        }
    
        private Function<MyItem, MyItem> getBitmap = new Function<MyItem, MyItem>() {
            @Override
            public MyItem apply(MyItem item) throws Exception {
                //同步方法返回观察者需要的数据结果
                //在这里处理线程化的操作
                Response response = OkGo.get(item.url).tag(TAG).execute();
    
                try {
                    if (response.isSuccessful()) {
                        byte[] bytes = response.body().bytes();
                        item.bitmap = BitmapFactory.decodeByteArray(bytes, 0, bytes.length);
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }
    
                return item;
            }
        };
    
    
        // 设置映射函数
        private Function<List<MyItem>, Observable<MyItem>> function = new Function<List<MyItem>, Observable<MyItem>>() {
    
            @Override
            public Observable<MyItem> apply(List<MyItem> lists) {
                MyItem[] items = new MyItem[lists.size()];
                for (int i = 0; i < lists.size(); i++) {
                    items[i] = lists.get(i);
                }
                return Observable.fromArray(items);
            }
        };
    
    
        //如果只是接受处理结果，那么可以不用DisposableObserver，而用Consumer（消费）
    //    private Consumer mConsumer = new Consumer<Bitmap>() {
    //        @Override
    //        public void accept(Bitmap bmp) throws Exception {
    //            image.setImageBitmap(bmp);
    //        }
    //    };
    
    
        @Override
        protected void onDestroy() {
            super.onDestroy();
            OkGo.getInstance().cancelTag(TAG);
        }
    }

布局文件：

<?xml version="1.0" encoding="utf-8"?>
    <LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
        android:id="@+id/activity_main"
        android:layout_width="match_parent"
        android:layout_height="match_parent"
        android:orientation="vertical">
    
        <ImageView
            android:id="@+id/image1"
            android:layout_width="wrap_content"
            android:layout_height="wrap_content"
            android:layout_gravity="center_horizontal" />
    
        <TextView
            android:id="@+id/text1"
            android:layout_width="match_parent"
            android:layout_height="wrap_content"
            android:textColor="@android:color/black" />
    
        <View
            android:layout_width="match_parent"
            android:layout_height="50dp"
            android:background="@android:color/holo_orange_light" />
    
        <ImageView
            android:id="@+id/image2"
            android:layout_width="wrap_content"
            android:layout_height="wrap_content"
            android:layout_gravity="center_horizontal" />
    
        <TextView
            android:id="@+id/text2"
            android:layout_width="match_parent"
            android:layout_height="wrap_content"
            android:textColor="@android:color/black" />
    </LinearLayout>

不要忘记在build.gradle配置：

compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
        compile 'io.reactivex.rxjava2:rxjava:2.0.1'
    
        compile 'com.lzy.net:okgo:+'        //版本号使用 + 可以自动引用最新版
        compile 'com.lzy.net:okserver:+'    //版本号使用 + 可以自动引用最新版

运行结果如图：

![Center][]

致谢：

冯祖学对本文有重大贡献！

[Center]: https://img-blog.csdn.net/20170325135814741?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvemhhbmdwaGls/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center