观察者模式

sky-mxc总结 转载请注明:https://sky-mxc.github.io/2016/12/25/designModel-observer

观察者模式

观察者模式定义了一种一对多的依赖关系,让多个观察者对象同时监听一个主题对象,当主题对象在状态上发生改变时,通知所有的观察者对象,并让他们自动更新自己;

观察者模式的组成

抽象主题角色:

将所有的观察者引用存放到一个集合中,每个主题可以拥有任意数量的观察者;主题提供一个接口,用来增加,移除通知观察者。一般用一个抽象类或接口来实现;

抽象观察者角色:

为所有的观察者定义一个接口,在得到主题通知时更新自己;

具体主题角色:

在具体主题状态发生改变时,通知所有登记过的观察者。具体主题通常由一个子类实现;

具体观察者角色:

该角色实现抽象观察者角色所要求的更新接口,在得到主题通知时更新自己,让本身的状态和观察者的状态相协调。通常是一个自类实现。如果需啊,可以在内部保存观察的主题的引用。

程序实现

抽象观察者角色

1
2
3
4
5
6
7
8
9
10
11
12
/**
* 抽象观察者接口
* Created by sky-mxc on 2016/12/25.
*/
public interface IObserver {
/**
* 主题发生变化
* @param str
*/
void update(String str);
}

抽象主题角色

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
/**
* 抽象主题
* Created by sky-mxc on 2016/12/25.
*/
public abstract class ISubject {
//观察者 集合
protected List<IObserver> observers = new ArrayList<>();
//主题名字
protected String name;
public ISubject(String name) {
this.name = name;
}
/**
* 增加 观察者
* @param observer 观察者
*/
public void addObserver(IObserver observer){
observers.add(observer);
}
/**
* 移除观察者
* @param observer 观察者
*/
public void removeObserver(IObserver observer){
observers.remove(observer);
}
/**
* 通知观察者
* @param str 通知内容
*/
protected abstract void notifyUpdate(String str);
}

具体主题角色

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
/**
* 具体主题
* Created by sky-mxc on 2016/12/25.
*/
public class Subject extends ISubject {
public Subject(String name) {
super(name);
}
@Override
public void notifyUpdate(String str) {
for (IObserver observer :observers){
observer.update(str+"\t\t\t--- "+name);
}
}
}

具体观察者角色

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
/**
* 具体观察者
* Created by sky-mxc on 2016/12/25.
*/
public class Observer implements IObserver {
private String name;
public Observer(String name) {
this.name = name;
}
@Override
public void update(String str) {
System.out.println(name+"接收到了通知:"+str);
}
}

运行

public class Main {

    public static void main(String[] args) {
        Observer observer1 =new Observer("张三");
        Observer observer2 =new Observer("李四");
        Observer observer3 =new Observer("王五");

        Subject subject = new Subject("PM");
        subject.addObserver(observer1);
        subject.addObserver(observer2);
        subject.addObserver(observer3);
        for (int i=0;i<5;i++){
            subject.notifyUpdate("通知:"+System.currentTimeMillis());
            try {
                Thread.sleep(1000*3);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("\n");
        }
    }
}

result:

运行结果