让你有做黑客感觉的网站腾讯广告

描述

观察者模式，顾名思义就是一个对象观察着其他对象，一旦被观察的对象发生变化时，观察者对象也要做出相应动作。

其中，被观察者持有观察者的引用。由观察者主动注入被观察者内（有点像，观察者向被观察者内部安插的一个内应）

通常包含2个抽象角色及其对应的实现

需要注意的是，实际使用中观察链不宜过长，可能引发性能问题

基本组件

• 定义观察者抽象及其实现

public interface IObserver {String getName();void action(IObservable observable, Object... params);
}public class DefaultObserver implements IObserver {private final String name;public DefaultObserver(String name) {this.name = name;}@Overridepublic String getName() {return this.name;}@Overridepublic void action(IObservable observable, Object... params) {System.out.println(this.getName() + " 观察到 ["+ observable.getName() +"] 的行为: " + Arrays.stream(params).map(String::valueOf).collect(Collectors.joining("; ")));}
}

• 定义被观察者抽象及实现

public class DefaultObservable implements IObservable {private final String name;private Set<IObserver> observers = new HashSet<>();public DefaultObservable(String name) {this.name = name;}@Overridepublic void addObserver(IObserver observer) {observers.add(observer);}@Overridepublic void removeObserver(IObserver observer) {observers.remove(observer);}@Overridepublic void notifyObserver(Object... params) {observers.forEach(observer -> observer.action(this, params));}public String getName() {return name;}
}

使用

public class Sample {public static void main(String[] args) {IObserver observer1 = new DefaultObserver("观察员1");IObserver observer2 = new DefaultObserver("观察员2");IObservable observable = new DefaultObservable("张三");observable.addObserver(observer1);observable.addObserver(observer2);observable.notifyObserver("发生了事件...");}
}