设计模式——观察者模式

观察者模式又称之为发布-订阅模式:定义对象间一种一对多的依赖关系，使得每当一个对象改变状态，则所有依赖于它的对象都会得到通知并且被自动的更新。

在日常生活中我们也会碰到许多的观察者模式的例子。例如微信的订阅推送、听收音机、看直播、电脑中的文件系统。所以根据这些实际例子我们不难推导出其实在观察者模式中，我们可以分为观察者和被观察者两个角色。用类图表示如下

Subject: 抽象的被观察者。
Observer: 抽象的观察者。
ConcreteSubject: 具体的被观察者。
ConcreteObserver: 具体的观察者。

电脑中的文件系统就是典型的观察者模式，当在一个目录下新建一个文件时，此时这个动作就会通知目录管理系统将此文件加入其中、另外磁盘管理系统也会相应的减少内存。在此情境中目录就是一个被观察者，而目录管理系统和磁盘管理系统就是观察者。

此时新建一个被观察者的抽象类

abstract interface Subject{

    List<Observer> observerList = new ArrayList<>();
    public void attach(Observer observer);
    public void detach(Observer observer);
    public void myNotify(File file);

}

观察者的抽象类

interface Observer{
    public void update(File file);
}

目录被观察者

class ConcreteSubject implements Subject{


    public void attach(Observer observer){
        observerList.add(observer);
    }

    public void detach(Observer observer){
        observerList.remove(observer);
    }

    public void addFile(File file){
        observerList.forEach(observer -> {
            observer.update(file);
        });
    }
}

磁盘管理系统观察

class DiskObserve implements Observer{

    private Integer DISK_SIZE = 1024;


    @Override
    public void update(File file) {
        Integer fileSize = file.getSize();
        setDISK_SIZE(getDISK_SIZE()-fileSize);
    }

    public Integer getDISK_SIZE() {
        return DISK_SIZE;
    }

    public void setDISK_SIZE(Integer DISK_SIZE) {
        this.DISK_SIZE = DISK_SIZE;
    }
}

目录管理系统观察

class CatalogObserve implements Observer{

    private List<String> fileNames = new ArrayList<>();

    @Override
    public void update(File file) {
        fileNames.add(file.getName());
    }

    public String getFileName(){
        StringBuffer stringBuffer = new StringBuffer();
        fileNames.forEach(fileName->{
            stringBuffer.append(fileName+",");
        });
        return stringBuffer.toString();
    }
}

File类描述

class File{
    private String name;
    private Integer size;
}

一个简单的文件管理系统就出现了，此时在此目录中新建文件都会在相应的目录管理系统和磁盘管理系统进行相应的更新操作。

        Subject Buxuewushu = new ConcreteSubject();
        Observer disk = new DiskObserve();
        Observer cataLog = new CatalogObserve();
        Buxuewushu.attach(disk);
        Buxuewushu.attach(cataLog);
        Buxuewushu.addFile(new File("q",100));
        Buxuewushu.addFile(new File("x",100));
        Buxuewushu.addFile(new File("y",100));
        System.out.println(((DiskObserve) disk).getDISK_SIZE());
        System.out.println(((CatalogObserve) cataLog).getFileName());

输出如下

磁盘大小还有: 724
Buxuewushu目录中文件有: q,x,y,