观察者模式

观察者模式，应以一种一对多的依赖关系，当状态改变，自动通知其他依赖的对象。也就是发布订阅模式。

具体实现包括四个部分：

• 抽象被观察者；
• 被观察者角色；
• 抽象观察者；
• 观察者角色。

创建抽象观察者：

public interface Observer {

    void update(String msg);

    String getName();
}

创建抽象被观察者：

public interface Subject {

    void attach(Observer observer);

    void detach(Observer Observer);

    void notifyObservers(String msg);
}

创建两个观察者：

public class LancerObserver implements Observer {

    private String name;

    public LancerObserver(String name) {
        this.name = name;
    }

    @Override
    public String getName() {
        return name;
    }

    @Override
    public void update(String msg) {
        System.out.println(name + " got msg " + msg);
    }
}

public class SaberObserver implements Observer {

    private String name;

    public SaberObserver(String name) {
        this.name = name;
    }

    @Override
    public void update(String msg) {
        System.out.println(name + " got msg " + msg);
    }

    @Override
    public String getName() {
        return name;
    }
}

创建被观察者：

public class SanGrealSubject implements Subject {

    List<Observer> observers = new ArrayList<>(10);

    @Override
    public void attach(Observer observer) {
        observers.add(observer);
    }

    @Override
    public void detach(Observer target) {
        observers.removeIf(observer -> StringUtils.equalsIgnoreCase(observer.getName(), target.getName()));
    }

    @Override
    public void notifyObservers(String msg) {
        for (Observer observer : observers) {
            observer.update(msg);
        }
    }
}

创建测试方法：

public class Main {

    public static void main(String[] args) {
        Subject subject = new SanGrealSubject();

        Observer saber = new SaberObserver("Arthur");
        Observer lancer = new LancerObserver("CuChulainn");

        subject.attach(saber);
        subject.attach(lancer);
        subject.notifyObservers("i am CuChulainn");

        subject.detach(lancer);
        subject.notifyObservers("why");
    }
}