在GOF的《设计模式:可复用面向对象软件的基础》一书中对观察者模式是这样定义的:定义对象的一种一对多的依赖关系,当一个对象的状态发生改变时,所有依赖于它的对象都得到通知并被自动更新。当一个对象发生了变化,关注它的对象就会得到通知;这种交互也成为发布-订阅(publish-subscribe)。
- #include
- #include
- using std::cout;
- using std::endl;
- using std::cin;
-
- class Observer
- {
- public:
- virtual ~Observer() {};
- virtual void Update(int) = 0;
- };
-
- class Subject
- {
- public:
- virtual ~Subject() {};
- virtual void Attach(Observer*) = 0;
- virtual void Detach(Observer*) = 0;
- virtual void Notify() = 0;
- };
-
-
- class ConcreteObserver : public Observer
- {
- private:
- Subject* _pSubject;
-
- public:
- ConcreteObserver(Subject* pSubject) :_pSubject(pSubject)
- {
- //在目标中注册当前观察者(此处的观察者是广义上的观察者,目标并不知道具体谁要观察它,目标只进行广播即可)
- this->_pSubject->Attach(this);
- cout << "I'm the observer \" 1 \".\n";
- }
-
- void Update(int value) override
- {
- cout << "ConcreteObserver get the update.New State:" << value << endl;
- }
- };
-
-
-
- class ConcreteObserver2 : public Observer
- {
- private:
- Subject* _pSubject;
-
- public:
- ConcreteObserver2(Subject* pSubject) :_pSubject(pSubject)
- {
- //在目标中注册当前观察者(此处的观察者是广义上的观察者,目标并不知道具体谁要观察它,目标只进行广播即可)
- this->_pSubject->Attach(this);
- cout << "I'm the observer \" 2 \".\n";
- }
-
- void Update(int value) override
- {
- cout << "ConcreteObserver2 get the update.New State:" << value << endl;
- }
- };
-
-
- class ConcreteSubject :public Subject
- {
- private:
- std::list
_pObserverList; - int _iState;
- public:
- void SetState(int state)
- {
- _iState = state;
- }
-
- void Attach(Observer* pObserver) override
- {
- _pObserverList.push_back(pObserver);
- }
-
-
- void Detach(Observer* pObserver) override
- {
- _pObserverList.remove(pObserver);
- }
-
-
- void Notify() override
- {
- auto begin = _pObserverList.begin();
- auto end = _pObserverList.end();
- while (begin != end)
- {
- (*begin)->Update(_iState);
- begin++;
- }
- }
- };
-
- int main()
- {
- //创建目标
- ConcreteSubject* pSubject = new ConcreteSubject();
-
- //创建观察者
- Observer* pObserver = new ConcreteObserver(pSubject);
- Observer* pObserver2 = new ConcreteObserver2(pSubject);
-
- //改变当前状态
- pSubject->SetState(2);
-
- //广播给所有广义上的观察者
- pSubject->Notify();
-
- //去除某个观察者
- pSubject->Detach(pObserver);
-
- //改变当前状态
- pSubject->SetState(3);
-
- //重新广播
- pSubject->Notify();
-
-
- //结束,释放对象
- delete pObserver;
- delete pObserver2;
- delete pSubject;
- return 0;
- }
意图:定义对象间的一种一对多的依赖关系,当一个对象的状态发生改变时,所有依赖于它的对象都会得到通知并被自动更新。
主要解决:一个对象状态改变并给其它对象通知的问题,而且要考虑到易用和低耦合,保证高度的协作。
何时使用:一个对象(目标对象)的状态发生改变,所有的依赖对象(观察者对象)都将得到通知,进行广播通知。
如何解决:使用面向对象技术,可以将这种依赖关系弱化。
关键代码:在抽象类里有一个arrayList存放观察者们。
应用实例:1、拍卖的时候,拍卖师观察最高价格,然后通知给其它竞价者竞价。2、西游记里面悟空请求菩萨降服红孩儿,菩萨洒了一地水找来一个老乌龟,这个老乌龟就是观察者(菩萨是被观察者),他观察菩萨这个动作。
优点:1、观察者和被观察者是抽象耦合的。2、建立一套触发机制。
缺点:1、如果一个被观察者对象有很多的直接和间接的观察者的话,将所有的观察者都通知到会花费很多时间。2、如果在观察者和观察目标之间有循环依赖的话,观察目标会触发它们之间进行循环调用,可能导致系统崩溃。3、观察者模式没有相应的机制让观察者知道所观察的目标对象是怎么发生变化的,而仅仅只是知道观察目标发生了变化。
使用场景:
注意事项:1、应避免循环引用。2、如果顺序执行,某一观察者错误会导致系统卡壳,一般采用异步方式(多线程)。