文档章节

522还不知道怎么表白吗?——经典设计模式之【观察者模式】

须臾之余
 须臾之余
发布于 05/21 21:51
字数 1338
阅读 471
收藏 13

写在前面:设计模式源于生活,而又高于生活!

什么是观察者模式

在对象之间定义一对多的依赖,这样一来,当一个对象改变状态,依赖它的对象收到通知并自动更新

其实就是发布订阅模式,发布者发布消息,订阅者获取消息,订阅了就能收到消息,没订阅就收不到消息。

观察者模式应用场景

Zookeeper事件通知节点、消息订阅通知、安卓开发事件注册

观察者模式原理类图

抽象被观察者角色:也就是一个抽象主题,它把所有对观察者对象的引用保存在一个集合中,每个主题都可以有任意数量的观察者。抽象主题提供一个接口,可以增加和删除观察者角色。一般用一个抽象类和接口来实现。

抽象观察者角色:为所有的具体观察者定义一个接口,在得到主题通知时更新自己。

具体被观察者角色:也就是一个具体的主题,在集体主题的内部状态改变时,所有登记过的观察者发出通知。

具体观察者角色:实现抽象观察者角色所需要的更新接口,一边使本身的状态与制图的状态相协调。

观察者模式实现方式一

抽象观察者

public interface ObServer {
    /**
     * 更新消息内容
     */
    public void update(String message);

}

抽象主题者

public interface AbstractSubject {
    /**
     * 添加obServer
     */
    void addObServer(ObServer obServer);
    /**
     * 移除obServer
     */
    void removeObServer(ObServer obServer);
    /**
     * 通知所有的notifyObServerAll
     */
    void notifyObServerAll(String message);
    /**
     * 设置更新内容
     */
    void setNtifyMessage(String message);

}

具体主题

public class WeChatSubject implements AbstractSubject {
    /**
     * 存放所有的ObServer
     */
    private List<ObServer> listObServer = new ArrayList<ObServer>();
    /**
     * 更新的内容
     */
    private String message;

    public void addObServer(ObServer obServer) {
        listObServer.add(obServer);
    }
    public void removeObServer(ObServer obServer) {
        listObServer.remove(obServer);
    }
    public void notifyObServerAll(String message) {
        for (int i = 0; i < listObServer.size(); i++) {
            ObServer obServer = listObServer.get(i);
            obServer.update(message);
        }
    }
    public void setNtifyMessage(String message) {
        this.message = message;
        System.out.println("微信公众号设置message:" + message);
        notifyObServerAll(message);

    }
}

具体观察者

public class UserObServer implements ObServer {
    /**
     * 订阅者用户名称
     */
    private String name;
    /**
     * 发送内容
     */
    private String message;

    public UserObServer(String name) {
        this.name = name;
    }
    public void update(String message) {
        this.message = message;
        read();
    }

    public void read() {
        System.out.println(name + "同学收到推送消息:" + message);
    }
}

运行测试

public class App {
    public static void main(String[] args) {
        // 1.注册主题
        AbstractSubject weChatSubject = new WeChatSubject();
        // 2.添加观察者 订阅主题
        weChatSubject.addObServer(new UserObServer("小须"));
        weChatSubject.addObServer(new UserObServer("小霞"));
        // 3.设置发送消息
        weChatSubject.setNtifyMessage("消息内容:小须喜欢小霞");

    }
}

返回结果

微信公众号设置message:消息内容:小须喜欢小霞
小须同学收到推送消息:消息内容:小须喜欢小霞
小霞同学收到推送消息:消息内容:小须喜欢小霞

观察者模式实现方式二

JDK自带观察实现消息发送

(1). Observable类追踪所有的观察者,并通知他们。
(2). Observer这个接口看起来很熟悉,它和我们之前写的类几乎一样。

自定义主题

public class MessageObServable extends Observable {

    @Override
    public void notifyObservers(Object arg) {
        // 1.改变数据
        setChanged();
        // 2.通知所有的观察者改变
        super.notifyObservers(arg);
    }
}

