一 概念
- 观察者模式定义了一种一对多的依赖关系,让多个观察者对象同时监听某一个主题对象。这个主题对象再状态发生变化时,会通知所有观察者对象,使它们能够自动更新自己。
二 UML图
- Subject类,它把所有对观察者对象的引用保存在一个聚集里,每个主题都可以有任何数量的观察者。抽象主题提供一个接口,可以增加和删除观察者对象。
- Observer类,抽象观察者,为所有的具体观察者定义一个接口,在得到主题的通知时更新自己。
- ConcreteSubject类,具体主题,将有关状态存入具体观察者对象,在具体主题的内部状态改变时,给所有登记过得观察者发出通知。
- ConcreteObserver类,具体观察者,实现抽象观察者角色所要求的更新接口,以便使本身的状态与主题的状态相协调。
三 观察者模式的特点
- 将一个系统分割成一系列相互协作的类有一个很不好的副作用,那就是需要维护相关对象间的一致性,我们不希望为了维持一致性而使各类紧密耦合,这样会给维护,扩展和重用都带来不便。
- 当一个对象的改变需要同时改变其他对象的时候,应当使用观察者模式
四 C++代码实现
#include "pch.h"
#include <iostream>
#include <list>
#include <string>
using namespace std;
//抽象的观察者,为所有的具体观察者定义一个接口,在得到主题的通知
//时更新自己
class Observer
{
public:
Observer() //默认构造函数
{
}
Observer(string name)
: str_ObserverName(name) {}
virtual void Update() = 0;
protected:
string str_ObserverName; //通知者的名字
};
//抽象的通知者,一般用一个类或者一个接口实现
class Subject
{
public:
virtual void Attach(Observer* observer) = 0;
virtual void Detach(Observer* observer) = 0;
virtual void Notify() = 0;
};
//具体的通知者类可能是前台,也可能是老板,他们也许有各自的一些方法,但对于通知者来说,
//它们是一样的,所以它们都去实现这个接口
class Boss : public Subject
{
public:
Boss()
{
}
~Boss()
{
}
//增加
void Attach(Observer* observer) override
{
observers.push_back(observer);
}
//减少
void Detach(Observer* observer) override
{
list<Observer*>::iterator it = observers.begin();
for (;it != observers.end(); ++it)
{
if (*it == observer)
{
observers.erase(it);
break;
}
}
}
//通知
void Notify() override
{
list<Observer*>::iterator it = observers.begin();
for (;it != observers.end(); ++it)
{
(*it)->Update();
}
}
private:
list<Observer*> observers;
string m_action;
};
//两个具体的观察者
class StockObserver : public Observer
{
public:
void Update() override
{
cout << "关闭股票行情,继续工作" << endl;
}
};
class NBAOberserver : public Observer
{
public:
void Update() override
{
cout << "关闭NBA直播,继续工作" << endl;
}
};
int main()
{
Boss* huhansan = new Boss();
//看股票的同事
StockObserver* tongshi1 = new StockObserver();
//看NBA直播的同事
NBAOberserver* tongshi2 = new NBAOberserver();
huhansan->Attach(tongshi1);
huhansan->Attach(tongshi2);
//移除一个同事
huhansan->Detach(tongshi2);
//老板回来发出通知
huhansan->Notify();
return 0;
}