设计模式学习笔记 - 设计模式与范式 -结构型:1.代理模式:代理在RPC、缓存、监控等场景中的应用

news/2024/4/28 9:49:41/文章来源:https://blog.csdn.net/chenjian723122704/article/details/136996756

概述

前面几个章节,我们学习了设计模式中的创建型模式。创建型模式主要解决对象的创建问题,封装复杂的创建过程,解耦对象的创建代码和使用代码。

  • 单例模式用来创建全局唯一的对象。
  • 工厂模式用来创建不同但是相关类型的对象(继承同一父类或接口的一组子类),由给定的参数来决定创建哪种类型的对象。
  • 建造者模式是用来创建复杂对象,可以通过设置不同的可选参数,“定制化” 地创建不同的对象。
  • 原型模式针对创建成本比较大的对象,利用已有对象进行复制的方式进行创建,已达到节省创建时间的目的。

从本章开始,我们学习结构性模式。结构性模式主要总结了一些类或对象组合在一起的经典结构,这些经典的结构可以解决特定应用场景的问题。结构型模式包括:代理模式、桥接模式、装饰器模式、适配器模式、门面模式、组合模式、享元模式。

本章要讲解结构型模式中的代理模式。它也是在实际开发中经常被用到的一种设计模式。


代理模式的原理解析

代理模式的原理和代码实现都不难掌握。它在不改变原始类(也叫被代理类)代码的情况下,通过引入代理类来给原始类附加功能。我们通过一个例子来解释下这段话。

这个例子来自我们在《设计原则 - 10.实战:针对非业务的通用框架开发,如何做需求分析和设计及如何实现一个支持各种统计规则的性能计数器》和《设计原则与思想总结:2.运用学过的设计原则和思想完善之前性能计数器项目》中讲的性能计数器。当时我们开发了一个 MetricsCollector 类,用来收集请求的原始数据,比如访问时间、处理时长等。在业务系统重,我们采用如下方式来使用这个 MetricsCollector 类。

public class UserController {// 省略其他属性和方法...private MetricsCollector metricsCollector; // 依赖注入public UserVo register(UserVo user) {long startTimestamp = System.currentTimeMillis();// 省略register逻辑...long endTimestamp = System.currentTimeMillis();long responseTime = endTimestamp - startTimestamp;RequestInfo requestInfo = new RequestInfo("register", responseTime, startTimestamp);metricsCollector.recordRequest(requestInfo);// 返回UserVo数据...return null;}public UserVo login(String telephone, String password) {long startTimestamp = System.currentTimeMillis();// 省略login逻辑...long endTimestamp = System.currentTimeMillis();long responseTime = endTimestamp - startTimestamp;RequestInfo requestInfo = new RequestInfo("login", responseTime, startTimestamp);metricsCollector.recordRequest(requestInfo);// 返回UserVo数据...return null;}
}

很显然,上面的写法有两个问题。

  • 第一,性能计数器框架代码侵入到业务代码中,跟业务代码高度耦合。如果未来需要替换这个框架,那替换的成本会比较大。
  • 第二,收集接口请求的代码跟业务代码无关,本就不应该放到一个类中。业务类最好职责更加单一,只聚焦业务处理。

为了将框架和业务代码解耦,代理模式就派上用场了。代理类 UserControllerProxy 和 原始类 UserController 实现相同的接口 IUserControllerUserController 类只负责业务功能。代理类 UserControllerProxy 负责在业务代码执行前后附加其他逻辑代码,并通过委托的方式调用原始类来执行业务代码。具体代码的实现如下:

