[Android开发] RxJava2之路二 - 基本使用方法

2019-11-09 15:28:16

字体：大中小

来源：转载

供稿：网友

一、啥是RXjava

1.1 简介一个在Java Jvm上使用可观测的序列来组成异步的、基于事件的程序的库。概念很复杂，没所谓。我们先学会使用。

RxJava github地址： https://github.com/ReactiveX/RxJava RxJava github地址： https://github.com/ReactiveX/RxAndroid

建议查看他的wiki，可以看它内容，进行通篇的认识。

1.2 三个概念

Observable：被观察者(主题Subject)Observer/Subscriber：观察者Subscribe：订阅

Observable和Observer 通过subscribe() 方法实现订阅关系

//以前是通过add到被观察者里面进行订阅，然后change来进行通知。 RxJava是一旦订阅就发送。

二、使用三部曲

前提是先依赖了

compile 'io.reactivex.rxjava2:rxandroid:2.0.1'// Because RxAndroid releases are few and far between, it is recommended you also// explicitly depend on RxJava's latest version for bug fixes and new features.compile 'io.reactivex.rxjava2:rxjava:2.0.1'

2.1 使用方法1

创建被观察者Observable/** * 定义被观察者 * @return */public Observable<String> getObservable(){ return Observable.create(new ObservableOnSubscribe<String>() { @Override public void subscribe(ObservableEmitter e) throws Exception { //只要有三个方法onNext、onError、onCompleted //onNext类似观察者模式的change e.onNext("HI"); //发送数据 e.onNext("天平"); //发送数据 //发射完成,这种方法需要手动调用onCompleted，才会回调Observer的onCompleted方法 e.onComplete(); //onComplete 和 onError 只调用一个，两个都用只认前面那个 //e.onError(new Exception("错误啦!")); } });创建观察者 Observer/** * 生成观察者 * @return */public Observer<String> getObserver(){ return new Observer<String>() { @Override public void onError(Throwable e) { Log.d(TAG, "onError: "+e.getMessage()); //发生错误调用 } @Override public void onComplete() { Log.d(TAG, "onCompleted: "); //数据接收完成时调用 } /** * * @param d */ @Override public void onSubscribe(Disposable d) { //最先回调，没有执行onNext、onComplete、onError也会回调 Log.d(TAG, "onSubscribe: "+d.toString()); //d.dispose(); //移除订阅关系 //d.isDisposed(); //判断是否有订阅关系 } /** * 被观察者调用onNext这里就会回调 * @param s 参数 */ @Override public void onNext(String s) { Log.d(TAG, "onNext: "+s); //正常接收数据调用 System.out.PRint(s); //将接收到来自sender的问候"Hi，Weavey！" } };}订阅@Overrideprotected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); Observable<String> observable = getObservable(); Observer<String> observer = getObserver(); //关联观察者和被观察者-> 订阅 observable.subscribe(observer);}

2.2 使用方法2

上面那样创建被观察者创建观察者

已经包含订阅

observable.subscribe(new Consumer<String>() { @Override public void accept(String s) throws Exception { //这个accept就等于观察者的onNext Log.e(TAG, "accept: "+s); } }, new Consumer<Throwable>() { @Override public void accept(Throwable throwable) throws Exception { //onError } }, new Action() { @Override public void run() throws Exception { } });

2.3 使用方法3

生成被观察者/** * 生成被观察者 * @return */public Observable<String> getObservable(){ //依次发送"just1"和"just2" return Observable.just("just1","just2");}定义观察者

包含了订阅

Observable<String> observable = getObservable();observable.subscribe(new Consumer<String>() { @Override public void accept(String s) throws Exception { //这个accept就等于观察者的onNext Log.e(TAG, "accept: "+s); }});

2.4 使用方法4

生成被观察者/** * 生成被观察者 * @return */public Observable<String> getObservable(){ return Observable.fromArray("from1","from2","from3");}定义观察者和上面一致

2.5 使用方法5

生成被观察者/** * 生成被观察者 * @return */public Observable<String> getObservable(){ return Observable.fromCallable(new Callable<String>() { @Override public String call() throws Exception { return "fromCallable"; } });}定义观察者和上面一致

上一篇：cacheColorHint，android:listSelector属性

下一篇：Android 平滑图片加载和缓存库 Glide 使用详解