美文网首页
观察者模式

观察者模式

作者: 哟破赛呦 | 来源:发表于2019-04-16 14:02 被阅读0次

气象观测站

你的团队接到一个任务,建立一个能显示气象站数据的应用,可以添加或移除布告板,布告板默认有 目前状况,气象统计,天气预测。用户可以随时添加或移除布告板。提供一个WeatherData对象,可以从气象站获得温度,湿度,气压等信息。
大概长这样


1-5

错误的实现

WeatherData类长这样


1-6

直接再函数中通知每一个布告板

void WeatherData::measurementsChanged(){
    float temp = getTemperature();
    float humidity = getHumidity();
    float pressure = getPressure();
    //通知每一个布告板
    bgb1.updata(temp,humidity,pressure);
    bgb2.updata(temp,humidity,pressure);
    bgb3.updata(temp,humidity,pressure);
}

有哪些不妥

  1. 我们是针对实现编程,而不是针对接口。
  2. 对于每一个布告板,我们都要修改代码
  3. 我们无法动态的增加或删除布告板
    。。。

使用观察者模式

出版者 + 订阅者 = 观察者模式


1-7

设计好出题和观察者的抽象基类,让WeatherData继承主题,布告板继承观察者。实现方式有很多,一种是Subject维护一个Observer对象的数组

class Observer{
    virtual void update(float temp,float humidity,float pressure)=0;
};

class Subject{
public:
    virtual void registerObserver(Observer * po)=0;
    virtual void removeObserver(Observer * po)=0;
    virtual void notifyObservers()=0;
protected:
    vector<Observer *> oblist;
};

具体实现
WeatherData

class WeatherData:public Subject{
public:
    virtual void registerObserver(Observer * po);
    virtual void removeObserver(Observer * po);
    virtual void notifyObservers();
    void setdata(float t,float h,float p);
private:
    float temperature;
    float humidity;
    float pressure;

};
void WeatherData::registerObserver(Observer * po){
    oblist.push_back(po);
}
void WeatherData::removeObserver(Observer * po){
    int i;
    for(i=0;i<oblist.size();i++){
        if(oblist[i]==po){
            oblist.erase(oblist.begin()+i);
            break;
        }
    }
}
void WeatherData::notifyObservers(){
    for(int i=0;i<oblist.size();i++){
        oblist[i]->update(temperature,humidity,pressure);
    }
}
void WeatherData::setdata(float t,float h,float p){
    temperature=t;
    humidity=h;
    pressure=p;
    notifyObservers();
}

布告板

class Bgb:public Observer{//布告板
public:
    virtual void update(float temp,float humidity,float pressure);
    void display();//打印
private:
    float t,h,p;//存放接受数据
};
void Bgb::update(float temp,float humidity,float pressure){
    t=temp; h=humidity; p=pressure;
}
void Bgb::display(){
    cout<<"Bjb * is"<<(int *)(this) <<endl;
    cout<<"temperature is :"<<t<<" humidity is :"<<h<<" pressure is :"<<p<<endl;
}

完整测试代码

#include <iostream>
#include <vector>
using namespace std;

class Observer{
public:
    virtual void update(float temp,float humidity,float pressure)=0;
};

class Subject{
public:
    virtual void registerObserver(Observer * po)=0;
    virtual void removeObserver(Observer * po)=0;
    virtual void notifyObservers()=0;
protected:
    vector<Observer *> oblist;
};
//----------------------------------------------------------
class WeatherData:public Subject{
public:
    virtual void registerObserver(Observer * po);
    virtual void removeObserver(Observer * po);
    virtual void notifyObservers();
    void setdata(float t,float h,float p);
private:
    float temperature;
    float humidity;
    float pressure;

};
class Bgb:public Observer{//布告板
public:
    virtual void update(float temp,float humidity,float pressure);
    void display();//打印
private:
    float t,h,p;//存放接受数据
};
//----------------------------------------------------------
int main(){
    WeatherData WD; //一个主题
    Bgb bjb1,bjb2,bjb3; //三个观察者
    WD.registerObserver(&bjb1);//注册
    WD.registerObserver(&bjb2);
    WD.registerObserver(&bjb3);
    WD.setdata(1,2,3);
    bjb1.display();//打印每个观察者得到的信息
    bjb2.display();
    bjb3.display();
    cout<<endl;
    WD.removeObserver(&bjb3);//bjb3 取消订阅
    WD.setdata(8,9,10);
    bjb1.display();//再次打印
    bjb2.display();
    bjb3.display();
    //bjb3 的信息没有更新
    return 0;
}
void Bgb::update(float temp,float humidity,float pressure){
    t=temp; h=humidity; p=pressure;
}
void Bgb::display(){
    cout<<"Bjb * is"<<(int *)(this) <<endl;
    cout<<"temperature is :"<<t<<" humidity is :"<<h<<" pressure is :"<<p<<endl;
}
void WeatherData::registerObserver(Observer * po){
    oblist.push_back(po);
}
void WeatherData::removeObserver(Observer * po){
    int i;
    for(i=0;i<oblist.size();i++){
        if(oblist[i]==po){
            oblist.erase(oblist.begin()+i);
            break;
        }
    }
}
void WeatherData::notifyObservers(){
    for(int i=0;i<oblist.size();i++){
        oblist[i]->update(temperature,humidity,pressure);
    }
}
void WeatherData::setdata(float t,float h,float p){
    temperature=t;
    humidity=h;
    pressure=p;
    notifyObservers();
}

程序输出


1-8

首先3个布告板都订阅,更新数据 1 2 3
然后布告板3取消订阅
更新数据 8 9 10
只有bgb3没有收到

观察者模式

定义了对象之间一对多的依赖,这样一来,当一个对象改变状态时,他的所有依赖者都会收到通知并自动更新。

相关文章

  • 11.9设计模式-观察者模式-详解

    设计模式-观察者模式 观察者模式详解 观察者模式在android中的实际运用 1.观察者模式详解 2.观察者模式在...

  • RxJava基础—观察者模式

    设计模式-观察者模式 观察者模式:观察者模式(有时又被称为发布(publish )-订阅(Subscribe)模式...

  • 前端面试考点之手写系列

    1、观察者模式 观察者模式(基于发布订阅模式) 有观察者,也有被观察者。 观察者需要放到被观察者列表中,被观察者的...

  • RxJava 原理篇

    一、框架思想 观察者模式观察者自下而上注入被观察者被观察者自上而下发射事件观察者模式 装饰器模式自上而下,被观察者...

  • 观察者模式

    观察者模式概念 观察者模式是对象的行为模式,又叫作发布-订阅(publish/subscrible)模式。 观察者...

  • 设计模式-观察者模式

    观察者模式介绍 观察者模式定义 观察者模式(又被称为发布-订阅(Publish/Subscribe)模式,属于行为...

  • 观察者模式

    观察者模式 观察者模式的定义 观察者模式(Observer Pattern)也叫做发布订阅模式(Publish/s...

  • iOS设计模式之观察者模式

    观察者模式 1、什么是观察者模式 观察者模式有时又被称为发布(publish)-订阅(Subscribe)模式、模...

  • 观察者模式和发布订阅模式区别

    观察者模式 所谓观察者模式,其实就是为了实现松耦合(loosely coupled)。 在观察者模式中,观察者需要...

  • RxJava(二)

    一、观察者模式 1.1、传统的观察者模式 1.2、RxJava 的观察者模式 区别传统的观察者模式是一个 Obse...

网友评论

      本文标题:观察者模式

      本文链接:https://www.haomeiwen.com/subject/kzkbwqtx.html