策略模式在数据接收和发送场景的应用

f23649fd15c2fe4ce5f356f5e7327076.gif

在本篇文章中,我们介绍了策略模式,并在数据接收和发送场景中使用了策略模式。

ffa5c09a602c2a7ff2abaacb0a6202ba.png

背景

在最近项目中,需要与外部系统进行数据交互,刚开始交互的系统较为单一,刚开始设计方案时打算使用了if else 进行判断:

if("A".equals(system)){
    ASystem.sync("向A同步数据");
}
if("B".equals(system)){
    BSystem.sync("向B同步数据");
}
...

02f331bfebc1552606f5b74e3164655b.png

升级为策略模式

这样设计有什么样的问题呢?首先随着外部系统接入越来越多,不具备良好的扩展性,会导致代码越来越臃肿,其次从软件的设计角度来看, 不符合单一职责原则, 也不符合开闭原则。

那么选择什么样的设计模式来解决if else 堆砌的问题呢?首先我想到了策略模式。

首先我们来看一下策略模式的定义:

策略模式(Strategy Pattern)定义了一组同类型的算法,在不同的类中封装起来,
每种算法可以根据当前场景相互替换,从而使算法的变化独立于使用它们的客户端(即算法的调用者)

那么代入到我们的需求场景,我需要向外部系统同步或接收数据,数据的类型决定了我需要同步给A系统或者B系统,这些不同的数据决定了不同的策略

策略模式的结构通常包括以下组成部分:

  1. 定义一个策略接口或抽象类:该接口或抽象类定义了所有策略类都需要实现的方法。

  2. 创建多个具体的策略类:每个具体的策略类都实现了策略接口或抽象类,并提供了不同的实现。

  3. 创建一个策略上下文类:该类负责使用策略,它通常会维护一个策略接口或抽象类的引用。

  4. 在客户端代码中使用策略上下文类:客户端代码可以根据需要选择不同的策略。

看定义有些抽象,下面的结构图应该会容易理解一些。

6c61eb2ddcca724f45da7b57f4b66aec.png

根据上面的结构,我们来实现一下我们的场景

1.我们需要定义一个策略接口,定义与外部系统间交互都需要实现的方法

public interface DataProcessingStrategy {
    void receiveData();
    void sendData();
}

2.为每个外部系统创建一个策略类:

public class ASystemDataProcessingStrategy implements DataProcessingStrategy {
    @Override
    public void receiveData() {
        // 接收数据的具体实现
    }


    @Override
    public void sendData() {
        // 发送数据的具体实现
    }
}
public class BSystemDataProcessingStrategy implements DataProcessingStrategy {
    @Override
    public void receiveData() {
        // 接收数据的具体实现
    }


    @Override
    public void sendData() {
        // 发送数据的具体实现
    }
}

3.创建一个选择外部系统的策略类,用于在运行时根据需要选择合适的策略类

public class Context {
    private DataProcessingStrategy strategy;


    public Context(DataProcessingStrategy strategy) {
        this.strategy = strategy;
    }


    public void setStrategy(DataProcessingStrategy strategy) {
        this.strategy = strategy;
    }


    public void sendData(String data) {
        strategy.sendData(data);
    }


    public String receiveData() {
        return strategy.receiveData();
    }
}

4.最后,在需要调用外部系统同步数据的地方实例化相关策略类和上下文类,并调用executeStrategy方法:

public class Main {
    public static void main(String[] args) {
        // 创建两个策略对象
        DataProcessingStrategy strategyA = new ASystemDataProcessingStrategy();
        DataProcessingStrategy strategyB = new BSystemDataProcessingStrategy();


        // 创建上下文对象,并传入策略对象
        Context context = new Context(strategyA);
        //使用 ASystemDataProcessingStrategy 请求和接收数据
        context.sendData("");  
        context.receiveData("");


        // 使用 BSystemDataProcessingStrategy 请求和接收数据
        context = new Context(strategyB);
        context.sendData("");  
        context.receiveData("");
    }
}

3ca7441fffdbee8afa562133ed1b27d7.png

