实战设计模式之观察者模式
与前面提到的工厂方法模式、抽象工厂模式等创建型设计模式不同,观察者模式属于行为设计模式。行为设计模式主要关注对象之间的职责分配,以及它们之间的通信。通过行为设计模式,可以更加清晰地表达复杂的控制流,提高代码的可读性、灵活性和可维护性。新闻订阅系统是运用观察者模式的一个典型例子:每当有新的文章发布时,所有订阅了该频道的用户都会收到通知。观察者模式提供了一种松耦合的方式让对象之间相互通信,适用于需要处
概述
与前面提到的工厂方法模式、抽象工厂模式等创建型设计模式不同,观察者模式属于行为设计模式。行为设计模式主要关注对象之间的职责分配,以及它们之间的通信。通过行为设计模式,可以更加清晰地表达复杂的控制流,提高代码的可读性、灵活性和可维护性。
新闻订阅系统是运用观察者模式的一个典型例子:每当有新的文章发布时,所有订阅了该频道的用户都会收到通知。观察者模式提供了一种松耦合的方式让对象之间相互通信,适用于需要处理多个对象对某个对象的状态变化做出反应的场景。
基本原理
观察者模式的基本原理是:通过建立一种对象之间的一对多依赖关系,使得每当一个对象(主题或发布者)改变状态时,所有依赖于它的对象(观察者或订阅者)都会得到通知并自动更新。其核心思想是:分离关注点,即把变化的对象和依赖这些变化的对象分离开来。观察者模式包括如下四个核心组件。
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;
}
总结
观察者模式使得主题和观察者之间的依赖关系变得松散,主题不需要知道具体的观察者是谁,只需要知道它们实现了特定的接口,这有助于提高代码的可维护性和扩展性。新的观察者可以很容易地被加入到系统中,而不会影响现有代码,这符合面向对象设计中的开闭原则(对扩展开放,对修改关闭)。
但不恰当地使用观察者模式,也可能带来很多潜在的风险和问题。在某些情况下,两个对象可能互相成为对方的观察者,形成循环依赖。如果不小心处理,这种结构可能会导致无限递归调用,最终引发栈溢出或其他错误。另外,由于观察者模式涉及到了多个对象之间的间接交互,当出现问题时,追踪问题的来源可能会比较困难。特别是当有多个观察者参与时,确定哪个观察者的动作引起了问题可能会非常棘手。
更多推荐
所有评论(0)