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

news2024/11/26 8:34:14

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.coloradmin.cn/o/1170715.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

uniapp原生插件之安卓文字转拼音原生插件

插件介绍 安卓文字转拼音插件&#xff0c;支持转换为声调模式和非声调模式&#xff0c;支持繁体和简体互相转换 插件地址 安卓文字转拼音原生插件 - DCloud 插件市场 超级福利 uniapp 插件购买超级福利 详细使用文档 uniapp 安卓文字转拼音原生插件 用法 在需要使用插…

新兴初创企业参展招募

一般来说&#xff0c;创业公司的生存率较低&#xff0c;失败率较高。根据不同的数据来源&#xff0c;创业公司的失败率高达 80%-90%。据统计&#xff0c;在中国每年新注册的企业数量超过 100 万家&#xff0c;但能够存活到 5 年以上的企业不足 7%&#xff0c;10 年以上不足 2%。…

Win10系统下查询WiFi强度信息

netsh wlan show networks modebssid 查询周围所有WiFi 可以获取到信号的强度 netsh wlan show interface查询当前网卡连接的wifi 对应的信号强度 具体见图

Hadoop学习总结(Shell操作)

HDFS Shell 参数 命令参数功能描述-ls查看指定路径的目录结构-du统计目录下所有文件大小-mv移动文件-cp复制文件-rm删除文件 / 空白文件夹-put上传文件-cat查看内容文件-text将源文件输出文本格式-mkdir创建空白文件夹-help帮助 一、ls 命令 ls 命令用于查看指定路径的当前目录…

稳定性测试—fastboot和monkey区别

一、什么是稳定性测试 稳定性测试是指检验程序在一定时间内能否稳定地运行&#xff0c;在不同的场景下能否正常地工作的过程。主要目的是检测崩溃、内存泄漏、堆栈错误等缺陷。 二、Monkey 1.什么是Monkey 是一个命令行工具&#xff0c;通常在adb安卓调试运行&#xff0c;模…

智能化审批:低代码平台助力招聘管理进程

都说流程很重要&#xff0c;确实如此。 企业运营中的内部流程是否高效&#xff0c;很大程度上决定了业务能否获得成功。不过&#xff0c;在各项流程中&#xff0c;还有一个重要“角色”不容忽略——审批&#xff0c;它就像是企业版的“开关按钮”&#xff0c;无论是报销、请假…

spss chi-square test

实验卡方检验_chi-square independence-CSDN博客 VAR01类别

前端难学还是后端难学?系统安全,web安全,网络安全是什么区别?

系统安全&#xff0c;web安全&#xff0c;网络安全是什么区别&#xff1f;三无纬度安全问题 系统安全&#xff0c;可以说是电脑软件的安全问题&#xff0c;比如windows经常提示修复漏洞&#xff0c;是一个安全问题 网页安全&#xff0c;网站安全&#xff0c;比如&#xff0c;…

你知道Python、Pycharm、Anaconda 三者之间的关系吗?

哈喽~大家好呀 Python作为深度学习和人工智能学习的热门语言&#xff0c;你知道Python、Pycharm、Anaconda 三者之间的关系吗&#xff1f;学习一门语言&#xff0c;除了学会其简单的语法之外还需要对其进行运行和实现&#xff0c;才能实现和发挥其功能和作用。下面来介绍运行P…

antv/g6元素之combo

介绍 在 G6 中&#xff0c;“Combo” 是一种特殊的元素&#xff0c;用于组合和展示多个节点元素的一种方式。它通常用于表示一个组或子图&#xff0c;将多个相关节点组织在一起&#xff0c;并在图形中以单一的形状显示。 属性 type&#xff1a;Combo 的类型&#xff0c;通常是…

地理信息系统原理-空间数据结构(7)

