手写观察者模式

观察者模式

• 定义了对象之间的一对多依赖，这样一来，当一个对象状态改变状态时，他的所有依赖都会收到通知并自动更新。 -摘自《Head First 设计模式》

  观察者模式结构图

  

• Subject:抽象主题（抽象被观察者），抽象主题角色把所有观察者对象保存在一个集合里面，每个主题都可以有任意数量的观察者，抽象主题提供一个接口，可以增加和删除观察者对象

• ConcreteSubject：具体主题（具体被观察者），该角色将有关状态存入具体观察者对象，在具体主题的内部状态发生改变时，给所有注册过的观察者发送通知。
• Observer：抽象观察者，是观察者者的抽象类，它定义了一个更新接口，使得在得到主题更改通知时更新自己。
• ConcrereObserver：具体观察者，是实现抽象观察者定义的更新接口，以便在得到主题更改通知时更新自身的状态。

  简单实现

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

  抽象观察者（Observer）

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

/**
 * 抽象观察者
 * 1.需要两个接口，观察者，和被观察者。
 * 2.被观察者接口需要有两个方法， 一个是注册观察者方法，一个是通知观察者方法。
 * 3.被观察者需要有一个集合，用于储存观察者，注册方法就是向集合里添加对象。
 *  通知方法就是遍历集合。
 *
 * @author beyond
 * @since 2021/6/2
 */
public interface Observer {
  /**
   * 接收变动通知
   */
  void update(String message);
}

具体观察者（ConcrereObserver）

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

/**
 * 具体观察者
 * @author beyond
 * @since 2021/6/3
 */
public class UserObserver implements Observer  {
  private String user;
  public UserObserver(String user){
    this.user = user;
  }
  public String getUser() {
    return user;
  }
  public void setUser(String user) {
    this.user = user;
  }
  @Override
  public void update(String message) {
    System.out.println("用户" +user + "  " + message);
  }
}

抽象被观察者（Subject）

抽象主题，提供了add(通知)、delete（删除）、notify（通知）三个方法：

/**
 * 抽象被观察者
 * @author beyond
 * @since 2021/6/3
 */
public interface Subject {
  /**
   * 添加
   * @param obs
   */
  void addUser(Observer obs);
  /**
   * 删除
   * @param obs
   */
  void deleteUser(Observer obs);
  /**
   * 通知
   * @param information
   */
  void notify(String information);
}

具体被观察者（ConcreteSubject）

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

/**
 * @author beyond
 * @since 2021/6/3
 */
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);
    }
  }
}

测试：

/**
 * @author beyond
 * @since 2021/6/3
 */
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("出门在外照顾好自己");
  }
}