RxJava2配置及使用详解

 更新时间:2017年06月30日 10:09:38   作者:惜梦哥哥_  
这篇文章主要介绍了RxJava2配置及使用详解,RxJava2.0是一个非常棒的流式编程,有兴趣的可以了解一下

RxJava2.0是一个非常棒的流式编程,采用的观察者模式思想,事件的产生者产生事间之后发送给绑定的接受者,接受顺序与发送顺序一致.

依赖:

compile 'io.reactivex.rxjava2:rxjava:2.0.1'
compile 'io.reactivex.rxjava2:rxandroid:2.0.1'

简单使用:

//观察者模式,这里产生事件,事件产生后发送给接受者,但是一定要记得将事件的产生者和接收者捆绑在一起,否则会出现错误
Observable.create(new ObservableOnSubscribe<String>() {
  @Override
  public void subscribe(ObservableEmitter<String> e) throws Exception {
    //这里调用的方法会在产生事件之后会发送给接收者,接收者对应方法会收到
    e.onNext("hahaha");
    e.onError(new Exception("wulala"));
    e.onComplete();
  }/*--
}).subscribe(new Observer<String>() {
  //接受者,根据事件产生者产生的事件调用不同方法
  @Override
  public void onSubscribe(Disposable d) {
    Log.e(TAG, "onSubscribe: ");
  }

  @Override
  public void onNext(String value) {
    Log.e(TAG, "onNext: " + value);
  }

  @Override
  public void onError(Throwable e) {
    Log.e(TAG, "onError: ", e);
  }

  @Override
  public void onComplete() {
    Log.e(TAG, "onComplete: ");
  }
});

我们来用图解一下这其中发生了什么事:


上游朝下游发送数据,经过subscribe使上下游产生关系,即达成订阅.

解析1:

ObservableEmitter,这是个啥东西?Emitter:顾名思义,即Rxjava的发射器,通过这个发射器,即可发送事件-----通过调用onNext,onError,onComplete方法发送不同事件.

注意:

虽然RxJava可以进行事件发送,但这并不意味着你可以随便发送,这其中需要遵循一些规则.

onNext:你可以发送无数个onNext,发送的每个onNext接受者都会接收到.

onError:当发送了onError事件之后,发送者onError之后的事件依旧会继续发送,但是接收者当接收到onError之后就会停止接收事件了.

onComplete:当发送了onComplete事件之后,发送者的onComplete之后的事件依旧会继续发送,但是接收者接收到onComplete之后就停止接收事件了.

onError事件和onComplete事件是互斥的,但是这并不代表你配置了多个onError和onComplete一定会崩溃,多个onComplete是可以正常运行的,但是只会接收到第一个,之后的就不会再接收到了,多个onError时,只会接收到第一个,第二个会直接造成程序崩溃. 

解析2:

Disposable又是个啥东西,翻译之后百度告诉我这东西叫做一次性的,是用来控制发送者和接受者之间的纽带的,默认为false,表示发送者和接受者直接的通信阀门关闭,可以正常通信,在调用dispose()方法之后,阀门开启,会阻断发送者和接收者之间的通信,从而断开连接.

重载方法:

     subscribe();     //表示发送者随意发送数据,接受者什么都不管,什么都不接收.
     subscribe(Consumer<? super T> onNext) {}   //只响应onNext()事件,其他的事件忽略.
     subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError) {}     //含义同上
     subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete) {}     //含义同上
     subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete, Consumer<? super Disposable> onSubscribe) {}   //含义同上

解析3:

默认情况下,发送者和接收者都运行在主线程,但是这显然是不符合实际需求的,我们在日常使用中,通常用的最多的就是在子线程进行各种耗时操作,然后发送到主线程进行,难道我们就没有办法继续用这个优秀的库了?想多了你,一个优秀的库如果连这都想不到,怎么能被称为优秀呢,RxJava中有线程调度器,通过线程调度器,我们可以很简单的实现这种效果,下面放代码.

Observable.create(new ObservableOnSubscribe<String>() {
  @Override
  public void subscribe(ObservableEmitter<String> e) throws Exception {
    e.onNext("hahaha");
    e.onNext("hahaha");
    e.onNext("hahaha");
    Log.e(TAG,"运行在什么线程" + Thread.currentThread().getName());
    e.onComplete();
  }
}).subscribeOn(Schedulers.newThread())        //线程调度器,将发送者运行在子线程
 .observeOn(AndroidSchedulers.mainThread())     //接受者运行在主线程
 .subscribe(new Observer<String>() {
  @Override
  public void onSubscribe(Disposable d) {
    Log.e(TAG, "onSubscribe: ");
    Log.e(TAG,"接收在什么线程" + Thread.currentThread().getName());
  }

  @Override
  public void onNext(String value) {
    Log.e(TAG, "onNext: " + value);
  }

  @Override
  public void onError(Throwable e) {
    Log.e(TAG, "onError: ", e);
  }

  @Override
  public void onComplete() {
    Log.e(TAG, "onComplete: ");
  }
});

最终结果:


可以看到我们只加了两行代码,就实现了效果,还有比这个更优秀,更简单的么?

注意事项:

subscribeOn(),只有在第一次调用的时候生效,之后不管调用多少次,只会以第一次为准.

observeOn(),可以被调用多次,每次调用都会更改线程.

RxJava线程池中的几个线程选项

  1.  - Schedulers.io()      io操作的线程, 通常io操作,如文件读写.
  2.  - Schedulers.computation()      计算线程,适合高计算,数据量高的操作.
  3.  - Schedulers.newThread()      创建一个新线程,适合子线程操作.
  4. - AndroidSchedulers.mainThread()      Android的主线程,主线程

本文介绍简单使用,以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

相关文章

  • Android 仿微信小程序入口动画

    Android 仿微信小程序入口动画

    突然发现微信下拉小程序入口动画非常细腻,比较好奇,所以仿照他做了一个,并不是很完美,部分效果还没完成,但总体自我感觉还不错,效果见下文
    2021-06-06
  • android图像绘制(四)自定义一个SurfaceView控件

    android图像绘制(四)自定义一个SurfaceView控件

    自定义控件(类似按钮等)的使用,自定义一个SurfaceView。如某一块的动态图(自定义相应),或者类似UC浏览器下面的工具栏,感兴趣的朋友可以了解下
    2013-01-01
  • Android编程中聊天页面背景图片、标题栏由于键盘引起问题的解决方法

    Android编程中聊天页面背景图片、标题栏由于键盘引起问题的解决方法

    这篇文章主要介绍了Android编程中聊天页面背景图片、标题栏由于键盘引起问题的解决方法,针对键盘弹出时标题栏及背景图片异常的相关解决方法,具有一定参考借鉴价值,需要的朋友可以参考下
    2015-10-10
  • Android Mms之:接收信息流程(图文详解)

    Android Mms之:接收信息流程(图文详解)

    本篇文章是对Android中的接收信息流程进行了详细的分析介绍,需要的朋友参考下
    2013-05-05
  • Android开发笔记之:ListView刷新顺序的问题详解

    Android开发笔记之:ListView刷新顺序的问题详解

    本篇文章是对Android中ListView刷新顺序的问题进行了详细的分析介绍,需要的朋友参考下
    2013-05-05
  • 解析Android框架之Volley源码

    解析Android框架之Volley源码

    我们知道Volley是在2013年Google I/O大会上推出了一个新的网络通信框架,他的设计目的就是为了那些请求数据量不是特别大,但是又是特别频繁的网络操作非常适合。但是对于数据量较大的请求,比如说下载一个较大的文件,Volley可能相比于其他的框架,就有点不足了。
    2021-06-06
  • Android中常见的图形绘制方式总结

    Android中常见的图形绘制方式总结

    Android中绘制图片或形状是我们常遇到的事情,通过最近的学习与在网上学习的案例与资料那么我今天就总结一下,这篇文章主要给大家介绍了关于Android中常见的图形绘制方式,需要的朋友可以参考下
    2021-07-07
  • 老生常谈ProgressBar、ProgessDialog的用法

    老生常谈ProgressBar、ProgessDialog的用法

    下面小编就为大家带来一篇老生常谈ProgressBar、ProgessDialog的用法。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-07-07
  • Android开发实现简单计算器功能

    Android开发实现简单计算器功能

    这篇文章主要为大家详细介绍了Android开发实现简单计算器,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2021-06-06
  • Android Service(不和用户交互应用组件)案例分析

    Android Service(不和用户交互应用组件)案例分析

    Service是在一段不定的时间运行在后台,不和用户交互应用组件,本文将详细介绍,需要了解的朋友可以参考下
    2012-12-12

最新评论