1、背景
1.2 业务重组与合并
1.2 解决技术债务
1.3 影响开发效率
1.4 监控体系不够完善
2、重构目标
3、设计
3.1 调研
3.2 规划
3.3 修缮者模式
3.4 领域设计(横向拆分)
3.5 模块设计(纵向拆分)
3.6 代码设计
4、上线过程
5、监控
6、总结
即使我们接手项目已经有一段时间,并对项目足够了解时,但排查问题起来依然费力费时,而且系统内部代码错综复杂,调用链路交错,难以正常维护,从长远的开发效率考虑,尽快提出新型方案来代替现有结构。
线上异常机制不够敏感,缺少关键业务指标的告警看板,作为一个业务开发,应保持对核心指标数据的敏感性。
开始重构之前,调研了互联网消金通用的架构解决方案:
通用方案由于是外部调研的通用架构设计,所以并非完全契合转转消费分期产品,但可以借鉴其分层架构设计的思想,在代码设计阶段,可以先对核心模块进行拆解和规划。
前端页面与后端重构计划分两次迭代进行,分阶段进行,可以有效分摊并降低项目上线风险,第一次迭代围绕后端主要模块进行剥离重新设计并上线;第二次重构目的是解决产品需求,对接前端新页面。
作为一个一线的业务开发,需要开展重构工作的同时还得保证产品需求的正常迭代,修缮者模式无疑是最佳选择。 第一次迭代历程,对于历史工程边缘逻辑保留并隔离,只对核心代码进行重构后转移到到新工程,新工程逐步接手老旧逻辑,并对老工程提供RPC接口,逐渐取代。此方案整体风险最低,同时能兼顾到正常的需求迭代。
第二次迭代历程,经历了第一次迭代后,新系统运行稳定,同时也具备接手新产品的能力,新工程开始与前端对接、联调,在此之后,V2版本也正式上线。
聚合业务:涵盖了消费分期主要业务,根据其各自产品需求特点,作为上层业务代码,对前端、收银台提供聚合接口。
基础服务:用户信贷所产生的数据、或依托合作方数据,围绕金融分期服务提供的数据支持。
三方对接:基于转转标准API下的逻辑实现,同时具备灵活接入合作方接口的能力。
基于以往项目存在的问题,再结合消费分期的特点,我们对分期购买到账单还款结清的整个流程进行拆解:用户主动填写申请信息,提交授信申请并获额,挑选商品分期下单,生成还款计划,提供绑卡、账单还款等功能。以上就是一个简单的分期购物流程,基于以上流程,我们把消费分期所包含的公共模块,如授信前获额、用信、账单还款,这些富有金融服务属性的功能进行剥离。消费分期作为转转的产品原型,在聚合层中各自维护,互不影响。
设计原则:在不改变原有代码逻辑的情况下,根据单一职责和依赖倒置原则的思想:对系统进行模块拆分与合并,以明确项目职责降低耦合度;对包进行重新规划,划分包与包之间的边界,进一步减少代码间的耦合。
好的代码重构一定离不开设计模式,基于原有单一的策略模式,我们把合作方对接模块与基础服务模块进行了拆解,采用双层模板、策略、工厂模式的组合,分别对授信、用信、贷后几个模块单独设计接口,维护好对合作方通用标准API接口,同时具备灵活接入的特点,举个例子,以下为授信模块主要代码类图:
第一层作为基础服务的策略模式;
第二层作为合作方对接的策略模式。
主要类图设计:
在定义接口与实现类后,形成了对合作方对接层依赖,同时对订单、用信、授信等核心数据进行落地,对消费分期提供数据支撑,举个例子,以下为授信模块主要代码:
/**
* 授信接口定义
**/
public interface ICreditService {
/**
* appId,资方定义的一个唯一ID
*/
String getAppId();
/**
* app名称
*
* @return zz or zlj
*/
String getAppName();
/**
* 获取授信结果
*
* @return result
*/
CreditResult creditResult(String logStr, Long uid);
}
/**
* 标准API对接实现
*
**/
public abstract class AbstractCreditService implements ICreditService {
/**
* 标准API对接
*
* @return IBaseApiService
*/
protected abstract IBaseApiService getApiThirdService();
@Override
public AppConfig getPartner() {
return commonConfigUtil.getAppConfig(getAppId());
}
@Override
public CreditResult creditResult(String logStr, Long uid) {
CreditResultInput input = new CreditResultInput();
input.setUid(uid);
ResponseProtocol<CreditResultOutput> output = getApiThirdService().creditResult(logStr, input);
String creditStatus = TransformUtil.approvalStatusTransform(output.getData());
return CreditResult.builder().result(creditStatus).build();
}
}
/**
* 合作方差异化接入
*/
@Service
@Slf4j
public class ZZABCCreditServiceImpl extends AbstractABCCreditService {
@Resource
ZZABCThirdServiceImpl abcThirdService;
@Override
public String getAppId() {
return PartnerEnum.ABC_ZZ_API.getAppId();
}
@Override
public String getAppName() {
return AppNameEnum.ZZ.getValue();
}
@Override
protected IABCThirdService getABCThirdService() {
return abcThirdService;
}
}
/**
* 标准API对接
*
* @author Rouse
* @date 2022/4/24 13:57
*/
public interface IBaseApiService {
/**
* 标准API,获取appId
*
* @return appId
*/
String getAppId();
/**
* 获取授信结果
*/
ResponseProtocol<CreditResultOutput> creditResult(CreditResultInput input);
}
/**
* 合作方,标准API对接实现
*
* @author Rouse
* @date 2022/4/24 14:04
*/
@Slf4j
public abstract class AbstractBaseApiService implements IBaseApiService {
@Override
public ResponseProtocol<CreditResultOutput> creditResult(CreditResultInput input) {
// 通用加解密
return getDataResponse(logStr, getAppConf().getUrl4CreditResult(), input, CreditResultOutput.class);
}
}
/**
* ABC合作方接口封装
**/
public interface IABCThirdService extends IBaseApiService {
/**
* 标准API,获取appId
*
* @return appId
*/
String getAppId();
/**
* 获取授信结果
*/
ResponseProtocol<ABCCreditResultOutput> creditResult(ABCCreditResultInput input);
}
/**
* 合作方抽象方法封装
**/
@Slf4j
public abstract class AbstractABCThirdService extends AbstractBaseApiService implements IABCThirdService {
@Override
public ResponseProtocol<ABCCreditResultOutput> creditResult(ABCCreditResultInput input) {
// 加解密差异化实现
return getDataResponse(logStr, getAppConf().getUrl4CreditResult(), input, ABCCreditResultOutput.class);
}
}
/**
* ABC合作方对接
*
*/
@Service
@Slf4j
public class ZZABCThirdServiceImpl extends AbstractABCThirdService{
@Override
public String getAppId() {
return PartnerEnum.ABC_API_ZZ.getAppId();
}
@Override
public String getAppName() {
return AppNameEnum.ZZ.getValue();
}
}
项目重构监控先行,这次我们采用了转转告警机制和Prometheus线上监控,另外搭建了一套线上看板,及时发现各个模块的潜在隐患。
日志,一个完美的系统离不开合理的日志,日志往往是定位问题最便捷的工具。
如喜欢本文,请点击右上角,把文章分享到朋友圈
如有想了解学习的技术点,请留言给若飞安排分享
因公众号更改推送规则,请点“在看”并加“星标”第一时间获取精彩技术分享
·END·
相关阅读:
架构师作者:罗思
来源:转转技术
版权申明:内容来源网络,仅供学习研究,版权归原创者所有。如有侵权烦请告知,我们会立即删除并表示歉意。谢谢!
我们都是架构师!
关注架构师(JiaGouX),添加“星标”
获取每天技术干货,一起成为牛逼架构师
技术群请加若飞:1321113940 进架构师群
投稿、合作、版权等邮箱:admin@137x.com