publish_subscribe

#什么是观察者模式

观察者模式： 发布-订阅(Publish/Subscribe)模式，由于Rxjava是基于观察者模式的，所以大家很有必要了解下什么是观察者模式。

观察者模式是对象的行为模式，又叫发布-订阅(Publish/Subscribe)模式、模型-视图(Model/View)模式、源-监听器(Source/Listener)模式或从属者(Dependents)模式。

观察者模式定义了一种一对多的依赖关系，让多个观察者对象同时监听某一个主题对象。这个主题对象在状态上发生变化时，会通知所有观察者对象，使它们能够自动更新自己。

• 目的： 定义对象间的一种一对多的依赖关系，当一个对象的状态发生改变时，所有依赖于它的对象都得到通知并被自动更新。

• 主要解决： 一个对象状态改变给其他对象通知的问题，而且要考虑到易用和低耦合，保证高度的协作。

• 何时使用： 一个对象（目标对象）的状态发生改变，所有的依赖对象（观察者对象）都将得到通知，进行广播通知。

• 解决方案： 使用面向对象技术，可以将这种依赖关系弱化。

• 关键代码： 在抽象类里有一个 ArrayList 存放观察者们。

• 应用实例：

  • 1、拍卖的时候，拍卖师观察最高标价，然后通知给其他竞价者竞价。
  • 2、西游记里面悟空请求菩萨降服红孩儿，菩萨洒了一地水招来一个老乌龟，这个乌龟就是观察者，他观察菩萨洒水这个动作。

* 优点： 1、观察者和被观察者是抽象耦合的。 2、建立一套触发机制。

• 缺点：
  • 1、如果一个被观察者对象有很多的直接和间接的观察者的话，将所有的观察者都通知到会花费很多时间。
  • 2、如果在观察者和观察目标之间有循环依赖的话，观察目标会触发它们之间进行循环调用，可能导致系统崩溃。
  • 3、观察者模式没有相应的机制让观察者知道所观察的目标对象是怎么发生变化的，而仅仅只是知道观察目标发生了变化。

* 使用场景： * 1、有多个子类共有的方法，且逻辑相同。 * 2、重要的、复杂的方法，可以考虑作为模板方法。

* 注意事项： * 1、JAVA 中已经有了对观察者模式的支持类。 * 2、避免循环引用。 * 3、如果顺序执行，某一观察者错误会导致系统卡壳，一般采用异步方式。

Rx概念

Rx是一个使用可观察数据流进行异步编程的编程接口，ReactiveX结合了观察者模式、迭代器模式和函数式编程的精华

• 迭代器模式

    为了更好的理解什么是Rx，有必要了解下迭代器模式:
    
    提供一种方法顺序访问一个聚合对象中的各种元素，而又不暴露该对象的内部表示
  

RxJava中的操作符

在Rxjava当中最重要的就是操作符，RxJava当中有着庞大的操作符

关于操作符的一些详细信息：

• ReactiveX/RxJava文档中文版