设计模式入门--观察者模式

2024-08-24 02:58

本文主要是介绍设计模式入门--观察者模式,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

概念

当一个主题对象状态发生变化时,则会自动通知它的依赖对象进行一些逻辑的处理,这就是观察者模式。
直白点说,一个类依赖另外一个乃至多个类,这个类实例状态变化时,会调用它所依赖对象的接口,触发它依赖对象进行某些逻辑的处理。专门拿出来感觉很抽象,事实上这个设计模式,我们经常在代码中都会使用到。


角色

  • 抽象主题:被观察者(Subject)。提供对观察者增删、通知等操作接口。

  • 具体主题:具体被观察者。内部提供一个供观察者注册的容器,每个观察者可以有任意多个观察者。当主题对象发生某种变化,会把变化通知给容器中注册的观察者对象。

  • 抽象观察者:Observer,是具体观察者的抽象类或接口,它定义了具体的逻辑处理方法,使得在得到主题更改通知时进行一些逻辑的处理。

  • 具体观察者:抽象观察者的具体实现类。

抽象主题和抽象观察者的意义:利用java的多态性特征,降低具体类与具体类之间的耦合性。


具体代码

1、com.learn.observerpattern.way1(借大佬例子一用)

场景:假设微信用户就是观察者,微信公众号是被观察者,有多个的微信用户关注了某个公众号,当这个公众号更新时就会通知这些订阅的微信用户

抽象主题

package com.learn.observerpattern.way1;/*** 抽象被观察者(Subject)抽象主题对象* Created by chao.du on 2018/2/1.*/
public interface ISubject {/*** 增加订阅者* @param observer*/void addObserver(IObserver observer);/*** 删除订阅者* @param observer*/void delObserver(IObserver observer);/*** 通知订阅者更新消息*/void notifyObserver();/*** 更新状态*/void updateState(String state);
}

具体主题

package com.learn.observerpattern.way1;import java.util.ArrayList;
import java.util.List;/*** 具体主题,被观察者具体实现类* Created by chao.du on 2018/2/1.*/
public class WeixinSubject implements ISubject{private String state;private List<IObserver> observers=new ArrayList<IObserver>();public void addObserver(IObserver observer) {this.observers.add(observer);}public void delObserver(IObserver observer) {this.observers.remove(observer);}public void notifyObserver() {for (IObserver observer:observers){observer.update(this.state);}}public void updateState(String state) {this.state=state;this.notifyObserver();}
}

抽象观察

package com.learn.observerpattern.way1;/*** 观察者接口* Created by chao.du on 2018/2/1.*/
public interface IObserver {public void update(String message);
}

具体观察者

package com.learn.observerpattern.way1;/*** 观察者接口具体观察实现者* Created by chao.du on 2018/2/1.*/
public class WeixinUser implements IObserver {private String name;public WeixinUser(String name) {this.name = name;}public void update(String message) {System.out.println(this.name+"收到了一个通知--"+message);}
}

客户端