自定义观察者

public class EmailObServer implements Observer {
    public void update(Observable o, Object arg) {
        // 1.获取主题
        MessageObServable messageObServable = (MessageObServable) o;
        System.out.println("发送邮件内容:" + arg);
    }
}
public class SmsObServer implements Observer {
    public void update(Observable o, Object arg) {
        System.out.println("发送短信内容:" + arg);
    }
}

运行监听开始

public class JdkObServer {
    public static void main(String[] args) {
        //1.创建主题
        MessageObServable messageObServable = new MessageObServable();
        // 2.添加订阅者
        messageObServable.addObserver(new EmailObServer());
        messageObServable.addObserver(new SmsObServer());
        // 3.组装消息内容
        JSONObject jsonObject = new JSONObject();
        jsonObject.put("email", "11111111@qq.com");
        jsonObject.put("phone", "11111111111");
        jsonObject.put("text", "小须喜欢小霞.");
        messageObServable.notifyObservers(jsonObject.toJSONString());
    }
}

pom依赖

<dependencies>
    <!-- fastjson -->
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>fastjson</artifactId>
        <version>1.2.30</version>
    </dependency>
</dependencies>

结果

发送短信内容:{"phone":"11111111111","text":"小须喜欢小霞.","email":"11111111@qq.com"}
发送邮件内容:{"phone":"11111111111","text":"小须喜欢小霞.","email":"11111111@qq.com"}

观察者模式实现方式三

Spring封装事件监听

OrderCreateEvent 

public class OrderCreateEvent extends ApplicationEvent {
    private JSONObject jsonObject;

    public OrderCreateEvent(Object source, JSONObject jsonObject) {
        super(source);
        this.jsonObject = jsonObject;
    }

    public JSONObject getJsonObject() {
        return jsonObject;
    }

    public void setJsonObject(JSONObject jsonObject) {
        this.jsonObject = jsonObject;
    }
}

EmailListener 

@Component
public class EmailListener implements ApplicationListener<OrderCreateEvent> {
    @Override
    @Async
    public void onApplicationEvent(OrderCreateEvent event) {
        System.out.println(Thread.currentThread().getName()+"发送邮件内容:" + event.getJsonObject().toJSONString());
    }
}

SmsListener 

@Component
public class SmsListener implements ApplicationListener<OrderCreateEvent> {
    @Override
    @Async
    public void onApplicationEvent(OrderCreateEvent event) {
        System.out.println(Thread.currentThread().getName() + "发送短信内容:" + event.getJsonObject().toJSONString());
    }
}

controller

@RestController
public class OrderController {

    @Autowired
    private ApplicationContext applicationContext;
    @RequestMapping("/sendMsg")
    public String sendMsg() {
        // 3.组装消息内容
        JSONObject jsonObject = new JSONObject();
        jsonObject.put("email", "11111111@qq.com");
        jsonObject.put("phone", "11111111111");
        jsonObject.put("text", "小须喜欢小霞.");
        OrderCreateEvent orderCreateEvent = new OrderCreateEvent(this, jsonObject);
        applicationContext.publishEvent(orderCreateEvent);
        return "success";
    }
}

AppStart 

@SpringBootApplication
@EnableAsync
public class AppStart {
    public static void main(String[] args) {
        SpringApplication.run(AppStart.class,args);
    }
}

pom

  <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.1.RELEASE</version>
    </parent>
<dependencies>
    <!-- fastjson -->
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>fastjson</artifactId>
        <version>1.2.30</version>
    </dependency>
    <!-- SpringBoot-整合Web组件 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
</dependencies>

结果输出

