//filename observer.h
#include <iostream>
#include <set>
#include <string>
using namespace std;
/////////////////////抽象模式定義
class CObservable;
//觀察者，純虛基類
class CObserver
{
public:
    CObserver(){};
    virtual ~CObserver(){};
    //當(dāng)被觀察的目標(biāo)發(fā)生變化時(shí)，通知調(diào)用該方法
    //來自被觀察者pObs, 擴(kuò)展參數(shù)為pArg
    virtual void Update(CObservable* pObs, void* pArg = NULL) = 0;
};
//被觀察者，即Subject
class CObservable
{
public:
    CObservable() : m_bChanged(false) {};
    virtual ~CObservable() {};

    void Attach(CObserver* pObs);   //注冊(cè)觀察者
    void Detach(CObserver* pObs);   //注銷觀察者
    void DetachAll();               //注銷所有觀察者
    void Notify(void* pArg = NULL); //若狀態(tài)變化，則遍歷觀察者，逐個(gè)通知更新
    bool HasChanged();              //測(cè)試目標(biāo)狀態(tài)是否變化
    int GetObserversCount();        //獲取觀察者數(shù)量
protected:
    void SetChanged();              //設(shè)置狀態(tài)變化!!!必須繼承CObservable才能設(shè)置目標(biāo)狀態(tài)
    void ClearChanged();            //初始化目標(biāo)為未變化狀態(tài)
private:
    bool m_bChanged;                //狀態(tài)
    set<CObserver*> m_setObs;       //set保證目標(biāo)唯一性
};
/////////////////////抽象模式實(shí)現(xiàn)
void CObservable::Attach(CObserver* pObs){
    if (!pObs) return;
    m_setObs.insert(pObs);
}
void CObservable::Detach(CObserver* pObs){
    if (!pObs) return;
    m_setObs.erase(pObs);
}
void CObservable::DetachAll(){
    m_setObs.clear();
}
void CObservable::SetChanged(){
    m_bChanged = true;
}
void CObservable::ClearChanged(){
    m_bChanged = false;
}
bool CObservable::HasChanged(){
    return m_bChanged;
}
int CObservable::GetObserversCount(){
    return m_setObs.size();
}
void CObservable::Notify(void* pArg /* = NULL */){
    if (!HasChanged()) return;
    cout << "notify observers…" << endl;
    ClearChanged();
    set<CObserver*>::iterator itr = m_setObs.begin();
    for (; itr != m_setObs.end(); itr++){
        (*itr)->Update(this, pArg);
    }
}
/////////////////////具體應(yīng)用類定義和實(shí)現(xiàn)
//bloger是發(fā)布者，即被觀察者(subject)
class CBloger : public CObservable
{
public:
    void Publish(const string &strContent){
        cout << "bloger publish, content: " << strContent << endl;
        SetChanged();
        Notify(const_cast<char*>(strContent.c_str()));
    }
};
//portal是發(fā)布者，即被觀察者(subject)
class CPortal : public CObservable
{
public:
    void Publish(const string &strContent){
        cout << "portal publish, content: " << strContent << endl;
        SetChanged();
        Notify(const_cast<char*>(strContent.c_str()));
    }
};
//RSS閱讀器，觀察者
class CRSSReader : public CObserver
{
public:
    CRSSReader(const string &strName) : m_strName(strName){}
    virtual void Update(CObservable* pObs, void* pArg = NULL){
        char* pContent = static_cast<char*>(pArg);
        //觀察多個(gè)目標(biāo)
        if (dynamic_cast<CBloger*>(pObs)){
            cout << m_strName << " updated from bloger, content: " << pContent << endl;
        }else if (dynamic_cast<CPortal*>(pObs)){
            cout << m_strName << " updated from portal, content: " << pContent << endl;
        }
    }
private:
    string m_strName;
};
//Mail閱讀器，觀察者
class CMailReader : public CObserver
{
public:
    CMailReader(const string &strName) : m_strName(strName){}
    virtual void Update(CObservable* pObs, void* pArg = NULL){
            char* pContent = static_cast<char*>(pArg);
            if (dynamic_cast<CBloger*>(pObs)){
                cout << m_strName << " updated from bloger, content: " << pContent << endl;
            }
            if (dynamic_cast<CPortal*>(pObs)){
                cout << m_strName << " updated from portal, content: " << pContent << endl;
            }
        }
private:
    string m_strName;
};

#include "observer.h"
int main()
{
                                  //目標(biāo)(被觀察者)
    CBloger* pBloger = new CBloger();
    CPortal* pPortal = new CPortal();
                                  //觀察者. 一個(gè)觀察者可以觀察多個(gè)目標(biāo)
    CRSSReader* pRssReader = new CRSSReader("rss reader");
    CMailReader* pMailReader = new CMailReader("mail reader");
    pBloger->Attach(pRssReader);  //bloger注冊(cè)觀察者
    pBloger->Attach(pMailReader); //bloger注冊(cè)觀察者
    pPortal->Attach(pRssReader);  //portal注冊(cè)觀察者
    pPortal->Attach(pMailReader); //portal注冊(cè)觀察者
                                  //博客發(fā)布信息
    pBloger->Publish("博客分享設(shè)計(jì)模式");
    cout << endl;
                                  //門戶發(fā)布信息
    pPortal->Publish("門戶分享設(shè)計(jì)模式");
    cout << "\nportal detached mail reader" << endl;
    
    pPortal->Detach(pMailReader);
    
    cout << "portal observers count: " << pPortal->GetObserversCount() << endl << endl;
    pPortal->Publish("門戶分享設(shè)計(jì)模式");
    
    system("pause");
    return 0;
}