升级为策略模式+工厂模式

那么策略模式存在什么样的问题呢?

  1. 硬编码的依赖关系:在上述代码中,我们直接将具体的策略类(例如StrategyA和StrategyB)硬编码到上下文类(Context)中。这意味着如果我们想要添加或修改策略,我们需要在上下文类中修改代码。这种硬编码的方式使得系统难以扩展和维护。

  2. 客户端与策略的具体实现紧密耦合:由于上下文类Context直接依赖于具体的策略类,因此客户端代码必须了解每个具体策略的细节。这增加了客户端代码的复杂性,并使得客户端代码与策略的具体实现紧密耦合,增加了代码的维护难度。

我们可以使用工厂模式来改进我们的设计。工厂模式可以帮助我们将对象的创建和使用过程分离,使得上下文类和客户端代码不需要了解具体策略的细节,那么我们来修改一下我们的实现:

// 策略接口和具体的策略类保持不变
public interface DataProcessingStrategy {
    void sendData(String data);
    String receiveData();
}


public class ASystemDataProcessingStrategy implements DataProcessingStrategy {
    @Override
    public void sendData(String data) {
        // 发送数据到系统A的实现
    }


    @Override
    public String receiveData() {
        // 从系统A接收数据的实现
    }
}


public class BSystemDataProcessingStrategy implements DataProcessingStrategy {
    @Override
    public void sendData(String data) {
        // 发送数据到系统B的实现
    }


    @Override
    public String receiveData() {
        // 从系统B接收数据的实现
    }
}


public class DataProcessingStrategyFactory {


   private static ConcurrentHashMap<String, DataProcessingStrategy> strategies = new ConcurrentHashMap<>();


   /**
    * 注册策略
    * @param strategyName
    * @param strategy
    */
   public static void register(String strategyName, DataProcessingStrategy strategy) {
       strategies.put(strategyName, strategy);
  }


   public static DataProcessingStrategy getStrategy(String strategyName) {
       return strategies.get(strategyName);
  }


}


//client类相关修改
public class Main {
    public static void main(String[] args) {
        DataProcessingStrategy systemA = DeployStrategyFactory.getStrategy("A");
        //使用 ASystemDataProcessingStrategy 请求和接收数据
        systemA.sendData("");  
        systemA.receiveData("");


        DataProcessingStrategy systemB = DeployStrategyFactory.getStrategy("B");
        // 使用 BSystemDataProcessingStrategy 请求和接收数据
        systemB.sendData("");  
        systemB.receiveData("");
    }
}

9e6b852fdee769b0bdc6ce846cd1c821.png

总结

在本篇文章中,我们介绍了策略模式,并在数据接收和发送场景中使用了策略模式。通过使用策略模式,我们可以在客户端代码中根据运行时条件动态地选择一个具体的策略类,并通过这个策略类来改变对象的行为。这样,我们就可以实现不同的数据接收和发送方式,而不需要在客户端代码中进行大量的if-else判断。同时通过策略模式+工厂模式的方式解决了客户端代码与策略的具体实现紧密耦合的问题。当然结合实际的场景灵活运用相应的设计模式也非常重要,避免过度设计。

19fee4c8c5204fa279ac4d9adb33692a.png

团队介绍

我们是淘天集团-天猫奢品技术团队。天猫奢品汇聚全球顶尖品牌,覆盖全品类的高质量生活方式,致力于打造奢侈品线上消费首选平台。依托淘宝天猫电商生态,不断探索契合奢侈品品牌的互联网新体验技术与解决方案,以更加智能、友好的科技帮助品牌更好的经营,让用户享受更好的消费体验。

¤ 拓展阅读 ¤

3DXR技术 | 终端技术 | 音视频技术

服务端技术 | 技术质量 | 数据算法

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

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

相关文章

宝塔面板使用Supervisor进程守护插件,配置守护Mysql的操作教程。

本篇文章主要讲解&#xff0c;在宝塔面板中使用Supervisor进程守护插件&#xff0c;配置守护Mysql的操作教程。 作者&#xff1a;任聪聪 日期&#xff1a;2023年11月5日 一、安装守护进程插件 安装插件一、进程守护插件 安装说明&#xff1a;在软件商店中搜索“进程守护”&am…

