java 设计模式_行为型_17观察者模式

17.观察者模式

观察者模式：定义了一种一对多的依赖关系，让多个观察者对象同时监听某一个主题对象。这个主题对象在状态发生变化时，会通知所有的观察者对象，使他们能够自动更新自己。

• 主要解决：一个对象状态改变给其他对象通知的问题，而且要考虑到易用和低耦合，保证高度的协作。
• 何时使用：一个对象（目标对象）的状态发生改变，所有的依赖对象（观察者对象）都将得到通知，进行广播通知。
• 如何解决：使用面向对象技术，可以将这种依赖关系弱化。
• 关键代码：在抽象类里有一个 ArrayList 存放观察者们。

代码背景
一个班级，有两类学生，A类：不学习，玩，但是玩的东西不一样，有的是做游戏，有的是看电视
B类：放哨的学生，专门看老师的动向，如果老师进班了就立即通知大家。
如此就形成了一个需求，放哨的学生要通知所有玩的学生：老师来了，而不同的学生有不同的反应，有的马上把电视关闭，有的停止玩游戏。

一、抽象观察者

public abstract class Observer {
    public abstract void updateState();
}

二、若干具体观察者（1.玩游戏观察者）

@Data
@NoArgsConstructor
@AllArgsConstructor
public class GameObserver extends Observer {


    //观察者的姓名
    private String name;


    //观察者的状态
    private String observerState;


    //明确具体的通知者
    private ConcreteSubject subject;


    @Override
    public void updateState() {
        observerState = subject.getSubjectState();
        System.out.println(String.format("%s在打游戏",name));
        System.out.println(String.format("观察者%s的:新状态是%s",name,observerState));
    }
}

（2.看电视观察者）

@Data
@AllArgsConstructor
@NoArgsConstructor
public class TVObserver extends Observer {
    //观察者的姓名
    private String name;


    //观察者的状态
    private String observerState;


    //明确具体的通知者
    private ConcreteSubject subject;


    @Override
    public void updateState() {
        observerState = subject.getSubjectState();
        System.out.println(String.format("%s在看电视",name));
        System.out.println(String.format("观察者%s的:新状态是%s",name,observerState));
    }
}

3.抽象通知者

@Data
@NoArgsConstructor
@AllArgsConstructor
public abstract class Subject {


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


    /**
     * 通知所有观察者
     */
    public void notifyMsg(){
        for (Observer observer : observerList) {
            observer.updateState();
        }
    }


}

4.具体通知者

@Data
public class ConcreteSubject extends Subject {
    private String subjectState;
}

5.测试

public class ObserverTest {
    public static void main(String[] args) {
        ConcreteSubject concreteSubject = new ConcreteSubject();


        GameObserver gameObserver = new GameObserver("小张","",concreteSubject);
        TVObserver tvObserver = new TVObserver("小李", "", concreteSubject);
        GameObserver gameObserver1 = new GameObserver("小王", "", concreteSubject);
        concreteSubject.getObserverList().add(gameObserver);
        concreteSubject.getObserverList().add(tvObserver);
        concreteSubject.getObserverList().add(gameObserver1);
        concreteSubject.setSubjectState("老师来了，赶快学习");
        concreteSubject.notifyMsg();
    }
}