栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

浅谈设计模式-观察者模式

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

浅谈设计模式-观察者模式

系列文章目录

浅谈设计模式-装饰者模式


文章目录
  • 系列文章目录
  • 前言
  • 一、观察者模式的引入
    • 问题分析
    • 常规思路
    • 存在问题
  • 二、什么是观察者模式?
    • 1.观察者模式定义
    • 2.如何理解
  • 三、代码部分
    • 1.Subject 代码:
    • 2.Observer 代码:
    • 3.WeatherData 代码:
    • 4.BaiduSite 代码:
    • 5.测试类Client 代码:
  • 五、观察者模式在jdk中的应用
    • JDK中Observable类
  • 总结
    • 个人理解:


前言

初学设计模式,看的韩顺平老师的视频和大话设计模式,记录一下。


一、观察者模式的引入 问题分析

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

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

按照我们正常的解决方法,就是设计两个类,一个是用于接收数据(观察者),一个是发送数据类(发布更新信息),然后在发送数据类里聚合接收数据类,一旦发送数据类里信息变更(成员变量变化)就调用聚合的接收数据类对象的方法(更新数据)。简而言之,就是更新数据类聚合观察者,更新数据类数据变化就直接调用这个聚合的观察者方法表示更新。

存在问题

常规思路的解决方案存在的问题就是,如果存在多个观察者,那么就需要修改原来的类,即每多一个观察者类就需要聚合一个观察者对象,违背了ocp原则。


二、什么是观察者模式? 1.观察者模式定义

观察者模式又叫发布-订阅(Publish/Subscribe)模式;
观察者模式定义了一种一对多的依赖关系,让多个观察者对象同时监听某一个主题对象。这个主题对象在状态发生变化时,会通知所有观察者对象,使它们能后自动更新自己。[DP]

2.如何理解

先来看一张图:

说明:这里抽象了两个接口,被观察者(Subject)和观察者(Observer),Subject的三个方法是订阅、取关和更新,Observer的方法是更新(调用显示最新数据);WeatherData类可认为是发布者,而CurrentCondition、Baidu、Sina是订阅者(订阅气象信息同步到自己网站)。

理解:发布者类会聚合所有的观察者(WeatherData类的observers字段),一旦发布者更新数据就会调用notifyObserver方法,该方法会遍历observers中所有订阅者,调用订阅者的update方法(推送)。


三、代码部分 1.Subject 代码:
//接口, 让WeatherData 来实现 
public interface Subject {
	
	public void registerObserver(Observer o);
	public void removeObserver(Observer o);
	public void notifyObservers();
}
2.Observer 代码:
//观察者接口,有观察者来实现
public interface Observer {

	public void update(float temperature, float pressure, 
						float humidity);
}
3.WeatherData 代码:
public class WeatherData implements Subject {
	private float temperatrue;
	private float pressure;
	private float humidity;
	//观察者集合
	private ArrayList observers;
	
	//加入新的第三方

	public WeatherData() {
		observers = new ArrayList();
	}

	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);
		}
	}
}
4.BaiduSite 代码:
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 + "***");
	}

}

注:另外两个订阅者实现类类似就不写出来了

5.测试类Client 代码:
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);
	}

}

五、观察者模式在jdk中的应用 JDK中Observable类

jdk在Observable类中就使用了观察者模式,其中Observable类是被观察者

模式角色分析:
1.Observable的作用和地位等价于我们前面讲过 Subject ;
2.Observable 是类,不是接口,类中已经实现了核心的方法,即管理Observer的方法add…delete … notify…;
3.Observer的作用和地位等价于我们前面讲过的Observer,有update ;
4.Observable和 Observer的使用方法和前面讲过的一样,只是Observable是类,通过继承来实现观察者模式。

从上面角色可以看出:如果要使用观察者模式则需要写一个类继承Observable类(即把Observable看成Subject接口)。


总结 个人理解:

观察者模式从代码层面来看,就是在被观察者类聚合了所有观察者类(订阅者),从思想层面上是就是发布者拥有所有订阅者对象,这样发布者一更新数据就可以通知所有订阅者(调用订阅者更新方法)。
PS:目前初学,理解还不到位!

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/1020318.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号