监听者模式普通版完成

boolean-dev · boolean-dev · commit 59214a173061 · 2018-11-06T09:42:10.000+08:00
diff --git a/.idea/workspace.xml b/.idea/workspace.xml
diff --git a/ch2-observer/src/main/java/com/tao/ch2observer/weather/CurrentDisplay.java b/ch2-observer/src/main/java/com/tao/ch2observer/weather/CurrentDisplay.java
@@ -1,13 +1,38 @@
 package com.tao.ch2observer.weather;
 
+/**
+ * 实时天气预报展示牌
+ */
 public class CurrentDisplay implements Oberver, DisplayElement {
+
+    private WeatherData weatherData;
+
+    private float temperature;
+    private float humidity;
+    private float pressure;
+
+    public CurrentDisplay() {
+    }
+
+    /**
+     * 构造方法注册到主题
+     * @param weatherData
+     */
+    public CurrentDisplay(WeatherData weatherData) {
+        this.weatherData = weatherData;
+        weatherData.addObserver(this);
+    }
+
     @Override
     public void display() {
-
+        System.out.println("实时天气预报:\n温度：" + temperature + "\n湿度:" + humidity + "\n气压" + pressure + "\n\n" );
     }
 
     @Override
     public void update(float temperature, float humidity, float pressure) {
-
+        this.temperature = temperature;
+        this.humidity = humidity;
+        this.pressure = pressure;
+        display();
     }
 }
diff --git a/ch2-observer/src/main/java/com/tao/ch2observer/weather/DisplayElement.java b/ch2-observer/src/main/java/com/tao/ch2observer/weather/DisplayElement.java
@@ -1,5 +1,8 @@
 package com.tao.ch2observer.weather;
 
+/**
+ * 展示牌接口
+ */
 public interface DisplayElement {
     void display();
 }
diff --git a/ch2-observer/src/main/java/com/tao/ch2observer/weather/ForecastDisplay.java b/ch2-observer/src/main/java/com/tao/ch2observer/weather/ForecastDisplay.java
@@ -1,13 +1,41 @@
 package com.tao.ch2observer.weather;
 
+/**
+ * 气压预报
+ */
 public class ForecastDisplay implements Oberver, DisplayElement {
+
+    private float lastPressure = 400f;
+    private float pressure;
+
+    private WeatherData weatherData;
+
+    public ForecastDisplay() {
+    }
+
+    /**
+     * 注册该监听者到主题
+     * @param weatherData
+     */
+    public ForecastDisplay(WeatherData weatherData) {
+        this.weatherData = weatherData;
+        weatherData.addObserver(this);
+    }
+
     @Override
     public void display() {
-
+        if (lastPressure > pressure) {
+            System.out.println("天气将更加下雨了，请注意收被子\n\n");
+        }else if(lastPressure < pressure) {
+            System.out.println("天气将更热，请注意中暑\n\n");
+        }else {
+            System.out.println("天气将不发生改变\n\n");
+        }
     }
 
     @Override
     public void update(float temperature, float humidity, float pressure) {
-
+        this.pressure = pressure;
+        display();
     }
 }
diff --git a/ch2-observer/src/main/java/com/tao/ch2observer/weather/Oberver.java b/ch2-observer/src/main/java/com/tao/ch2observer/weather/Oberver.java
@@ -1,5 +1,8 @@
 package com.tao.ch2observer.weather;
 