​四叉树编码 1.四叉树编码定义 四叉树数据结构是一种对栅格数据的压缩编码方法&#xff0c;其基本思想是将一幅栅格数据层或图像等分为四部分&#xff0c;逐块检查其格网属性值&#xff08;或灰度&#xff09;&#xff1b;如果某个子区的所有格网值都具有相同的值&#xff0…

SOLIDWORKS 2024新功能--SOLIDWORKS Electrical篇

SOLIDWORKS Electrical 对齐零部件 在设计 3D 机柜布局时使用对齐零部件时&#xff0c;可以在图形区域中预览更改。这大大减少了在 3D 机柜布局中对齐 SOLIDWORKS 零部件所需的工作量。对齐零部件 PropertyManager 简化并改进了工作流程。 SOLIDWORKS Electrical 更改多个导…

Java 基础知识:面试官必问的问题

本文重点关注Java编程语言的基础知识&#xff0c;并针对求职面试中常见的问题进行了总结。希望帮助读者准备面试&#xff0c;了解常见的Java基础问题 数据类型 基本类型 byte/8char/16short/16int/32float/32long/64double/64boolean/~ boolean 只有两个值&#xff1a;true、…

海外媒体发稿:如何利用8种出口贸易媒体发稿实现销售突破-华媒舍

出口贸易是许多企业追求业务增长的重要途径。在全球市场上突出自己并吸引潜在客户并非易事。幸运的是&#xff0c;利用出口贸易媒体发稿的机会可以成为推动销售突破的有效策略。本文将介绍8种出口贸易媒体以及如何利用它们发稿推广&#xff0c;从而实现销售突破。 1. 行业媒体…

魔术《4 Kings 折纸》的三重境界(三)——群论描述

早点关注我&#xff0c;精彩不错过&#xff01; 前面两篇讲完了基于奇偶性和集合论基础解释《4 Kings 折纸》的方法&#xff0c;详情请戳&#xff1a; 魔术《4 Kings 折纸》的三重境界&#xff08;二&#xff09;——集合语言和数理逻辑 魔术《4 Kings 折纸》的三重境界&#x…

overleaf里插入中文语句

作业要求是需要插入中文 我直接插入中文生成pdf会报错&#xff1a; 解决办法&#xff1a; overleaf官网里提供了教程&#xff1a;https://www.overleaf.com/learn/latex/Chinese 使用XeLaTeX或者LuaLaTeX进行编译是支持UTF-8编码。所以改变编译器的步骤如下&#xff1a; 点击…

Java web(五):会话技术

文章目录 一、会话跟踪技术二、Cookie三、Session四、Cookie和Session的区别五、项目实战 一、会话跟踪技术 二、Cookie 在JSP页面如何获取Cookie&#xff1f; 方式&#xff1a;${cookie.key.value} //key指存在cookie的键的名称 三、Session Session是基于Cookie实现的&…

安装docker可视化工具:Portainer

文章目录 前言一、安装Portainer&#xff08;docker可视化工具&#xff09;1.拉镜像2. 启动容器3.查看4.访问 总结 前言 一、安装Portainer&#xff08;docker可视化工具&#xff09; 1.拉镜像 docker pull portainer/portainer2. 启动容器 docker run -d -p 8100:8000 -p 9…

第九周实验记录

1、安装Nerfstudio 环境配置 首先需要创建环境python3.8&#xff0c;接着需要安装cuda11.7或11.3 这里安装cuda11.7 pip uninstall torch torchvision functorchpip install torch1.13.1 torchvision functorch --extra-index-url https://download.pytorch.org/whl/cu117安…

AI:55-基于深度学习的人流量检测

🚀 本文选自专栏:AI领域专栏 从基础到实践,深入了解算法、案例和最新趋势。无论你是初学者还是经验丰富的数据科学家,通过案例和项目实践,掌握核心概念和实用技能。每篇案例都包含代码实例,详细讲解供大家学习。 📌📌📌在这个漫长的过程,中途遇到了不少问题,但是…