观察者模式学习笔记

介绍

观察者模式属于行为型模式.当对象存在一对多的关系时,使用观察者模式.比如当一个对象被修改时,自动通知它的依赖对象

分析

我觉得很重要的一点是搞清哪一个是观察者,哪一个是被观察者,就是说到底是观察者还是被观察者,从它的另一个名字:订阅发布模式可以知道很明显就是发布者也就是被观察者,是订阅者,也就是观察者.从这两个名字的措辞来看,这两个名字的主被动关系刚好完全被颠倒.从易理解角度看,订阅发布模式的名字可能更好.

所以分析的结果就是:

: 发布者,被观察者
: 订阅者,观察者

练习

说明

  • 被观察者

被观察者,状态的改变是通过这个对象发布给观察者的,也有可能是作为被观察者和观察者的桥梁,与观察者和被观察者都关联,被观察者把状态的改变传递给这个桥梁,桥梁把这个状态的改变再发布给发布者.

  • 观察者

观察者被动的接受被观察者发布信息,所以说订阅发布模式更符合这种模式的叫法,观察者通常设计会设计一个成抽象类或者接口,因为观察者往往有很多,这种设计容纳一些顶层设计.

示例

观察者设置为一个抽象类(个人认为不优雅)

  • 被观察者基类

通常基类有三个函数addObserver(Observer observer),removeObserver(Observer observer)和一个抽象函数publishMessage(),addObserver(Observer observer)函数用来绑定观察者和被观察者,removeObserver(Observer observer)函数用来移除观察者和被观察者的绑定关系(订阅关系),值得注意的是,如果是通过抽象类的方式,那么观察者必须要持有被观察者的引用,绑定关系的添加和移除通常都由观察者(订阅者)进行,这也是我认为这种方式不优雅的原因,因为观察者通常有多个,这种会造成代码维护困难,但好处是把订阅和解除订阅的权利交给了观察者

import java.util.ArrayList;
import java.util.List;

public abstract class Observeable {

    List<Observer> Observers = new ArrayList<>();

    public void addObseriver(Observer observer){
        Observers.add(observer);
    }

    public void removeObserver(Observer observer){
        Observers.remove(observer);
    }

    public abstract void publishMessage();

}
  • 被观察者

被观察者必须实现publishMessage(),这个方法是一个通知订阅的对象的函数,因为要传递的事件或者说参数具体都不同.

public class Observe extends Observeable {

    private String state;

    public String getState() {
        return state;
    }

    public void setState(String state) {
        this.state = state;
        publishMessage();
    }

    @Override
    public void publishMessage() {
        for (Observer observer:Observers){
            observer.receiveMessage();
        }
    }
}
  • Observer基类

Observer拥有一个类似receive()的抽象函数,子类实现这个函数用来处理被观察者传递过来的事件或者数据,如果是通过抽象类的方式来实现观察者模式,那个每个Observer必须持有一个Observe对象

public abstract class Observer {

    public abstract void receiveMessage();

    protected Observe observe;
}

  • Observer子类

Observer子类实现Observer基类,拥有订阅和解除订阅的权利,通过实现抽象函数receiveMessage()来处理被观察者传递过来的事件或者数据


public class FristObserver extends Observer {

    public FristObserver(Observe observe){
        this.observe = observe;
        observe.addObseriver(this);
    }


    @Override
    public void receiveMessage() {
        System.out.println("frist observer receive message"+observe.getState());
    }
}
观察者通过接口的方式实现观察者模式

这是观察者模式非常通用的形式,观察者必须实现这个接口,这种方式下,是一种中央集权的方式:只有被观察者有权力添加和移除观察者对象(其实都是通过被观察对象添加或解除订阅关系,只是位置不同而已)

  • Observe基类Observeable
import java.util.ArrayList;
import java.util.List;

public abstract class Observeable {

    List<Observer> Observers = new ArrayList<>();

    public void addObseriver(Observer observer){
        Observers.add(observer);
    }

    public void removeObserver(Observer observer){
        Observers.remove(observer);
    }

    public abstract void publishMessage();

}
  • Observe
public class Observe extends Observeable {

    private String state;

    public String getState() {
        return state;
    }

    public void setState(String state) {
        this.state = state;
        publishMessage();
    }

    @Override
    public void publishMessage() {
        for (Observer observer:Observers){
            observer.receiveMessage(state);
        }
    }
}

  • Observer接口
public interface Observer{

    void receiveMessage(String message);
}
  • Observer实现类
public class FristObserver implements Observer {


    @Override
    public void receiveMessage(String message) {
        System.out.println("frist observer receive message"+message);
    }

}
通过泛型的方式实现观察者模式(以后再说)
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 1 场景问题# 1.1 订阅报纸的过程## 来考虑实际生活中订阅报纸的过程,这里简单总结了一下,订阅报纸的基本流程...
    七寸知架构阅读 4,700评论 5 57
  • 设计模式汇总 一、基础知识 1. 设计模式概述 定义:设计模式(Design Pattern)是一套被反复使用、多...
    MinoyJet阅读 3,993评论 1 15
  • 1. 概述 有时被称作发布/订阅模式,观察者模式定义了一种一对多的依赖关系,让多个观察者对象同时监听某一个主题对象...
    eb51589b1211阅读 402评论 0 0
  • 原文地址: Vim入门高频功能分享 自己用Vim也已经5年了,如果让我回忆五年前刚毕业我做得最有价值的事情是什么,...
    erichua23阅读 480评论 4 7
  • dubbo的直连方式即消费方不通过zookeeper注册中心去调用注册的服务,而是直接绕过zookeeper环节直...
    先生_吕阅读 6,438评论 0 1