设计模式-观察者模式-阿里云开发者社区

开发者社区> 黄威的世界> 正文

设计模式-观察者模式

简介:
+关注继续查看

我的理解

很久之前有个老师给我们讲观察者模式时,举了一个例子:
妈妈照顾婴儿,他们在不同的房间,婴儿在婴儿房间A,妈妈在书房M,
为了保证婴儿睡醒之后能及时得到照顾,妈妈每隔10分钟就去房间A瞧瞧,看看婴儿是否醒了.
妈妈为了防止忘记,给自己定了一个闹钟,每隔10分钟响一次.

while (10分钟之后) {
      watchBaby();//检查婴儿是否睡醒
}

一段时间之后,妈妈觉得很累,而且效率很低,因为很多次妈妈去照看婴儿时,发现婴儿在睡觉啥事也没有.

后来,妈妈发现了一个好方法,在婴儿身上寄一个铃铛,婴儿只要一动,铃铛就会响,妈妈就能听到.
这样妈妈就可以安心工作了,只要听到铃铛响就跑过去照看下.

关系图:

2018-11-06_17-39-21.jpg

其实上面的例子涉及到两种模式:

  1. 妈妈每隔10分钟主动去查看 是轮询模式;
  2. 妈妈不用主动去检查,婴儿醒了,妈妈就会听到铃铛, 是观察者模式

那种模式效率更高呢?
一般情况下,观察者模式效率更高,
轮询,每隔一段时间去查看,浪费了资源.

观察者模式的角色

有如下角色:观察者,被观察者,事件,
有如下操作:注册,通知

观察者

案例中的妈妈就是观察者,她观察婴儿,看它醒了没有,有什么需求

被观察者

婴儿是被观察者,是被关注的对象.
一旦它发生什么事件,观察者就会有所响应

事件

观察者关注的事件就是铃铛是否响,铃铛一响说明婴儿醒了.婴儿一醒,妈妈就要去照顾,比如喂奶等.

注册(订阅)

妈妈在婴儿身上挂一个铃铛,就是注册事件.
一旦该事件发生,观察者就会有所响应.一旦婴儿醒了,妈妈就会听到铃铛声(收到通知)

通知

发生事件(婴儿醒了)时,被观察者(婴儿)会主动通知观察者(妈妈)

java 类图

1541486567409-56be49be-6f97-4897-9e0e-7afe1e6611f1.png

示例

接口

观察者:

/**
 * 接口描述: 观察者. <br />
 *
 * @author hanjun.hw
 * @since 2018/11/6
 */
public interface Observer {
    /**
     * 观察者收到通知后,观察者进行响应
     *
     * @param observable
     */
    void update(Observable observable);
}

被观察者:

public abstract class Observable {
    /**
     * 订阅观察者
     *
     * @param observer
     */
    public abstract void register(Observer observer);


    /**
     * 通知观察者
     */
    protected abstract void notifyAllObservers();


    /**
     * 观察者真正感兴趣的事件
     */
    public void wakeUp() {
        bellRinging();
        notifyAllObservers();
    }


    /**
     * 观察者观察的事件
     */
    protected abstract void bellRinging();
}

观察者实现

/**
 * 类描述: 具体观察者:妈妈. <br />
 *
 * @author hanjun.hw
 * @since 2018/11/6
 */
public class Mother implements Observer {
    @Override
    public void update(Observable observable) {
        System.out.println("婴儿醒了,去照看 :" + observable);
    }
}

被观察者实现

/**
 * 类描述: 被观察者:婴儿. <br />
 *
 * @author hanjun.hw
 * @since 2018/11/6
 */
public class Baby extends Observable {
    private HashSet<Observer> observers = new HashSet<>();


    /**
     * 把铃铛系在婴儿身上
     * @param observer
     */
    @Override
    public void register(Observer observer) {
        observers.add(observer);
    }


    /**
     * 妈妈听到铃铛声,做出响应
     */
    @Override
    protected void notifyAllObservers() {
        observers.forEach(o -> o.update(this));
    }


    @Override
    protected void bellRinging() {
        System.out.println("婴儿睡醒了 ,铃铛响了");
    }
}

测试

public static void main(String[] args) {
        Baby concreteObservable = new Baby();
        Mother concreteObserver = new Mother();
        concreteObservable.register(concreteObserver);


        concreteObservable.wakeUp();
    }

应用场景

Google eventbus

组成部分

事件(什么类型的事件)---对应铃铛响了
事件监听器,即事件处理程序(响应)----对应妈妈
注册事件监听器(register);----对应往婴儿身上挂铃铛
触发事件(trigger/post);---婴儿醒了,摇动了铃铛

实例

事件,可以是任何自定义对象

/**
 * Created by whuanghkl on 17/6/22.<br />
 * 自定义事件
 */
public class AccessLoggerEvent {

}

事件监听器

/**
 * Created by whuanghkl on 17/6/22.<br />
 * 事件监听器
 */
@Component
public class AccessLoggerListener {
    @Resource
    private EventBus eventBus;
    /**
    * 订阅
    */
    @PostConstruct
    public void init() {
        eventBus.register(this);
    }


