⭐⭐⭐ Spring Boot 项目实战 ⭐⭐⭐ Spring Cloud 项目实战
《Dubbo 实现原理与源码解析 —— 精品合集》 《Netty 实现原理与源码解析 —— 精品合集》
《Spring 实现原理与源码解析 —— 精品合集》 《MyBatis 实现原理与源码解析 —— 精品合集》
《Spring MVC 实现原理与源码解析 —— 精品合集》 《数据库实体设计合集》
《Spring Boot 实现原理与源码解析 —— 精品合集》 《Java 面试题 + Java 学习指南》

摘要: 原创出处 juejin.cn/post/7276261829726191676 「Lxlxxx」欢迎转载,保留摘要,谢谢!


🙂🙂🙂关注微信公众号:【芋道源码】有福利:

  1. RocketMQ / MyCAT / Sharding-JDBC 所有源码分析文章列表
  2. RocketMQ / MyCAT / Sharding-JDBC 中文注释源码 GitHub 地址
  3. 您对于源码的疑问每条留言都将得到认真回复。甚至不知道如何读源码也可以请教噢。
  4. 新的源码解析文章实时收到通知。每周更新一篇左右。
  5. 认真的源码交流微信群。

一、耦合问题

有些时候我们在进行接口调用的时候,比如说一个 push 推送接口,有可能会涉及到不同渠道的推送。以我目前业务场景为例,我做结算后端服务的,会与金蝶财务系统进行交互,那么我结算后端会涉及到多个结算单类型,如果每一个种类型的结算单都去暴露一个 contoller 接口给前端提供,而且其实对接第三方的接口,有些接口是共通的。

前端涉及到的问题

  • 需要调用后端多个 controller,不同接口传不同的参数,如果遇到后端接口修改,会涉及到多个页面的修改,耦合度很高;
  • 需要对多个按钮设置权限配置。

后端涉及到的问题

  • 需要每个业务接口,都去写一个对接第三方接口的 push 推送方法,无形中增加很多重复的代码,耦合度也很高;
  • 如果涉及到第三方服务接口改造,后端接口也需要进行更改,会修改大量代码。

二、如何解决

  1. 创建对接第三方服务的微服务,暂定为 tps 服务,该服务只作为一个后端微服务,与第三方服务进行对接,并且合理封装调用参数,将公共参数提出进行封装;
  2. 后端其余业务系统对接这个独立的微服务,比如订单、结算、供应商系统对接这个服务,由 tps 服务统一提供对接接口,其余服务实现这个 tps 提供的 feign 接口;
  3. 业务系统只需要关注 service 层业务的实现,无需处理对接的业务逻辑。

大致的流程图就是这样的:

三、具体实现

Tps 服务

Tps 服务暴露为 feign 接口,前端统一通过 Tps 提供的接口进行调用。

//对接第三方服务接口
public interface IKingdeeManagementService {
Boolean push(KingdeePushCO.Request request);
}

Feign 接口实现类:

@Slf4j
@Service
public class KingdeeManagementServiceImpl implements IKingdeeManagementService {

@Autowired
private ApplicationContext applicationContext;
@Autowired
private KingdeeThirdSettingService kingdeeThirdSettingService;

@Override
public Boolean push(KingdeePushCO.Request request) {

KingdeeBusinessPushServiceEnum kingdeePushServiceEnum = KingdeeBusinessPushServiceEnum.getKingdeePushServiceEnumByType(request.getBusinessType());

IKingdeeBusinessPushService kingdeePushService = null;
try {
kingdeePushService = (IKingdeeBusinessPushService) applicationContext.getBean(kingdeePushServiceEnum.getClazz());
} catch (BeansException e) {
log.error("当前类型暂未实现,请联系开发");
throw new ServiceException("当前类型暂未实现,请联系开发");
}
R<Boolean> result = null;
result = kingdeePushService.pushKingdee(request);


return true;
}
}

枚举类定义:

public enum KingdeeBusinessPushServiceEnum {

private Class clazz;

private Integer type;

private String interFaceName;

KingdeeBusinessPushServiceEnum(Class clazz, Integer type, String interFaceName) {
this.clazz = clazz;
this.type = type;
this.interFaceName = interFaceName;
}
RECEIPT_VOUCHER(IJaKingdeeBillClient.class, KingdeeBusinessTypeConstant.RECEIPT_VOUCHER, KingdeeSettingEnum.INTERFACE_TYPE_JA_RECEIPT_VOUCHER.getCode()), ;
}

分别有 clazz、type、interFaceName 属性,

  • clazz 定义为 feign 接口,业务系统提供的服务接口;
  • type 代表前端需要传的参数,不同的 Integer 值代表不同的 feign 接口映射;
  • interFaceName 第三方接口枚举,表示需要具体调用哪个第三方接口。

业务系统

拿 bms 服务举例说明:继承 Tps 服务的 feign 接口,重写 push 方法;

Feign 接口实现,通过 factory 工厂类初始化,不同的 service 实现类;

JaKingdeeFactoryUtil 工厂工具类,获取工厂实例,这里其实也可以使用枚举映射,避免以后接口太多,需要写很多 case when。

JaKingdeeServiceFactory 是个接口,提供方法:

实现上面的接口,通过单例工厂的模式 double check 的模式实现,并且加悲观锁,避免一个工作线程多次创建工厂实例,SpringContextUtils/getBean/ 获取 servcie 实例,业务层只需要实现 service 接口,实现不同业务逻辑的 push 推送方法。

四、总结

这是我之前设计的关于接口统一调用的流程,当然其实还是包括对接第三方重复调用的问题、调用结果缓存、调用超时解决、失败降级的一些策略,作为抛砖引玉。

文章目录
  1. 1. 一、耦合问题
    1. 1.0.0.1. 前端涉及到的问题
    2. 1.0.0.2. 后端涉及到的问题
  • 2. 二、如何解决
  • 3. 三、具体实现
    1. 3.0.0.1. Tps 服务
    2. 3.0.0.2. 业务系统
  • 4. 四、总结