观察者模式在java中通过observer和observable实现,用于处理对象间的依赖关系。1. observer接口定义update()方法,接收状态更新通知;2. observable类维护观察者列表,并在状态改变时调用setchanged()和notifyobservers()通知观察者;3. 通过addobserver()注册观察者;4. java事件监听机制如actionlistener是观察者模式的具体应用;5. 避免过度使用observable可通过接口委托、第三方库或自定义事件总线替代;6. 处理循环依赖可采用弱引用、标记、事件队列或重新设计对象关系;7. 实际应用场景包括gui编程、消息队列、mvc框架、配置管理和传感器数据处理。

观察者模式在Java中,本质上就是一种对象间的依赖关系,当一个对象(被观察者)的状态发生改变时,所有依赖于它的对象(观察者)都会得到通知并自动更新。Java的事件监听机制就是对这种模式的一种实现。

解决方案

在Java中实现观察者模式,主要涉及两个核心接口:Observer(观察者)和 Observable(被观察者)。
立即学习“Java免费学习笔记(深入)”;

Observer接口: 定义了观察者需要实现的方法,通常是update()方法,用于接收被观察者的状态更新通知。Observable类: Java提供了一个java.util.Observable类,可以作为被观察者的基类。Observable类负责维护观察者列表,并在状态改变时通知这些观察者。
具体步骤如下:
创建观察者类: 实现
Observer接口,并实现update()方法。在这个方法中,编写当被观察者状态改变时需要执行的逻辑。创建被观察者类: 继承
Observable类。 在被观察者类的状态改变时,调用setChanged()方法标记状态已改变,然后调用notifyObservers()方法通知所有观察者。注册观察者: 在被观察者对象上调用
addObserver()方法,将观察者对象添加到观察者列表中。
举个例子:
import java.util.Observable;
import java.util.Observer;
// 观察者接口的实现类
class ConcreteObserver implements Observer {
private String name;
public ConcreteObserver(String name) {
this.name = name;
}
@Override
public void update(Observable o, Object arg) {
System.out.println(name + " 收到通知,状态已更新: " + arg);
}
}
// 被观察者
class ConcreteObservable extends Observable {
private String state;
public String getState() {
return state;
}
public void setState(String state) {
this.state = state;
setChanged(); // 标记状态已改变
notifyObservers(state); // 通知所有观察者
}
}
public class ObserverExample {
public static void main(String[] args) {
ConcreteObservable observable = new ConcreteObservable();
ConcreteObserver observer1 = new ConcreteObserver("Observer 1");
ConcreteObserver observer2 = new ConcreteObserver("Observer 2");
observable.addObserver(observer1);
observable.addObserver(observer2);
observable.setState("Initial State");
observable.setState("New State");
}
}这段代码展示了如何使用 Observable 和 Observer 来实现一个简单的观察者模式。 ConcreteObservable 是被观察者,当其状态改变时,会通知所有注册的 ConcreteObserver。
Java事件监听机制的联系
Java的事件监听机制,比如ActionListener, MouseListener,其实就是观察者模式的一种具体应用。 事件源(例如JButton)是被观察者,事件监听器(ActionListener的实现类)是观察者。 当按钮被点击(事件发生),按钮(事件源)会通知所有注册的监听器(观察者),监听器会执行相应的处理逻辑。
如何避免Observable的过度使用?
java.util.Observable 存在一些问题,例如它是类而不是接口,导致被观察者类必须继承它,限制了类的继承结构。 此外,Observable 默认是线程安全的,但这种线程安全是通过同步方法实现的,可能导致性能问题。
替代方案包括:
-
使用接口和委托: 定义一个接口作为被观察者,然后创建一个委托类来管理观察者列表和通知逻辑。 这样可以避免继承
Observable类。 - 使用第三方库: 例如 RxJava 或 Reactor,它们提供了更强大和灵活的响应式编程模型,可以更好地处理异步事件和数据流。
- 自定义事件总线: 使用 ConcurrentHashMap 或其他线程安全的数据结构来维护观察者列表,并使用 ExecutorService 来异步通知观察者。 这种方式需要自己处理线程安全问题。
如何处理观察者模式中的循环依赖?
循环依赖指的是观察者A观察被观察者B,同时被观察者B又观察观察者A,导致状态更新时出现无限循环。
解决方法:
-
弱引用: 使用
java.lang.ref.WeakReference来存储观察者,这样当观察者不再被其他对象引用时,垃圾回收器会自动回收它,从而打破循环依赖。 - 标记: 在通知观察者之前,设置一个标记,表示当前正在通知,如果在通知过程中又收到相同的通知,则忽略该通知。
- 事件队列: 将事件放入队列中,然后异步处理队列中的事件。 这样可以避免立即通知观察者,从而打破循环依赖。
- 重新设计对象关系: 这是最根本的解决方案。 重新思考对象之间的依赖关系,避免出现循环依赖。 可能需要引入新的抽象层或者调整对象的职责。
观察者模式在实际项目中的应用场景有哪些?
观察者模式在实际项目中应用广泛,包括:
- GUI 编程: Java Swing 和 JavaFX 中的事件处理机制就是观察者模式的典型应用。 例如,按钮的点击事件、文本框的输入事件等。
- 消息队列: 消息队列可以看作是一种特殊的观察者模式。 消息生产者是被观察者,消息消费者是观察者。 当有新消息到达时,消息队列会通知所有注册的消费者。
- 模型-视图-控制器(MVC)框架: 在 MVC 框架中,模型是被观察者,视图是观察者。 当模型数据发生改变时,会通知所有视图更新显示。
- 配置管理: 当配置信息发生改变时,需要通知所有使用该配置的模块。 可以使用观察者模式来实现配置的动态更新。
- 传感器数据处理: 传感器是被观察者,数据处理模块是观察者。 当传感器数据发生改变时,会通知数据处理模块进行处理。
总之,观察者模式是一种非常常用的设计模式,可以帮助我们构建松耦合、可扩展的系统。 理解观察者模式的原理和应用场景,对于编写高质量的Java代码至关重要。