    @Subscribe
    public void logEvent(AccessLoggerEvent event) {
        System.out.println("logEvent");
    }
}

事件监听器自己注册到eventBus

在控制器中触发事件

AccessLoggerEvent accessLoggerEvent = new AccessLoggerEvent();
        eventBus.post(accessLoggerEvent);

婴儿是什么? 是上述代码(eventBus.post)所在类

java swing 按钮单击/文本框回车

JButton cancelButton = new JButton("Cancel");
cancelButton.setActionCommand("Cancel");
cancelButton.addActionListener(new ActionListener() {//ActionListener 是观察者
    @Override
    public void actionPerformed(ActionEvent e) {//观察者的响应
        LoginDialog.this.dispose();
    }
});

涉及的元素:
按钮 -----对应婴儿
按钮增加事件 ,即调用 addActionListener() ---对应往婴儿身上挂铃铛
用户点击按钮;---婴儿醒了,摇动了铃铛
执行 addActionListener()
执行 addActionListener() 添加的ActionListener ---对应 妈妈听到铃声之后去照看
妈妈是什么? 是ActionListener 对象

react 数据的双向绑定

参考:https://juejin.im/post/59f2e9b16fb9a04529360146

mq 消息队列订阅

多路复用机制epoll 也使用了观察者模式,

与之相对的select:整个socket集合会被遍历一次,比如集合里面有1024个socket,即便只有一个socket有数据可读,也遍历所有的1024个socket,这个是观察者模式的反例.
epoll的实现逻辑就是观察者模式的思想:
协议数据包到达网卡并被排入socket的接收队列。
睡眠在socket的睡眠队列wait_entry被唤醒,wait_entry_sk的回调函数epoll_callback_sk被执行。
epoll_callback_sk将当前socket插入epoll的ready_list中。
这样就不用遍历整个socket队列了,而只需要遍历ready_list

观察者模式的作用

解耦,比如 Google eventbus
提高响应速度(相对于轮询)
一般是辅助的容易变化的业务

观察者模式和mq(发布订阅) 的区别

mq:削峰,被观察者和观察者不用感知对方的存在;
观察者模式中,观察者和被观察者可以感知到对方的存在

思考

设计模式是经验的总结,是一套被反复使用的、多数人知晓的、经过分类编目的、代码设计经验的总结;
观察者模式其实在日常生活中也有体现,
比如银行业务 有短信通知,如果我绑定了手机号(订阅),那么银行卡有交易时(关注的事件发生),就会自动给我们发短信(响应)

既能把观察者模式理解成为一种思想,也能理解为解耦的一种策略

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
阿里云服务器怎么设置密码?怎么停机?怎么重启服务器?
如果在创建实例时没有设置密码,或者密码丢失,您可以在控制台上重新设置实例的登录密码。本文仅描述如何在 ECS 管理控制台上修改实例登录密码。
10012 0
Android观察者模式初探
前提 好久都没更新了,最近因为看设计模式,因为首先看的是观察者模式。对观察者模式有了一个比较全面的理解。今天斗胆来说一下自己的理解,还望各位看官老爷轻点打脸。
479 0
阿里云服务器如何登录?阿里云服务器的三种登录方法
购买阿里云ECS云服务器后如何登录?场景不同,阿里云优惠总结大概有三种登录方式: 登录到ECS云服务器控制台 在ECS云服务器控制台用户可以更改密码、更换系.
13810 0
IOS设计模式第七篇之观察者设计模式
版权声明:原创作品,谢绝转载!否则将追究法律责任。 观察者设计模式 在观察者设计模式里面,一个对象通知其他的对象一些状态的改变。涉及这些对象不需要知道另一个对象---因此鼓励解耦设计模式。这个设计模式经常被用来通知感兴趣的对象当一个属性被改变时候。
740 0
设计模式之观察者模式
写作方法:    一般用于异步通讯1. 定义ObServer类   定义允许调用的虚函数,保护其他函数使不可见。
588 0
设计模式(二十) 观察者模式
观察者模式也是一种行为型模式,它的作用是将被观察者的任何状态变化传递给观察者。观察者模式在GUI编程的双向绑定等领域都有应用。只要我们希望实现一个类似消息订阅、接收的模式,就可以使用观察者模式。
611 0
观察者模式
阅读目录 一、概念 二、观察者模式组成 三、观察者模式实现方式 四、参考资料 回到顶部 一、概念   观察者模式,又被称为发布—订阅模式、源—收听者模式,是软件设计模式的一种。在此种模式中,一个目标物件管理所有相依与它的观察者物件,并且在它本身的状态改变时主动发出同时,此种模式通常被用来实现事件处理系统。
683 0
+关注
黄威的世界
我是一个热衷IT技术的人,希望自己不断地设计开发出对别人非常有用的软件。有近7年的java开发经验(包括2年Android开发经验)和一年左右的linux使用经验。擅长Java Web后台开发 ,喜欢研究新的各种实用技术
668
文章
0
问答
来源圈子
更多
+ 订阅
文章排行榜
最热
最新
相关电子书
更多
《2021云上架构与运维峰会演讲合集》
立即下载
《零基础CSS入门教程》
立即下载
《零基础HTML入门教程》
立即下载