当前位置: 首页 > news >正文

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;@Overridepublic 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;@Overridepublic 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();}
}

相关文章:

  • 如何设计幂等性接口防止Seata事务悬挂?
  • AJAX——前后端传输数据场景下使用的技术
  • 基于Docker编译运行orb-slam2_with_semantic_labelling
  • C# 枚 举(枚举)
  • [nginx]反向代理grpc
  • [技巧] 接口优化技巧合集
  • 数列求和计算
  • 人口贩卖暑期威胁消解:算法协同提升安全预警
  • 学习昇腾开发的第一天--环境配置
  • 技术实录-从 MySQL 启动失败到大小写兼容恢复:一次完整故障排查复盘20250614
  • Flask入门:从零搭建Python Web应用
  • Flink task、Operator 和 UDF 之间的关系
  • 【论文解读】OmegaPRM:MCTS驱动的自动化过程监督,赋能LLM数学推理新高度
  • [学习] 牛顿迭代法:从数学原理到实战
  • 50天50个小项目 (Vue3 + Tailwindcss V4) ✨ | AnimatedNavigation(动态导航)
  • 【Spring源码核心篇-08】spring中配置类底层原理和源码实现
  • Vite 预构建机制深度解析(Vite缺点之一)
  • BeckHoff <--> Festo Cmmt AS驱动器 EtherCat通讯
  • C++基础算法————二分查找
  • JavaScript 事件循环
  • 芙蓉区营销型网站建设定制/站长友情链接平台
  • 长春网站建设免费咨询/株洲今日头条新闻
  • 合肥专业做网站的公司哪家好/长春做网络优化的公司
  • 做百度糯米网站的团队/网站seo关键词排名
  • 墙绘做网站推广有作用没/淘宝联盟怎么推广
  • 网站专题制作教程/西安seo排名收费