RxJava2系列(一) 简单使用

<h1>一、基本概念</h1>
 <img alt="" src="https://beijingoptbbs.oss-cn-beijing.aliyuncs.com/cs/5606289-30b2c58b728cc178e7e52a0bd1082fb4.png">
<h2>1、定义 </h2>
RxJava在GitHub上《<a href="https://github.com/ReactiveX/RxJava">RxJava</a>》的自我介绍是：a library for composing asynchronous and event-based programs using observable sequences for the Java VM.(一个在Java VM 上使用可观测的序列来组成异步的，基于事件的程序的库)，有些人可能感到疑惑，其实本质上可以用一词来概括——“异步”，它就是一个异步的操作库，而别的定语都基于这之上。
<h2>2、优点</h2>
简洁
异步操作很关键的一点是简洁性，因为在调度过程比较复杂的情况下，异步代码既难写也难读懂。Android创造的Handler和AsyncTask其实都是为了让异步代码更加简洁，RxJava的优势也是简洁，它的特别之处是：随着程序代码逻辑的变得越来越复杂，它依然保持简洁。 
响应式编程
它是一种基于异步数据流概念的编程模式。数据流就像一条河：它可以被观测，被过滤，被操作，或者为新的消费者与另外一条流合并为一条新的流。
响应式编程的一个关键概念是事件。事件可以被等待，可以触发过程，也可以触发其它事件。事件是唯一的以合适的方式将我们的现实世界映射到我们的软件中：如果屋里太热了我们就打开一扇窗户。同样的，当我们的天气app从服务端获取到新的天气数据后，我们需要更新app上展示天气信息的UI；汽车上的车道偏移系统探测到车辆偏移了正常路线就会提醒驾驶者纠正，就是是响应事件。
今天，响应式编程最通用的一个场景是UI：我们的移动App必须做出对网络调用、用户触摸输入和系统弹框的响应。在这个世界上，软件之所以是事件驱动并响应的是因为现实生活也是如此。
 
<h1>二、基本使用</h1>
<h2>1、观察者模式</h2>
观察者模式面向的需求是:A对象(观察者)对B对象(被观察者)的某种变化高度敏感，需要在B对象变化的一瞬间做出变化。程序的观察者模式，观察者不需要时刻盯着被观察者，而是采用注册(Regsiter)或者订阅(Subscribe)的方式，告诉被观察者，我是你的某种状态，你的状态在发生变化的时候来通知我。
<ul><li>Observable ( 被观察者 ) / Observer ( 观察者 )</li><li> Flowable （被观察者）/ Subscriber （观察者） </li></ul>
 <img alt="" height="414" src="https://beijingoptbbs.oss-cn-beijing.aliyuncs.com/cs/5606289-24ae1c8a6befe5e8cf4daef26b88f631.png" width="600">
<h2>2、背压</h2>
背压是指在异步场景中，被观察者发送事件速度远快于观察者的处理速度的情况下，一种告诉上游的被观察者降低发送速度的策略。简而言之，背压是流速控制的一种策略。
由于基于FLowable发射的数据流，以及对数据加工处理的各种操作符都添加的背压支持，附加额外的逻辑，其运行效率要比Observable慢的多。
大数据流用Flowable，小数据流用Observable
 51 回复
<h2>3、三部曲</h2>
<ul><li>第一步：初始化 Observable //观察者，它决定事件发生时有怎么样的行为；</li><li>第二步：初始化 Observer // 被观察者，它决定什么时候出发事件以及触发什么样的事件；</li><li>第三步：建立订阅关系subscribe() //订阅，将Observer和Observable关联起来。</li></ul>
<pre class="blockcode"><code class="language-java"> //1、创建被观察者Observable
 Observable<String> observable = Observable.create(new ObservableOnSubscribe<String>() {
 @Override
 public void subscribe(ObservableEmitter<String> e) throws Exception {
 e.onNext("1");
 e.onNext("2");
 e.onNext("3");
 e.onComplete();
 }
 });

 //2、创建观察者Observer
 Observer<String> observer =