一、引入话题-发散思考
1、如果你是安卓开发工程师,是否经常遇到给所有的用户或者特定的用户推送消息的业务场景呢?例如:我曾经做的一款APP就是用极光推送一个消息,下载该APP的用户都能收到消息提示。
2、如果你了解zookeeper分布式调节框架?假设一个集群有1000台机器Master-Slave结构,我想给这个集群修改配置文件,都是一模一样的文件在不同机器上,难道我们一台一台机器修改?答案是当然不能。那怎么解决?那配置文件注册到zookeeper上,然后集群机器监听配置文件的变化,当配置文件改变以后,观察者就能知道,并且对配置文件作出对应的配置。如果兴趣想详细了解看我zookeeper文章介绍。
二、简介
观察者模式:定义了对象之间的一对多依赖,这样一来,当一个对象改变状态时,它的所有依赖者都会接受到通知并且自动更新。
应用场景:
- 消息推送(广播)
- 注册中心/消息订阅
场景描述:
假设观察者们都是电灯泡,当他们的state为1的时候,所有的电灯泡都点亮,如果state为0的时候,所有的电灯泡都熄灭。那么假设有一个电灯泡注册中心,也就是总开关,所有的电灯泡的控制权都需在电灯泡注册中心手上,当注册中心设置灯泡的开关为1的时候,所有的电灯泡都会收到一个消息,那么就会根据消息数据做出相应的反应。
二、自定义接口实现
//主题接口 public interface Subject { void registerObserver(Observer observer); void removeObject(Observer observer); void notifyObservers(); } //主题具体实现类 public class ConcreteSubject implements Subject{ List<Observer> observers=new ArrayList<Observer>(); private int state; //注册观察者 @Override public void registerObserver(Observer observer) { observers.add(observer); } //移除观察者 @Override public void removeObject(Observer observer) { int index=observers.indexOf(observer); if(index>=0){ observers.remove(index); return; } } //通知观察者:类似消息推送 @Override public void notifyObservers() { for(Observer observer:observers){ observer.update(this); } } public int getState() { return state; } public void setState(int state) { this.state = state; notifyObservers(); } } //观察者接口 public interface Observer { void update(Subject subject); } //观察者实现类 public class ConcreteObserver implements Observer{ private int state; //同步主题的状态 @Override public void update(Subject subject) { this.state=((ConcreteSubject)subject).getState(); } public int getState() { return state; } public void setState(int state) { this.state = state; } } //客户端测试类 public class Client { public static void main(String[] args) { Subject subject=new ConcreteSubject(); ConcreteObserver observerA=new ConcreteObserver(); ConcreteObserver observerB=new ConcreteObserver(); subject.registerObserver(observerA); subject.registerObserver(observerB); ((ConcreteSubject)subject).setState(10); System.out.println("观察者A(订阅者A):"+observerA.getState()); System.out.println("观察者B(订阅者B):"+observerB.getState()); } } 运行结果: 观察者A(订阅者A):10 观察者B(订阅者B):10
三、Java提供API
//具体主题类(继承自主题类Observable) public class ConcreteSubject extends Observable{ private int state; public void setState(int state) { this.state = state; setChanged(); notifyObservers(); } public int getState() { return state; } } //具体观察者(实现javaAPI Observer) public class ConcreteObserver implements Observer{ private int state; @Override public void update(Observable o, Object arg) { this.state=((ConcreteSubject)o).getState(); } public int getState() { return state; } } //客户端 public class Client { public static void main(String[] args) { ConcreteSubject subject=new ConcreteSubject(); ConcreteObserver observerA=new ConcreteObserver(); ConcreteObserver observerB=new ConcreteObserver(); subject.addObserver(observerA); subject.addObserver(observerB); subject.setState(123); System.out.println("观察者A(订阅者A):"+observerA.getState()); System.out.println("观察者B(订阅者B):"+observerB.getState()); } } 运行结构: 观察者A(订阅者A):123 观察者B(订阅者B):123
四、版权声明
作者:邱勇Aaron
出处:http://www.cnblogs.com/qiuyong/
您的支持是对博主深入思考总结的最大鼓励。
本文版权归作者所有,欢迎转载,但未经作者同意必须保留此段声明,且在文章页面明显位置给出原文连接,尊重作者的劳动成果。
参考:Head First 设计模式
时间: 2024-07-30 14:10:47