设计模式-行为型模式-观察者模式

你的名字 2023-07-04 04:49 26阅读 0赞

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

public class CurrentConditions {
    private float temperature;
    private float pressure;
    private float humidity;
    public void update(float temperature,float pressure,float humidity){
    this.temperature=temperature;
    this.pressure=pressure;
    this.humidity=humidity;
    display();}
    public void display(){
    System.out.println("***Today mTemperature: "+temperature+"***");
    System.out.println("***Today mPressure: "+pressure+"***");
    System.out.println("***Today mHumidity: "+humidity+"***");
    }}
    public class WeatherData {
    private float temperatrue;
    private float pressure;
    private float humidity;
    private CurrentConditions currentConditions;
    public WeatherData(CurrentConditions currentConditions) {
    this.currentConditions = currentConditions; }
    public float getTemperature() {
    return temperatrue; }
    public float getPressure() {
    return pressure; }
    public float getHumidity() {
    return humidity; }
    public void dataChange() {
    currentConditions.update(getTemperature(), getPressure(), getHumidity());}
    public void setData(float temperature, float pressure, float humidity) {
    this.temperatrue = temperature;
    this.pressure = pressure;
    this.humidity = humidity;
    dataChange();}}
    public class InternetWeather {
    public static void main(String[] args) {
    CurrentConditions currentConditions = new CurrentConditions();
    WeatherData weatherData = new WeatherData(currentConditions);
    weatherData.setData(30, 150, 40);
    }
    }

**观察者模式(Observer)**

 观察者模式类似订牛奶业务  
1) 奶站/气象局：Subject  
2) 用户/第三方网站：Observer  
 Subject：登记注册、移除和通知

1) registerObserver 注册  
2) removeObserver 移除  
3) notifyObservers() 通知所有的注册的用户，根据不同需求，可以是更新数据，让用户来取，也可能是实施推送，看具体需求定

**观察者模式(Observer) 原理**

Observer：接收输入

观 察者模式 ：对 象之间 多对一依赖为 的一种设计方案，被依赖的对象为Subject，为依赖的对象为Observer ，Subject 通知Observer变 变化 化, 比如这里的奶站是Subject ，是1 的一方。用户时Observer ，是多的一方。

//观察者接口，有观察者来实现
    public interface Observer {
    	public void update(float temperature, float pressure, float humidity);
    }
    //接口, 让WeatherData 来实现 
    public interface Subject {
    	public void registerObserver(Observer o);
    	public void removeObserver(Observer o);
    	public void notifyObservers();
    }
    /**
     * 类是核心
     * 1. 包含最新的天气情况信息 
     * 2. 含有 观察者集合，使用ArrayList管理
     * 3. 当数据有更新时，就主动的调用   ArrayList, 通知所有的（接入方）就看到最新的信息
     * @author Administrator
     *
     */
    public class WeatherData implements Subject {
    	private float temperatrue;
    	private float pressure;
    	private float humidity;
    	//观察者集合
    	private ArrayList<Observer> observers;
    	
    	//加入新的第三方
    	public WeatherData() {
    		observers = new ArrayList<Observer>();
    	}
    
    	public float getTemperature() {
    		return temperatrue;
    	}
    
    	public float getPressure() {
    		return pressure;
    	}
    
    	public float getHumidity() {
    		return humidity;
    	}
    
    	public void dataChange() {
    		//调用 接入方的 update
    		notifyObservers();
    	}
    
    	//当数据有更新时，就调用 setData
    	public void setData(float temperature, float pressure, float humidity) {
    		this.temperatrue = temperature;
    		this.pressure = pressure;
    		this.humidity = humidity;
    		//调用dataChange， 将最新的信息 推送给 接入方 currentConditions
    		dataChange();
    	}
    
    	//注册一个观察者
    	@Override
    	public void registerObserver(Observer o) {
    		// TODO Auto-generated method stub
    		observers.add(o);
    	}
    
    	//移除一个观察者
    	@Override
    	public void removeObserver(Observer o) {
    		// TODO Auto-generated method stub
    		if(observers.contains(o)) {
    			observers.remove(o);
    		}
    	}
    
    	//遍历所有的观察者，并通知
    	@Override
    	public void notifyObservers() {
    		// TODO Auto-generated method stub
    		for(int i = 0; i < observers.size(); i++) {
    			observers.get(i).update(this.temperatrue, this.pressure, this.humidity);
    		}
    	}
    }
    public class BaiduSite implements Observer {
    
    	// 温度，气压，湿度
    	private float temperature;
    	private float pressure;
    	private float humidity;
    
    	// 更新 天气情况，是由 WeatherData 来调用，我使用推送模式
    	public void update(float temperature, float pressure, float humidity) {
    		this.temperature = temperature;
    		this.pressure = pressure;
    		this.humidity = humidity;
    		display();
    	}
    
    	// 显示
    	public void display() {
    		System.out.println("===百度网站====");
    		System.out.println("***百度网站 气温 : " + temperature + "***");
    		System.out.println("***百度网站 气压: " + pressure + "***");
    		System.out.println("***百度网站 湿度: " + humidity + "***");
    	}
    
    }
    public class Client {
    
    	public static void main(String[] args) {
    		// TODO Auto-generated method stub
    		//创建一个WeatherData
    		WeatherData weatherData = new WeatherData();
    		
    		//创建观察者
    		CurrentConditions currentConditions = new CurrentConditions();
    		BaiduSite baiduSite = new BaiduSite();
    		
    		//注册到weatherData
    		weatherData.registerObserver(currentConditions);
    		weatherData.registerObserver(baiduSite);
    		
    		//测试
    		System.out.println("通知各个注册的观察者, 看看信息");
    		weatherData.setData(10f, 100f, 30.3f);
    		
    		
    		weatherData.removeObserver(currentConditions);
    		//测试
    		System.out.println();
    		System.out.println("通知各个注册的观察者, 看看信息");
    		weatherData.setData(10f, 100f, 30.3f);
    	}
    }

**观察者模式的好处**：

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