【设计模式】 Java 设计模式 – 观察者模式简介
观察者模式 又叫发布-订阅(Publish-Subscribe)模式,是对象的行为模式,订阅是表示这些观察者对象需要向目标对象进行注册,这样目标对象才知道有哪些对象在观察它。发布指的是当目标对象的状态改变时,它就向它所有的观察者对象发布状态更改的消息,以让这些观察者对象知晓。定义对象间的一种一对多的依赖关系,当一个对象的状态发生改变时,所有依赖于它的对象都得到通知并被自动更新。 就像 数学函数 那样,设 函数 y=x²,y随着x的增长而增长,我就称x为 自变量 ,y为 因变量 。
1、描述
观察者模式 UML 如图:
2、实例
本次实验通过定义产品列表作为被观察对象,定义两个观察者观察变化,在测试中添加产品,使得被观察对象向观察者发送消息。也就是发布-订阅模式。
①、产品列表
观察者模式是在观察者和被观察者双方,观察者可以是多个。在产品列表类中需要继承java.util.Observable的方法。
构建方法私有化,采用单例模式,避免直接通过new的方式去实例化对象,而是通过 getInstance 方法去实例化对象。可以通过addProductListObserver方法来添加一个观察者。addProduct用来添加产品,并且通知观察者
package com.lyd.demo.product;
import java.util.ArrayList;
import java.util.List;
import java.util.Observable;
import java.util.Observer;
/**
* @Author: lyd
* @Description: 被观察的产品对象
* @Date: 2022-08-20
*/public class ProductList extends Observable {
private List<String> productList = null; // 产品列表
private static ProductList instance; // 唯一实例
private ProductList() {} // 构建方法私有化
/**
* 获取唯一实例
* @return 实例
*/ public static ProductList getInstance() {
if (instance == null) {
instance = new ProductList();
instance.productList = new ArrayList<String>();
}
return instance;
}
/**
* 增加观察者(电商接口)
* @param observable 观察者
*/ public void addProductListObserver(Observer observable) {
this.addObserver(observable);
}
public void addProduct(String newProduct) {
productList.add(newProduct);
System.out.println("产品列表新增加了产品:" + newProduct);
this.setChanged(); // 设置被观察对象发送变化
this.notifyObservers(newProduct); // 通知观察者,并传递新产品
}
}
②、观察者
构建两个观察者,简单做个打印,观察者需要实现java.util.Observer接口,并且实现update方法。 淘宝:
package com.lyd.demo.observer;
import java.util.Observable;
import java.util.Observer;
/**
* @Author: lyd
* @Description: 淘宝观察者接口
* @Date: 2022-08-20
*/public class TaoBaoObserver implements Observer {
public void update(Observable o, Object product) {
String newProduct = (String) product;
System.out.println("发送给新产品:" + newProduct + " 同步到淘宝商城");
}
}
、、
京东 :
package com.lyd.demo.observer;
import java.util.Observable;
import java.util.Observer;
/**
* @Author: lyd
* @Description: 京东观察者接口
* @Date: 2022-08-20
*/public class JingDongObserver implements Observer {
public void update(Observable o, Object product) {
String newProduct = (String) product;
System.out.println("发送给新产品:" + newProduct + " 同步到 京东商城 ");
}
}
③、测试
先添加观察者,在添加产品,这样就能看到被观察者发布消息给观察者。