RxJava2学习之一:观察者模式

什么是观察者模式

观察者(Observer)模式:是对象的行为模式,又叫做发布-订阅(Publish/Subscribe)模式、模型-视图(Model/View)模式、源-监听(Source/Listener)模式或者从属(Dependents)模式。

观察者模式定义了一种一对多的依赖关系,让多个观察者对象同时监听某一个主题对象,这个主题对象在状态上发生变化时,会通知所有观察者对象,使它们能够自动更新自己。

观察者模式

  • 抽象主题(Subject)角色

抽象主题角色把所有对观察者对象的引用保存在一个聚集(比如ArrayList对象)里,每个主题都可以有任何数量的观察者。抽象主题提供一个接口,可以增加和删除观察者对象,抽象主题角色又叫做抽象被观察者(Observable)角色。

  • 具体主题(ConcreteSubject)角色

将有关状态存入具体观察者对象;在具体主题的内部状态改变时,给所有登记过的观察者发出通知。具体主题角色又叫做具体被观察者(Concrete Observable)角色。

  • 抽象观察者(Observer)角色

为所有的具体观察者定义一个接口,在得到主题的通知时更新自己,这个接口叫做更新接口。

  • 具体观察者(ConcreteObserver)角色

存储与主题的状态自恰的状态。具体观察者角色实现抽象观察者角色所要求的更新接口,以便使本身的状态与主题的状态 像协调。如果需要,具体观察者角色可以保持一个指向具体主题对象的引用。

观察者模式实践

  1. Observable:被观察者(主题Subject)
  2. Observer/Subscriber:观察者
  3. Subscribe:订阅

Observable 和 Observer 通过 subscribe() 方法实现订阅关系

  • 定义观察者接口
1
2
3
4
public interface Observer {
String getName();
void update(String state);
}
  • 定义监听主题抽象类
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
public abstract class Subject {

//保存观察者集合
private List<Observer> observers = new ArrayList<Observer>();

/**
* 添加观察者
* @param observer
*/
public void attach(Observer observer) {
observers.add(observer);
System.out.println("添加观察者:" + observer.getName());
}

public void dettch(Observer observer) {
observers.remove(observer);
System.out.println("移除观察者:" + observer.getName());
}

/**
* 通知所有观察者更新状态
* @param state
*/
public void notifyObservers(String state) {
for (Observer observer : observers) {
observer.update(state);
}
}

}
  • 观察者模式的一个实现:女朋友观察者
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
public class GFObserver implements Observer {

private String name;

public GFObserver(String name) {
this.name = name;
}

@Override
public String getName() {
return name;
}

@Override
public void update(String state) {
System.out.println(this.name + " 接收到新消息,最新状态:" + state);
}

}
  • 订阅主题的一个实现
1
2
3
4
5
6
7
public class MySubject extends Subject {

public void change(String state) {
notifyObservers(state);
}

}
  • 主函数测试
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
public class MainClient {

public static void main(String[] args) {
Observer observer1 = new GFObserver("张含韵");
Observer observer2 = new GFObserver("范冰冰");
Observer observer3 = new GFObserver("杨颖");

MySubject subject = new MySubject();

subject.attach(observer1);
subject.attach(observer2);
subject.attach(observer3);

subject.change("我在工作");
subject.change("我在开会");

subject.dettch(observer3);
subject.change("我在大保健");
}

}

运行结果

1
2
3
4
5
6
7
8
9
10
11
12
添加观察者:张含韵
添加观察者:范冰冰
添加观察者:杨颖
张含韵 接收到新消息,最新状态:我在工作
范冰冰 接收到新消息,最新状态:我在工作
杨颖 接收到新消息,最新状态:我在工作
张含韵 接收到新消息,最新状态:我在开会
范冰冰 接收到新消息,最新状态:我在开会
杨颖 接收到新消息,最新状态:我在开会
移除观察者:杨颖
张含韵 接收到新消息,最新状态:我在大保健
范冰冰 接收到新消息,最新状态:我在大保健

Powered by AppBlog.CN     浙ICP备14037229号

Copyright © 2012 - 2020 APP开发技术博客 All Rights Reserved.

访客数 : | 访问量 :