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

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 {@Overridepublic void receiveData() {// 接收数据的具体实现}@Overridepublic void sendData() {// 发送数据的具体实现}
}
public class BSystemDataProcessingStrategy implements DataProcessingStrategy {@Overridepublic void receiveData() {// 接收数据的具体实现}@Overridepublic 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 {@Overridepublic void sendData(String data) {// 发送数据到系统A的实现}@Overridepublic String receiveData() {// 从系统A接收数据的实现}
}public class BSystemDataProcessingStrategy implements DataProcessingStrategy {@Overridepublic void sendData(String data) {// 发送数据到系统B的实现}@Overridepublic 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.mzph.cn/news/132836.shtml

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

相关文章

函数调用指令, 返回机制分析(x86_64)

预备 #include <stdio.h>int addDetail(int a, int b) {return a b; }int add(int a, int b) {int c;c addDetail(a, b);return c; }int main(int argc, char *argv[]) {int sum;sum add(3, 5);printf("sum %d\n", sum);return 0; }汇编 main add addDeta…

ZZ038 物联网应用与服务赛题第J套

2023年全国职业院校技能大赛 中职组 物联网应用与服务 任 务 书 &#xff08;J卷&#xff09; 赛位号&#xff1a;______________ 竞赛须知 一、注意事项 1.检查硬件设备、电脑设备是否正常。检查竞赛所需的各项设备、软件和竞赛材料等&#xff1b; 2.竞赛任务中所使用…

FreeRTOS_任务通知

目录 1. 任务通知简介 2. 发送任务通知 2.1 函数 xTaskNotify() 2.2 函数 xTaskNotifyFromISR() 2.3 函数 xTaskNotifyGive() 2.4 函数 vTaskNotifyGiveFromISR() 2.5 函数 xTaskNotifyAndQuery() 2.6 函数 xTaskNotifyAndQueryFromISR() 3. 任务通知通用发送函数 3.…

【NI-DAQmx入门】NI-DAQmx之C、C++、VB、VB.net与C#支持

DAQmx应用程序编程接口(API) DAQmx附带数据采集编程所需的API。DAQmx API只是一组库&#xff0c;其中包含关于如何执行所有数据采集操作的函数。这些API支持LabWindows/CVI、C、C、Visual Basic 6.0、VB.NET和C#。 DAQmx API随DAQmx驱动程序一起安装&#xff0c;包含以下参考…

Lambda 架构 vs Kappa 架构

大数据处理架构详解&#xff1a;Lambda架构、Kappa架构、流批一体、Dataflow模型、实时数仓 https://www.cnblogs.com/robots2/p/17769376.html 大数据架构设计&#xff08;四十五&#xff09; - 知乎 浅析Lambda架构 - 简书 Lambda 架构 vs Kappa 架构 Lambda架构和Kappa架…

基于 golang 从零到一实现时间轮算法 (二)

Go实现单机版时间轮 上一章介绍了时间轮的相关概念&#xff0c;接下来我们会使用 golang 标准库的定时器工具 time ticker 结合环状数组的设计思路&#xff0c;实现一个单机版的单级时间轮。 首先我们先运行一下下面的源码&#xff0c;看一下如何使用。 https://github.com/x…

【Python语言速回顾】——爬虫基础知识

目录 一、爬虫概述 1、准备工作 2、爬虫类型 3、爬虫原理 二、爬虫三大库 1、Requests库 2、BeautifulSoup库 3、Lxml库 一、爬虫概述 爬虫又称网络机器人&#xff0c;可以代替人工从互联网中采集、整理数据。常见的网络爬虫主要有百度公司的Baiduspider、360公司的36…

自动驾驶算法(七):基于遗传算法的路径规划(下)

目录 1 遗传选择 2 遗传交叉 3 遗传变异 4 结语 1 遗传选择 我们书接上回&#xff0c;我们完成了种群的初始化&#xff0c;将所有的种群放入了new_pop1中&#xff0c;这个new_pop1是一个&#xff08;种群大小 * 路径&#xff09;的一个矩阵&#xff0c;我们来看如何进行遗传…

Java面向对象(进阶)-- super关键字的使用与子类对象实例化全过程

文章目录 一、super关键字的使用&#xff08;1&#xff09;为什么需要super&#xff1f;&#xff08;2&#xff09;super的理解&#xff08;3&#xff09;super可以调用的结构1、super调用方法举例1举例2举例3小结 2、super调用属性举例1举例2举例3小结 3、super调用构造器引入…

el-tree中展示项换行展示

文章目录 效果如下所示&#xff1a;没有换行展示的效果修改样式换行之后的展示效果 想要了解el-tree使用的详情往下看代码和数据如下所示Vue代码中可能使用到的数据如下Vue的代码如下&#xff1a;没有换行展示的效果换行之后的展示效果样式调试 效果如下所示&#xff1a; 没有…

数据库的备份和恢复

备份&#xff1a;完全备份&#xff0c;增量备份 完全备份&#xff1a;将整个数据库完整的进行备份 增量备份&#xff1a;在完全备份基础的之上&#xff0c;对后续新增的内容进行备份 备份的需求 1生产环境中&#xff0c;数据的安全性至关重要&#xff0c;任何数据都可能产生非…

【计算机架构】程序指令计数 | 功耗计算 | 电力功耗 | 安德尔定律(Amdahl‘s Law)

0x00 程序的指令计数 程序的指令计数&#xff08;Instruction Count&#xff09;由程序本身、ISA&#xff08;指令集架构&#xff09;和编译器决定。这表示一个程序中包含的指令数量受到程序编写方式、计算机体系结构和编译器的影响。 每条指令的平均周期数&#xff08;Averag…

人体姿态估计和手部姿态估计任务中神经网络的选择

一、人体姿态估计任务适合使用卷积神经网络&#xff08;CNN&#xff09;来解决。 人体姿态估计任务的目标是从给定的图像或视频中推断出人体的关节位置和姿势。这是一个具有挑战性的计算机视觉任务&#xff0c;而CNN在处理图像数据方面表现出色。 使用CNN进行人体姿态估计的一种…

Uniapp 中,能够同时兼容H5、web、app、微信小程序的引入高德地图的语法格式

在 Uniapp 中&#xff0c;可以通过使用 uni-app 统一的 API 来同时兼容 H5、web、App 和微信小程序&#xff0c;而引入高德地图则有以下两种语法格式供选择&#xff1a; 使用 Vue.js 的语法格式&#xff1a; <template><view><map :longitude"longitude&…

在云上jupylab(codelab)常用的shell命令

1、切换当前文件目录位置&#xff1a; %cd /project/train/ 2、删除目标文件夹和文件夹下面的内容&#xff0c;注意这个r是不能少的&#xff1a; !rm -r /project/train/src_repo/dataset 3、创建数据集相关文件夹 !mkdir /project/train/src_repo/dataset 4、复制指定…

想学计算机编程从什么学起?零基础如何自学计算机编程?中文编程开发语言工具箱之渐变标签组构件

想学计算机编程从什么学起&#xff1f;零基础如何自学计算机编程&#xff1f; 给大家分享一款中文编程工具&#xff0c;零基础轻松学编程&#xff0c;不需英语基础&#xff0c;编程工具可下载。 这款工具不但可以连接部分硬件&#xff0c;而且可以开发大型的软件&#xff0c;…

LeetCode 0318. 最大单词长度乘积

【LetMeFly】318.最大单词长度乘积 力扣题目链接&#xff1a;https://leetcode.cn/problems/maximum-product-of-word-lengths/ 给你一个字符串数组 words &#xff0c;找出并返回 length(words[i]) * length(words[j]) 的最大值&#xff0c;并且这两个单词不含有公共字母。如…

FastDFS整合nginx

从您提供的步骤来看&#xff0c;FastDFS整合nginx的过程包括准备工作、安装FastDFS的nginx模块、配置nginx以及启动nginx服务。接下来我将基于您提供的信息对步骤进行修改和补充&#xff0c;以确保更加清晰易懂。 1. 安装前配置fastdfs-nginx-module 1.1 上传并解压fastdfs-n…

数据结构实验二停车场

内容仅供个人复习 *设停车场内只有一个的停放 n 辆汽车的狭长通道&#xff0c;且只有一个大门可供汽车进出。汽车 在停车场内按车辆到达时间的先后顺序&#xff0c;依次由北向南排列&#xff08;大门在最南端&#xff0c;最先到达的第 一辆车停放在车场的最北端&#xff09;&am…

linux硬盘挂载(linux 修改某个磁盘挂载到新目录\lvm扩容)

文章目录 一、什么是硬盘挂载二、linux 修改某个磁盘挂载到新目录三、Esxi下扩容硬盘1. 判断一个已有的文件系统是否使用了LVM(逻辑卷管理)2. 原本文件系统没有使用lvm&#xff0c;还可以lvm扩容吗&#xff1f;3. 原有文件系统使用lvm场景下扩容(lvm扩容)了解LVMEsxi LVM扩容步…