elasticsearch下载和安装(linux)看这一篇就够了

配置java环境&#xff08;11版本以上&#xff09; 1.下载安装包 我是放在usr下的java里了 2.解压 tar -zxvf jdk-17_linux-x64_bin.tar.gz3.配置环境变量 vim /etc/profile在文件的最下面添加 JAVA_HOME/usr/java/jdk-17.0.9 #你自己的安装路径 JRE_HOME$JAVA_HOME/jre C…

项目实战:组件扫描实现(1)-扫描类路径所有文件

1、ComponentScan 组件扫描类 一下知识本人都是在Maven工程下总结的&#xff0c;所以目录结构会不一样这个类的作用是扫描所有的classes目录下的所有的字节码文件&#xff0c;找到相应的类&#xff0c;然后找到相应类上的注解 package com.csdn.mymvc.core; import java.io.Fi…

6.数据类型与运算符

目录 mysql数据类型 整型数据类型 浮点数类型和定点数类型 1、日期时间类型 1、YEAR 2、TIME 3、DATE类型 4、DATETIME 5、TIMESTAMP 2、字符串类型 1、CHAR 和 VARCHAR类型&#xff1a; 2、TEXT类型 3、ENUM类型 4、SET类型 二进制字符串类型 1、BIT类型 2、…

链表面试OJ题(1)

今天讲解两道链表OJ题目。 1.链表的中间节点 给你单链表的头结点 head &#xff0c;请你找出并返回链表的中间结点。 如果有两个中间结点&#xff0c;则返回第二个中间结点。 示例 输入&#xff1a;head [1,2,3,4,5] 输出&#xff1a;[3,4,5] 解释&#xff1a;链表只有一个…

iOS17.2正式版什么时候发布? 13大新功能细节抢先看

苹果已经发布了针对开发者的iOS 17.2 Beta测试版&#xff0c;而iOS 17.2正式版预计会在2023年12月发&#xff0c;新版本给iPhone带来不少新功能&#xff0c;下面小编就带大家抢先了解iOS 17.2即将带来的13个新功能亮点细节。 1.手记Journal App上线 全新「手记」 Journal App终…

访问控制、RBAC和ABAC模型

访问控制、RBAC和ABAC模型 访问控制 访问控制的目的是保护对象&#xff08;数据、服务、可执行应用该程序、网络设备或其他类型的信息技术&#xff09;不受未经授权的操作的影响。操作包括&#xff1a;发现、读取、创建、编辑、删除和执行等。 为实现访问控制&#xff0c; 计…

使用cpolar配合Plex搭建私人媒体站并实现远程访问

文章目录 1.前言2. Plex网站搭建2.1 Plex下载和安装2.2 Plex网页测试2.3 cpolar的安装和注册 3. 本地网页发布3.1 Cpolar云端设置3.2 Cpolar本地设置 4. 公网访问测试5. 结语 1.前言 用手机或者平板电脑看视频&#xff0c;已经算是生活中稀松平常的场景了&#xff0c;特别是各…

软件开发项目文档系列之十如何撰写测试用例

目录 1 概述1.1 编写目的1.2 定义1.3 使用范围1.4 参考资料1.5 术语定义 2 测试用例2.1 功能测试2.1.1 用户登录功能2.1.2 商品搜索功能 2.2 性能测试2.2.1 网站响应时间2.2.2 并发用户测试 附件&#xff1a; 测试用例撰写的要素和注意事项附件1 测试用例要素附件2 测试用例的注…

el-input输入校验插件(正则表达式)

使用方法&#xff1a;在main.js文件中注册插件然后直接在<el-input>加入‘v-插件名’ (1)在main.js文件&#xff1a; // 只能输入数字指令 import onlyNumber from /directive/only-number; Vue.use(onlyNumber); &#xff08;2&#xff09;在src/directive文件夹中 &a…

NOIP2023模拟12联测33 A. 构造

