概念
观察者模式又叫做发布-订阅(publish/Subscribe)模式
观察者模式定义了一种一对多的依赖关系,让多个观察者对象同时监听某一个主题对象。这个主题对象在状态发生变化时,会通知所有观察者对象,使它们能够自动更新自己。
观察者模式所做的工作其实就是在解除耦合。让耦合的双方都依赖于抽象。而不是依赖于具体。从而使得各自的变化都不会影响另一边的变化,体现了依赖倒转原则(面向接口编程)。
代码实现
目录结构
具体代码
抽象观察者接口Observer
package service;
/**
* @author SHshuo
* @data 2021/10/16--19:30
* 观察者抽象类
*/
public interface Observer {
// 更新状态
void update();
}
package service;
/**
* @author SHshuo
* @data 2021/10/16--19:29
* 通知者接口
* 这里依赖了观察者的接口,后续会去掉。
* 将移动到客户端用事务处理器进行添加删除观察者,并携带对应的被通知的内容
*
* 通知会用到循环遍历,后续会修改成委托给事件处理器EventHandler
* 因为一个委托可以搭载多个方法
*/
public interface Subject {
// 添加观察者
void attach(Observer observer);
// 删除观察者
void detach(Observer observer);
// 通知观察者
void subjectNotify();
// 通知者的状态
String subjectState();
}
具体实现观察者StockObserver、NBAObserver
package service.Impl.ConcreteObserver;
import service.Observer;
import service.Subject;
/**
* @author SHshuo
* @data 2021/10/16--19:44
* 买股票的观察者
*/
public class StockObserver implements Observer {
private String name;
private Subject subject;
public StockObserver(String name, Subject subject){
this.name = name;
this.subject = subject;
}
@Override
public void update() {
System.out.println(subject.subjectState() + name + "股票关闭,继续工作" );
}
}
具体实现的通知者SecretarySubject、BossSubject
package service.Impl.ConcreteSubject;
import service.Observer;
import service.Subject;
import java.util.ArrayList;
import java.util.List;
/**
* @author SHshuo
* @data 2021/10/16--19:33
* 前台秘书通知
*/
public class SecretarySubject implements Subject {
// 存放观察者
List<Observer> list = new ArrayList<>();
// 老板的状态
private String subjectState;
public void setSubjectState(String subjectState) {
this.subjectState = subjectState;
}
public String getSubjectState() {
return subjectState;
}
@Override
public String subjectState() {
return subjectState;
}
@Override
public void attach(Observer observer) {
list.add(observer);
}
@Override
public void detach(Observer observer) {
list.remove(observer);
}
// 循环遍历通知观察者
@Override
public void subjectNotify() {
for(Observer o : list){
o.update();
}
}
}
Client
package controller;
import service.Impl.ConcreteObserver.NBAObserver;
import service.Impl.ConcreteObserver.StockObserver;
import service.Impl.ConcreteSubject.BossSubject;
import service.Impl.ConcreteSubject.SecretarySubject;
/**
* @author SHshuo
* @data 2021/10/16--15:07
* 模板方法模式
*/
public class Client {
public static void main(String[] args) {
// 通知者
SecretarySubject subject = new SecretarySubject();
// 观察者
NBAObserver nbaObserver = new NBAObserver("hshuo", subject);
StockObserver stockObserver = new StockObserver("lvmozhu", subject);
// 添加观察者
subject.attach(nbaObserver);
subject.attach(stockObserver);
// 通知观察者
subject.setSubjectState("老板回来了");
subject.subjectNotify();
}
}
UML类图
拓展:用事件委托实现
目的:
由于通知者接口仍依赖于观察者接口,进一步解除耦合。
委托:
- 就是一种引用方法的类型。一旦为委托分配了方法,委托将与该方法具有完全相同的行为。委托方法的使用可以像其他任何方法一样,具体的参数和返回值。委托可以看作是对函数的抽象,是函数的类,委托实例将代表一个具体的函数。
- 一个委托可以搭载多个方法,所有的方法被依次唤起。更重要的是可以使得委托对象所搭载的方法并不需要属于同一类。
- 委托对象所搭载的所有方法必须具有相同的原形和形式,也就是是拥有相同的参数列表和返回值类型。
由于java没有delegate的声明委托,大多自己封装具体用反射实现。

京公网安备 11010502036488号