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

最简单的观察者模式:

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

RxJava——扩展的观察者模式-LMLPHP

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

Observable--->Subscriber

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

普通的观察者模式:

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

RxJava——扩展的观察者模式-LMLPHP

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

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

  • Observer与Observable是通过subscrible()来达成订阅关系。
  • Rxjava中的事件回调有三种:onNext()、onCompleted()、onError()。
  • 如果一个Observable没有任何的Observer,那么这个Observable是不会发出任何事件的。

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

  • 热启动Observable任何时候都会发送消息,即使没有任何观察者监听它。【它没有什么实际意义,所以说了解下既可】
  • 冷启动Observable只有在至少有一个订阅者的时候才会发送消息。【所以工作中使用的都是冷启动】

RxJava的观察者模式:

相比普通观察者模式,RxJava的观察者模式如下图:

RxJava——扩展的观察者模式-LMLPHP
当一个事件触发时,会有一些方法回调,如下:

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

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

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

第一步:创建观察者Observer。

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

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

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

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

RxJava——扩展的观察者模式-LMLPHP

所以贴出之前实现过的代码:

RxJava——扩展的观察者模式-LMLPHP

编译运行:

RxJava——扩展的观察者模式-LMLPHP

这时制造一个异常再看下输出:

RxJava——扩展的观察者模式-LMLPHP

编译运行:

RxJava——扩展的观察者模式-LMLPHP

从打印中可以看出,onError()和onCompleted()是不共戴天滴。

除 Observer 接口之外,RxJava 还内置了一个实现 Observer 的抽象类:Subscriber(发 [səb'skraɪbɚ])。 Subscriber 对 Observer 接口进行了一些扩展,但他们的基本使用方式是完全一样的:
RxJava——扩展的观察者模式-LMLPHP

编译运行:

RxJava——扩展的观察者模式-LMLPHP

那既然观察者有两个:Observer和Subscriber,那这两者有啥区别呢?当然是有区别滴,不过在未来会进行学习,这里先有个印象。

另外在Rxjava中,如果对于事件回调中,只想要onNext()方法,onError()和onCompleted()都不需要,有木有简化方案呢?当然有:

RxJava——扩展的观察者模式-LMLPHP

而之前我们创建Observable是通过它:

RxJava——扩展的观察者模式-LMLPHP

所以简化版采用just操作符来,如下:

RxJava——扩展的观察者模式-LMLPHP

编译运行:

RxJava——扩展的观察者模式-LMLPHP

下面改用Action1类来达到我们所要的需求:

RxJava——扩展的观察者模式-LMLPHP

编译运行:

RxJava——扩展的观察者模式-LMLPHP

但是!!!官方并不推荐使用该类来简化操作,因为Action1并不支持背压(BackPressure),而产生的大至原因是由于Rxjava的事件产生过快时导致,这个后面会再学习,也先有个了解既可。

05-16 10:26