概述

        与前面提到的工厂方法模式、抽象工厂模式等创建型设计模式不同,观察者模式属于行为设计模式。行为设计模式主要关注对象之间的职责分配,以及它们之间的通信。通过行为设计模式,可以更加清晰地表达复杂的控制流,提高代码的可读性、灵活性和可维护性。

        新闻订阅系统是运用观察者模式的一个典型例子:每当有新的文章发布时,所有订阅了该频道的用户都会收到通知。观察者模式提供了一种松耦合的方式让对象之间相互通信,适用于需要处理多个对象对某个对象的状态变化做出反应的场景。

基本原理

        观察者模式的基本原理是:通过建立一种对象之间的一对多依赖关系,使得每当一个对象(主题或发布者)改变状态时,所有依赖于它的对象(观察者或订阅者)都会得到通知并自动更新。其核心思想是:分离关注点,即把变化的对象和依赖这些变化的对象分离开来。观察者模式包括如下四个核心组件。

        1、主题。这是被观察的对象,也称为目标或发布者。主题可以维护一系列观察者的列表,并提供添加、删除和通知观察者的方法。

        2、具体主题。实现了抽象主题接口的具体类,当状态改变时,会通知所有的观察者。

        3、观察者。定义了一个更新接口,当主题更改时,所有实现此接口的观察者将收到通知。

        4、具体观察者。实现了抽象观察者接口,根据需要可保存一个指向具体主题对象的引用,以便获取其状态。

        基于上面的核心组件,观察者模式的实现主要有以下三个步骤。

        1、定义接口。首先,我们需要定义两个核心接口:主题和观察者。主题接口包含添加观察者、移除观察者和通知所有观察者的方法。观察者接口包含一个更新方法或者回调函数,当主题状态改变时,观察者会收到这个调用,并可以根据需要进行响应。

        2、实现具体类。到这里,我们需要创建具体的主题类和观察者类来实现上述接口。具体主题类会维护一个观察者列表,并实现主题接口中定义的方法。当主题的状态发生变化时,调用通知方法来通知所有的观察者。具体观察者类会实现观察者接口中的更新方法,还可能会保存指向具体主题对象的引用,以便获取状态或数据。

        3、注册与通知机制。观察者通过调用主题的注册方法(比如:Attach或Add)加入到观察者列表中。如果观察者不想再接收通知,可以通过调用主题的反注册方法(比如:Detach或Remove)从列表中移除自己。当主题的状态发生改变时,它会遍历观察者列表,并对每个观察者调用更新方法(比如:Update)。

实战解析

        在下面的实战代码中,我们使用观察者模式模拟了一个简单的新闻订阅系统。

        首先,我们定义了CSubscriber观察者接口,为所有观察者规定了必须实现的Update方法,该方法用于接收来自主题的通知。接着,我们定义了CSubject作为主题接口,它不仅声明了添加、移除观察者以及通知的方法,还包含了维护观察者列表的成员变量m_vctSubscribers。

        CNewsChannel具体主题类继承自CSubject,实现了Notify方法来遍历并通知所有已注册的观察者。同时,它还提供了一个SetNews方法,用于设置最新的新闻内容以触发通知。CUser类作为具体的观察者,实现了CSubscriber接口。每个用户实例都保存了自己的名字,并在接收到更新时打印出消息。

        在main函数中,我们创建了两个CUser实例user1和user2,分别代表不同的订阅用户。然后,将它们添加到具体主题techNewsChannel中。当techNewsChannel调用SetNews发布新的文章时,会调用每个观察者的Update方法来传递最新新闻的信息。当user2被从观察者列表中移除后,后续发布的新闻将不会再通知到user2。

        从整个实战代码中可以看到,当主题状态发生变化时,所有相关的观察者都能及时得到通知。主题和观察者之间的这种松耦合关系,使得系统更加灵活且易于扩展。同时,还允许动态地添加或移除观察者。

#include <iostream>
#include <vector>
#include <string>

using namespace std;

// 观察者接口
class CSubscriber
{
public:
    virtual void Update(const string& strNews) = 0;
    virtual ~CSubscriber() {}
};

// 主题接口
class CSubject
{
public:
    virtual ~CSubject() {}

    virtual int Attach(CSubscriber* pSubscriber)
    {
        if (pSubscriber == NULL)
        {
            return -1;
        }

        m_vctSubscribers.push_back(pSubscriber);
        return 0;
    }

    virtual int Detach(CSubscriber* pSubscriber)
    {
        if (pSubscriber == NULL)
        {
            return -1;
        }

        m_vctSubscribers.erase(remove(m_vctSubscribers.begin(), 
            m_vctSubscribers.end(), pSubscriber), m_vctSubscribers.end());
        return 0;
    }

    virtual void Notify() = 0;

protected:
    vector<CSubscriber*> m_vctSubscribers;
};

// 具体主题类
class CNewsChannel : public CSubject
{
public:
    virtual void Notify()
    {
        vector<CSubscriber*>::iterator it = m_vctSubscribers.begin();
        while (it != m_vctSubscribers.end())
        {
            CSubscriber *pSubscriber = *it;
            pSubscriber->Update(m_strLatestNews);
            ++it;
        }
    }

    void SetNews(const string& strNews)
    {
        m_strLatestNews = strNews;
        Notify();
    }

private:
    string m_strLatestNews;
};

// 具体观察者类
class CUser : public CSubscriber
{
public:
    CUser(const string& name) : m_strName(name) {}

    void Update(const string& news)
    {
        cout << m_strName << " received news: " << news << endl;
    }

private:
    string m_strName;
};

int main()
{
    // 创建两个具体观察者
    CUser user1("Jack");
    CUser user2("Mike");

    // 两个观察者向具体主题订阅
    CNewsChannel techNewsChannel;
    techNewsChannel.Attach(&user1);
    techNewsChannel.Attach(&user2);

    // 发布一条新闻
    techNewsChannel.SetNews("A new technology has been developed");

    // 取消某个观察者的订阅
    techNewsChannel.Detach(&user2);

    // 再发布一条新闻
    techNewsChannel.SetNews("Another breakthrough in AI research");
    return 0;
}

总结

        观察者模式使得主题和观察者之间的依赖关系变得松散,主题不需要知道具体的观察者是谁,只需要知道它们实现了特定的接口,这有助于提高代码的可维护性和扩展性。新的观察者可以很容易地被加入到系统中,而不会影响现有代码,这符合面向对象设计中的开闭原则(对扩展开放,对修改关闭)。

        但不恰当地使用观察者模式,也可能带来很多潜在的风险和问题。在某些情况下,两个对象可能互相成为对方的观察者,形成循环依赖。如果不小心处理,这种结构可能会导致无限递归调用,最终引发栈溢出或其他错误。另外,由于观察者模式涉及到了多个对象之间的间接交互,当出现问题时,追踪问题的来源可能会比较困难。特别是当有多个观察者参与时,确定哪个观察者的动作引起了问题可能会非常棘手。

Logo

助力广东及东莞地区开发者,代码托管、在线学习与竞赛、技术交流与分享、资源共享、职业发展,成为松山湖开发者首选的工作与学习平台

更多推荐