国外的平面设计网站,无锡网站排名提升,WordPress主题DUX修改,网站推广是做什么工作观察者模式
参考#xff1a;
bugstack 虫洞栈Refactoringhttps://www.cnblogs.com/myseries/p/8735490.htmlhttps://www.jianshu.com/p/4f1cd513a72d 当一个行为发生时传递信息给另外一个用户接收做出相应的处理#xff0c;两者之间没有直接的耦合关联。 在我们编程开发中也…观察者模式
参考
bugstack 虫洞栈Refactoringhttps://www.cnblogs.com/myseries/p/8735490.htmlhttps://www.jianshu.com/p/4f1cd513a72d 当一个行为发生时传递信息给另外一个用户接收做出相应的处理两者之间没有直接的耦合关联。 在我们编程开发中也会常用到一些观察者的模式或者组件例如我们经常使用的MQ服务虽然MQ服务是有一个通知中心并不是每一个类服务进行通知但整体上也可以算作是观察者模式的思路设计。再比如可能有做过的一些类似事件监听总线让主线服务与其他辅线业务服务分离为了使系统降低耦合和增强扩展性也会使用观察者模式进行处理。 1. 结构 2. 实现
2.1 Obverse 和 Obversable 该方式已经在 Java 9 被弃用 This class and the Observer interface have been deprecated. The event model supported by Observer and Observable is quite limited, the order of notifications delivered by Observable is unspecified, and state changes are not in one-for-one correspondence with notifications. For a richer event model, consider using the java.beans package. For reliable and ordered messaging among threads, consider using one of the concurrent data structures in the java.util.concurrent package. For reactive streams style programming, see the java.util.concurrent.Flow API. 2.1.1 被观察者
当被观察者的 state 变化时通知所有进制的观察者。
public class Subject extends Observable {private int state;public int getState() {return state;}public void setState(int state) {this.state state;this.setChanged();this.notifyObservers();}
}2.1.2 多个观察者
public class BinaryObserver implements Observer {public BinaryObserver(Observable observable) {observable.addObserver(this);}Overridepublic void update(Observable o, Object arg) {if (o instanceof Subject) {System.out.println(Binary String: Integer.toBinaryString(((Subject) o).getState()));}}
}public class OctalObserver implements Observer {public OctalObserver(Observable observable) {observable.addObserver(this);}Overridepublic void update(Observable o, Object arg) {if (o instanceof Subject) {System.out.println(Binary String: Integer.toOctalString(((Subject) o).getState()));}}
}public class HexaObserver implements Observer {public HexaObserver(Observable observable) {observable.addObserver(this);}Overridepublic void update(Observable o, Object arg) {if (o instanceof Subject) {System.out.println(Binary String: Integer.toHexString(((Subject) o).getState()));}}
}2.1.3 测试
public class Test{public static void main(String[] args) {Subject subject new Subject();new BinaryObserver(subject);new OctalObserver(subject);new HexaObserver(subject);System.out.println(First state change: 15);subject.setState(15);System.out.println(Second state change: 10);subject.setState(10);}
}还值得优化的部分可以把添加观察者还有删除观察者的功能提取到一个单独的管理类中。 2.2 PropertyChangeEventPropertyChangeSupportPropertyChangeListener
这三个类分别对应的职责
PropertyChangeListener观察者PropertyChangeSupport管理者PropertyChangeEvent事件
class EventSource {private String name;/** 在事件源的地方添加一个PropertyChangeSupport对象间接地由它负责添加监听、激发事件*/private final PropertyChangeSupport listeners new PropertyChangeSupport(this);/*** 在事件源上添加监听实际上是在PropertyChangeSupport对象上添加监听*/public void addListener(PropertyChangeListener listener) {listeners.addPropertyChangeListener(listener);}/*** 同上*/public void removeListener(PropertyChangeListener listener) {listeners.removePropertyChangeListener(listener);}/*** 事件源发生变化时也是通过PropertyChangeSupport对象把事件发送到监听者上的*/public void setName(String name) {String oldValue this.name;this.name name;// 触发事件源监听者得到触发变化listeners.firePropertyChange(name, oldValue, this.name);}
}Slf4j
class Monitor implements PropertyChangeListener {Overridepublic void propertyChange(PropertyChangeEvent evt) {log.info(事件源 {} 发生变化, {} {}, evt.getPropertyName(), evt.getOldValue(), evt.getNewValue());}
}public class TestPropertyChangeSupport {public static void main(String[] args) {EventSource eventSource new EventSource();Monitor monitor new Monitor();//在事件源上添加监听发生变化时就会调用propertyChange方法eventSource.addListener(monitor);eventSource.setName(11);}
}
