一、观察者模式
当对象中存在一对多的关系时，就需要使用这种模式。比如说一个对象发生改变时，会通知到依赖它的对象。
介绍
- 意图：定义对象之间一对多的依赖关系，当一个对象的状态发生改变时，会通知到其它依赖该对象的行为。
- 主要解决：一个对象状态改变给其他对象通知的问题，而且要考虑到易用和低耦合，保证高度的协作。
- 如何解决：采用面向对象的技术，可以将这种关系弱化。
- 关键代码：在被订阅类里面采用一个集合来存放观察者，并且在状态改变时一一通知他们去更新。
- 应用实例：1.对于在订阅了微信公众号某个主题的用户来说，每当公众号有发布新的内容时，会自动的将内容及时推送到用户；2.在初中的教室上课，当下课铃声响起的时候，学生们会主动收拾书包准备下课回家吃饭了；3.在某会议上面，领导召集了负责各个业务模块的子领导，及时传达了某些核心思想，参与了此次会议的小负责人会通知到各个下属。
- 注意事项：1.Java中已经有了对于观察者的支持类。2.避免循环引用。3.如果顺序执行，某一个观察者执行时发生了错误，会导致卡克，一般采取异步的方式去执行。
演示
下面通过一个小的demo来展示一下观察者模式的使用场景。
-
微信公众号推送文章
首先先来明确下各个扮演的角色，对于订阅了某个公众号的用户来说，他们属于观察者，而公众号的文章的发布属于被观察者。明确了这一点后，下面就比较好撸代码了。
1、定义被观察者的主要方法，采取接口来定义/** * 微信主题的接口 即被观察着 他会有三个方法 * @author rain * */ public interface IWxServerSubject { void attach(IObserver observer); void detach(IObserver observer); void updateObserver(); }
2 、定义抽象的观察者接口
/**
* 观察者 订阅了微信主题的观察者
* @author rain
*
*/
public interface IObserver {
void receiveContent(String info);
}
`3、实现具体的被观察者
public class IWxSubjectImpl implements IWxServerSubject{
//观察者列表 订阅了微信公众号的读者
private List<IObserver> observers = new ArrayList<>();
private String submitContent;
@Override
public void attach(IObserver observer) {
observers.add(observer);
}
//一个信号 即发布了新的文章
public void submitContent(String content){
this.submitContent = content;
updateObserver();
}
@Override
public void detach(IObserver observer) {
if(observers.contains(observer)){
observers.remove(observer);
}
}
@Override
public void updateObserver() {
for (IObserver iObserver : observers) {
iObserver.receiveContent(submitContent);
}
}
}
4、定义一个具体的观察者
/**
* 读者 订阅了微信公众号的 观察者
* @author rain
*
*/
public class ReaderObsever implements IObserver{
private String name;
public ReaderObsever(String name) {
this.name = name;
}
@Override
public void receiveContent(String info) {
System.out.println(name +" ，请注意：Rain发布了新的微信公众号文章---"+info);
}
public String getName(){
return name;
}
}
5、来个测试类模拟一下吧
public class Test {
public static void main(String[] args) {
IWxServerSubject subject = new IWxSubjectImpl();
//创建了四个读者 并且都关注了该公众号的 只有赵六没有关注
ReaderObsever reader1 = new ReaderObsever("张三");
ReaderObsever reader2 = new ReaderObsever("李四");
ReaderObsever reader3 = new ReaderObsever("王五");
//订阅了该公众号的读者 即观察者角色
subject.attach(reader1);
subject.attach(reader2);
subject.attach(reader3);
//公众号发布了文章了
((IWxSubjectImpl)subject).submitContent("观察者设计模式开始啦！！！");
}
}
运行一下：
模拟观察者.png
可以看到，订阅过该公众号的用户确实收到了新发布的文章，good。。。
网友评论