public interface IUserController {UserVo login(String telephone, String password);UserVo register(UserVo user);
}public class UserController implements IUserController {// 省略其他属性和方法...@Overridepublic UserVo login(String telephone, String password) {// 省略login逻辑...// 返回UserVo数据...return null;}@Overridepublic UserVo register(UserVo user) {// 省略register逻辑...// 返回UserVo数据...return null;}
}public class UserControllerProxy implements IUserController {private MetricsCollector metricsCollector;private UserController userController;@Overridepublic UserVo login(String telephone, String password) {long startTimestamp = System.currentTimeMillis();// 委托UserVo userVo = userController.login(telephone, password);long endTimestamp = System.currentTimeMillis();long responseTime = endTimestamp - startTimestamp;RequestInfo requestInfo = new RequestInfo("login", responseTime, startTimestamp);metricsCollector.recordRequest(requestInfo);return userVo;}@Overridepublic UserVo register(UserVo user) {long startTimestamp = System.currentTimeMillis();// 委托UserVo userVo = userController.register(user);long endTimestamp = System.currentTimeMillis();long responseTime = endTimestamp - startTimestamp;RequestInfo requestInfo = new RequestInfo("register", responseTime, startTimestamp);metricsCollector.recordRequest(requestInfo);return userVo;}
}// UserControllerProxy 使用举例
// 因为原始类和代理类实现相同的接口,是基于接口而非实现编程
// 将UserController类对象替换为 UserControllerProxy 类对象,不需要改动太多代码
IUserController userController = new UserControllerProxy(new UserController());

参照基于接口而非实现编程的设计思想,将原始类对象替换为代理对象时,为了让代码改动尽量少,在刚刚的代理模式的代码实现中,代理类和原始类需要实现相同的接口。但是,如果原始类并没有定义接口,并且原始类代码不是我们开发维护的(比如它来自一个第三方的类库),我们也没有办法修改原始类,给它重新定义一个接口。在这种情况下,该如何实现代理模式呢?

对于这种外部类的扩展,我们一般都是采用继承的方式。这里也不例外。我们让代理类继承原始类然后扩展附加功能。原理很简单,你直接看代码就能明白。具体代码如下所示:

public class UserControllerProxy extends UserController {private MetricsCollector metricsCollector;@Overridepublic UserVo login(String telephone, String password) {long startTimestamp = System.currentTimeMillis();UserVo userVo = super.login(telephone, password);long endTimestamp = System.currentTimeMillis();long responseTime = endTimestamp - startTimestamp;RequestInfo requestInfo = new RequestInfo("login", responseTime, startTimestamp);metricsCollector.recordRequest(requestInfo);return userVo;}@Overridepublic UserVo register(UserVo user) {long startTimestamp = System.currentTimeMillis();UserVo userVo = super.register(user);long endTimestamp = System.currentTimeMillis();long responseTime = endTimestamp - startTimestamp;RequestInfo requestInfo = new RequestInfo("register", responseTime, startTimestamp);metricsCollector.recordRequest(requestInfo);return userVo;}
}

动态代理的原理解析

其实,刚刚的代码还是有点问题。

  • 一方面,我们需要再代理类中,将原始类的所有方法,都重新实现一遍,并且为每个方法都附加相似的代码逻辑。
  • 另一方面,如果要添加的附加功能的类又不止一个,我们需要对每个类都创建一个代理类。

如果有 50 个要添加附加功能的原始类,我们就要创建 50 个代理类。这会导致项目中类的个数成倍增加,增加了代码的维护成本。并且,每个代理类中的代码都有点像模板模式的 “重复” 代码,也增加了不必要的开发成本。这个问题怎么解决呢?

可以使用动态代理来解决这个问题。所谓动态代理,就是我们不事先为每个原始类编写代理类,而是在运行的时候,动态地创建原始类对应的代理类,然后再=在系统中用代理类替换掉原始类。

如果你熟悉 Java 语言,实现动态代理就是件很简单的事情。因为 Java 语言本身就提供了动态代理的语法(实际上,动态代理底层依赖的就是 Java 的发射语法)。我们来看一下,如何使用 Java 的动态代理来实现刚刚的功能。具体的代码如下所示。其中, MetricsCollectorProxy 作为一个动态代理类,动态地给每个需要收集接口请求的类创建代理类。

public class MetricsCollectorProxy {private MetricsCollector metricsCollector;public MetricsCollectorProxy(MetricsCollector metricsCollector) {this.metricsCollector = metricsCollector;}public Object createProxy(Object proxiedObject) {Class<?>[] interfaces = proxiedObject.getClass().getInterfaces();DynamicProxyHandler handler = new DynamicProxyHandler(proxiedObject);return Proxy.newProxyInstance(proxiedObject.getClass().getClassLoader(), interfaces, handler);}private class  DynamicProxyHandler implements InvocationHandler {private Object proxiedObject;public DynamicProxyHandler(Object proxiedObject) {this.proxiedObject = proxiedObject;}@Overridepublic Object invoke(Object proxy, Method method, Object[] args) throws Throwable {long startTimestamp = System.currentTimeMillis();Object result = method.invoke(proxiedObject, args);long endTimestamp = System.currentTimeMillis();long responseTime = endTimestamp - startTimestamp;String apiName = proxiedObject.getClass().getName() + "." + method.getName();RequestInfo requestInfo = new RequestInfo(apiName, responseTime, startTimestamp);metricsCollector.recordRequest(requestInfo);return result;}}
}// MetricsCollectorProxy使用举例
MetricsCollectorProxy proxy = new MetricsCollectorProxy();
IUserController userCpntroller = (IUserController) proxy.createProxy(new UserController());

实际上,Spring AOP 底层的实现原理就是基于动态代理。用户配置好需要给那些类创建代理,并定义好在执行原始类的业务代码前后执行哪些附加功能。Spring 为这些类创建动态代理对象,并在 JVM 中替代原始对象。原本在代码中执行的原始类的方法,被换作执行代理类的方法,也就实现了给原始类添加附加功能的目的。

代理模式的应用场景

代理模式的应用场景非常多,这里列举一些比较常见的用法,希望你能举一反三地应用在你的项目开发中。

1.业务系统的非功能性需求开发

代理模式最常用的一个应用场景就是,在业务系统开发一些非功能性需求,比如:监控、统计、鉴权、限流、事务、幂等、日志。我们将这些附加功能与业务功能解耦,放到代理类中统一处理,让程序员只需要关注业务方面的开发。实际上,前面举的搜集接口请求信息的例子,就是这个应用场景的一个典型例子。

如果你熟悉 Java 语言和 Spring 框架,这部分工作都是可以在 Spring AOP 切面中完成的。前面也提到过,Spring AOP 底层的实现原理就是基于动态代理。

2.代理模式在 RPC、缓存中应用

实际上,RPC 框架也可以看做一种代理模式。GoF 的《设计模式》中把它称作远程代理。通过远程代理,将网络通信、数据编解码等细节隐藏起来。客户端在使用 RPC 服务的时候,就像使用本地函数一样,无需了解跟服务器交互的细节。此外,RPC 服务的开发者也只需要开发业务逻辑,就像开发本地使用的函数一样,不需要关注跟客户端的交互细节。

关于远程代理的代码示例,我自己实现了一个简单的 RPC 框架 Demo。

首先是服务端代码

// 服务端的Rpc基础类
public class RpcServer {public void export(Object service, int port) throws Exception {if (service == null) {throw new IllegalArgumentException("service instance == null");}if (port <= 0 || port > 65535) {throw new IllegalArgumentException("invalid port: " + port);}ServerSocket server = new ServerSocket(port);while (true) {final Socket socket = server.accept();new Thread(new Runnable() {@Overridepublic void run() {try {ObjectInputStream input = new ObjectInputStream(socket.getInputStream());ObjectOutputStream output = new ObjectOutputStream(socket.getOutputStream());try {String methodName = input.readUTF();Class<?>[] parameterTypes = (Class<?>[]) input.readObject();Object[] args = (Object[]) input.readObject();Method method = service.getClass().getMethod(methodName, parameterTypes);Object result = method.invoke(service, args);output.writeObject(result);} catch (Throwable t) {output.writeObject(t);} finally {output.close();input.close();socket.close();}} catch (IOException e) {e.printStackTrace();}}}).start();}}
}// 业务的接口
public interface CalculatorService {int add(int a, int b);
}// 业务的实现类
public class CalculatorServiceImpl implements CalculatorService {@Overridepublic int add(int a, int b) {return a + b;}
}// 业务端 RPC 服务Demo
public class RpcServerApplication {public static void main(String[] args) throws Exception {CalculatorService service = new CalculatorServiceImpl();RpcServer server = new RpcServer();server.export(service, 1234);}
}

接下来是客户端代码

// 客户端RPC应用的基础类
public class RpcClient {public <T> T refer(final Class<T> interfaceClass, final String host, final int port) {if (interfaceClass == null) {throw new IllegalArgumentException("interface class == null");}if (!interfaceClass.isInterface()) {throw new IllegalArgumentException("The " + interfaceClass.getName() + " must be interface class");}if (host == null || host.length() == 0) {throw new IllegalArgumentException("host == null");}if (port <= 0 || port > 65535) {throw new IllegalArgumentException("invalid port: " + port);}return (T) Proxy.newProxyInstance(interfaceClass.getClassLoader(), new Class[]{interfaceClass}, new InvocationHandler() {@Overridepublic Object invoke(Object proxy, Method method, Object[] args) throws Throwable {Socket socket = new Socket(host, port);try {ObjectOutputStream output = new ObjectOutputStream(socket.getOutputStream());try {output.writeUTF(method.getName());output.writeObject(method.getParameterTypes());output.writeObject(args);ObjectInputStream input = new ObjectInputStream(socket.getInputStream());try {Object result = input.readObject();if (result instanceof Throwable) {throw (Throwable) result;}return result;} finally {input.close();}} finally {output.close();}} finally {socket.close();}}});}
}// 需要调用的接口(服务端)
public interface CalculatorService {int add(int a, int b);
}// 客户端使用demo
public class ClientDemo {public static void main(String[] args) {RpcClient client = new RpcClient();CalculatorService service = client.refer(CalculatorService.class, "127.0.0.1", 1234);int result = service.add(2, 4);System.out.println("result: " + result);}
}

再来看代理模式在缓存中的应用。假设我们要开发一个接口请求的缓存功能,对于某些接口,如果入参相同,在设定的过期时间内,直接返回缓存结果,而不用重新进行逻辑处理。比如,针对获取用户个人信息的需求,我们可以开发两个接口,一个支持缓存,一个支持实时查询。对于需要实时数据的需求,我们让其调用实时查询接口,对于不需要实时数据的需求,我们让其调用支持缓存的接口。那如何实现接口请求的缓存功能呢?

最简单的实现方法就是,给每个需要支持缓存的查询需求都开发两个不同的接口,一个支持缓存,一个支持实时查询。但是,这样做显然增加了开发成本,而且会让代码看起来非常臃肿(接口个数成倍增加),也不方便缓存接口的集中管理(增加、删除缓存接口)、集中配置(比如配置每个接口缓存过期时间)。

针对这些问题,代理模式就派上用场了。如果是基于 Spring 框架来开发的话,那就可以在 AOP 切面中完成接口缓存的功能。在应用启动时,我们从配置文件中加载需要支持缓存的接口,以及相应的缓存策略(比如过期时间)等。当请求到来的时候,我们在 AOP 切面中拦截请求,如果请求中带有支持缓存的字段(比如 http://…?..&cache=true),我们便从缓存中获取数据直接返回。

总结

1.代理模式的原理与实现

在不改变原始类(或者叫被代理类)的情况下,通过引入代理类来给原始类附加功能。一般情况下,我们让代理类和原始类实现相同的接口。但是,如果原始类并没有定义接口,并且原始类代码并不是我们开发维护的。在这种情况下,我们可以通过让代理类继承原始类的方法来实现代理模式。

2.动态代理的原理与实现

静态代理需要针对每个类都创建一个代理类,并且每个代理类中的代码都有像模板式的 “重复” 代码,增加了维护成本和开发成本。对于静态代理存在的问题,我们可以通过动态代理来解决。我们不事先为每个原始类编写代理类,而是在运行时动态地创建代理类,然后再系统中用代理类代替原始类。

3.代理模式的应用场景

代理模式常用在业务系统中开发一些非功能性需求,比如:监控、统计、鉴权、限流、事务、幂等、日志。我们将这些附加功能与业务功能解耦,放到代理类中统一处理,让程序员只关注业务方面的开发。此外,代理模式还可以用在 RPC 、缓存等应用场景中。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.luyixian.cn/news_show_1027672.aspx

如若内容造成侵权/违法违规/事实不符,请联系dt猫网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

【tensorflow框架神经网络实现鸢尾花分类】

文章目录 1、数据获取2、数据集构建3、模型的训练验证可视化训练过程 1、数据获取 从sklearn中获取鸢尾花数据&#xff0c;并合并处理 from sklearn.datasets import load_iris import pandas as pdx_data load_iris().data y_data load_iris().targetx_data pd.DataFrame…

Scikit-Learn K近邻分类

Scikit-Learn K近邻分类 1、K近邻分类1.1、K近邻分类及原理1.2、超参数K1.3、K近邻分类的优缺点2、Scikit-Learn K近邻分类2.1、Scikit-Learn K近邻分类API2.2、K近邻分类实践(鸢尾花分类)2.3、交叉验证寻找最佳K2.4、K近邻分类与Pipeline1、K近邻分类 K近邻是一种常用的分类…

ES学习日记(一)-------单节点安装启动

基于ES7.4.1编写,其实一开始用的最新的8.1,但是问题太多了!!!!不稳定,降到7.4 下载好的安装包上传到服务器或虚拟机,创建ES目录,命令mkdir -p /路径xxxx 复制安装包到指定路径并解压: tar zxvf elasticsearch-8.1.0-linux-x86_64.tar.gz -C /usr/local/es/ 进入bin目录安装,命…

bugku-web-Flask_FileUpload

查看页面源码 这里提示给他一个文件&#xff0c;它将返回一个python运行结果给我&#xff0c;并且提示只能上传jpg和png文件 传递一个图片 查看源码 传递一个非图片 将源码写入新建的txt文件中 print(hello world) 将文件后缀改为jpg 上传 上传成功 查看源码 得到运行结果 我…

SpringMVC第一个helloword项目

文章目录 前言一、SpringMVC是什么&#xff1f;二、使用步骤1.引入库2.创建控制层3.创建springmvc.xml4.配置web.xml文件5.编写视图页面 总结 前言 提示&#xff1a;这里可以添加本文要记录的大概内容&#xff1a; SpringMVC 提示&#xff1a;以下是本篇文章正文内容&#xf…

​python学习之变量类型​

print单纯输中的十种数据类型只需要用print()函数即可&#xff0c;()里面直接写变量名。 下面重点介绍print格式输出&#xff1a; 第一种方法&#xff1a;一个萝卜一个坑&#xff0c;下面的代码中&#xff0c;{0}、{1}、{2}分别表示j,i,j*i&#xff0c;单引号里面是输出格式。…

WPF 多路绑定、值转换器ValueConvert、数据校验

值转换器 valueconvert 使用ValueConverter需要实现IValueConverter接口&#xff0c;其内部有两个方法&#xff0c;Convert和ConvertBack。我们在使用Binding绑定数据的时候&#xff0c;当遇到源属性和目标控件需要的类型不一致的&#xff0c;就可以使用ValueConverter&#xf…

将html文件转化为pdf

1.用浏览器将html文件打开 2.空白处右键点击打印 3.另存为PDF即可

day72Html

常用标签&#xff1a; 分类&#xff1a; 块级标签&#xff1a;独立成行 行级标签&#xff1a;不独立成行&#xff0c;同一行可放多个行级标 注意网页显示时&#xff0c;忽略空白字符,(回车符&#xff0c;空格&#xff0c;tab制表符&#xff09; 一&#xff09;块级标签&#xf…

【MATLAB源码-第20期】基于matlab的短波通信多径信道仿真,多径数目为3,用QPSK来测试误码率效果输出误码率对比图。

操作环境&#xff1a; MATLAB 2022a 1、算法描述 短波通信是一种使用短波频段的无线电通信技术&#xff0c;它具有以下特点&#xff1a; 1. 频段范围&#xff1a;短波通信通常使用3MHz到30MHz之间的频段。这个频段之所以称为“短波”&#xff0c;是因为它的波长相对较短&am…

Prometheus +Grafana +node_exporter可视化监控Linux + windows虚机

1、介绍 待补充 2、架构图 Prometheus &#xff1a;主要是负责存储、抓取、聚合、查询方面。 node_exporter &#xff1a;主要是负责采集物理机、中间件的信息。 3、搭建过程 配置要求&#xff1a;1台主服务器 n台从服务器 &#xff08;被监控的linux或windows虚机&am…

基于js css的瀑布流demo

要实现照片按照瀑布流展示&#xff0c;写个小demo&#xff0c;记录下。 瀑布流实现思路如下&#xff1a; CSS 弹性布局对 3 列按横向排列&#xff0c;对每一列内部按纵向排列 html代码&#xff1a; <div class"content"></div> css代码&#xff1a; …

【leetcode】环形链表的约瑟夫问题

大家好&#xff0c;我是苏貝&#xff0c;本篇博客带大家刷题&#xff0c;如果你觉得我写的还不错的话&#xff0c;可以给我一个赞&#x1f44d;吗&#xff0c;感谢❤️ 点击查看题目 首先我们要明确一点&#xff0c;题目要求我们要用环形链表&#xff0c;所以用数组等是不被允…

网站为什么要选择使用安全加速SCDN?

安全加速SCDN&#xff08;安全内容交付网络&#xff09;是一种网络加速服务&#xff0c;旨在提高网站和应用程序的性能和安全性。它使用专门的技术和基础设施来加速内容传输并保护网站免受网络攻击。 安全加速SCDN可以通过内容缓存、快速传输和动态路由技术来加速网站和应用程…

FPGA时钟资源详解(3)——全局时钟资源

FPGA时钟系列文章总览&#xff1a;FPGA原理与结构&#xff08;14&#xff09;——时钟资源https://ztzhang.blog.csdn.net/article/details/132307564 一、概述 全局时钟是 FPGA 中的一种专用互连网络&#xff0c;旨在将时钟信号分配到 FPGA 内各种资源的时钟输入处。这种设计…

【黑马头条】-day04自媒体文章审核-阿里云接口-敏感词分析DFA-图像识别OCR-异步调用MQ

文章目录 day4学习内容自媒体文章自动审核今日内容 1 自媒体文章自动审核1.1 审核流程1.2 内容安全第三方接口1.3 引入阿里云内容安全接口1.3.1 添加依赖1.3.2 导入aliyun模块1.3.3 注入Bean测试 2 app端文章保存接口2.1 表结构说明2.2 分布式id2.2.1 分布式id-技术选型2.2.2 雪…

【全栈小5】我的创作纪念日

目录 前言机缘收获粉丝和原创个人成就六边形战士 回顾文章原代码代码优化 憧憬 前言 全栈小5 &#xff0c;有幸再次遇见你&#xff1a; 还记得 2019 年 03 月 29 日吗&#xff1f; 你撰写了第 1 篇技术博客&#xff1a; 《前端 - 仿动态效果 - 展开信息图标》 在这平凡的一天&…

Matlab之求直角坐标系下两直线的交点坐标

目的&#xff1a;在直角坐标系下&#xff0c;求两个直线的交点坐标 一、函数的参数说明 输入参数&#xff1a; PointA&#xff1a;直线A上的点坐标&#xff1b; AngleA&#xff1a;直线A的倾斜角&#xff0c;单位度&#xff1b; PointB&#xff1a;直线B上的点坐标&#xf…

Git命令及GUI基本操作

不习惯使用Git命令的可移步下面Git GUI基本操作 Git 常用命令 git branch 查看本地所有分支 git status 查看当前状态 git commit 提交 git branch -a 查看所有的分支 git branch -r 查看本地所有分支 git commit -am "init" 提交并且加注释 git remote add orig…

Linux根据时间删除文件或目录

《liunx根据时间删除文件》和 《Linux 根据时间删除文件或者目录》已经讲述了根据时间删除文件或目录的方法。 下面我做一些补充&#xff0c;讲述一个具体例子。以删除/home目录下的文件为例。 首先通过命令&#xff1a; ls -l --time-style"%Y-%m-%d %H:%M:%S"…