Rx_java（4）Rx_java2中的线程控制 从网络下载图片并显示在界面小案例

相关文章

观察者模式实例讲解

使用java中的类（Observable与Observer）实现观察者模式

Rx_java2的基本使用

Rx_java2操作符介绍1（Map、Flatmap）

Rx_java2操作符介绍2(debounce 、filter 、switchMap )

Rx_java2操作符介绍3（throttleFirst、debounce ）

Retrofit结合RxJava2使用

写在前面

在Android中，执行耗时任务，需要放在子线程中去，但是不能再子线程中更新ui，通常我们使用Handler或AsyncTask去完成这些操作。

我们知道Rx_java就是为了解决异步任务而出现的，在Rxjava中，用Scheduler来进行线程控制。

Scheduler有四个方法;首先对这个四个方法作个大概讲解，最后，再通过一个Rx_java的具体实例来加深对rxjava和Scheduler的理解。

Scheduler线程控制

Schedulers.immediate():

直接在当前线程运行，相当于不指定线程。这是默认的 Scheduler。

Schedulers.newThread():

总是启用新线程，并在新线程执行操作。

Schedulers.io():

I/O 操作（读写文件、读写数据库、网络信息交互等）所使用的 Scheduler。行为模式和 newThread() 差不多，区别在于 io() 的内部实现是是用一个无数量上限的线程池，可以重用空闲的线程，因此多数情况下 io() 比 newThread() 更有效率。不要把计算工作放在 io() 中，可以避免创建不必要的线程。

Schedulers.computation():

计算所使用的 Scheduler。这个计算指的是 CPU 密集型计算，即不会被 I/O 等操作限制性能的操作，例如图形的计算。这个 Scheduler 使用的固定的线程池，大小为 CPU 核数。不要把 I/O 操作放在 computation() 中，否则 I/O 操作的等待时间会浪费 CPU。

AndroidSchedulers.mainThread()：

它指定的操作将在 Android 主线程运行。

实例讲解：从网络下载一张图片，并显示在ImageView中

首先，需要在build.gradle中添加以下依赖

dependencies {
...
compile 'com.squareup.okhttp3:okhttp:3.7.0'
compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
compile 'io.reactivex.rxjava2:rxjava:2.1.7'
}

添加网络请求权限

<uses-permission android:name="android.permission.INTERNET"/>

创建HttpUtils类，创建downLoadImage方法，在此方法中，创建Observable，并返回，Observable中请求网络，获取图片数据

/**
* description:
* author: dujun
* created at: 2018/1/2 11:19
* update: 2018/1/2
* version:
*/
public class HttpUtils {
private OkHttpClient client;

public HttpUtils(){
client = new OkHttpClient();
}

/**
*
* @param path 图片路径
* @return
*/
public Observable<byte[]> downLoadImage(String path){
Observable<byte[]> observable = Observable.create(new ObservableOnSubscribe<byte[]>() {
@Override
public void subscribe(@NonNull ObservableEmitter<byte[]> observableEmitter) throws Exception {
// 请求网络
Request request = new Request.Builder().url(path).build();
Response response = client.newCall(request).execute();
if(response.isSuccessful()){
byte[] bytes = response.body().bytes();
if(bytes != null){
observableEmitter.onNext(bytes);
}
observableEmitter.onComplete();
}
}

});

return observable;
}
}

主界面下面放了一个按钮，上面放了一个ImageView，点击按钮，下载网络图片，并显示在ImageView上。

按钮的点击事件中我们绑观察者。

button.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
httpUtils.downLoadImage(path)
// 绑定
.subscribe(new Observer<byte[]>() {
Disposable mD = null;
@Override
public void onSubscribe(@NonNull Disposable d) {
mD = d;
}

@Override
public void onNext(@NonNull byte[] bytes) {

// 把字节流转换为bitmip，并显示在ImageView上面
Bitmap bitmap = BitmapFactory.decodeByteArray(bytes, 0, bytes.length);
mIv.setImageBitmap(bitmap);

}

@Override
public void onError(@NonNull Throwable e) {
Log.d(TAG,e.getMessage());
}

@Override
public void onComplete() {
Log.d(TAG,"complete");
}
});
}
});

现在我们点击按钮下载图片，查看log日志

异常信息为，在ui线程进行了网络请求，我们都知道，执行耗时操作都要放在子线程中，所以此时，我们需要用到线程调度器Schedulers，我们需要明白的是，我们创建的Observable和Observer都实在主线程中，现在我们需要在Observable的参数ObservableOnSubscribe的subscribe中执行耗时操作，所以，我们需要指定被观察者Observable在子线程中，所以，我们修改绑定时的代码为：



当我们点击按钮，图片并没有现在出来。当我们查看logcat



上面异常的意思就是我们在子线程更新了ui。

原因是，当我们调用了.subscribeOn(Schedulers.io())把时间注册在了子线程，因为，我们在onNext()方法中，吧下载的图片设置在了ImageView上，所以，更新ui的操作需要放在ui线程，我们调用

.observeOn(AndroidSchedulers.mainThread()指定观察者回调方法处在ui线程



再次运行项目，查看结果



图片现在显示完成。

写在后面

看完实例，在去回顾上面的Scheduler线程控制，在不同的情况下，使用不同的方法，通常用的多的是Schedulers.io():方法。线程控制就到这里，下篇将介绍Rx_java2的操作符。