案例：文章推送

假設我是一個科幻小說愛好者，我維護著一個叫做ScienceFictionPusher的公眾號，定期向豆瓣、知乎等平臺推送那些我覺得有趣的科幻小說，于是為了方便管理，我的推送程式是這樣的邏輯
在這里插入圖片描述

class ScienceFictionPusher 
{
public:
	//推送內容
    void newPush()
    {
    	//分別向各大平臺推送內容
        _zhihu->update(_url, _title, _desc);
        _douban->update(_url, _title, _desc);
    }
	
	//設定新的內容
    void setNewFiction(const std::string& url, const std::string& title, const std::string& desc)
    {
        _url = url;
        _title = title;-
        _desc = desc;
        newPush();
    }

private:
    std::string _url;    //小說鏈接
    std::string _title;  //小說名
    std::string _desc;   //小說簡介
    Douban* _douban;
    Zhihu* _zhihu;
};

上面這種實作方式咋一看沒什么問題，甚至在某些地方處理的還不錯，因為我們將內容的更新從平臺主動的拉取變為了公眾號的主動推送，大大減少了空轉時間，因此，我們將代碼投入使用

隨著粉絲越來越多，公眾號的名氣也越來越大，于是乎越來越多的平臺開始邀請我的專欄入駐，但是此時就出現了問題
在這里插入圖片描述
如果采用上面這種模式的話，當有大量的平臺時，代碼會是這樣的，存在大量的冗余，可讀性也極差

void newPush()
{
 	//分別向各大平臺推送內容
     _zhihu->update(_url, _title, _desc);
     _douban->update(_url, _title, _desc);
     _wechat->update(_url, _title, _desc);
     _uc->update(_url, _title, _desc);
     _tiktok->update(_url, _title, _desc);
     _bilibili->update(_url, _title, _desc);
     _baidu->update(_url, _title, _desc);
     _csdn->update(_url, _title, _desc);
     ...........................
 }

由于公眾號的經營也存在波動，當流量大的時候我們會有新增的平臺，當某個平臺流量小的時候我們也不會再去維護，所以平臺的數量是時刻變化的，那這樣的代碼就意味著我們需要時刻去程式中修改，無法動態的增加、洗掉，效率極低，

那有什么好的解決方法嗎？這就到了 觀察者模式出場的時候

觀察者模式

觀察者模式也叫做發布訂閱模式，它定義了物件之間的一對多依賴，當一個物件改變狀態的時候，它的所有依賴著都會收到通知并自動更新，

為了方便舉例，這里我們將發布內容的物件稱為主題，接收內容的物件稱為觀察者

觀察者模式的運作流程

在這里插入圖片描述

此時物件C也想要獲取內容，所以它告訴主題他想要注冊成為觀察者
在這里插入圖片描述

由于主題發布的內容質量逐漸降低，物件A不再需要訂閱，此時它請求注銷主題

從上面我們可以看到，主題主要做了三件事，注冊、洗掉、通知觀察者，而觀察者所做的只是被動的接受主題提供的資料

觀察者模式解決的問題

講了這么多，其實觀察者模式最主要的作用就是讓主題和觀察者松耦合：即這兩個物件雖然互相可以互動，但是它們都不清楚彼此的細節

主題只知道觀察者實作了Observer介面，它并不需要知道觀察者的具體類是誰，也不需要了解它究竟實作了什么，它只需要呼叫觀察者的update將資料更新過去即可，

同樣的，因為主題依賴的只是實作了Observer介面的物件串列，所以無論我們是對觀察者增加還是洗掉，都不會對主題造成影響，主題也不需要為了兼容這些觀察者而去修改代碼，

甚至我們還可以在其他地方獨立的復用主題和觀察者，例如我們新增一個新的主題，又或者是新增一個觀察者，由于二者并非緊耦合，所以不會有任何的影響，

總結一下就是，這種設計將物件之間的互相依賴降到了最低，因此我們的程式具有彈性，能夠應對各種變化，

觀察者模式大顯身手

回到上面的問題，當我們的公眾號發布新內容的時候，我們會將這些內容推送到所有的入駐平臺中，這正好就符合上面所說的觀察者模式的場景，此時公眾號充當主題物件，而平臺充當觀察者，

此時完整的關系圖如下
在這里插入圖片描述
根據上面所提到的內容，我們抽象出具體的主題介面和觀察者介面，為了方便使用不同語言的讀者閱讀，我會盡量少用C++的特性，如果還是有不理解的可以私信或者評論區留言，