NOIP2023模拟12联测33 A. 构造 文章目录 NOIP2023模拟12联测33 A. 构造题目大意思路code 题目大意 构造题 思路 想一种构造方法&#xff0c;使得 y y y 能够凑成尽可能多的答案 第一行 x y r y ⋯ r xyry \cdots r xyry⋯r 第二行 r y x y ⋯ x ryxy \cdots x ryxy⋯x …

使用Anaconda安装TensorFlow环境以及没有搜到的报错的解决方法

1.在官网下载Anaconda 这一步几乎不会有人报错 下稳定的版本 或者最新的版本都可以 2.TensorFlow分两个版本 一个是用cpu跑 另一个是用gpu跑 显而易见 cpu的计算性能已经比不上现在主流的显卡了 所以有独显的电脑尽量安装gpu版本 CPU版本: 先给出cpu版本的安装方法: 打开A…

C++ PrimerPlus 复习 第九章 内存模型和名称空间

第一章 命令编译链接文件 make文件 第二章 进入c 第三章 处理数据 第四章 复合类型 &#xff08;上&#xff09; 第四章 复合类型 &#xff08;下&#xff09; 第五章 循环和关系表达式 第六章 分支语句和逻辑运算符 第七章 函数——C的编程模块&#xff08;上&#xff…

面试算法54:所有大于或等于节点的值之和

题目 给定一棵二叉搜索树&#xff0c;请将它的每个节点的值替换成树中大于或等于该节点值的所有节点值之和。假设二叉搜索树中节点的值唯一。例如&#xff0c;输入如图8.10&#xff08;a&#xff09;所示的二叉搜索树&#xff0c;由于有两个节点的值大于或等于6&#xff08;即…

第七章:计算failure概率

文章目录 第七章Random testingSerial BlocksParallel Blocks如何创建 reliability 的 Block digramsmarkov model如何根据系统来构建马尔科夫计算模型software reliability growthbasic execution time model观察 failure操作概要(operational profiles)Time理解 reliablity …

【JavaSE】基础笔记 - 类和对象(上)

目录 1、面向对象的初步认知 1.1、什么是面向对象 1.2、面向对象与面向过程 2. 类定义和使用 2.1、简单认识类 2.2、类的定义格式 2.3、自定义类举例说明 2.3.1、定义一个狗类 2.3.2、定义一个学生类 3、类的实例化 3.1、什么是实例化 3.2、类和对象的说明 1、面向…

19、Flink 的Table API 和 SQL 中的内置函数及示例(1)

Flink 系列文章 1、Flink 部署、概念介绍、source、transformation、sink使用示例、四大基石介绍和示例等系列综合文章链接 13、Flink 的table api与sql的基本概念、通用api介绍及入门示例 14、Flink 的table api与sql之数据类型: 内置数据类型以及它们的属性 15、Flink 的ta…

Keep-Alive中通过component多次加载同样的动态组件无法保持状态的解决办法

Keep-Alive中通过component多次加载同样的动态组件无法保持状态的解决办法 Keep-Alive中通过component多次加载同样的动态组件无法保持状态的解决办法 | 软件开发服务商 (yidianhulian.com)https://yidianhulian.com/?p12263 问题描述 项目功能上有需要动态添加组件的需求&…

H5ke9 异步处理

目录 .then()的使用详解 案例一:触小图标变大,移走变回 案例三:页面提交文件,我服务器端接收 上次fetvh就一个参数url,,就是get请求 fetch还可以第二个参数对象,可以指定method:改为POST 请求头header :发送txt,servlet,json给客户端,,异步请求图片 1都是客户端传到服务器端…

高数笔记06:无穷级数

图源&#xff1a;文心一言 时间比较紧张&#xff0c;仅导图~~&#x1f95d;&#x1f95d; 第1版&#xff1a;查资料、画导图~&#x1f9e9;&#x1f9e9; 参考资料&#xff1a;《高等数学 基础篇》武忠祥 &#x1f433;目录 &#x1f433;常数项级数 &#x1f40b;概要 &…
最新文章