在学习RxJava的时候，经常提到观察者与被观察者，这不就是JAVA的观察者模式的运用么？是的，但是跟传统意义的上观察者模式还不太一样，所以Rxjava实际上是一种扩展的观察者模式，所以有必要对这个扩展的观察者模式做进一步的了解。
最简单的观察者模式：
对于之前写的关于Rxjava的代码先回顾一下：
但是如果我们不要修改事件，就不需要在Observable和Subscriber【它是Observer的子类】中插入Operator，那么时间Rxjava的结构如下：
Observable--->Subscriber
这看起来很像设计模式的观察者模式，但是有个重要的区别之一在于在没有Subscriber之前，Observable不会产生事件。
普通的观察者模式：
对于普通的观察者模式这里不多说，简单概念它就是：观察者(Observer)需要在被观察者(Observable)变化的一顺间做出反应。而两者通过注册(Register)或者订阅(Subscrible)的方式进行绑定。如下图所示：
RxJava--扩展的观察者模式：
而Rxjava的观察者模式跟上面普通的观察者模式差不多，但是也有几点差别：
- Observer与Observable是通过subscrible()来达成订阅关系。
- Rxjava中的事件回调有三种：onNext()、onCompleted()、onError()。
- 如果一个Observable没有任何的Observer，那么这个Observable是不会发出任何事件的。
其中关于第三点，需要说明一下，在Rxjava中其实Observable有两种形式：热启动Observable和冷启动Observable:
- 热启动Observable任何时候都会发送消息，即使没有任何观察者监听它。【它没有什么实际意义，所以说了解下既可】
- 冷启动Observable只有在至少有一个订阅者的时候才会发送消息。【所以工作中使用的都是冷启动】
RxJava的观察者模式：
相比普通观察者模式，RxJava的观察者模式如下图：
当一个事件触发时，会有一些方法回调，如下：
- onNext():基本事件。
- onCompleted()事件队列完结。RxJava不仅把每个事件单独处理，还会把它们看作一个队列，RxJava规定，当不会再有新的onNext()事件发出时，需要触发onCompleted()方法作为标志。
- onError()事件队列异常，在事件过程中出现异常时，onError()会被触发，同时队列自动终止，不允许再有事件发出。
RxJava的实现和使用【之前开篇已经有介绍过，这里再细致回顾下】：
RxJava的实现主要有如下三步：
第一步：创建观察者Observer。
第二步：创建被观察者Observable。
第三步：Subscribe(订阅)（被观察者Observable订阅观察者Observer，注意：不同于普通观察者，这里是被观察者订阅观察者）。
所以贴出之前实现过的代码：
编译运行：
这时制造一个异常再看下输出：
编译运行：
从打印中可以看出，onError()和onCompleted()是不共戴天滴。
编译运行：
那既然观察者有两个：Observer和Subscriber，那这两者有啥区别呢？当然是有区别滴，不过在未来会进行学习，这里先有个印象。
另外在Rxjava中，如果对于事件回调中，只想要onNext()方法，onError()和onCompleted()都不需要，有木有简化方案呢？当然有：
而之前我们创建Observable是通过它：
所以简化版采用just操作符来，如下：
编译运行：
下面改用Action1类来达到我们所要的需求：
编译运行：
但是！！！官方并不推荐使用该类来简化操作，因为Action1并不支持背压(BackPressure)，而产生的大至原因是由于Rxjava的事件产生过快时导致，这个后面会再学习，也先有个了解既可。