+/**
+ * 观察者接口
+ */
 public interface Oberver {
 
     void update(float temperature, float humidity, float pressure);
diff --git a/ch2-observer/src/main/java/com/tao/ch2observer/weather/StatisDisplay.java b/ch2-observer/src/main/java/com/tao/ch2observer/weather/StatisDisplay.java
@@ -1,13 +1,52 @@
 package com.tao.ch2observer.weather;
 
+/**
+ * 温度统计接口
+ */
 public class StatisDisplay implements Oberver, DisplayElement {
+
+    private float maxTemper = 38.0f;
+    private float minTemper = 25.0f;
+    private float sumTemper = 100.0f;
+    private float avgTemper = 0.0f;
+    private float currTemper;
+    private int count = 3;
+
+    private WeatherData weatherData;
+
+    public StatisDisplay() {
+    }
+
+    /**
+     * 注册监听者到主题
+     * @param weatherData
+     */
+    public StatisDisplay(WeatherData weatherData) {
+        this.weatherData = weatherData;
+        weatherData.addObserver(this);
+    }
+
     @Override
     public void display() {
-
+        System.out.println("温度统计:\n当前温度:" + currTemper + "\n最高温度:" + maxTemper + "\n最低温度:" + minTemper + "\n平均温度" + avgTemper);
     }
 
     @Override
     public void update(float temperature, float humidity, float pressure) {
 
+        currTemper = temperature;
+
+        avgTemper = (sumTemper+temperature) / ++count;
+
+        if (temperature > maxTemper) {
+            maxTemper = temperature;
+        }
+
+        if (temperature < minTemper) {
+            minTemper = temperature;
+        }
+
+        display();
+
     }
 }
diff --git a/ch2-observer/src/main/java/com/tao/ch2observer/weather/Subject.java b/ch2-observer/src/main/java/com/tao/ch2observer/weather/Subject.java
@@ -1,5 +1,8 @@
 package com.tao.ch2observer.weather;
 
+/**
+ * 主题接口
+ */
 public interface Subject {
 
     void addObserver(Oberver oberver);
diff --git a/ch2-observer/src/main/java/com/tao/ch2observer/weather/WeatherData.java b/ch2-observer/src/main/java/com/tao/ch2observer/weather/WeatherData.java
@@ -1,10 +1,12 @@
 package com.tao.ch2observer.weather;
 
-import org.omg.CORBA.Object;
-
 import java.util.ArrayList;
 import java.util.List;
 
+/**
+ * 主题
+ * 天气预报数据中心
+ */
 public class WeatherData implements Subject {
 
     private List<Oberver> oberverList;
@@ -16,6 +18,19 @@ public WeatherData() {
         this.oberverList = new ArrayList<>();
     }
 
+    /**
+     * 更新完天气数据之后，通知监听者更新数据
+     * @param temperature
+     * @param humidity
+     * @param pressure
+     */
+    public void updateData(float temperature,float humidity,float pressure) {
+        this.temperature = temperature;
+        this.humidity = humidity;
+        this.pressure = pressure;
+        this.notifyObservers();
+    }
+
     @Override
     public void addObserver(Oberver oberver) {
         oberverList.add(oberver);
diff --git a/ch2-observer/src/main/java/com/tao/ch2observer/weather/main.java b/ch2-observer/src/main/java/com/tao/ch2observer/weather/main.java
@@ -0,0 +1,22 @@
+package com.tao.ch2observer.weather;
+
+public class main {
+
+    public static void main(String[] args) {
+
+        //初始化weatherData
+        WeatherData weatherData = new WeatherData();
+
+        //将监听者注册到主题
+        CurrentDisplay currentDisplay = new CurrentDisplay(weatherData);
+        ForecastDisplay forecastDisplay = new ForecastDisplay(weatherData);
+        StatisDisplay statisDisplay = new StatisDisplay(weatherData);
+
+        //主题更新数据，进行推送
+        weatherData.updateData(30,80,400);
+        weatherData.updateData(40,90,500);
+        weatherData.updateData(25,70,300);
+    }
+
+
+}

Original file line number	Diff line number	Diff line change
`@@ -1,5 +1,8 @@`
`1`	`1`	`package com.tao.ch2observer.weather;`
`2`	`2`
	`3`	`+/**`
	`4`	`+ * 展示牌接口`
	`5`	`+ */`
`3`	`6`	`public interface DisplayElement {`
`4`	`7`	`void display();`
`5`	`8`	`}`