定义
定义对象间的一种一对多的依赖关系，让多个观察者对象同时监听某一个主题对象。这个主题对象在状态发生改变时，会通知所有观察者对象，使它们能够自动更新自己。
结构图
老板来了的例子
由于有很多共同的代码，所以这里仍然采用书中的第二版，采用基类的模式。至于采用接口的方式，可以参考下面的链接
《大话设计模式》——观察者模式(订阅--发布模式)观察者没有必要通过持有主题对象，访问他的SubjectState公共属性来得到主题的消息，完全可以通过方法的参数的形式来传递消息。iOS系统的通知中心，就是传递一个通知对象NSNotification参数。
用委托delegate的方式，可以让观察者自定义方法的名字，这个涉及到将方法当做参数传递的问题。书中是采用EventHandder的方式实现。iOS系统是通过Selector的方式实现。在这个小例子中就做这块了。方法固定为
public abstract void update(String subjectState)这是典型的一对多关系，类似UML结构图中的“聚合关系”。主题Subject就相当于“雁群”，各个观察者Observer相当于“大雁”。主题Subject中维护着一个成员变量
private List<Observer> observerList = new ArrayList<Observer>();是观察者的集合。设想的场景如下：
主题取名叫
whoComeSubject，也就是观察谁来了；定义3个观察者实例，其中1个没有加入观察者列表，另外两个加入了观察者列表。另外，这2个观察者有2个在看股票行情，有1个在看NBA直播。
通过参数传递的subjectState定义为人物类型，比如“老板来了”，就传“老板”；“秘书来了”，就传“秘书”
观察者收到消息后，首先查看主题Subject传过来的subjectState参数内容。如果是“老板”，那么就赶紧停下当前的消遣，继续工作；如果是“秘书”，那么就继续消遣；如果是其他的内容，就当没有收到消息，什么也不做。
另外，有1个观察者没有加入观察列表，所以不管谁来了，他都我行我素，一点都不改变。
- 测试界面
- 主题Subject：基本上差不多，所以就用一个类表示，连继承都不用。iOS系统的通知中心由系统提供，我们根本就不用管。
class Subject {
private String subjectState;
private List<Observer> observerList = new ArrayList<Observer>();
// 设置主题状态
public void setSubjectState(String subjectState) {
this.subjectState = subjectState;
}
// 添加观察者
public void attach(Observer observer) {
observerList.add(observer);
}
// 移除观察者
public void detach(Observer observer) {
observerList.remove(observer);
}
// 通知，notify这个名字不能用
// 把主题的状态subjectState通过参数的方式传递给观察者Observer
public void notice() {
for (Observer observer:observerList) {
observer.update(subjectState);
}
}
}
- 观察者基类Observer，这里因为由显示的公共方法，所以用了基类，实际中也可以用接口。
abstract class Observer {
protected String name;
protected String action = "没有观察到主题变化，该干嘛干嘛";
public Observer(String name) {
this.name = name;
}
// 收到主题消息后的响应
public abstract void update(String subjectState);
// 展示响应信息
public String showAction() {
return action;
}
}
- 具体的观察者：股票观察者，NBA观察者... ...
class StockObserver extends Observer {
public StockObserver(String name) {
super(name);
action = "没有发现人来，" + name + "在看股票行情";
}
@Override
public void update(String subjectState) {
if (subjectState == "老板") {
action = "老板来了，" + name + "关闭股票行情，继续工作！";
} else if (subjectState == "秘书") {
action = "秘书来了，" + name + "可以继续看股票行情";
} else {
// 不知道谁来了，不操作
}
}
}
class NBAObserver extends Observer {
public NBAObserver(String name) {
super(name);
action = "没有发现人来，" + name + "在看NBA直播";
}
@Override
public void update(String subjectState) {
if (subjectState == "老板") {
action = "老板来了，" + name + "关闭NBA直播，继续工作！";
} else if (subjectState == "秘书") {
action = "秘书来了，" + name + "可以继续看NBA直播";
} else {
// 不知道谁来了，不操作
}
}
}
- 客户端程序
public class ObserverActivity extends AppCompatActivity {
public static void launch(Context context) {
if (null != context) {
Intent intent = new Intent();
intent.setClass(context, ObserverActivity.class);
if (!(context instanceof Activity)) {
intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
}
context.startActivity(intent);
}
}
TextView whatToDoTextView;
Subject whoComeSubject;
StockObserver notObserver;
StockObserver observer;
NBAObserver nbaObserver;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_observer);
setTitle("观察者模式");
whatToDoTextView = findViewById(R.id.textViewWhatToDo);
whoComeSubject = new Subject();
notObserver = new StockObserver("魏光茶");
observer = new StockObserver("易冠茶");
nbaObserver = new NBAObserver("朗球迷");
// notObserver不加入观察列表
whoComeSubject.attach(observer);
whoComeSubject.attach(nbaObserver);
}
public void onBossClick(View view) {
whoComeSubject.setSubjectState("老板");
whoComeSubject.notice();
}
public void onSecretaryClick(View view) {
whoComeSubject.setSubjectState("秘书");
whoComeSubject.notice();
}
public void onNotObserverClick(View view) {
whatToDoTextView.setText(notObserver.showAction());
}
public void onObserverClick(View view) {
whatToDoTextView.setText(observer.showAction());
}
public void onNBAClick(View view) {
whatToDoTextView.setText(nbaObserver.showAction());
}
}
Demo地址
https://gitee.com/zhangxusong888/Android/tree/master/design_pattern
