观察者模式C++实现
1定义
Observer/Publish/subscribe发布订阅模式
定义对象间一种一对多的依赖关系，使得当一个对象改变状态时，所有依赖他的对象都能获得通知并被自动更新
2类图
角色分析
Subject被观察者，定义被观察者必须实现的职责，必须能动态增加，取消观察者。管理观察者并通知观察者
Observer观察者，接收消息后，即进行Update 。对接收到的信息进行处理
ConcreteSubject具体被观察者，定义自己业务，同时定义对那些时间进行通知
ConcreteObserver具体观察者，每个观察者都应当有自己具体的处理逻辑
3实现
class Subject
{
protected:
Subject();
public:
virtual ~Subject()=0;
void add(Observer x)
{_obv.push_back(x);}
void del(Observer x)
{_obv.remove(x);}
//通知所有观察者
void notifyObservers()
{
for(int i = 0; i< _obv.size();++i)
{
_obv[i].update();
}
}
private:
vector<Observer> _obv;//保存所有观察本对象的观察者
};
class ConcreteSubject:public Subject
{
public:
void doSomething()
{
//doSomething;
notifyObservers();
}
};
class Observer
{
protected:
Observer();
public:
virtual ~Objserver()=0;
virtual void update()=0;
};
class ConcreteObserver:public Observer
{
public:
ConcreteObserver();
~ConcreteObserver();
void update()
{
cout << "接受小心，并进行处理"<<endl;
}
};
class Client
{
public:
void operator()()
{
Subject* sub = new ConcreteSubject();
Observer *obs = new ConcreteObserver();
sub->add(obs);
sub->doSomething();
}
};
4应用
优点
观察者和被观察者之间的抽象耦合
建立一套触发机制，链式运动，类似责任链
缺点
多级触发影响效率，且会有一层中断而影响整体的问题存在。应当异步处理
5使用场景
关联行为场景
时间多级触发
跨系统的消息交换场景，eg消息队列的处理机制
6注意事项
也就是缺点了：
广播链问题， 所以->最多出现一个对象既是观察者又是被观察者/最多传递两次
异步处理问题，因为可能多个观察者同时观察一个对象，∴ 异步，∵异步，∴线程安全和队列问题。参考Message Queue
7扩展
①将被观察者对于观察者的注册工作替换为 观察者检查被观察者状态的变更。做到单一职责，观察者将被观察者作为参数
②真实项目中的观察者和被观察者
a存在消息沟通
b观察者响应方式：多线程技术（异步架构）/缓存技术（同步架构）
c被观察者尽量自己做主，对于被观察者行为，自己进行确定该是否需要上报观察者
8常见距离
文件系统，文件变更-报告容量。
猫和老鼠