最近在遇到了 Android 的开发中常用到的设计模式之观察者模式，观察者模式，所谓的模式就是一种设计思想，可以按照某种模式，写出更合理，简单，有效的代码。可以用在 Android 开发中，也可以用在 Java，C#等等开发中，就类似单例模式，代理模式，模版等等。

观察者模式在实际项目中使用的也是非常频繁的，它最常用的地方是 GUI 系统、订阅——发布系统等。因为这个模式的一个重要作用就是解耦，使得它们之间的依赖性更小，甚至做到毫无依赖。以 GUI 系统来说，应用的 UI 具有易变性，尤其是前期随着业务的改变或者产品的需求修改，应用界面也经常性变化，但是业务逻辑基本变化不大，此时，GUI 系统需要一套机制来应对这种情况，使得 UI 层与具体的业务逻辑解耦，观察者模式此时就派上用场了。

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

• 观察者模式属于行为型模式。
• 观察者模式又被称作发布/订阅模式。
• 观察者模式主要用来解耦，将被观察者和观察者解耦，让他们之间没有没有依赖或者依赖关系很小。

• 当一个对象的改变需要通知其它对象改变时，而且它不知道具体有多少个对象有待改变时。
• 当一个对象必须通知其它对象，而它又不能假定其它对象是谁
• 跨系统的消息交换场景，如消息队列、事件总线的处理机制。

• 例一：生活中，我们一群人围着锅吃饭，饭好了，我们就开吃。（观察者：人们，被观察者：饭）
• 例二：Android 中，最常见的点击事件，通过设置控件的 OnClickListener 并传入一个 OnClickListener 的实现类来回调点击事件。（观察者：OnClickListener，被观察者：控件）
• 例三：Android 中，我们从 A 页面–>B 页面–>C 页面–>D 页面–>F 页面…. 我们想把 A 页面信息传递给最后一个页面，如果通过页面传递那么很繁琐，我们直接可以在需要的页面去订阅 A 页面的事件，当 A 页面刷行数据，其他订阅了 A 页面事件的就可以直接接受数据。（相当于少了中间商赚差价，是不爽了很多，而且效率还比较高）
• 例四：Android 中，我们常用的 recyclerView，listView 刷行数据时调用 notifyDataSetChanged()来更新 ui，想知道具体原因，那么请仔细往下看完这篇文章。
• 例五：Android 中，我们通常发送一个广播，凡是注册了该广播的都可以接收到该广播，这也是 Android 中典型的观察者模式。

• Subject（被观察者）：把所有观察者对象的引用保存到一个集合里，每个主题都可以有任何数量的观察者。抽象主题提供一个接口，可以增加和删除观察者对象，主要包含三个方法：

  1. addObserver 方法可以添加观察者对象，可以理解为观察者把自己注册到了被观察者这里，只有注册了的观察者，才能接到被观察者的通知。
  2. deleteObserver 方法是将观察者移除，被移除的观察者自然就不能再接到通知了。
  3. notifyObserves 方法可以把通知发送给所有的已注册的观察者，至于观察者们后续做什么事情，被观察者是完全不关心的。

• Observer (抽象观察者)：为所有的具体观察者定义一个接口，在得到主题通知时更新自己。

• ConcreteSubject（被观察者的具体实现）：将有关状态存入具体观察者对象；在具体主题内部状态改变时，给所有登记过的观察者发出通知。

• ConcrereObserver（观察者的具体实现）：实现抽象观察者定义的更新接口，当得到主题更改通知时更新自身的状态。

下面以日常生活中追剧案例实现观察者模式，如果电视剧更新，则会通知所有订阅者。（典型的一对多关系）

该抽象主题定义了一些通用的方法（订阅、取消订阅、通知），即具体主题里面需要实现的。

interface Observable {
    /**
     * 添加观察者
     */
    fun addObserver(observer: Observer)
    /**
     * 移除观察者
     */
    fun deleteObserver(observer: Observer)
    /**
     * 通知观察者
     */
    fun notifyObserver(msg: String)
}

被观察者的具体实现，完成观察者对其订阅、取消订阅以及遍历通知所有观察者 msg 方法。

class Teleplay : Observable {
    // 保存观察者对象
    var list: MutableList<Observer> = ArrayList()
    /**
     * 添加订阅
     */
    override fun addObserver(observer: Observer) {
        if(!list.contains(observer)){
            list.add(observer)
        }
    }
    /**
     * 取消订阅
     */
    override fun deleteObserver(observer: Observer) {
        list.remove(observer)
    }

    /**
     * 通知观察者，遍历通知所有观察者对象
     */
    override fun notifyObserver(msg: String) {
        list.forEach {
            it.action(msg);
        }
    }
}

定义了所有具体观察者需要实现的方法，收到电视剧更新的通知

interface Observer {
    /**
     * 更新内容
     */
    fun action(msg:String);
}

