java 观察者模式

                            《Head First 设计模式》学习中

   观察者模式

• 定义了对象之间的一对多依赖，这样一来，当一个对象状态改变状态时，他的所有依赖都会收到通知并自动更新。

   观察者模式结构图

• Subject：抽象主题（抽象被观察者），抽象主题角色把所有观察者对象保存在一个集合里，每个主题都可以有任意数量的观察者，抽象主题提供一个接口，可以增加和删除观察者对象。
• ConcreteSubject：具体主题（具体被观察者），该角色将有关状态存入具体观察者对象，在具体主题的内部状态发生改变时，给所有注册过的观察者发送通知。
• Observer：抽象观察者，是观察者者的抽象类，它定义了一个更新接口，使得在得到主题更改通知时更新自己。
• ConcrereObserver：具体观察者，是实现抽象观察者定义的更新接口，以便在得到主题更改通知时更新自身的状态。

 简单实现

  比如： 你想给你的客户推送一天暖心信息

抽象观察者（Observer）

里面定义了一个更新的方法：

package com.Observer.model;public interface Observer {  void update(String information); }

具体观察者（ConcrereObserver）

用户是观察者，里面实现了更新的方法：

package com.Observer.model;public class userObserver implements Observer {  private String user;  public userObserver(String user){  this.user = user; }  @Override public void update(String information) {  System.out.println("用户" +user + " " + information); } public String getUser() {  return user; } public void setUser(String user) {  this.user = user; } }

抽象被观察者（Subject）

抽象主题，提供了add、delete、notify三个方法：

package com.Observer.model;public interface Subject {  void addUser(Observer obs);  void deleteUser(Observer obs);  void notify(String information);}

具体被观察者（ConcreteSubject）

具体主题（具体被观察者），里面存储了所有用户，并实现了抽象主题中的方法：

package com.Observer.model;import java.util.ArrayList;import java.util.List;public class SubscriptionSubject implements Subject { private List<Observer> list = new ArrayList<>();  @Override public void addUser(Observer obs) {  userObserver user = (userObserver) obs;  System.out.println("增加用户：" + user.getUser());  list.add(obs); } @Override public void deleteUser(Observer obs) {  userObserver user = (userObserver) obs;  System.out.println("删除用户：" + user.getUser());  list.remove(obs); } @Override public void notify(String information) {  for (Observer obs : list) {   obs.update(information);  } }}

测试：

package com.Observer.model;public class TestObserver { public static void main(String[] args) {    //创建对象  SubscriptionSubject sub = new SubscriptionSubject();    //模拟用户  userObserver inUpdate = new userObserver("张三");  userObserver inUpdate1 = new userObserver("李四");  userObserver inUpdate2 = new userObserver("王五");    //添加用户  sub.addUser(inUpdate);  sub.addUser(inUpdate1);  sub.addUser(inUpdate2);    //推送消息  sub.notify("天冷了,出门在外多加衣,注意保暖");    //删除用户  sub.deleteUser(inUpdate);    //再次推送消息  sub.notify("出门在外照顾好自己");     }}

效果：

增加用户：张三增加用户：李四增加用户：王五用户张三 天冷了,出门在外多加衣,注意保暖用户李四 天冷了,出门在外多加衣,注意保暖用户王五 天冷了,出门在外多加衣,注意保暖删除用户：张三用户李四 出门在外照顾好自己用户王五 出门在外照顾好自己

 设计原则描述

• 找出程序中会变化的方面，然后将其和固定不变的方面相分离

　　　　在观察者模式中，会改变的是主题的状态，以及观察者的数目，用这个模式，你可以改变依赖于主题状态的对象，却不必改变主题，这叫提前规则。

• 针对接口编程，而不是针对实现编程

　　　　主题与观察者都使用接口，观察者利用主题的接口向主题注册，而主题利用观察者接口通知观察者，这样可以让两者之间运作正常，又同时具有松耦合                   的特点。

• 多用组合少用继承

·　　　　　观察者模式利用 “组合” 将许多观察者组合进主题中，对象之间的这种关系不是通过继承产生的，而是在运行时利用组合的方式产生。

使用场景

• 关联行为场景，需要注意的是，关联行为是可拆分的，而不是“组合”关系。
• 事件多级触发场景。
• 跨系统的消息交换场景，如消息队列、事件总线的处理机制。

优点

　　解除耦合，让耦合的双方都依赖于抽象，从而使得各自的变换都不会影响另一边的变换。

缺点

　　在应用观察者模式时需要考虑一下开发效率和运行效率的问题，程序中包括一个被观察者、多个观察者，开发、调试等内容会比较复杂，而且在Java中消息           的通知一般是顺序执行，那么一个观察者卡顿，会影响整体的执行效率，在这种情况下，一般会采用异步实现。

  参考