SimpleAsyncTaskExecutor-2发送短信内容:{"phone":"11111111111","text":"小须喜欢小霞.","email":"11111111@qq.com"}
SimpleAsyncTaskExecutor-1发送邮件内容:{"phone":"11111111111","text":"小须喜欢小霞.","email":"11111111@qq.com“}

版权@须臾之余https://my.oschina.net/u/3995125

本文参考:蚂蚁课堂:http://www.mayikt.com

© 著作权归作者所有

须臾之余
粉丝 74
博文 35
码字总数 93277
作品 0
吉安
程序员
私信 提问
加载中

评论(1)

一条开发狗
一条开发狗
2019年最新总结,从程序员到CTO,从专业走向卓越,大牛分享文档pdf与PPT整理
https://github.com/0voice/from_coder_to_expert
《JavaScript设计模式与开发实践》模式篇(3)—— 代理模式

代理模式是为一个对象提供一个代用品或占位符,以便控制对它的访问 故事背景: 假设当 A 在心情好的时候收到花,小明表白成功的几率有 60%,而当 A 在心情差的时候收到花,小明表白的成功率无...

嗨呀豆豆呢
2018/12/13
0
0
编程中的那些套路——关于策略模式

该文章属于《编程中的那些经典套路——设计模式汇总》系列,并且以下内容基于语言PHP 今天讲讲策略模式,策略模式 和工厂模式十分相像(或者说在代码逻辑层面,他们是一样的)。 但策略模式与...

gzchen
2018/08/27
0
0
编程中的那些套路——关于适配器模式

该文章属于《编程中的那些经典套路——设计模式汇总》系列,并且以下内容基于语言PHP 今天我们来谈谈适配器模式。 想象一个场景: 有一个类方法它部署在服务器上,专门负责大多数语言都通用的...

gzchen
2018/08/27
0
0
编程中的那些套路——关于工厂模式

该文章属于《编程中的那些经典套路——设计模式汇总》系列,并且以下内容基于语言PHP 前面我们写了简单工厂模式,《编程中的那些套路——关于简单工厂模式》,但简单工厂模式有一些不足(违反...

gzchen
2018/08/27
0
0
编程中的那些套路——关于单例模式

该文章属于《编程中的那些经典套路——设计模式汇总》系列,并且以下内容基于语言PHP 在设计模式中,单例模式和工厂模式)可以说是使用的最普遍的设计模式了,所以掌握此种模式尤为重要。 单...

gzchen
2018/08/27
0
0

没有更多内容

加载失败,请刷新页面

加载更多

不写代码即可快速开发应用,JEPaaS助力企业数字化创新

在企业实现信息化和数字化的过程中,通常有三种方式可以满足企业的大量软件系统需求:一是可以采购如ERP和CRM等的标准化软件产品,二是企业内部自己开发,还有一种是可以通过外包的方式去进行...

JEPaaS云平台
6分钟前
0
0
微信小程序数据 java 解密版

微信小程序的数据,解密方法,官方居然没得 java版的解密demo, 木有java 木有java 木有java 。 简直反人类。 翻阅多位大神的博客,于是乎,写一篇 简要教程: 1. 加入pom.xml <dependency> ...

MrBoyce
8分钟前
0
0
35岁大龄程序员的职业生涯发展之道-大龄码农如何避免被裁员-IT人工职能IOT网联网算法各种高精尖技术情况下大龄程序员如何跟上节奏不被淘汰-程序员迷茫如何自我革新-软件设计在大陆的生命活力

这是一篇从“人”(而非技术也非管理)的角度,聚焦于自身职业发展方方面面的文章,包括职业、学习、生产力、影响力等。 1. 拥有商业心态 你所能犯的最大错误就是相信自己是在为别人工作,职业...

letwang
22分钟前
1
0
Spring Aware 到底是什么?

通过如下前序两篇文章: Spring Bean 生命周期之“我从哪里来”? Spring Bean 生命周期之“我要到哪里去”? 我们了解了 Spring Bean 的生命周期核心内容,bean 是如何被初始化变为 Ready fo...

tan日拱一兵
46分钟前
6
0
Android 调用第三方浏览器打开网址或下载文件

/** * 调用第三方浏览器打开 * @param context * @param url 要浏览的资源地址 */ public static void openBrowser(Context context,String url){ final Intent intent = new Intent(); int......

丁佳辉
51分钟前
3
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部