class Person(private var name: String) : Observer {
    /**
     * 接收被观察者发送的通知
     */
    override fun action(msg: String) {
        Log.e("msg","$name , $msg")
    }
}

以上 4 步基本上已经完成观察者模式的创建工作，下面模拟 2 个观察者实现以上功能。

class MainActivity : AppCompatActivity(){

    private val teleplay:Teleplay by lazy {
        Teleplay()
    }
    private val person1:Person by lazy {
        Person("张三疯")
    }
    private val person2:Person by lazy {
        Person("赵四史")
    }

    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_main)
    }
    fun subscribe01(view: View) {
        teleplay.addObserver(person1)
    }
    fun subscribe02(view: View) {
        teleplay.addObserver(person2)
    }
    fun upDate(view: View) {
        teleplay.notifyObserver("五十度飞更新了！！！")
    }
    fun cancel(view: View) {
        teleplay.deleteObserver(person1)
        teleplay.deleteObserver(person2)
    }

    override fun onDestroy() {
        super.onDestroy()
        teleplay.deleteObserver(person1)
        teleplay.deleteObserver(person2)
    }
}

上述代码中流程：

1. 创建了 2 个 Person 对象（即观察者对象），一个 Teleplay 对象（即被观察者对象）
2. 通过点击事件完成添加订阅方法：teleplay.addObserver()
3. 电视剧更新后通过点击事件调用：teleplay.notifyObserver()方法完成通知
4. 观察者收到通知消息：

msg: 张三疯 , 五十度飞更新了！！！
msg: 赵四史 , 五十度飞更新了！！！

5. 在不需要监听时，记得取消订阅：teleplay.deleteObserver()

到这里我们便实现了观察者模式。

无论 ListView 还是 RecyclerView 里，notifyDataSetChanged 方法都是至关重要的，这是最常见的观察者模式。

当 ListView 的数据发生变化时，我们调用 Adapter 的 notifyDataSetChanged()方法，这个方法又会调用所有观察者（AdapterDataSetObserver）的 onChanged()方法，onChanged()方法又会调用 requestLayout()方法来重新进行布局。

BroadcastReceiver 作为 Android 的四大组件之一,实际上也是一个典型的观察者模式.通过 sendBroadcast 发送广播时,只有注册了相应的 IntentFilter 的 BroadcastReceiver 对象才会收到这个广播信息,其 onReceive 方法才会被调起.

EventBus 是一个组件间通信框架，开发者在 Activity、Fragment、Service、Thread 之间传递消息时可以避免使用复杂的 Intent、Handler 和 BroadCast

RxJava 作为同样基于观察者模式的组件间通信框架，要比 EventBus 的应用更广泛。尤其它针对 Android 的扩展——RxAndroid 完全可以替代 AsycTask 来完成各种异步操作，而且还有 BindActivity 和 BindFragment 方法来避免异步操作时的 Activity 和 Fragment 的生命周期问题。

• 在观察者模式中，观察者和被观察者之间是抽象耦合，保证了订阅系统的灵活性和可扩展性。在需要 UI 层与业务逻辑解耦的关联行为场景或事件多级触发场景非常实用。

• 跨进程或者跨 App 的消息交换场景。

• 观察者模式定义了一种一对多的依赖关系，让多个观察者对象同时监听某一个主题对象。观察者模式完美的将观察者和被观察的对象分离开，一个对象的状态发生变化时，所有依赖于它的对象都得到通知并自动刷新。
• 回调函数其实也算是一种观察者模式的实现方式，回调函数实现的观察者和被观察者往往是一对一的依赖关系。

所以最明显的区别是观察者模式是一种设计思路，而回调函数式一种具体的实现方式；另一明显区别是一对多还是多对多的依赖关系方面。

观察者模式就是将观察者和被观察者彻底隔离，实现解耦，只依赖于我们定义的抽象。

• 解除观察者与主题之间的耦合。让耦合的双方都依赖于抽象，而不是依赖具体。从而使得各自的变化都不会影响另一边的变化。
• 易于扩展，对同一主题新增观察者时无需修改原有代码。

• 依赖关系并未完全解除，抽象主题仍然依赖抽象观察者。
• 使用观察者模式时需要考虑一下开发效率和运行效率的问题，程序中包括一个被观察者、多个观察者，开发、调试等内容会比较复杂，而且在 Java 中消息的通知一般是顺序执行，那么一个观察者卡顿，会影响整体的执行效率，在这种情况下，一般会采用异步实现。
• 可能会引起多余的数据通知。

观察者模式看起来很高大上，其实说白了就是一个类维护了另一个类的一个集合，并通过这个集合绑定解绑或调用另一个类的方法，只不过，在设计底层框架时候，利用了多态的特性抽象出了接口和抽象类，以便适用于各种场合。

其实在做终端页面时候完全用不到，因为多态只能增加运行时开销。然而，设置一个庞大系统时候，这种设计模式在面向对象的编程语言，可谓不能不用的手段了。