主題介面只需要提供必須的注冊、洗掉、發布即可

class Subject
{
public:
    virtual ~Subject() = default;
    virtual void registerObserver(Observer*) = 0;   //注冊觀察者
    virtual void removeObserver(Observer*) = 0;     //移除觀察者
    virtual void notifyObservers() = 0;             //通知所有觀察者
};

觀察者被動等待主題的資料，所以我們也只提供一個更新介面供主題更新資料

class Observer
{
public:
    virtual ~Observer() = default;
    virtual void update(const std::string& url, const std::string& title, const std::string& desc) = 0;      //更新資料
};

考慮到每個平臺獲取到新內容都必定要將其展示出來，而每個平臺展示的方式又有所不同，所以我們將其再抽象為一個介面類，觀察者需要繼承這個類并實作自己的展示方法

class DisplayElement
{
public:
    virtual ~DisplayElement() = default;
    virtual void display() = 0;     //顯示資料
};

下面就開始具體實體的實作吧

為了保證不會對同一平臺重復發送，以及后續可能會對某些平臺單獨推送內容，我們使用一個哈希表來存盤所有入駐的平臺

//主題派生子類
class ScienceFictionPusher : public Subject
{
public:
	//增加觀察者
    void registerObserver(Observer* observer)
    {
        _observers.insert(observer);
    }
	
	//洗掉觀察者
    void removeObserver(Observer* observer)
    {
        _observers.erase(observer);
    }
	
	//向所有平臺推送內容
    void notifyObservers()
    {
        for(const auto& ob : _observers)
        {
            ob->update(_url, _title, _desc);
        }
    }
	
	//推送新內容
    void newPush()
    {
        notifyObservers();
    }
	
	//設定新內容，當有新內容發布的時候，就會自動推送給所有的平臺
    void setNewFiction(const std::string& url, const std::string& title, const std::string& desc)
    {
        _url = url;
        _title = title;
        _desc = desc;
        newPush();
    }

private:
    std::string _url;    //小說鏈接
    std::string _title;  //小說名
    std::string _desc;   //小說簡介
    std::unordered_set<Observer*> _observers;   //入駐的平臺
};

當有新的平臺想要入駐的時候，它只需要繼承觀察者類并實作update介面即可，同時由于我們接收新內容后還需要在自身平臺中顯示，所以還需要繼承發布內容類，并實作display介面

為了方便注冊和洗掉觀察者，我們需要保存一個指向主題的指標

//觀察者派生子類
class Zhihu : public Observer, public DisplayElement
{
public:
    Zhihu(Subject* ScienceFictionPusher)
        : _ScienceFictionPusher(ScienceFictionPusher)
    {
        _ScienceFictionPusher->registerObserver(this);
    }

    ~Zhihu()
    {
        _ScienceFictionPusher->removeObserver(this);
    }

	//實作更新介面，讓主題主動推送資料
    void update(const std::string& url, const std::string& title, const std::string& desc)
    {
        _url = url;
        _title = title;
        _desc = desc;

        display();
    }
	
	//在平臺中顯示推送的內容
    void display()
    {
        std::cout << "知乎每日書籍推薦：" << std::endl;
        std::cout << "鏈接：" << _url << std::endl;
        std::cout << "標題：" << _title << std::endl;
        std::cout << "簡介：" << _desc << "\n" <<std::endl; 
    }
    
private:
    std::string _url;    //小說鏈接
    std::string _title;  //小說名
    std::string _desc;   //小說簡介
    Subject* _ScienceFictionPusher; //主題物件，方便注冊和洗掉
};

其他的觀察者也類似，為了節省篇幅這里就不多寫了，下面寫個簡單的程式測驗一下

int main()
{
    ScienceFictionPusher* _subject = new ScienceFictionPusher;
    Douban* douban = new Douban(_subject);
    Zhihu* zhihu = new Zhihu(_subject);

    _subject->setNewFiction("www.aaaaaaa.com", "三體", "作品講述了地球人類文明和三體文明的資訊交流、生死搏殺及兩個文明在宇宙中的興衰歷程，");
    _subject->setNewFiction("www.bbbbbbb.com", "球形閃電", "描述了一個歷經球狀閃電的男主角對其歷盡艱辛的研究歷程，向我們展現了一個獨特、神秘而離奇的世界");

    delete zhihu;
    delete douban;
    delete _subject;
    
    return 0;
}