在系统中,当一个对象状态变化了,某些与他相关的对象也会随之发生变化。这是一种对象与对象之间的关系。例如:监测天气的气象仪检测到天气变化,那么它应该自动通知到气象台。我们将这个变化的对象(气象仪)称为观察目标,被通知变化的对象(气象台)称为观察者
观察者模式定义
指多个对象间存在一对多的依赖关系,当一个对象的状态发生改变时,所有依赖于它的对象都得到通知并被自动更新。这种模式有时又称作发布-订阅模式、模型-视图模式,它是对象行为型模式。
优点:
- 降低了目标与观察者之间的耦合关系,两者之间是抽象耦合关系。符合依赖倒置原则。
- 目标与观察者之间建立了一套触发机制
缺点:
- 目标与观察者之间的依赖关系并没有完全解除,而且有可能出现循环引用。
- 当观察者对象很多时,通知的发布会花费很多时间,影响程序的效率。
观察者模式的结构与实现
结构
- 抽象主题(Subject)角色:也叫抽象目标类,它提供了一个用于保存观察者对象的聚集类和增加、删除观察者对象的方法,以及通知所有观察者的抽象方法。
- 具体主题(Concrete Subject)角色:也叫具体目标类,它实现抽象目标中的通知方法,当具体主题的内部状态发生改变时,通知所有注册过的观察者对象。
- 抽象观察者(Observer)角色:它是一个抽象类或接口,它包含了一个更新自己的抽象方法,当接到具体主题的更改通知时被调用。
- 具体观察者(Concrete Observer)角色:实现抽象观察者中定义的抽象方法,以便在得到目标的更改通知时更新自身的状态。
实现
实现场景:房价(目标),持房者,炒房者,和购房者的关系。
package com.wly.DesignPatterns;
import java.util.ArrayList;
import java.util.List;
/**
* @program: StudyDome
* @author: yuanzhang
* @create: 2020-12-29 11:20
**/
public class ObserverPatterns {
public static void main(String[] args) {
//房价:目标
HousingPrice housingPrice = new ConcreteHousingPrice();
//观察者-----------------订阅
//有房人
Observer homeowners = new Homeowners();
//炒房者
Observer estateSpeculator = new EstateSpeculator();
//买房者
Observer homeBuyers = new HomeBuyers();
//添加观察者
housingPrice.addObservers(homeowners);
housingPrice.addObservers(estateSpeculator);
housingPrice.addObservers(homeBuyers);
//房价没变
housingPrice.priceChange(0);
//房价上涨
housingPrice.priceChange(1);
//房价下跌
housingPrice.priceChange(2);
}
}
/**
* @Annotation:抽象观察者:注意房价的人
* @Author: yuanzhang
* @Date: 11:27
*/
interface Observer{
void mood(Integer housingPriceVariation);
}
/**
* @Annotation:具体观察者:有房人
* @Author: yuanzhang
* @Date: 11:39
*/
class Homeowners implements Observer{
@Override
public void mood(Integer housingPriceVariation) {
String mood = "悠闲";
if (housingPriceVariation==1){
//价格上涨
mood = "不错不错,身价涨了";
}else if (housingPriceVariation==2){
//价格下跌
mood = "我淦,买早了,亏了亏了";
}
System.out.println("持房者心情:"+mood);
}
}
class EstateSpeculator implements Observer{
@Override
public void mood(Integer housingPriceVariation) {
String mood= "心系房价";
if (housingPriceVariation==1){
//价格上涨
mood = "NICE,挣钱了";
}else if (housingPriceVariation==2){
//价格下跌
mood = "/(ㄒoㄒ)/~~,亏死了";
}
System.out.println("炒房者心情:"+mood);
}
}
class HomeBuyers implements Observer{
@Override
public void mood(Integer housingPriceVariation) {
String mood= "房价跌一跌呀!";
if (housingPriceVariation==1){
//价格上涨
mood = "/(ㄒoㄒ)/~~,啥时才能凑够首付呀";
}else if (housingPriceVariation==2){
//价格下跌
mood = "NICE,终于买得起房了";
}
System.out.println("买房者心情:"+mood);
}
}
abstract class HousingPrice{
protected List<Observer> observers = new ArrayList <>();
public void deleteObservers(Observer observer) {
observers.remove(observer);
}
public void addObservers(Observer observer) {
observers.add(observer);
}
public abstract void notifyObserver(Integer housingPriceVariation);
public abstract void priceChange(Integer housingPriceVariation);
}
class ConcreteHousingPrice extends HousingPrice{
@Override
public void notifyObserver(Integer housingPriceVariation) {
for (Observer observer : observers) {
observer.mood(housingPriceVariation);
}
}
@Override
public void priceChange(Integer housingPriceVariation) {
String HousingPriceStatus = "没变";
if (housingPriceVariation==1){
//价格上涨
HousingPriceStatus = "价格上涨";
}else if (housingPriceVariation==2){
//价格下跌
HousingPriceStatus = "价格下跌";
}
System.out.println("房价:"+HousingPriceStatus);
System.out.println("观察者心情---------------------------------");
notifyObserver(housingPriceVariation);
}
}
输出
房价:没变 观察者心情--------------------------------- 持房者心情:悠闲 炒房者心情:心系房价 买房者心情:房价跌一跌呀! 房价:价格上涨 观察者心情--------------------------------- 持房者心情:不错不错,身价涨了 炒房者心情:NICE,挣钱了 买房者心情:/(ㄒoㄒ)/~~,啥时才能凑够首付呀 房价:价格下跌 观察者心情--------------------------------- 持房者心情:我淦,买早了,亏了亏了 炒房者心情:/(ㄒoㄒ)/~~,亏死了 买房者心情:NICE,终于买得起房了