1.本文仅基于RxJava2.0、Retrofit2.0(引入背压)
当下Rxjava,Retrofit已成项目标配，为了提升自己逼格，本人最近也重新加入Rx大队伍中，其实一年前就使用过Rxjava1、Retrofit写过项目，但是后来因为种种原因，没能继续探索下去，现如今重新拾起，希望能有一个好的结果。
RxJava引入的目的：异步，代码更清晰
优点：采用观察者模式链式调用，简洁明了，以往实现子线程主线程切换需自己手动new Thread(推荐线程池)，并且线程之间还需要使用handler进行通信，Rxjava一步到位，极其简单
1.基础概念：
Observable：在观察者模式中称为“被观察者”；
Observer：观察者模式中的“观察者”，可接收Observable发送的数据；
subscribe：订阅，观察者与被观察者，通过subscribe()方法进行订阅；
Subscriber：也是一种观察者，在2.0中 它与Observer没什么实质的区别，不同的是 Subscriber与 Flowable(也是一种被观察者)联合使用，该部分内容是2.0新增的，后续文章再介绍。
Flowable:也是悲观餐者的一种，与Subscriber进行配合使用，实现背压操作
总结：观察者订阅被观察者，Obsesrver用于订阅Observable,而Subscriber用于订阅Flowable
具体可以解释为：A 对象（观察者）对 B 对象（被观察者）的某种变化高度敏感，需要在 B 变化的一瞬间做出反应。
注意：Observer是个接口，Observable是个类。
RxJava的异步实现方式：让Observable (被观察者)开启子线程执行耗操作，完成耗时操作后，触发回调，通知Observer (观察者)进行主线程UI更新。如此轻松便可以实现Android中的异步，且代码简洁明了，集中分布。RxJava中默认Observer (观察者)和Observable (被观察者)都在同一线程执行任务。
2.RxJava常用操作符
操作符就是用于在Observable和最终的Observer之间，通过转换Observable为其他观察者对象的过程，修改发出的事件，最终将最简洁的数据传递给Observer对象
map()操作符，就是把原来的Observable对象转换成另一个Observable对象，同时将传输的数据进行一些灵活的操作，方便Observer获得想要的数据形式。
flatMap()操作符 返回任何它想返回的Observable对象。
filter()操作符 过滤出想要的
take()操作符：输出最多指定数量的结果
doOnNext()允许我们在每次输出一个元素之前做一些额外的事情
3.Scheduler（调度器）切换线程
Schedulers.immediate(): 直接在当前线程运行，相当于不指定线程。默认的
Schedulers.newThread(): 总是启用新线程，并在新线程执行操作。
Schedulers.io(): I/O 操作（读写文件、读写数据库、网络信息交互等）所使用的 Scheduler。能够重用空闲的线程
Schedulers.computation(): 计算所使用的 Scheduler。这个计算指的是 CPU 密集型计算，即不会被 I/O 等操作限制性能的操作，例如图形的计算。
AndroidSchedulers.mainThread()，它指定的操作将在 Android 主线程运行。
subscribeOn(): 指定Observable(被观察者)所在的线程，或者叫做事件产生的线程。
observeOn(): 指定 Observer(观察者)所运行在的线程，或者叫做事件消费的线程。
4.Flowable与Subscriber
BackpressureStrategy.ERROR 在ERROR策略下，如果缓存池溢出，就会立刻抛出MissingBackpressureException异常
BackpressureStrategy.BUFFER 支持存很多很多的数据,不会产生OOM,总之BUFFER要慎用
BackpressureStrategy.DROP 当消费者处理不了事件，就丢弃。
BackpressureStrategy.LATEST 与DROP功能基本一致,唯一的区别就是LATEST总能使消费者能够接收到生产者产生的最后一个事件。
具体使用：
一.导入配置，使用 Gradle 方式添加依赖：
二、创建retrofit
1)因为需要跟okhttp配合使用，故先创建okhttpclient
2)创建retrofit
3)定义具体逻辑接口和bean对象
4）最后就可以愉快的使用啦
后续会推出更多相关文章！
网友评论