Retrofit&&RXJava傻瓜式入门（下）

2016-08-12 本文已影响493人 blink_dagger

官网给出的文档指出RXJava是一个通过观察序列来构成异步和基于事件的程序库，我们将它傻瓜地理解为一个帮助我们简化异步操作的库即可。通过RXJava提供的链式API，我们可以很清晰地处理多线程的异步操作。

在正式介绍RXJava前，我们可以先简单了解下观察者模式。

观察者（Observer）与被观察者（Observable）通过订阅Subscribe的形式联系起来，被观察者在准备OK的时候通过回调方法通知观察者，从而观察者能及时作出对应处理。
经典案例便是Button的点击操作，我们为Button设置的clickListener就可抽象理解为一个观察者，而Button本身就是被观察者，当我们点击按钮时就会把点击事件告知Listener，让我们得以处理点击事件。不明白回调机制的同学可以点这里。
了解了观察者模式那就可以继续往下看RXJava的简单用法和其逻辑的清晰性。

RXJava的傻瓜使用方式：

1 创建观察者

        Subscriber<String> subscriber = new Subscriber<String>() {
            @Override
            public void onNext(String s) {
            }

            @Override
            public void onCompleted() {
            }

            @Override
            public void onError(Throwable e) {
            }

            @Override
            public void onStart() {
            }
        };
    }

这里的Subscriber是RXJava已经实现的一个观察者抽象类，其内部有我们常用的四个方法。
onNext()：事件回调方法
onCompleted()：事件完成标识
onError():事件异常标识
onStart()：事件还会开始时执行此方法，可用来做一些loading操作

2创建被观察者

Observable observable = Observable.create(new Observable.OnSubscribe<String>() {
    @Override
    public void call(Subscriber< > subscriber) {
        subscriber.onNext("");
        subscriber.onCompleted();
    }
});

需要注意的是onCompleted()与onError互相排斥，仅且只能存在一个。除了通过Observable.create的方式来创建被观察者，还可以通过.just(T)、.from(T[])来快速创建，这儿不再额外叙述。

3通过Scheduler调度线程
讲了这么多，终于到了控制线程的地方啦！我们可以通过Scheduler指定事件产生、回调、订阅、解订的线程，直接上代码：

observable
     .subscribeOn(Schedulers.io()) // 指定 subscribe() 发生在 IO 线程
     .observeOn(AndroidSchedulers.mainThread()) // 指定 Subscriber 的回调发生在主线程

这样我们就可已很清晰地在IO线程进行网络请求等耗时操作，在主线程更新UI。除了这两个线程外，还有很多其他线程可供选择，在这不再扩展。

4完成订阅 Subscribe

observable.subscribe(subscriber);

傻瓜式入门教学到这结束，此文的宗旨只是为了让初学者了解RXJava,不做深究其map,lift等变换。下面可以看一下具体的demo实现。

Retrofit&&RXJava结合 demo

1 将我们创建的Retrofit API接口返回值从Call改为Observable

public interface DoubanAPI {
    @GET("v2/movie/us_box")
    Observable<MovieInfo> getUSMovie();
}

2 实例化retrofit时添加以下Factory方法

 .addCallAdapterFactory(RxJavaCallAdapterFactory.create())

3 通过接口函数获取被观察者，然后就能愉快地进行我们想要的操作了。

  doubanService.getUSMovie().subscribeOn(Schedulers.io())
                           .unsubscribeOn(Schedulers.io())
                           .observeOn(AndroidSchedulers.mainThread())
                           .subscribe(subscriber);

4 最后将回调事件中获取到的数据传递给我们封装的adapter中，就万事具备了～

            @Override
            public void onCompleted() {
                Toast.makeText(MainActivity.this, "getUSMovie Completed", Toast.LENGTH_SHORT).show();
            }

            @Override
            public void onError(Throwable e) {
                //mTextView.setText(e.getMessage());
                Toast.makeText(MainActivity.this, e.getMessage(), Toast.LENGTH_SHORT).show();
                Log.e("lxg",e.getMessage());
            }

            @Override
            public void onNext(MovieInfo movieInfo) {

                if (movieInfo.getSubjects() != null) {
                    if (list != null) {
                        list.clear();
                    }
                    list.addAll(movieInfo.getSubjects());
                    adapter.notifyDataSetChanged();
                }
            }

        if (list != null) {
            adapter=new CommonRecyclerAdapter<MovieInfo.SubjectsBean>(this,R.layout.movie_item,list) {


                @Override
                protected void convert(ViewHolder holder, MovieInfo.SubjectsBean subjectBean) {
                    holder.setText(R.id.titleTextView,subjectBean.getSubject().getTitle());
                    holder.setImageURI(R.id.contentImageView,subjectBean.getSubject().getImages().getLarge());
                }
            };
            mrecycler.setAdapter(adapter);
        }

解析后的Json数据只需取我们要用的list即可，这样一个异步获取网络数据并更新ui的简单界面就完成了。

Retrofit&&RXJava傻瓜式入门（下）

RXJava的傻瓜使用方式：

Retrofit&&RXJava结合 demo

猜你喜欢

热点阅读