给企业做网站的平台,全网推广平台有哪些,陕西专业网站开发公司,网站没快照什么是观察者模式
顾名思义#xff0c;观察者模式就是在多个对象之间#xff0c;定义一个一对多的依赖#xff0c;当一个对象状态改变时#xff0c;所有依赖这个对象的对象都会自动收到通知。
观察者模式也称为发布订阅模式(Publish-Subscribe Design Pattern)#xff0…什么是观察者模式
顾名思义观察者模式就是在多个对象之间定义一个一对多的依赖当一个对象状态改变时所有依赖这个对象的对象都会自动收到通知。
观察者模式也称为发布订阅模式(Publish-Subscribe Design Pattern)一般被依赖的对象称为被观察者,依赖的对象称为观察者不过也有其他的叫法例如Subject和ObserverPublisher和SubscriberProducer和ConsumerEvenEemitter(事件发布器)和EventListene还有Dispatcher和Listener。只要场景符合观察者模式的定义都算观察者模式的应用。
类图 主题Subject 主题中包含着所有调用registerObservers来进行注册的 Observer(观察者) 主题收到消息后通过notifyObservers方法告知所有观察者其状态的改变 观察者Observer 包含着收到消息的处理逻辑处理逻辑存在于其update方法中
之前在学习设计模式的时候有了解过这个模式在使用MQ中间件的时候其实也有实践过观察者模式不过这次EventBus又接触到了观察者模式所以就总结记录一下吧同时也再复习一下观察者模式。
典型代码实现
是从一个博主那里引用过来的他写的很详细博主的详细博文在文末链接。
/*** 主题接口** author liuyp* date 2022/11/28*/
public interface SubjectT {void registerObserver(ObserverT obverser);void removeObserver(ObserverT obverser);void notifyObservers(T message);
}
/*** 观察者接口** author liuyp* date 2022/11/28*/
public interface ObserverT {void update(T message);
}
/*** 主题的具体实现** author liuyp* date 2022/11/28*/
public class ConcreteSubjectT implements SubjectT {/*** 线程安全的Set容器保存obversers*/private SetObserverT obversers new CopyOnWriteArraySet();Overridepublic void registerObserver(ObserverT obverser) {obversers.add(obverser);}Overridepublic void removeObserver(ObserverT obverser) {System.out.println(Obversable this.hashCode() 移除观察者 obverser.hashCode());obversers.remove(obverser);}Overridepublic void notifyObservers(T message) {System.out.println(Obversable this.hashCode() 发布了一条消息 message.toString());obversers.forEach(obverser - obverser.update(message));}
}
/*** 具体的观察者** author liuyp* date 2022/11/28*/
public class ConcreteObverserT implements ObserverT {Overridepublic void update(T message) {System.out.println(Obverser this.hashCode() 收到通知 message);}
}
/*** 测试类** author liuyp* date 2022/11/28*/
public class TestMain {public static void main(String[] args) {//定义主题 也是被观察者observableSubjectString subject new ConcreteSubject();//定义观察者 observerObserverString observer1 new ConcreteObverser();ObserverString observer2 new ConcreteObverser();//订阅主题 subjectsubject.registerObserver(observer1);subject.registerObserver(observer2);//发布通知subject.notifyObservers(消息1明天是2022年11月29日);//移除观察者1subject.removeObserver(observer1);//重新发布通知subject.notifyObservers(消息2琪琪农历10月17生日);}
}
Obversable1802598046 发布了一条消息消息1明天是2022年11月29日
Obverser240650537 收到通知消息1明天是2022年11月29日
Obverser483422889 收到通知消息1明天是2022年11月29日
Obversable1802598046 移除观察者240650537
Obversable1802598046 发布了一条消息消息2琪琪农历10月17生日
Obverser483422889 收到通知消息2琪琪农历10月17生日
观察者模式的作用
可以使得发布者和订阅者的代码解耦合增加代码的可靠性和灵活性。
EventBus
下期我们再来说说观察者模式的应用EventBus~
原博客不小心关掉了 找不到了 如有侵权 请博主与我联系我挂上博主原文连接~