package com.learn.observerpattern.way1;/*** 测试客户端* Created by chao.du on 2018/2/1.*/
public class Client {public static void main(String[] args) {//创建微信订阅主题ISubject subject=new WeixinSubject();//给主题添加订阅者subject.addObserver(new WeixinUser("小明"));subject.addObserver(new WeixinUser("小花"));subject.addObserver(new WeixinUser("小美"));//主题更新,通知订阅者subject.updateState("XX微信公众号发布了一篇新文章《如何与dalao同归于尽》");}}

测试结果
这里写图片描述

2、com.learn.observerpattern.way2

场景:资讯网站每天给注册用户推送新闻。抽象主题就是资讯网站,被观察者是注册用户。

抽象主题

package com.learn.observerpattern.way2;/*** 抽象主题* Created by chao.du on 2018/2/1.*/
public interface ISubject {/*** 注册/添加观察者* @param observer*/void addObserver(IObserver observer);/*** 更新主题对象消息状态* @param isGood* @param message*/void updateMessage(boolean isGood,String message);/*** 通知观察者* @param isGood*/void notiryObserver(boolean isGood);}

具体主题

package com.learn.observerpattern.way2;import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;/*** 具体主题,具体被观察者* Created by chao.du on 2018/2/1.*/
public class RealSubject implements ISubject {/*** 消息*/private String message;/*** 观察者容器*/private List<IObserver> observerList=new ArrayList<IObserver>();/*** 添加观察者* @param observer*/public void addObserver(IObserver observer){this.observerList.add(observer);}/*** 更新主题对象消息,通知观察者* @param isGood* @param message*/public void updateMessage(boolean isGood,String message) {this.message=message;this.notiryObserver(isGood);}/*** 通知对象,把Message消息对象发送给* @param isGood true好消息 false坏消息*/public void notiryObserver(boolean isGood) {HashMap<String,Object> content=new HashMap<String, Object>();content.put("message",this.message);for (IObserver observer:observerList) {if(isGood){observer.getWeiXinInfo(new Message(Message.MessageType.GOOD,content));}else{observer.getWeiXinInfo(new Message(Message.MessageType.BAD,content));}}}
}

抽象观察者

package com.learn.observerpattern.way2;/*** 抽象观察者* Created by chao.du on 2018/2/1.*/
public interface IObserver {void getWeiXinInfo(Message message);
}

具体观察者1

package com.learn.observerpattern.way2;/*** 具体观察者* Created by chao.du on 2018/2/1.*/
public class RealObserver1 implements IObserver{private String name;public RealObserver1(String name, ISubject weiXinSubject) {this.name=name;weiXinSubject.addObserver(this);}public void getWeiXinInfo(Message message) {System.out.println(this.name+"收到一个"+message.getType().getInfoTip()+"----"+message.getContent().get("message"));}
}

具体观察者2

package com.learn.observerpattern.way2;/*** 具体观察者* Created by chao.du on 2018/2/1.*/
public class RealObserver2 implements IObserver{private String name;public RealObserver2(String name, ISubject weiXinSubject) {this.name=name;weiXinSubject.addObserver(this);}public void getWeiXinInfo(Message message) {System.out.println(this.name+"收到一个"+message.getType().getInfoTip()+"----"+message.getContent().get("message"));}
}

具体观察者3

package com.learn.observerpattern.way2;/*** 具体观察者* Created by chao.du on 2018/2/1.*/
public class RealObserver3 implements IObserver{private String name;public RealObserver3(String name, ISubject weiXinSubject) {this.name=name;weiXinSubject.addObserver(this);}public void getWeiXinInfo(Message message) {System.out.println(this.name+"收到一个"+message.getType().getInfoTip()+"----"+message.getContent().get("message"));}
}

通知消息实体

package com.learn.observerpattern.way2;import java.util.Map;/*** 通知消息实体封装* Created by chao.du on 2018/2/1.*/
public class Message {private  MessageType type;private Map<String,Object> content;public Message(MessageType type, Map<String, Object> content) {this.type = type;this.content = content;}public MessageType getType() {return type;}public void setType(MessageType type) {this.type = type;}public Map<String, Object> getContent() {return content;}public void setContent(Map<String, Object> content) {this.content = content;}enum  MessageType{GOOD(true,"好消息"),BAD(false,"坏消息");private final boolean infoState;private final String infoTip;MessageType(boolean infoState,String infoTip){this.infoState=infoState;this.infoTip=infoTip;}public boolean getInfoState() {return infoState;}public String getInfoTip() {return infoTip;}}
}

客户端

package com.learn.observerpattern.way2;/*** 客户端,测试* Created by chao.du on 2018/2/1.*/
public class Client {public static void main(String[] args) {//创建主题ISubject subject=new RealSubject();//创建观察者,并放入主题集合new RealObserver1("农民",subject);new RealObserver2("教师",subject);new RealObserver3("工人",subject);//主题修改,通知观察者subject.updateMessage(true,"还有几天要放年假了!!!");System.out.println("----------------------------------");subject.updateMessage(false,"过完年房价要涨了!!!");}
}

测试结果
这里写图片描述

github代码


参考资料:
1、《设计模式(三):观察者模式与发布/订阅模式区别》
2、《观察者模式》
3、《 设计模式(五)观察者模式》

这篇关于设计模式入门--观察者模式的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1101254

相关文章

从入门到精通MySQL联合查询

《从入门到精通MySQL联合查询》:本文主要介绍从入门到精通MySQL联合查询,本文通过实例代码给大家介绍的非常详细,需要的朋友可以参考下... 目录摘要1. 多表联合查询时mysql内部原理2. 内连接3. 外连接4. 自连接5. 子查询6. 合并查询7. 插入查询结果摘要前面我们学习了数据库设计时要满

Java设计模式---迭代器模式(Iterator)解读

《Java设计模式---迭代器模式(Iterator)解读》:本文主要介绍Java设计模式---迭代器模式(Iterator),具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,... 目录1、迭代器(Iterator)1.1、结构1.2、常用方法1.3、本质1、解耦集合与遍历逻辑2、统一

Java 线程安全与 volatile与单例模式问题及解决方案

《Java线程安全与volatile与单例模式问题及解决方案》文章主要讲解线程安全问题的五个成因(调度随机、变量修改、非原子操作、内存可见性、指令重排序)及解决方案,强调使用volatile关键字... 目录什么是线程安全线程安全问题的产生与解决方案线程的调度是随机的多个线程对同一个变量进行修改线程的修改操

从入门到精通C++11 <chrono> 库特性

《从入门到精通C++11<chrono>库特性》chrono库是C++11中一个非常强大和实用的库,它为时间处理提供了丰富的功能和类型安全的接口,通过本文的介绍,我们了解了chrono库的基本概念... 目录一、引言1.1 为什么需要<chrono>库1.2<chrono>库的基本概念二、时间段(Durat

解析C++11 static_assert及与Boost库的关联从入门到精通

《解析C++11static_assert及与Boost库的关联从入门到精通》static_assert是C++中强大的编译时验证工具,它能够在编译阶段拦截不符合预期的类型或值,增强代码的健壮性,通... 目录一、背景知识:传统断言方法的局限性1.1 assert宏1.2 #error指令1.3 第三方解决

从入门到精通MySQL 数据库索引(实战案例)

《从入门到精通MySQL数据库索引(实战案例)》索引是数据库的目录,提升查询速度,主要类型包括BTree、Hash、全文、空间索引,需根据场景选择,建议用于高频查询、关联字段、排序等,避免重复率高或... 目录一、索引是什么?能干嘛?核心作用:二、索引的 4 种主要类型(附通俗例子)1. BTree 索引(

Redis 配置文件使用建议redis.conf 从入门到实战

《Redis配置文件使用建议redis.conf从入门到实战》Redis配置方式包括配置文件、命令行参数、运行时CONFIG命令,支持动态修改参数及持久化,常用项涉及端口、绑定、内存策略等,版本8... 目录一、Redis.conf 是什么?二、命令行方式传参(适用于测试)三、运行时动态修改配置(不重启服务

MySQL DQL从入门到精通

《MySQLDQL从入门到精通》通过DQL,我们可以从数据库中检索出所需的数据,进行各种复杂的数据分析和处理,本文将深入探讨MySQLDQL的各个方面,帮助你全面掌握这一重要技能,感兴趣的朋友跟随小... 目录一、DQL 基础:SELECT 语句入门二、数据过滤:WHERE 子句的使用三、结果排序:ORDE

Redis Cluster模式配置

《RedisCluster模式配置》:本文主要介绍RedisCluster模式配置,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录分片 一、分片的本质与核心价值二、分片实现方案对比 ‌三、分片算法详解1. ‌范围分片(顺序分片)‌2. ‌哈希分片3. ‌虚

RabbitMQ工作模式中的RPC通信模式详解

《RabbitMQ工作模式中的RPC通信模式详解》在RabbitMQ中,RPC模式通过消息队列实现远程调用功能,这篇文章给大家介绍RabbitMQ工作模式之RPC通信模式,感兴趣的朋友一起看看吧... 目录RPC通信模式概述工作流程代码案例引入依赖常量类编写客户端代码编写服务端代码RPC通信模式概述在R