观察者模式是一种行为设计模式,用于实现对象间的一对多依赖通知机制。1. 它通过主题维护观察者列表并状态变化时主动通知所有观察者实现自动更新;2. 主要角色包括主题(subject)、观察者(observer)、具体主题(concretesubject)和具体观察者(concreteobserver);3. 应用场景涵盖gui事件处理、消息队列、推送通知、excel公式计算和mvc框架等;4. 与发布/订阅模式相比,缺少中介消息代理且耦合度更高但适用于简单场景;5. 使用时需注意避免循环依赖和内存泄漏问题,可通过弱引用和及时注销观察者解决。

观察者模式是一种行为设计模式,它定义了一种一对多的依赖关系,让多个观察者对象同时监听某一个主题对象。当主题对象的状态发生改变时,所有依赖它的观察者都会收到通知并自动更新。简单来说,就是“发布-订阅”模式。

解决方案

Java中的观察者模式主要涉及以下几个角色:
立即学习“Java免费学习笔记(深入)”;
- 主题(Subject): 也称为可观察对象,它维护一个观察者列表,并提供添加、删除观察者的方法。当主题状态发生改变时,它负责通知所有注册的观察者。
- 观察者(Observer): 定义一个更新接口,当接收到主题的通知时,观察者会执行相应的更新操作。
- 具体主题(ConcreteSubject): 主题的具体实现类,维护自身的状态,并在状态改变时通知观察者。
- 具体观察者(ConcreteObserver): 观察者的具体实现类,实现更新接口,并在接收到通知时执行具体的更新逻辑。
工作流程图解 (用文字描述,因为我无法直接生成图片)

- 注册: 具体观察者向具体主题注册,表示它希望监听主题的状态变化。具体主题维护一个观察者列表,将注册的观察者添加到列表中。
- 状态改变: 具体主题的状态发生改变。
-
通知: 具体主题调用
notifyObservers()方法,遍历观察者列表,并调用每个观察者的update()方法。 -
更新: 每个具体观察者接收到通知,执行
update()方法中定义的更新逻辑,通常是根据主题的状态来更新自身的状态。
Java代码示例
// 观察者接口
interface Observer {
void update(String message);
}
// 主题接口
interface Subject {
void registerObserver(Observer observer);
void removeObserver(Observer observer);
void notifyObservers();
}
// 具体观察者
class ConcreteObserver implements Observer {
private String name;
public ConcreteObserver(String name) {
this.name = name;
}
@Override
public void update(String message) {
System.out.println(name + " received message: " + message);
}
}
// 具体主题
class ConcreteSubject implements Subject {
private List observers = new ArrayList<>();
private String message;
@Override
public void registerObserver(Observer observer) {
observers.add(observer);
}
@Override
public void removeObserver(Observer observer) {
observers.remove(observer);
}
@Override
public void notifyObservers() {
for (Observer observer : observers) {
observer.update(message);
}
}
public void setMessage(String message) {
this.message = message;
notifyObservers();
}
}
// 示例
public class ObserverPatternExample {
public static void main(String[] args) {
ConcreteSubject subject = new ConcreteSubject();
ConcreteObserver observer1 = new ConcreteObserver("Observer 1");
ConcreteObserver observer2 = new ConcreteObserver("Observer 2");
subject.registerObserver(observer1);
subject.registerObserver(observer2);
subject.setMessage("New message from subject!");
subject.removeObserver(observer1);
subject.setMessage("Another message!");
}
} 观察者模式在实际开发中有哪些应用场景?
观察者模式的应用非常广泛,例如:
- GUI事件处理: 按钮点击、鼠标移动等事件,GUI框架会通知注册的监听器。
- 消息队列: 发布者发布消息,订阅者接收消息。
- 推送通知: 当用户关注的内容更新时,系统会推送通知给用户。
- Excel公式计算: 当单元格的值改变时,依赖该单元格的公式会自动重新计算。
- MVC框架: 模型(Model)发生变化时,视图(View)会自动更新。
本质上,任何需要在多个对象之间建立松散耦合关系,并且一个对象的状态变化需要通知其他对象的情况,都可以考虑使用观察者模式。
观察者模式和发布/订阅模式有什么区别?
虽然观察者模式和发布/订阅模式很相似,但它们之间存在一些关键区别:
- 中介者: 观察者模式中,主题直接维护观察者列表并通知它们。发布/订阅模式中,存在一个消息代理(Message Broker),发布者将消息发布到消息代理,订阅者从消息代理订阅消息。
- 耦合度: 观察者模式中,主题和观察者之间存在直接的依赖关系。发布/订阅模式中,发布者和订阅者之间通过消息代理解耦,彼此不知道对方的存在。
- 灵活性: 发布/订阅模式比观察者模式更灵活,可以实现更复杂的发布/订阅关系,例如基于主题的订阅、基于内容的订阅等。
简单来说,观察者模式是发布/订阅模式的一种简化版本,适用于简单的场景。发布/订阅模式更适合复杂的、分布式的系统。
如何避免观察者模式中的循环依赖和内存泄漏?
在使用观察者模式时,需要注意避免循环依赖和内存泄漏:
- 循环依赖: 如果观察者和主题之间存在相互依赖关系,可能会导致无限循环调用。可以通过仔细设计对象之间的关系,避免循环依赖。
- 内存泄漏: 如果观察者没有及时从主题中注销,可能会导致内存泄漏。例如,如果一个观察者对象被销毁了,但仍然注册在主题中,主题会一直持有该对象的引用,导致该对象无法被垃圾回收。可以使用弱引用(WeakReference)来解决这个问题。
另外,在多线程环境下使用观察者模式时,需要注意线程安全问题,可以使用锁或其他同步机制来保证线程安全。考虑使用并发集合,例如ConcurrentLinkedQueue,来存储观察者列表。










