作用

模拟一个气象站，通过订阅的方式发布信息。

效果

  1. 温湿度布告栏订阅了气象信息
  2. 完整信息布告栏订阅了气象信息
  3. [温湿度布告栏]接收到来自气象站的更新，现在更新
  4. 当前显示温湿度布告栏
  5. 温度:35.2F degrees 
  6. 适度:22.2%
  7. [完整信息布告栏]接收到来自气象站的更新，现在更新
  8. 当前显示完整信息布告栏
  9. 温度:35.2F degrees 
  10. 适度:22.2%
  11. 气压:1000.0pa

UML

图片.png

完整代码

  1. import java.util.ArrayList;
  3. import javax.swing.text.WrappedPlainView;
  6. // 数据的类
  7. class weaterData_ST{
  8.     double temp;
  9.     double humidity;
  10.     double presure;
  12.     public void setData(double d, double e, double presure) {
  13.         this.temp = d;
  14.         this.humidity = e;
  15.         this.presure = presure;
  16.     }
  17. }
  19. // 观察者接口
  20. interface Observer{
  21.     // 获取更新数据
  22.     public void update(weaterData_ST data);
  23.     // 获取观察者名称
  24.     public String getName();
  25. }
  27. // 订阅相关接口
  28. interface Subject {
  29.     public void registerObserver(Observer o); // 注册
  30.     public void removeObserver(Observer o);  // 注销
  31.     public void notifyObserver();    // 通知
  33. }
  35. // 布告栏显示接口
  36. interface DisplayElement{
  37.     public void display();
  38. }
  40. // 气象站本体
  41. class WeatherStation implements Subject{
  42.     private ArrayList observers; // 订阅者列表
  43.     private weaterData_ST weaterData; // 气象数据
  45.     public WeatherStation() {
  46.         // TODO Auto-generated constructor stub
  47.         observers = new ArrayList();
  48.     }
  50.     public void registerObserver(Observer o) {
  51.         observers.add(o);
  52.         System.out.println(o.getName() +  "订阅了气象信息");
  53.     }
  55.     public void removeObserver(Observer o) {
  56.         int i = observers.indexOf(o);
  57.         if (i >= 0) {
  58.             observers.remove(i);
  59.         }
  60.     }
  62.     public void notifyObserver() {
  63.         for(int i = 0; i < observers.size(); i++) {
  64.             // 获取订阅列表中的订阅者
  65.             Observer observer = (Observer) observers.get(i);
  66.             // 调用每一个订阅者实现的更新接口来实现通知
  67.             observer.update(weaterData);
  68.         }
  69.     }
  70.     // 当数据改变了通知所有的订阅者
  71.     public void measurementsChanged() {
  72.         notifyObserver();
  73.     }
  75.     public void setMeasurements(weaterData_ST data) {
  76.         this.weaterData = data;
  77.         measurementsChanged();
  78.     }
  80. }
  82. // 当前温湿度布告栏实现的类
  83. class CurrentConditionDisplay implements Observer, DisplayElement{
  85.     private weaterData_ST weaterData;
  87.     public CurrentConditionDisplay(Subject weaterStation) {
  88.         // 订阅气象站内容
  89.         weaterStation.registerObserver(this);
  90.     }
  92.     @Override
  93.     public void update(weaterData_ST data) {
  94.         // TODO Auto-generated method stub
  95.         System.out.println("[" + getName() + "]" + "接收到来自气象站的更新，现在更新");
  96.         weaterData = data;
  97.         display();
  98.     }
  100.     @Override
  101.     public void display() {
  102.         // TODO Auto-generated method stub
  103.         System.out.println("当前显示" + getName());
  104.         System.out.println("温度:" + weaterData.temp + "F degrees ");
  105.         System.out.println("适度:" + weaterData.humidity + "%");
  106.     }
  108.     @Override
  109.     public String getName() {
  110.         // TODO Auto-generated method stub
  111.         return "温湿度布告栏";
  112.     }
  113. }
  115. // 显示完整信息的布告栏
  116. class AllConditionDisplay implements Observer, DisplayElement{
  117.     private weaterData_ST weaterData;
  119.     public AllConditionDisplay(Subject weaterStation) {
  120.         // TODO Auto-generated constructor stub
  121.         weaterStation.registerObserver(this);
  122.     }
  124.     @Override
  125.     public void display() {
  126.         // TODO Auto-generated method stub
  127.         System.out.println("当前显示" + getName());
  128.         System.out.println("温度:" + weaterData.temp + "F degrees ");
  129.         System.out.println("适度:" + weaterData.humidity + "%");
  130.         System.out.println("气压:" + weaterData.presure + "pa");
  131.     }
  133.     @Override
  134.     public void update(weaterData_ST data) {
  135.         // TODO Auto-generated method stub
  136.         System.out.println("[" + getName() + "]" + "接收到来自气象站的更新，现在更新");
  137.         weaterData = data;
  138.         display();
  139.     }
  141.     @Override
  142.     public String getName() {
  143.         // TODO Auto-generated method stub
  144.         return "完整信息布告栏";
  145.     }
  147. }
  149. public class main {
  150.     public static void main(String[] args) {
  151.         weaterData_ST weaterData = new weaterData_ST();
  152.         WeatherStation WeatherStation = new WeatherStation();
  153.         // 创建观察者订阅气象站
  154.         CurrentConditionDisplay currentConditionDisplay = new CurrentConditionDisplay(WeatherStation);
  155.         AllConditionDisplay AllConditionDisplay = new AllConditionDisplay(WeatherStation);
  157.         weaterData.setData(35.2, 22.2, 1000);
  158.         // 只要修改了信息，那么就会通知所有订阅者
  159.         WeatherStation.setMeasurements(weaterData);
  161.     }
  162. }