目录

描述

套路

使用场景

优缺点

UE4实践

创建观察者抽象类

创建具体观察者类：工作人员

创建目标抽象类

创建目标具体类

---

描述

定义对象之间的一种一对多依赖关系，使得每当一个对象状态发生改变时，其相关依赖对象都得到通知并更新。

观察者模式又称

• 发布-订阅（Publish-Subscribe）模式
• 模型-视图（Model-View）模式
• 源-监听器（Source-Listener）模式
• 从属者（Dependents）模式

套路

• 抽象目标（Subject）
  被观察的目标，每个目标都可以有任何数量的观察者。抽象目标提供一个接口，可以增加和删除观察者对象。
• 具体目标（ConcreteSubject）
  具体目标持有状态，当内部状态改变时，向所有观察者发出通知。同时向观察者提供用于查询状态的接口。
• 抽象观察者（Observer）
  为所有的具体观察者定义一个接口，在得到目标通知时更新自己。
• 具体观察者（ConcreteObserver）
  持有具体目标的引用。实现抽象观察者角色所要求的更新接口，以便使本身的状态与目标状态协调。

使用场景

• 一个抽象模型有两个方面，其中一个方面依赖于另一个方面。将这些方面封装在独立的对象中使它们可以各自独立地改变和复用。
• 一个对象的改变将导致其他一个或多个对象也发生改变，而不知道具体有多少对象将发生改变，可以降低对象之间的耦合度。
• 一个对象必须通知其他对象，而并不知道这些对象是谁。
• 需要在系统中创建一个触发链，A对象的行为将影响B对象，B对象的行为将影响C对象……，可以使用观察者模式创建一种链式触发机制。
• 示例，凡是涉及到一对一或者一对多的对象交互场景都可以使用观察者模式。
  • 电子商务网站可以在执行发送操作后给用户多个发送商品打折信息
  • 可用于各种消息分发，如游戏活动通知、队伍副本攻略进度
  • UE4中的委托代理、蓝图中的事件调度器dispatcher、按键事件绑定、碰撞事件绑定
  • MVC 架构模式就应用了观察者模式——多个 view 注册监听 model

优缺点

• 优点
  • 观察者模式可以实现表示层和数据逻辑层的分离，并定义了稳定的消息更新传递机制，抽象了更新接口，使得可以有各种各样不同的表示层作为具体观察者角色
  • 观察者模式在观察目标和观察者之间建立一个抽象的耦合
  • 观察者模式支持广播通信
  • 符合开闭原则
• 缺点
  • 如果一个观察目标对象有很多直接和简介的观察者的话，将所有的观察者都通知到会花费很多时间
  • 如果在观察者和观察目标之间有循环依赖的话，会发生循环引用，可能导致系统崩溃
  • 观察者模式没有相应的机制让观察者知道所观察的目标是怎么发生变化的，而仅仅知道观察目标发生了变化
  • 订阅后如果不进行取消订阅操作，容易引起内存泄漏

UE4实践

不适用UE4中的委托代理，自己实现一个消息通知

做一个核辐射检测和救援人员受影响的例子

创建观察者抽象类

// 抽象观察者类 
UCLASS(Abstract)
class DESIGNPATTERNS_API UObserver : public UObject
{
	GENERATED_BODY()
public:
 
	virtual void Update() PURE_VIRTUAL(UObserver::IsValid, );
};

创建具体观察者类：工作人员

// 具体观察者类 —— 工作人员
UCLASS(Blueprintable, BlueprintType)
class DESIGNPATTERNS_API UWorker : public UObserver
{
	GENERATED_BODY()
public:
 
	// 设置核辐射监测对象
	void SetNuclearRadiation(UNuclearRadiation* pNuclearRadiation) {
		m_pNuclearRadiation = pNuclearRadiation;
	}
 
	virtual void Update() override {
		if (m_pNuclearRadiation)
		{
			int32 CurrentLevel = m_pNuclearRadiation->GetRadiationDegree();
			if (CurrentLevel < 1)
			{
				UE_LOG(LogTemp, Warning, TEXT(__FUNCTION__" %s报告: 生命体征正常"), *this->GetName());
			}
			else if (CurrentLevel < 2)
			{
				UE_LOG(LogTemp, Warning, TEXT(__FUNCTION__" %s报告: 轻级损伤"), *this->GetName());
			}
			else if (CurrentLevel < 4)
			{
				UE_LOG(LogTemp, Warning, TEXT(__FUNCTION__" %s报告: 中级损伤"), *this->GetName());
			}
			else if (CurrentLevel < 6)
			{
				UE_LOG(LogTemp, Warning, TEXT(__FUNCTION__" %s报告: 重级损伤"), *this->GetName());
			}
			else if (CurrentLevel < 8)
			{
				UE_LOG(LogTemp, Warning, TEXT(__FUNCTION__" %s报告: 极重级损伤"), *this->GetName());
			}
			else
			{
				UE_LOG(LogTemp, Warning, TEXT(__FUNCTION__" %s已无生命体征"), *this->GetName());				
				this->ConditionalBeginDestroy();
				// 不要在此处取消订阅，否则影响TArray遍历
			}
		}
	}
 
private:
	UNuclearRadiation* m_pNuclearRadiation;
};

