设计模式学习笔记（六、行为型-观察者模式）

/**
 * 被观察者
 *
 * @author zhoude
 * @date 2020/4/12 14:48
 */
public interface Observer {

    /**
     * 接受观察者的通知消息
     *
     * @param message 通知消息
     */
    void notify(String message);
}

public interface Subject {

    /**
     * 添加一个被观察者
     *
     * @param observer 被观察者
     */
    void addObserver(Observer observer);

    /**
     * 移除一个被观察者
     *
     * @param observer 被观察者
     */
    void removeObserver(Observer observer);

    /**
     * 给被观察者发送消息
     *
     * @param message 通知消息
     */
    void notifyObservers(String message);
}

public class SubjectImpl implements Subject {

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

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

    @Override
    public void removeObserver(Observer observer) {
        observers.remove(observer);
    }

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

public class ObserverImpl1 implements Observer {

    @Override
    public void notify(String message) {
        System.err.println("observer1 message:" + message);
    }
}

public class ObserverImpl2 implements Observer {

    @Override
    public void notify(String message) {
        System.err.println("observer2 message:" + message);
    }
}

public class Test {

    public static void main(String[] args) {
        Subject subject = new SubjectImpl();
        subject.addObserver(new ObserverImpl1());
        subject.addObserver(new ObserverImpl2());
        subject.notifyObservers("msg");
    }
}