化繁为简:中介者模式如何管理复杂对象交互
化繁为简:中介者模式如何管理复杂对象交互
中介者模式 是一种行为型设计模式,定义了一个中介者对象,来封装一组对象之间的交互。中介者模式通过将对象之间的交互行为从多个对象中抽离出来,集中封装在一个中介者对象中,从而使各个对象之间的耦合松散,且可以独立地改变它们之间的交互。
核心思想:
中介者模式通过引入一个中介者,协调多个对象之间的交互,避免对象之间的直接通信,从而减少对象之间的耦合。
中介者模式的组成角色
Mediator(中介者接口):
- 中介者定义了对象之间交互的接口,负责协调各个对象之间的通信行为。
ConcreteMediator(具体中介者):
- 实现了
Mediator
接口,协调各具体同事对象之间的交互。它了解所有的同事对象,并通过其实现交互逻辑。
Colleague(同事类):
- 每个同事对象只知道中介者,不能直接与其他同事对象通信。所有的交互都通过中介者来完成。
ConcreteColleague(具体同事类):
- 实现了
Colleague
接口,依赖中介者与其他同事对象通信。每个具体同事对象的行为受到中介者的约束。
中介者模式的 UML 类图
类图解释:
- Mediator(中介者接口):定义了同事对象之间的通信接口,通常定义
send()
方法来协调通信。 - ConcreteMediator(具体中介者):
- 实现了
Mediator
接口,具体负责管理和协调同事对象之间的通信。它知道所有的具体同事对象,并通过send()
方法传递消息或协调操作。 - 它也可以持有具体的同事对象的引用,负责管理这些对象。
- 实现了
- Colleague(同事类):抽象类或接口,每个同事对象依赖中介者与其他同事进行交互。它不直接与其他同事对象通信,而是通过中介者通信。
- ConcreteColleague1、ConcreteColleague2(具体同事类):实现
Colleague
,定义各自的具体操作。同事对象通过中介者协调相互间的通信
工作原理
- 集中通信:中介者模式通过引入
Mediator
,将多个对象之间的交互逻辑集中到中介者中,使得各个同事类之间的关系变得松散耦合。 - 消息传递:同事对象通过调用中介者的
send()
方法进行通信。中介者负责接收和转发消息,并协调其他同事对象的行为。 - 解耦同事对象:同事对象之间不直接交互,而是通过中介者来处理。这样一来,各个对象之间的依赖关系被削弱了。
案例:机场塔台与飞机的调度
场景说明:
在机场,飞机起飞和降落的调度是一个非常复杂的过程。如果每架飞机都直接与其他飞机进行通信,会导致混乱并增加空中事故的风险。因此,机场有一个控制塔(塔台),它负责协调所有飞机的起飞和降落。
控制塔是中介者,飞机之间的所有通信都必须通过控制塔进行。飞机通过塔台来获取是否可以起飞或降落,从而避免与其他飞机发生冲突。
中介者模式的角色在机场塔台场景中的映射:
- Mediator(中介者接口):机场控制塔,负责协调所有飞机的起飞和降落。
- ConcreteMediator(具体中介者):具体实现的控制塔,协调飞机的飞行状态。
- Colleague(同事类):抽象飞机类,代表参与通信的对象(飞机)。
- ConcreteColleague(具体同事类):具体的飞机类,通过控制塔来决定起飞或降落。
代码实现:机场塔台调度系统
Step 1: 定义中介者接口
中介者接口定义了调度方法,用于协调飞机之间的通信。
// 中介者接口:塔台
public interface Mediator {void notify(String message, Airplane airplane);
}
Step 2: 实现具体的中介者
ControlTower
类是具体的中介者,它负责接收飞机的状态并通知其他飞机,确保起飞和降落顺序的安全。
import java.util.ArrayList;
import java.util.List;// 具体中介者:控制塔
public class ControlTower implements Mediator {private List<Airplane> airplanes;public ControlTower() {this.airplanes = new ArrayList<>();}public void registerAirplane(Airplane airplane) {airplanes.add(airplane);}@Overridepublic void notify(String message, Airplane airplane) {for (Airplane a : airplanes) {if (a != airplane) {a.receive(message); // 通知其他飞机}}}
}
Step 3: 定义飞机抽象类
飞机类通过中介者来发送和接收信息,而不直接与其他飞机通信。
// 飞机抽象类
public abstract class Airplane {protected Mediator mediator;protected String name;public Airplane(Mediator mediator, String name) {this.mediator = mediator;this.name = name;}public abstract void send(String message);public abstract void receive(String message);
}
Step 4: 实现具体飞机类
具体飞机类实现了 send()
和 receive()
方法,通过塔台来发送和接收消息。
Boeing737 类
// 具体飞机:Boeing 737
public class Boeing737 extends Airplane {public Boeing737(Mediator mediator, String name) {super(mediator, name);}@Overridepublic void send(String message) {System.out.println(this.name + " sends message: " + message);mediator.notify(message, this); // 通过塔台发送消息}@Overridepublic void receive(String message) {System.out.println(this.name + " receives message: " + message);}
}
AirbusA320 类
// 具体飞机:Airbus A320
public class AirbusA320 extends Airplane {public AirbusA320(Mediator mediator, String name) {super(mediator, name);}@Overridepublic void send(String message) {System.out.println(this.name + " sends message: " + message);mediator.notify(message, this); // 通过塔台发送消息}@Overridepublic void receive(String message) {System.out.println(this.name + " receives message: " + message);}
}
Step 5: 测试中介者模式
通过 ControlTower
来协调 Boeing737
和 AirbusA320
之间的通信,确保飞机的起飞和降落顺序。
public class MediatorPatternDemo {public static void main(String[] args) {// 创建控制塔ControlTower tower = new ControlTower();// 创建飞机并注册到塔台Airplane boeing737 = new Boeing737(tower, "Boeing 737");Airplane airbusA320 = new AirbusA320(tower, "Airbus A320");tower.registerAirplane(boeing737);tower.registerAirplane(airbusA320);// 飞机发送消息boeing737.send("Requesting permission to land.");airbusA320.send("Requesting permission to take off.");}
}
输出结果:
Boeing 737 sends message: Requesting permission to land.
Airbus A320 receives message: Requesting permission to land.
Airbus A320 sends message: Requesting permission to take off.
Boeing 737 receives message: Requesting permission to take off.
中介者模式在机场塔台场景中的工作原理
- 集中通信:所有的飞机(同事类)不直接通信,而是通过控制塔(中介者)进行协调。每架飞机都通过塔台发送和接收消息。
- 消息传递:当一架飞机发送起飞或降落请求时,塔台负责通知其他飞机,并保证飞行安全和秩序。
- 降低耦合性:飞机之间不直接通信,所有交互通过塔台完成,从而降低了飞机之间的耦合,增强了系统的灵活性和扩展性。
SpringMVC 中的 应用
在 Spring Framework 中,DispatcherServlet
作为前端控制器,实际上也承担了类似于中介者的作用。它在 Spring MVC 架构中负责协调不同组件(如控制器、视图解析器和处理器)的交互。
原理:
DispatcherServlet
作为一个统一的请求分发器,负责接收 HTTP 请求,并根据请求的 URL 或其他条件,将请求分发给适当的处理器(如@Controller
的方法)。它并不直接参与具体的请求处理,而是协调多个组件来完成请求-响应的流程。- 控制器、视图解析器、处理器等组件之间不直接通信,而是通过
DispatcherServlet
进行交互。
// DispatcherServlet 伪代码,简化示例
public class DispatcherServlet extends HttpServlet {@Overrideprotected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {// 根据请求查找对应的控制器Handler handler = getHandler(request);// 调用控制器处理请求ModelAndView mv = handler.handleRequest(request, response);// 解析视图并返回响应render(mv, response);}
}
在这里,DispatcherServlet
类似于中介者,协调多个组件之间的交互,不同的控制器和视图解析器不直接互相通信,而是通过 DispatcherServlet
进行处理。
中介者模式的优缺点与应用场景总结
优点:
- 降低对象之间的耦合性:
- 中介者模式通过引入中介者,使多个对象之间的依赖关系转变为与中介者的依赖,减少了对象之间的直接交互,降低了系统的耦合度。
- 简化对象之间的通信:
- 所有通信都通过中介者集中管理,使得系统结构更加清晰,逻辑集中,尤其在多方通信的复杂系统中,简化了交互逻辑。
- 符合开闭原则:
- 中介者模式可以方便地扩展或修改交互逻辑,而不影响各个同事对象。可以通过修改中介者来增加或调整各对象之间的交互。
- 提高系统的灵活性:
- 当需要增加新的对象或修改对象之间的交互行为时,可以通过中介者进行控制,增强了系统的扩展性和灵活性。
缺点:
- 中介者可能变得复杂:
- 随着系统中同事对象的增多,中介者需要处理的交互逻辑也会变得越来越复杂,可能导致中介者变得难以维护,形成一个“上帝对象”。
- 不适合简单场景:
- 如果对象之间的交互非常简单,使用中介者模式会引入不必要的复杂性,增加维护成本。
应用场景:
- 复杂对象交互的系统:
- 在多个对象之间存在复杂交互的系统中,中介者模式非常适用。例如,GUI 控件交互(如按钮、文本框、下拉菜单等)可以通过中介者来管理。
- 消息队列系统:
- 在消息队列(如 JMS)中,中介者管理生产者和消费者之间的消息传递,解耦了消息的发送和接收,避免直接通信。
- 事件驱动系统:
- 在事件驱动架构中,事件发布者和监听者之间的通信可以通过中介者来协调,避免对象之间的紧密耦合。例如,Spring 的事件驱动机制利用
ApplicationEventPublisher
和ApplicationListener
解耦了事件发布和处理。
- 在事件驱动架构中,事件发布者和监听者之间的通信可以通过中介者来协调,避免对象之间的紧密耦合。例如,Spring 的事件驱动机制利用
- 航空管制系统:
- 像机场塔台这种需要协调多架飞机起降的系统,中介者可以集中管理对象的行为,保证复杂交互的有序进行。
相关文章:

化繁为简:中介者模式如何管理复杂对象交互
化繁为简:中介者模式如何管理复杂对象交互 中介者模式 是一种行为型设计模式,定义了一个中介者对象,来封装一组对象之间的交互。中介者模式通过将对象之间的交互行为从多个对象中抽离出来,集中封装在一个中介者对象中,…...
控制STM32蜂鸣器示例代码(江科大)
以下代码来源于本人学习江科大的课程,这是一个简单的STM32微控制器程序,用于控制连接到GPIOB第12号引脚的蜂鸣器。程序通过GPIOB的第12号引脚输出PWM波形来控制蜂鸣器的频率,从而产生声音。 #include "stm32f10x.h" …...

Java基础知识扫盲
目录 Arrays.sort的底层实现 BigDecimal(double)和BigDecimal(String)有什么区别 Char可以存储一个汉字吗 Java中的Timer定时调度任务是咋实现的 Java中的序列化机制是咋实现的 Java中的注解是干嘛的 Arrays.sort的底层实现 Arrays.sort是Java中提供的对数组进行排序的…...

ZLMediaKit Windows编译以及使用
1.运行ZLMediaKit 2.通过ffmpeg把视频源推流给ZLMediaKit 执行以下命令,将本地视频通过RTSP协议推流给ZLMediaKit。 ffmpeg -re -stream_loop -1 -i "D:\workplace\armgb\public\1.fileh264" -vcodec h264 -f rtsp rtsp://127.0.0.1/live/test 若想将本…...

基于YOLOv5s的无人机航拍输电线瓷瓶检测(附数据集与操作步骤)
本文主要内容:详细介绍了无人机航拍输电线瓷瓶检测的整个过程,从创建数据集到训练模型再到预测结果全部可视化操作与分析。 文末有数据集获取方式,请先看检测效果 现状 输电线路绝缘瓷瓶的检测主要依赖人工巡检。巡检人员需携带专业设备,攀…...
【Python百日进阶-Web开发-FastAPI】Day805 - FastAPI的请求体
文章目录 一、导入 Pydantic 的 BaseModel二、创建数据模型三、声明为参数四、结果五、自动化文档六、编辑器支持七、使用模型八、请求体 + 路径参数九、请求体 + 路径参数 + 查询参数十、不使用 Pydantichttps://fastapi.tiangolo.com/zh/tutorial/body/ 当你需要将数据从客户…...
【Kubernetes】常见面试题汇总(二十八)
目录 79.您如何看待公司从单一服务转向微服务并部署其服务容器? 80.什么是 Headless Service? 特别说明: 题目 1-68 属于【Kubernetes】的常规概念题。 题目 69-113 属于【Kubernetes】的生产应用题。 79.您如何看待公司从单一服务转…...
单ISP与双ISP的区别是什么
单ISP(单一互联网服务提供商)与双ISP(双重互联网服务提供商)主要在以下几个方面有区别: 服务冗余: 单ISP:只有一个互联网服务提供商提供的网络连接。如果该ISP发生故障,整个网络连接…...

【linux】gcc makefile
🔥个人主页:Quitecoder 🔥专栏:linux笔记仓 目录 01.gcc如何完成02.gcc选项03.函数库与动静态链接静态链接动态链接库文件特点和用途动态链接版本和兼容性 04.makefile自动推导 01.gcc如何完成 预处理(进行宏替换) 预处理功能主要…...

12.Java基础概念-面向对象-static
欢迎来到我的博客,很高兴能够在这里和您见面!希望您在这里可以感受到一份轻松愉快的氛围,不仅可以获得有趣的内容和知识,也可以畅所欲言、分享您的想法和见解。 Facts speak louder than words! 一、static关键字的含义…...

移动开发(三):使用.NET MAUI打包第一个安卓APK完整过程
目录 一、修改AndroidManifest.xml 配置APP基本信息权限 二、修改项目属性调整输出Android包格式为APK 三、项目发布 四、APP分发 五、总结 之前给大家介绍过使用使用.NET MAUI开发第一个安卓APP,今天给大家介绍如何打包成APK,然后安装到安卓手机正常运行。这里还是沿用…...
数据库中的DUAL表
在日常的数据库操作中,DUAL表是一个特殊的存在。它是一个伪表,用于在不需要实际数据表的情况下进行简单的查询。特别是在执行一些无关联的数据计算时,DUAL表经常派上用场。 什么是DUAL表? DUAL表最早出现在Oracle数据库中&#…...

寄宿制学校自闭症教育:为每个孩子创造奇迹
寄宿制学校自闭症教育:星贝育园——为每个孩子创造奇迹 在自闭症儿童教育的广阔领域中,寄宿制学校以其独特的教育模式和全方位的关怀体系,正逐步成为推动这些特殊孩子成长与发展的重要力量。广州的星贝育园自闭症儿童寄宿制学校,…...
Vue前端无法接收到后端返回的数据以及全局CSS样式影响(已解决)
Vue前端无法接收到后端返回的数据 前提:把很久以前的项目,翻出来重新优化一下,做一下前端的美化(以前都是用的element的UI,现在想自己写)。 由于是自己利用简单的html语句,主要面向各个按钮控…...

力扣234 回文链表 Java版本
文章目录 题目描述代码 题目描述 给你一个单链表的头节点 head ,请你判断该链表是否为 回文链表 。如果是,返回 true ;否则,返回 false 。 示例 1: 输入:head [1,2,2,1] 输出:true 示例 2&…...

银行性能测试怎么做?来认识下这4个性能测试工具!
一、银行项目性能测试是什么? 银行项目性能测试是一种软件测试形式,用于评估银行应用程序的性能和负载能力。 它的主要目标是确保银行系统能够在不同负载水平下提供稳定、高效的服务。 性能测试涵盖了多个方面,包括响应时间、吞吐量、并发用…...

FME学习笔记
读取数据 方法一:add reader 通过读模块来进行数据的读取 方法二:FeatureReader Parameters 通过转换器来进行数据的读取 可以通过空间范围进行筛选 在FME中,所有数据处理都要用到的,绝对的重点:转换器ÿ…...

机器翻译之创建Seq2Seq的编码器、解码器
1.创建编码器、解码器的基类 1.1创建编码器的基类 from torch import nn#构建编码器的基类 class Encoder(nn.Module): #继承父类nn.Moduledef __init__(self, **kwargs): #**kwargs:不定常的关键字参数super().__init__(**kwargs)def forward(self, X, *args…...
锤炼核心技能以应对编程革命
一、引言 随着人工智能的快速发展,尤其是AIGC等大语言模型的涌现,AI辅助编程工具逐渐成为程序员的新伙伴。这一变革不仅引发了关于AI是否能取代部分编程工作的讨论,也促使程序员重新思考自己的职业发展和技能提升路径。在AI时代࿰…...

2024 go-zero社交项目实战
背景 一位商业大亨,他非常看好国内的社交产品赛道,想要造一款属于的社交产品,于是他找到了负责软件研发的小明。 小明跟张三一拍即合,小明决定跟张三大干一番。 社交产品MVP版本需求 MVP指:Minimum Viable Product&…...
Vue记事本应用实现教程
文章目录 1. 项目介绍2. 开发环境准备3. 设计应用界面4. 创建Vue实例和数据模型5. 实现记事本功能5.1 添加新记事项5.2 删除记事项5.3 清空所有记事 6. 添加样式7. 功能扩展:显示创建时间8. 功能扩展:记事项搜索9. 完整代码10. Vue知识点解析10.1 数据绑…...

优选算法第十二讲:队列 + 宽搜 优先级队列
优选算法第十二讲:队列 宽搜 && 优先级队列 1.N叉树的层序遍历2.二叉树的锯齿型层序遍历3.二叉树最大宽度4.在每个树行中找最大值5.优先级队列 -- 最后一块石头的重量6.数据流中的第K大元素7.前K个高频单词8.数据流的中位数 1.N叉树的层序遍历 2.二叉树的锯…...
2023赣州旅游投资集团
单选题 1.“不登高山,不知天之高也;不临深溪,不知地之厚也。”这句话说明_____。 A、人的意识具有创造性 B、人的认识是独立于实践之外的 C、实践在认识过程中具有决定作用 D、人的一切知识都是从直接经验中获得的 参考答案: C 本题解…...

如何在网页里填写 PDF 表格?
有时候,你可能希望用户能在你的网站上填写 PDF 表单。然而,这件事并不简单,因为 PDF 并不是一种原生的网页格式。虽然浏览器可以显示 PDF 文件,但原生并不支持编辑或填写它们。更糟的是,如果你想收集表单数据ÿ…...
重启Eureka集群中的节点,对已经注册的服务有什么影响
先看答案,如果正确地操作,重启Eureka集群中的节点,对已经注册的服务影响非常小,甚至可以做到无感知。 但如果操作不当,可能会引发短暂的服务发现问题。 下面我们从Eureka的核心工作原理来详细分析这个问题。 Eureka的…...

九天毕昇深度学习平台 | 如何安装库?
pip install 库名 -i https://pypi.tuna.tsinghua.edu.cn/simple --user 举个例子: 报错 ModuleNotFoundError: No module named torch 那么我需要安装 torch pip install torch -i https://pypi.tuna.tsinghua.edu.cn/simple --user pip install 库名&#x…...
LangChain知识库管理后端接口:数据库操作详解—— 构建本地知识库系统的基础《二》
这段 Python 代码是一个完整的 知识库数据库操作模块,用于对本地知识库系统中的知识库进行增删改查(CRUD)操作。它基于 SQLAlchemy ORM 框架 和一个自定义的装饰器 with_session 实现数据库会话管理。 📘 一、整体功能概述 该模块…...
【Kafka】Kafka从入门到实战:构建高吞吐量分布式消息系统
Kafka从入门到实战:构建高吞吐量分布式消息系统 一、Kafka概述 Apache Kafka是一个分布式流处理平台,最初由LinkedIn开发,后成为Apache顶级项目。它被设计用于高吞吐量、低延迟的消息处理,能够处理来自多个生产者的海量数据,并将这些数据实时传递给消费者。 Kafka核心特…...

轻量级Docker管理工具Docker Switchboard
简介 什么是 Docker Switchboard ? Docker Switchboard 是一个轻量级的 Web 应用程序,用于管理 Docker 容器。它提供了一个干净、用户友好的界面来启动、停止和监控主机上运行的容器,使其成为本地开发、家庭实验室或小型服务器设置的理想选择…...

大模型——基于Docker+DeepSeek+Dify :搭建企业级本地私有化知识库超详细教程
基于Docker+DeepSeek+Dify :搭建企业级本地私有化知识库超详细教程 下载安装Docker Docker官网:https://www.docker.com/ 自定义Docker安装路径 Docker默认安装在C盘,大小大概2.9G,做这行最忌讳的就是安装软件全装C盘,所以我调整了下安装路径。 新建安装目录:E:\MyS…...