码迷,mamicode.com
首页 > 其他好文 > 详细

观察者模式

时间:2019-08-26 14:55:56      阅读:63      评论:0      收藏:0      [点我收藏+]

标签:抽象类   引用   class   sds   update   main   arraylist   server   状态改变   

观察者模式

定义

对象之间定义一对多的依赖,当这个对象状态发生变化,它所依赖的对象都能得到变化后的状态值。(简单的来说,就类似消息系统的发布订阅模式。其中消息系统中的消费者就是观察者,消息系统中的生产者就是被观察者。当生产者的状态发生变化,那么订阅该消息的消费者就将全部接收到变化的信息)

类图

技术图片

说明

由UML可以看出,该模式由四个对象组成:

  • 抽象被观察者角色:也就是一个抽象主题,它把所有对观察者对象的引用保存在一个集合中,每个主题都可以有任意数量的观察者。抽象主题提供一个接口,可以增加和删除观察者角色。一般用一个抽象类和接口来实现。
  • 抽象观察者角色:为所有的具体观察者定义一个接口,在得到主题通知时更新自己。
  • 具体被观察者角色:也就是一个具体的主题,在集体主题的内部状态改变时,所有登记过的观察者发出通知。
  • 具体观察者角色:实现抽象观察者角色所需要的更新接口,一边使本身的状态与制图的状态相协调。

代码实现

  1. Subject
public interface Subject {
    void initMsg(String msg);
    public void addObserver(Observer observer);

    public void removeObserver(Observer observer);

    public void notifyObserver();
}
  1. Observer
public interface Observer {
    public void updateMsg(String msg);
}
  1. MsgSubject
public class MsgSubject implements Subject {
    private List<Observer> observerList = new ArrayList<>();
    private String msg;

    @Override
    public void initMsg(String msg) {
        this.msg = msg;
        System.out.println("收到消息:" + this.msg);
        // 通知观察者
        this.notifyObserver();

    }

    @Override
    public void addObserver(Observer observer) {
        this.observerList.add(observer);

    }

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

    @Override
    public void notifyObserver() {
        observerList.forEach(o -> {
            o.updateMsg(this.msg);
        });

    }
  1. MsgObserver
public class MsgObserver implements Observer {
    private String userName;

    public MsgObserver(String userName) {
        this.userName = userName;
    }

    @Override
    public void updateMsg(String msg) {
        System.out.println(userName + "收到消息: " + msg);
    }

    public int hashCode() {
        return super.hashCode();
    }

    public boolean equals(Object obj) {
        return super.equals(obj);
    }

    public String toString() {
        return super.toString();
    }
}
  1. 测试
public static void main(String[] args) {
        Observer observer = new MsgObserver("a");
        Observer observer1 = new MsgObserver("b");
        Observer observer2 = new MsgObserver("c");
        Subject subject = new MsgSubject();
        subject.addObserver(observer);
        subject.addObserver(observer1);
        subject.addObserver(observer2);
        subject.initMsg("sds");
        subject.removeObserver(observer1);
        subject.initMsg("adsd");
    }


收到消息:sds
a收到消息: sds
b收到消息: sds
c收到消息: sds
收到消息:adsd
a收到消息: adsd
c收到消息: adsd

观察者模式

标签:抽象类   引用   class   sds   update   main   arraylist   server   状态改变   

原文地址:https://www.cnblogs.com/KevinStark/p/11412338.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!