观察者模式是软件开发中常用的一种设计模式,它通过定义一对多的依赖关系,使得一个对象(主题)的状态变化可以通知多个其他对象(观察者)。
这种模式的优点是解耦和增加扩展性,用于实现对象之间的松耦合通信。
如果要自己编码实现,我们通常定义一个主题接口(Subject)和一个观察者接口(Observer)。主题接口中包含注册观察者、移除观察者和通知观察者的方法,而观察者接口中则定义了更新状态的方法。具体的主题类和观察者类实现这些接口,并进行相应的业务逻辑实现。
考虑到实现简单点,我们假定有一个广播类,这个广播类实际上就是一个主题Subject,有多个听众收听这个广播,这里每个听众就是一个观察者Observer
定义一个主题Subject的接口类
/**
* 主题,被观察者
*/
public interface Subject {
/**
* 添加观察者
*/
void addObserver(Observer observer);
/**
* 移除观察者
*/
void removeObserver(Observer observer);
/**
* 通知观察者
*/
void notifyObserver(String message);
}
定义一个观察者Observer的接口类
/**
* 观察者
*/
public interface Observer {
void recieve(String message);
}
接下来,就是定义一个广播的类,用来实现主题接口
/**
* 广播,负责向听众广播消息
*/
public class Broadcast implements Subject{
private final List<Observer> observerList = new ArrayList<>();
@Override
public void addObserver(Observer observer) {
observerList.add(observer);
}
@Override
public void removeObserver(Observer observer) {
observerList.remove(observer);
}
@Override
public void notifyObserver(String message) {
for (Observer observer : observerList) {
observer.recieve(message);
}
}
}
再定义一个听众类,用来实现观察者接口
public class Audience implements Observer {
private final String name;
public Audience(String name) {
this.name = name;
}
@Override
public void recieve(String message) {
System.out.println(name + " received message: " + message);
}
}
写一个测试类来测试结果
public class Test {
public static void main(String[] args) {
Broadcast broadcast = new Broadcast();
Audience audience1 = new Audience("哈尔滨听众");
Audience audience2 = new Audience("大庆听众");
broadcast.addObserver(audience1);
broadcast.addObserver(audience2);
broadcast.notifyObserver("中央电视台黑龙江电视台");
broadcast.notifyObserver("黑龙江电视台中央电视台");
broadcast.removeObserver(audience2);
broadcast.notifyObserver("大庆听众关了广播");
}
}
结果打印如下
文章来源:https://www.toymoban.com/news/detail-671531.html
解释一下,广播了两拨消息,2名听众都收到了这两拨消息。后面移除了一个听众,广播了第三波消息,这时,只有剩下的那个听众收到了广播消息文章来源地址https://www.toymoban.com/news/detail-671531.html
到了这里,关于浅谈Java中的观察者模式的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!