介绍

多个其他类想对某一个类的属性实现同步时使用

原理image-20201013133118936.png

对原理类图的说明-即(命名模式的角色及职责)

  1. Subject接口目的是管理观察者，registerObserver注册观察者，removeObserver移除观察者,notifyObservers通知观察者
  2. 数据源类就是观察者观察的目标，数据源需要提前把观察者注册到observers集合中，当数据源类数据更新时，能自身通知各个观察者或者提供接口让观察者调用查看最新数据。
  3. Observer是观察者的一个抽象接口，update方法是当数据源信息更新时，同步到观察者上的数据的方法

案例

天气预报项目需求,具体要求如下：

  1. 气象站可以将每天测量到的温度，湿度，气压等等以公告的形式发布出去(比如发布到自己的网站或第三方)。
  2. 需要设计开放型API，便于其他第三方也能接入气象站获取数据。
  3. 提供温度、气压和湿度的接口
  4. 测量数据更新时，要能实时的通知给第三方

image-20201013133747462.png

  1. //Subject三个方法都是操作的观察者集合的
  2. public interface Subject {
  3.     public void registerObserver(Observer o);
  4.     public void removeObserver(Observer o);
  5.     public void notifyObservers();
  6. }
  8. //WeatherData（天文台）实现Subject实现操作观察者的方法
  9. public class WeatherData implements Subject{
  10.     private double temperature;
  11.     private double pressure;
  12.     private double humidity;
  13.     private ArrayList<Observer> observers = new ArrayList<>();
  15.     public double getTemperrature() {
  16.         return temperature;
  17.     }
  19.     public double getPressure() {
  20.         return pressure;
  21.     }
  23.     public double getHumidity() {
  24.         return humidity;
  25.     }
  27.     public void dataChange(){
  28.         notifyObservers();
  29.     }
  31.     public void setWeatherData(double temperature,double pressure,double humidity){
  32.         this.temperature = temperature;
  33.         this.pressure = pressure;
  34.         this.humidity = humidity;
  35.         dataChange();       //通知观察者数据改变
  36.     }
  38.     @Override
  39.     public void registerObserver(Observer o) {
  40.         observers.add(o);
  41.     }
  43.     @Override
  44.     public void removeObserver(Observer o) {
  45.         if (observers.contains(o)){
  46.             observers.remove(o);
  47.         }
  48.     }
  50.     @Override
  51.     public void notifyObservers() {
  52.         for (Observer observer : observers) {
  53.             observer.update(this.temperature,this.pressure,this.humidity);
  54.         }
  55.     }
  56. }
  1. //抽象观察者接口
  2. public interface Observer {
  3.     public void update(double temperature,double pressure,double humidity);
  4. }
  6. //新浪观察者实现类
  7. public class xinlang implements Observer{
  8.     private double temperature;
  9.     private double pressure;
  10.     private double humidity;
  12.     @Override
  13.     public void update(double temperrature, double pressure, double humidity) {
  14.         this.temperature = temperrature;
  15.         this.pressure = pressure;
  16.         this.humidity = humidity;
  17.         display();
  18.     }
  20.     private void display() {
  21.         System.out.println("新浪-------温度为 "+ temperature + "度--------");
  22.         System.out.println("新浪-------气压为 "+ pressure + "帕--------");
  23.         System.out.println("新浪-------湿度为 "+ humidity + "%--------");
  24.     }
  25. }
  27. //百度观察者实现类
  28. public class Baidu implements Observer{
  29.     private double temperature;
  30.     private double pressure;
  31.     private double humidity;
  33.     @Override
  34.     public void update(double temperrature, double pressure, double humidity) {
  35.         this.temperature = temperrature;
  36.         this.pressure = pressure;
  37.         this.humidity = humidity;
  38.         display();
  39.     }
  41.     private void display() {
  42.         System.out.println("百度-------温度为 "+ temperature + "度--------");
  43.         System.out.println("百度-------气压为 "+ pressure + "帕--------");
  44.         System.out.println("百度-------湿度为 "+ humidity + "%--------");
  45.     }
  46. }
  1. //Client端测试
  2. public class Client {
  3.     public static void main(String[] args) {
  4.         //创建WeatherData天气数据对象
  5.         WeatherData weatherData = new WeatherData();
  7.         //创建观察者
  8.         Observer observer1 = new Baidu();
  9.         Observer observer2 = new xinlang();
  11.         //注册观察者
  12.         weatherData.registerObserver(observer1);
  13.         weatherData.registerObserver(observer2);
  15.         //天文台数据改变
  16.         weatherData.setWeatherData(30,150,60);
  18.     }
  19. }

只要天文台数据改变就能通知到所有注册的观察者image-20201013134536868.png

观察者模式的好处

  1. 观察者模式设计后，会以集合的方式来管理用户(Observer)，包括注册，移除和通知。
  2. 这样，我们增加观察者(这里可以理解成一个新的公告板)，就不需要去修改核心类WeatherData不会修改代码，遵守了ocp原则。

个人总结

此模式的核心是使用一个接口把全部观察者统一接管了,再在数据源类中用集合统一管理所有观察者,核心的方法是
1.注册观察者

2.移除观察者

3.通知所有观察者