初探Rxjava2

2017-11-01 本文已影响0人 beatzcs

Rxjava的基本概念：

1.自我介绍：

a library for composing asynchronous and event-based programs using observable sequences for the Java VM"

一个在 Java VM 上使用可观测的序列来组成异步的、基于事件的程序的库。

2.特性：

1.异步

2.简洁

ps：随着代码量的增加，Rxjava可以保持逻辑的简洁明了，替代了层层的嵌套。

3.角色：

1.观察者：Observer/Subscriber

2.被观察者：Observable/Flowable

3.订阅/注册：subscribe

ps：实际开发中常用到的两个组合Observable/Observer和Flowable/Subscriber。

Rxjava的基本使用：

1.引入：

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

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

2.步骤：

1.创建被观察者，生产事件；

2.根据需求利用操作符来实现事件传递中的变换等加工操作；

3.订阅观察者，实现事件处理。

talk is less

1.创建

Observable

Observer

Observable其他创建方式：

just()，from()，fromIterable()，range( )，timer( )，repeat( )，defer()

2.Consumer

没必要使用Observer时，可以根据需要使用Consumer来分别实现

等价于Observer/Subscriber

subscribe函数参数

3.ActionX/FuncX

相较于Rxjava1.x的改动如下：

其中，Action0 改名成Action，Action1改名成Consumer，而Action2改名成了BiConsumer，而Action3 - Action9都不再使用了，ActionN变成了Consumer。

同样，Func改名成Function，Func2改名成BiFunction，Func3 - Func9 改名成 Function3 - Function9，FuncN 由Function取代。

4.操作符

map()操作符

flatMap()操作符

filter()操作符

take()操作符

doOnNext()

lift()和compose()等操作符可参考给 Android 开发者的 RxJava 详解、给初学者的RxJava2.0教程。

5.线程调度

如果不指定线程的话，Rxjava是同步进行的，即在哪个线程调用subscribe()就在那个线程生产事件和消费事件，切换线程使用Schedule调度器。

Schedule线程控制器：

1.Schedulers.immediate()：默认的，直接在当前线程执行，相当于不指定线程。

2.Schedulers.newThread()：总是启用新线程，在新线程执行操作。

3.Schedulers.io()：耗时操作（读写文件、读写数据库、访问网络等），和newThread()的区别在于，io() 的内部实现是用一个无数量上限的线程池，可以重用空闲的线程，因此多数情况下 io() 比 newThread() 更有效率。注意不要把计算工作放在 io() 中，可以避免创建不必要的线程。

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

5.AndroidSchedulers.mainThread()：指定的操作将在 Android 主线程运行。

调用方式：

1.subscribeOn()：指定Observable（被观察者）所在线程，或叫做事件产生的线程。

2.observeOn()：指定Observer（观察者）所在线程，或叫做事件消费的线程。