创建目标抽象类

// 抽象目标类 
UCLASS(Abstract)
class DESIGNPATTERNS_API USubject : public UObject
{
	GENERATED_BODY()
public:
 
	// 添加订阅者
	virtual void BindNotify(UObserver* Observer) {
		if (!ObserverList.Contains(Observer)) {
			ObserverList.Add(Observer);
			UE_LOG(LogTemp, Warning, TEXT(__FUNCTION__" %s 已订阅"), *Observer->GetName());
			// 第一次绑定 获取当前数据
			Observer->Update();
		}
	}
 
	// 移除订阅者
	virtual void UnbindNotify(UObserver* Observer) {
		if (ObserverList.Contains(Observer)) {		
			UE_LOG(LogTemp, Warning, TEXT(__FUNCTION__" %s 已取消订阅"), *Observer->GetName());
			ObserverList.Remove(Observer);
		}
	}
 
	// 通知
	virtual void Notify() {
		for (auto It = ObserverList.CreateConstIterator(); It; It++)
		{
			if (IsValid(*It))
			{
				(*It)->Update();
			}		
		}
	}
 
protected:
	TArray ObserverList;
};

创建目标具体类

// 具体目标类 —— 辐射地带、辐射监测
UCLASS(Blueprintable, BlueprintType)
class DESIGNPATTERNS_API UNuclearRadiation : public USubject
{
	GENERATED_BODY()
public:
	// 更新辐射程度
	void UpdateRadiationDegree(int32 pLevel) {
		m_pLevel = pLevel;
		Notify();
	}
 
	// 获取辐射程度
	int32 GetRadiationDegree() {
		return m_pLevel;
	}
 
private:
	// 辐射程度 1-9级
	int32 m_pLevel;
};

测试

// 调用测试用的Actor
UCLASS()
class DESIGNPATTERNS_API AObserverActor : public AActor
{
	GENERATED_BODY()
public:
 
	void BeginPlay() override {
 
		// 创建核辐射监测
		UNuclearRadiation* NuclearRadiation = NewObject();
 
		// 创建救援人员、监测核辐射程度
		UWorker* Worker0 = NewObject();
		Worker0->SetNuclearRadiation(NuclearRadiation);
		NuclearRadiation->BindNotify(Worker0);
 
		UWorker* Worker1 = NewObject();
		Worker1->SetNuclearRadiation(NuclearRadiation);
		NuclearRadiation->BindNotify(Worker1);
 
		UWorker* Worker2 = NewObject();
		Worker2->SetNuclearRadiation(NuclearRadiation);
		NuclearRadiation->BindNotify(Worker2);
 
		// 核辐射升级
		NuclearRadiation->UpdateRadiationDegree(1);
		NuclearRadiation->UpdateRadiationDegree(2);
		NuclearRadiation->UpdateRadiationDegree(3);
 
		// 有人先出来了，取消核辐射继续影响
		NuclearRadiation->UnbindNotify(Worker2);
 
		// 核辐射继续升级
		NuclearRadiation->UpdateRadiationDegree(5);
		NuclearRadiation->UpdateRadiationDegree(7);
		NuclearRadiation->UpdateRadiationDegree(9);
 
		GEngine->ForceGarbageCollection(true);
	}
};

LogTemp: Warning: USubject::BindNotify Worker_0 已订阅
LogTemp: Warning: UWorker::Update Worker_0报告: 生命体征正常

LogTemp: Warning: USubject::BindNotify Worker_1 已订阅
LogTemp: Warning: UWorker::Update Worker_1报告: 生命体征正常

LogTemp: Warning: USubject::BindNotify Worker_2 已订阅
LogTemp: Warning: UWorker::Update Worker_2报告: 生命体征正常

LogTemp: Warning: UWorker::Update Worker_0报告: 轻级损伤
LogTemp: Warning: UWorker::Update Worker_1报告: 轻级损伤
LogTemp: Warning: UWorker::Update Worker_2报告: 轻级损伤

LogTemp: Warning: UWorker::Update Worker_0报告: 中级损伤
LogTemp: Warning: UWorker::Update Worker_1报告: 中级损伤
LogTemp: Warning: UWorker::Update Worker_2报告: 中级损伤

LogTemp: Warning: UWorker::Update Worker_0报告: 中级损伤
LogTemp: Warning: UWorker::Update Worker_1报告: 中级损伤
LogTemp: Warning: UWorker::Update Worker_2报告: 中级损伤

LogTemp: Warning: USubject::UnbindNotify Worker_2 已取消订阅

LogTemp: Warning: UWorker::Update Worker_0报告: 重级损伤
LogTemp: Warning: UWorker::Update Worker_1报告: 重级损伤

LogTemp: Warning: UWorker::Update Worker_0报告: 极重级损伤
LogTemp: Warning: UWorker::Update Worker_1报告: 极重级损伤

LogTemp: Warning: UWorker::Update Worker_0已无生命体征
LogTemp: Warning: UWorker::Update Worker_1已无生命体征