RxJava——扩展的观察者模式

在学习RxJava的时候，经常提到观察者与被观察者，这不就是JAVA的观察者模式的运用么？是的，但是跟传统意义的上观察者模式还不太一样，所以Rxjava实际上是一种扩展的观察者模式，所以有必要对这个扩展的观察者模式做进一步的了解。

最简单的观察者模式：

对于之前写的关于Rxjava的代码先回顾一下：

但是如果我们不要修改事件，就不需要在Observable和Subscriber【它是Observer的子类】中插入Operator，那么时间Rxjava的结构如下：

Observable--->Subscriber

这看起来很像设计模式的观察者模式，但是有个重要的区别之一在于在没有Subscriber之前，Observable不会产生事件。

普通的观察者模式：

对于普通的观察者模式这里不多说，简单概念它就是：观察者(Observer)需要在被观察者(Observable)变化的一顺间做出反应。而两者通过注册(Register)或者订阅(Subscrible)的方式进行绑定。如下图所示：

RxJava--扩展的观察者模式：

而Rxjava的观察者模式跟上面普通的观察者模式差不多，但是也有几点差别：

其中关于第三点，需要说明一下，在Rxjava中其实Observable有两种形式：热启动Observable和冷启动Observable:

RxJava的观察者模式：

相比普通观察者模式，RxJava的观察者模式如下图：

当一个事件触发时，会有一些方法回调，如下：

onNext():基本事件。
onCompleted()事件队列完结。RxJava不仅把每个事件单独处理，还会把它们看作一个队列，RxJava规定，当不会再有新的onNext()事件发出时，需要触发onCompleted()方法作为标志。
onError()事件队列异常，在事件过程中出现异常时，onError()会被触发，同时队列自动终止，不允许再有事件发出。

RxJava的实现和使用【之前开篇已经有介绍过，这里再细致回顾下】：

RxJava的实现主要有如下三步：

第一步：创建观察者Observer。

Observer 即观察者，它决定事件触发的时候将有怎样的行为。注意:Observer是个接口。

第二步：创建被观察者Observable。

第三步：Subscribe(订阅)（被观察者Observable订阅观察者Observer，注意：不同于普通观察者，这里是被观察者订阅观察者）。

创建 Observable 和 Observer 之后，再 subscribe() 法将它们联结起来，整条链子就可以作。代码形式很简单: