重学 Java 设计模式:实战适配器模式

一、前言

擦屁屁纸80%的面积都是保护手的!

工作到3年左右很大一部分程序员都想提升自己的技术栈,开始尝试去阅读一些源码,例如SpringMybaitsDubbo等,但读着读着发现越来越难懂,一会从这过来一会跑到那去。甚至怀疑自己技术太差,慢慢也就不愿意再触碰这部分知识。

而这主要的原因是一个框架随着时间的发展,它的复杂程度是越来越高的,从最开始只有一个非常核心的点到最后开枝散叶。这就像你自己开发的业务代码或者某个组件一样,最开始的那部分核心代码也许只能占到20%,而其他大部分代码都是为了保证核心流程能正常运行的。所以这也是你读源码费劲的一部分原因。

框架中用到了设计模式吗?

框架中不仅用到设计模式还用了很多,而且有些时候根本不是一个模式的单独使用,而是多种设计模式的综合运用。与大部分小伙伴平时开发的CRUD可就不一样了,如果都是if语句从上到下,也就算得不上什么框架了。就像你到Spring的源码中搜关键字Adapter,就会出现很多实现类,例如;UserCredentialsDataSourceAdapter。而这种设计模式就是我们本文要介绍的适配器模式。

适配器在生活里随处可见

如果提到在日常生活中就很多适配器的存在你会想到什么?在没有看后文之前可以先思考下。

二、开发环境

  1. JDK 1.8
  2. Idea + Maven
  3. 涉及工程三个,可以通过关注公众号bugstack虫洞栈,回复源码下载获取(打开获取的链接,找到序号18)
工程 描述
itstack-demo-design-6-00 场景模拟工程;模拟多个MQ消息体
itstack-demo-design-6-01 使用一坨代码实现业务需求
itstack-demo-design-6-02 通过设计模式优化改造代码,产生对比性从而学习

三、适配器模式介绍

适配器模式的主要作用就是把原本不兼容的接口,通过适配修改做到统一。使得用户方便使用,就像我们提到的万能充、数据线、MAC笔记本的转换头、出国旅游买个插座等等,他们都是为了适配各种不同的,做的兼容。。

除了我们生活中出现的各种适配的场景,那么在业务开发中呢?

在业务开发中我们会经常的需要做不同接口的兼容,尤其是中台服务,中台需要把各个业务线的各种类型服务做统一包装,再对外提供接口进行使用。而这在我们平常的开发中也是非常常见的。

四、案例场景模拟

随着公司的业务的不断发展,当基础的系统逐步成型以后。业务运营就需要开始做用户的拉新和促活,从而保障DAU的增速以及最终ROI转换。

而这时候就会需要做一些营销系统,大部分常见的都是裂变、拉客,例如;你邀请一个用户开户、或者邀请一个用户下单,那么平台就会给你返利,多邀多得。同时随着拉新的量越来越多开始设置每月下单都会给首单奖励,等等,各种营销场景。

那么这个时候做这样一个系统就会接收各种各样的MQ消息或者接口,如果一个个的去开发,就会耗费很大的成本,同时对于后期的拓展也有一定的难度。此时就会希望有一个系统可以配置一下就把外部的MQ接入进行,这些MQ就像上面提到的可能是一些注册开户消息、商品下单消息等等。

而适配器的思想方式也恰恰可以运用到这里,并且我想强调一下,适配器不只是可以适配接口往往还可以适配一些属性信息。

1. 场景模拟工程

itstack-demo-design-6-00
└── src└── main└── java└── org.itstack.demo.design├── mq│   ├── create_account.java│   ├── OrderMq.java│   └── POPOrderDelivered.java└── service├── OrderServicejava└── POPOrderService.java
  • 这里模拟了三个不同类型的MQ消息,而在消息体中都有一些必要的字段,比如;用户ID、时间、业务ID,但是每个MQ的字段属性并不一样。就像用户ID在不同的MQ里也有不同的字段:uId、userId等。
  • 同时还提供了两个不同类型的接口,一个用于查询内部订单订单下单数量,一个用于查询第三方是否首单。
  • 后面会把这些不同类型的MQ和接口做适配兼容。

2. 场景简述

1.1 注册开户MQ

public class create_account {private String number;      // 开户编号private String address;     // 开户地private Date accountDate;   // 开户时间private String desc;        // 开户描述// ... get/set
}

1.2 内部订单MQ

public class OrderMq {private String uid;           // 用户IDprivate String sku;           // 商品private String orderId;       // 订单IDprivate Date createOrderTime; // 下单时间     // ... get/set
}

1.3 第三方订单MQ

public class POPOrderDelivered {private String uId;     // 用户IDprivate String orderId; // 订单号private Date orderTime; // 下单时间private Date sku;       // 商品private Date skuName;   // 商品名称private BigDecimal decimal; // 金额// ... get/set
}

1.4 查询用户内部下单数量接口

public class OrderService {private Logger logger = LoggerFactory.getLogger(POPOrderService.class);public long queryUserOrderCount(String userId){logger.info("自营商家,查询用户的订单是否为首单:{}", userId);return 10L;}}

1.5 查询用户第三方下单首单接口

public class POPOrderService {private Logger logger = LoggerFactory.getLogger(POPOrderService.class);public boolean isFirstOrder(String uId) {logger.info("POP商家,查询用户的订单是否为首单:{}", uId);return true;}}
  • 以上这几项就是不同的MQ以及不同的接口的一个体现,后面我们将使用这样的MQ消息和接口,给它们做相应的适配。

五、用一坨坨代码实现

其实大部分时候接MQ消息都是创建一个类用于消费,通过转换他的MQ消息属性给自己的方法。

我们接下来也是先体现一下这种方式的实现模拟,但是这样的实现有一个很大的问题就是,当MQ消息越来越多后,甚至几十几百以后,你作为中台要怎么优化呢?

1. 工程结构

itstack-demo-design-6-01
└── src└── main└── java└── org.itstack.demo.design└── create_accountMqService.java└── OrderMqService.java└── POPOrderDeliveredService.java
  • 目前需要接收三个MQ消息,所有就有了三个对应的类,和我们平时的代码几乎一样。如果你的MQ量不多,这样的写法也没什么问题,但是随着数量的增加,就需要考虑用一些设计模式来解决。

2. Mq接收消息实现

public class create_accountMqService {public void onMessage(String message) {create_account mq = JSON.parseObject(message, create_account.class);mq.getNumber();mq.getAccountDate();// ... 处理自己的业务}}
  • 三组MQ的消息都是一样模拟使用,就不一一展示了。可以获取源码后学习。

六、适配器模式重构代码

接下来使用适配器模式来进行代码优化,也算是一次很小的重构。

适配器模式要解决的主要问题就是多种差异化类型的接口做统一输出,这在我们学习工厂方法模式中也有所提到不同种类的奖品处理,其实那也是适配器的应用。

在本文中我们还会再另外体现出一个多种MQ接收,使用MQ的场景。来把不同类型的消息做统一的处理,便于减少后续对MQ接收。

在这里如果你之前没要开发过接收MQ消息,可能听上去会有些不理解这样的场景。对此,我个人建议先了解下MQ。另外就算不了解也没关系,不会影响对思路的体会。

再者,本文所展示的MQ兼容的核心部分,也就是处理适配不同的类型字段。而如果我们接收MQ后,在配置不同的消费类时,如果不希望一个个开发类,那么可以使用代理类的方式进行处理。

1. 工程结构

itstack-demo-design-6-02
└── src└── main└── java└── org.itstack.demo.design├── impl│   ├── InsideOrderService.java│   └── POPOrderAdapterServiceImpl.java├── MQAdapter,java├── OrderAdapterService,java└── RebateInfo,java

适配器模型结构

  • 这里包括了两个类型的适配;接口适配、MQ适配。之所以不只是模拟接口适配,因为很多时候大家都很常见了,所以把适配的思想换一下到MQ消息体上,增加大家多设计模式的认知。
  • 先是做MQ适配,接收各种各样的MQ消息。当业务发展的很快,需要对下单用户首单才给奖励,在这样的场景下再增加对接口的适配操作。

2. 代码实现(MQ消息适配)

2.1 统一的MQ消息体

public class RebateInfo {private String userId;  // 用户IDprivate String bizId;   // 业务IDprivate Date bizTime;   // 业务时间private String desc;    // 业务描述// ... get/set
}
  • MQ消息中会有多种多样的类型属性,虽然他们都有同样的值提供给使用方,但是如果都这样接入那么当MQ消息特别多时候就会很麻烦。
  • 所以在这个案例中我们定义了通用的MQ消息体,后续把所有接入进来的消息进行统一的处理。

2.2 MQ消息体适配类

public class MQAdapter {public static RebateInfo filter(String strJson, Map<String, String> link) throws NoSuchMethodException, InvocationTargetException, IllegalAccessException {return filter(JSON.parseObject(strJson, Map.class), link);}public static RebateInfo filter(Map obj, Map<String, String> link) throws NoSuchMethodException, InvocationTargetException, IllegalAccessException {RebateInfo rebateInfo = new RebateInfo();for (String key : link.keySet()) {Object val = obj.get(link.get(key));RebateInfo.class.getMethod("set" + key.substring(0, 1).toUpperCase() + key.substring(1), String.class).invoke(rebateInfo, val.toString());}return rebateInfo;}}
  • 这个类里的方法非常重要,主要用于把不同类型MQ种的各种属性,映射成我们需要的属性并返回。就像一个属性中有用户ID;uId,映射到我们需要的;userId,做统一处理。
  • 而在这个处理过程中需要把映射管理传递给Map<String, String> link,也就是准确的描述了,当前MQ中某个属性名称,映射为我们的某个属性名称。
  • 最终因为我们接收到的mq消息基本都是json格式,可以转换为MAP结构。最后使用反射调用的方式给我们的类型赋值。

2.3 测试适配类

2.3.1 编写单元测试类

@Test
public void test_MQAdapter() throws NoSuchMethodException, IllegalAccessException, InvocationTargetException {create_account create_account = new create_account();create_account.setNumber("100001");create_account.setAddress("河北省.廊坊市.广阳区.大学里职业技术学院");create_account.setAccountDate(new Date());create_account.setDesc("在校开户");          HashMap<String, String> link01 = new HashMap<String, String>();link01.put("userId", "number");link01.put("bizId", "number");link01.put("bizTime", "accountDate");link01.put("desc", "desc");RebateInfo rebateInfo01 = MQAdapter.filter(create_account.toString(), link01);System.out.println("mq.create_account(适配前)" + create_account.toString());System.out.println("mq.create_account(适配后)" + JSON.toJSONString(rebateInfo01));System.out.println("");OrderMq orderMq = new OrderMq();orderMq.setUid("100001");orderMq.setSku("10928092093111123");orderMq.setOrderId("100000890193847111");orderMq.setCreateOrderTime(new Date()); HashMap<String, String> link02 = new HashMap<String, String>();link02.put("userId", "uid");link02.put("bizId", "orderId");link02.put("bizTime", "createOrderTime");RebateInfo rebateInfo02 = MQAdapter.filter(orderMq.toString(), link02);System.out.println("mq.orderMq(适配前)" + orderMq.toString());System.out.println("mq.orderMq(适配后)" + JSON.toJSONString(rebateInfo02));
}
  • 在这里我们分别模拟传入了两个不同的MQ消息,并设置字段的映射关系。
  • 等真的业务场景开发中,就可以配这种映射配置关系交给配置文件或者数据库后台配置,减少编码。

2.3.2 测试结果

mq.create_account(适配前){"accountDate":1591024816000,"address":"河北省.廊坊市.广阳区.大学里职业技术学院","desc":"在校开户","number":"100001"}
mq.create_account(适配后){"bizId":"100001","bizTime":1591077840669,"desc":"在校开户","userId":"100001"}mq.orderMq(适配前){"createOrderTime":1591024816000,"orderId":"100000890193847111","sku":"10928092093111123","uid":"100001"}
mq.orderMq(适配后){"bizId":"100000890193847111","bizTime":1591077840669,"userId":"100001"}Process finished with exit code 0
  • 从上面可以看到,同样的字段值在做了适配前后分别有统一的字段属性,进行处理。这样业务开发中也就非常简单了。
  • 另外有一个非常重要的地方,在实际业务开发中,除了反射的使用外,还可以加入代理类把映射的配置交给它。这样就可以不需要每一个mq都手动创建类了。

3. 代码实现(接口使用适配)

就像我们前面提到随着业务的发展,营销活动本身要修改,不能只是接了MQ就发奖励。因为此时已经拉新的越来越多了,需要做一些限制。

因为增加了只有首单用户才给奖励,也就是你一年或者新人或者一个月的第一单才给你奖励,而不是你之前每一次下单都给奖励。

那么就需要对此种方式进行限制,而此时MQ中并没有判断首单的属性。只能通过接口进行查询,而拿到的接口如下;

接口 描述
org.itstack.demo.design.service.OrderService.queryUserOrderCount(String userId) 出参long,查询订单数量
org.itstack.demo.design.service.OrderService.POPOrderService.isFirstOrder(String uId) 出参boolean,判断是否首单
  • 两个接口的判断逻辑和使用方式都不同,不同的接口提供方,也有不同的出参。一个是直接判断是否首单,另外一个需要根据订单数量判断。
  • 因此这里需要使用到适配器的模式来实现,当然如果你去编写if语句也是可以实现的,但是我们经常会提到这样的代码很难维护。

3.1 定义统一适配接口

public interface OrderAdapterService {boolean isFirst(String uId);}
  • 后面的实现类都需要完成此接口,并把具体的逻辑包装到指定的类中,满足单一职责。

3.2 分别实现两个不同的接口

内部商品接口

public class InsideOrderService implements OrderAdapterService {private OrderService orderService = new OrderService();public boolean isFirst(String uId) {return orderService.queryUserOrderCount(uId) <= 1;}}

第三方商品接口

public class POPOrderAdapterServiceImpl implements OrderAdapterService {private POPOrderService popOrderService = new POPOrderService();public boolean isFirst(String uId) {return popOrderService.isFirstOrder(uId);}}
  • 在这两个接口中都实现了各自的判断方式,尤其像是提供订单数量的接口,需要自己判断当前接到mq时订单数量是否<= 1,以此判断是否为首单。

3.3 测试适配类

3.3.1 编写单元测试类

@Test
public void test_itfAdapter() {OrderAdapterService popOrderAdapterService = new POPOrderAdapterServiceImpl();System.out.println("判断首单,接口适配(POP):" + popOrderAdapterService.isFirst("100001"));   OrderAdapterService insideOrderService = new InsideOrderService();System.out.println("判断首单,接口适配(自营):" + insideOrderService.isFirst("100001"));
}

3.3.2 测试结果

23:25:47.076 [main] INFO  o.i.d.design.service.POPOrderService - POP商家,查询用户的订单是否为首单:100001
判断首单,接口适配(POP):true
23:25:47.079 [main] INFO  o.i.d.design.service.POPOrderService - 自营商家,查询用户的订单是否为首单:100001
判断首单,接口适配(自营):falseProcess finished with exit code 0
  • 从测试结果上来看,此时已经的接口已经做了统一的包装,外部使用时候就不需要关心内部的具体逻辑了。而且在调用的时候只需要传入统一的参数即可,这样就满足了适配的作用。

七、总结

  • 从上文可以看到不使用适配器模式这些功能同样可以实现,但是使用了适配器模式就可以让代码:干净整洁易于维护、减少大量重复的判断和使用、让代码更加易于维护和拓展。
  • 尤其是我们对MQ这样的多种消息体中不同属性同类的值,进行适配再加上代理类,就可以使用简单的配置方式接入对方提供的MQ消息,而不需要大量重复的开发。非常利于拓展。
  • 设计模式的学习学习过程可能会在一些章节中涉及到其他设计模式的体现,只不过不会重点讲解,避免喧宾夺主。但在实际的使用中,往往很多设计模式是综合使用的,并不会单一出现。

八、推荐阅读

  • 1. 重学 Java 设计模式:实战工厂方法模式(多种类型商品发奖场景)
  • 2. 重学 Java 设计模式:实战抽象工厂模式(替换Redis双集群升级场景)
  • 3. 重学 Java 设计模式:实战建造者模式(装修物料组合套餐选配场景)
  • 4. 重学 Java 设计模式:实战原型模式(多套试每人题目和答案乱序场景)
  • 5. 重学 Java 设计模式:实战单例模式(Effective Java 作者推荐枚举单例模式)

重学 Java 设计模式:实战适配器模式相关推荐

  1. 《重学 Java 设计模式》PDF 出炉了 - 小傅哥,肝了50天写出18万字271页的实战编程资料...

    持续坚持原创输出,点击蓝字关注我吧 作者:小傅哥 博客:https://bugstack.cn ❝ 沉淀.分享.成长,让自己和他人都能有所收获!???? ❞ 目录 一.前言 二.简介 1. 谁发明了设 ...

  2. 重学Java设计模式-创建者模式-工厂方法模式

    重学Java设计模式-创建者模式-工厂方法模式 内容摘自:重学 Java 设计模式:实战工厂方法模式「多种类型商品不同接口,统一发奖服务搭建场景」 | bugstack 虫洞栈 工厂方法模式介绍 图片 ...

  3. 重学Java设计模式-创建者模式-建造者模式

    重学Java设计模式-创建者模式-建造者模式 内容摘自:重学 Java 设计模式:实战建造者模式「各项装修物料组合套餐选配场景」 | bugstack 虫洞栈 建造者模式介绍 图片来自:https:/ ...

  4. 重学 Java 设计模式:实战适配器模式「从多个MQ消息体中,抽取指定字段值场景」

    作者:小傅哥 博客:https://bugstack.cn 沉淀.分享.成长,让自己和他人都能有所收获!

  5. java 观察者模式_重学 Java 设计模式:实战观察者模式「模拟类似小客车指标摇号过程,监听消息通知用户中签场景」...

    一.前言 知道的越多不知道的就越多 编程开发这条路上的知识是无穷无尽的,就像以前你敢说精通Java,到后来学到越来越多只想写了解Java,过了几年现在可能想说懂一点点Java.当视野和格局的扩大,会让 ...

  6. 重学 Java 设计模式:实战组合模式(营销差异化人群发券,决策树引擎搭建场景)

    一.前言 小朋友才做选择题,成年人我都要 头几年只要群里一问我该学哪个开发语言,哪个语言最好.群里肯定聊的特别火热,有人支持PHP.有人喊号Java.也有C++和C#.但这几年开始好像大家并不会真的刀 ...

  7. 重学 Java 设计模式:实战访问者模式「模拟家长与校长,对学生和老师的不同视角信息的访问场景」

    作者:小傅哥 博客:https://bugstack.cn - 原创系列专题文章 沉淀.分享.成长,让自己和他人都能有所收获!

  8. 学区摇号软件设计_重学 Java 设计模式:实战观察者模式「模拟类似小客车指标摇号过程,监听消息通知用户中签场景」...

    作者:小傅哥 博客:https://bugstack.cn - 原创系列专题文章 沉淀.分享.成长,让自己和他人都能有所收获!

  9. 重学 Java 设计模式:实战模版模式「模拟爬虫各类电商商品,生成营销推广海报场景」

    作者:小傅哥 博客:https://bugstack.cn - 原创系列专题文章 沉淀.分享.成长,让自己和他人都能有所收获!

最新文章

  1. 百度腾讯齐刷刷强调“产业+AI”,李彦宏看深,马化腾见远
  2. mysql常用命令行操作(二):表和库的操作、引擎、聚合函数
  3. python五十四:isinstance和issubclass
  4. 2020年 | 云计算发展的5大趋势
  5. 密码技术--对称加密算法及Go语言应用
  6. 医院病案档案管理系统php_医疗产品经理必懂:医院业务流程及系统
  7. PS网页设计教程XXIX——如何在PS中设计一个画廊布局
  8. centos安装virtualbox
  9. 精通android学习笔记(一)---广播
  10. HTML(一):HTML基本元素标签
  11. jQuery学习笔记(边学边记版本)
  12. Junit单元测试的基本编码步骤
  13. fc安卓模拟器_跨平台游戏模拟器RetroArch,一个软件畅玩FC 、MD、SFC、GBA游戏
  14. SQL 删除数据空格(Trim、RTrim、LTrim函数)
  15. win7台式计算机型号怎么查,win7系统电脑查看主板型号的四种方法
  16. 湖南工程学院CSDN高校俱乐部简介
  17. 基于java的幼儿园早教网站
  18. 跟我20天学Java:01-计算机基础以及JDK、IDEA等安装详解
  19. WIN32,GetBitmapBits与GetPixel
  20. 学生宿舍管理mysql设计_学生宿舍管理系统设计与实现(SSH,MySQL)

热门文章

  1. 用命令清理计算机,快速清理电脑垃圾用什么命令
  2. 宝宝专业智力测试软件,0-3岁6个月婴幼儿智能综合格塞尔Gesell智力测试工具包及软件...
  3. python五子棋游戏_python小项目之五子棋游戏
  4. 计算机内部是如何表示数字和文字的呢?
  5. 交通事故责任认定标准怎么确定
  6. 关于洗牌的研究(五)——从数学到魔术之印度洗牌
  7. 看Java、C#大比拚
  8. Google Earth Engine(GEE)——自定义图标样式ui.chart(内附详细的图表格式修改方式)
  9. 从地球出发,到宇宙边缘
  10. 谷歌浏览器卸载后点击安装程序没反应