记录一次还算优雅的代码设计
作者:京东零售 常文标
商卡聚合服务是一个小巧的rpc应用,功能是统一查询商品的促销、自营包邮、价格信息、区域库存、区域可配送等等利益点或其他信息。本文重点分享商卡聚合服务的代码设计,包括合理的Sirector线程调度(cpu使用率低),和可维护性的设计。 简版代码示例如下: [email protected]:changwenbiao/demosoa.git
代码使用sirector-core组件并行调度(使用线程并行执行EventHandler的onEvent方法)请求上游rpc接口获取各利益点或其他商品信息。因为请求上游有些通用处理逻辑比如ump监控、调用开关等,所以抽象出一个通用的EventHandler名为AbstractBenefitHandler。具体调用利益点的实现类只需继承AbstractBenefitHandler并重写其抽象方法。
接下来重点讲代码如何节省cpu使用率和易于维护的设计。
1.如何节省cpu
AbstractBenefitHandler提供isSwitchOn方法,用于决定是否使用sirector组件分配线程执行调度EventHandler。相对于分配线程执行全部的EventHandler,判断是否需要调用才分配线程调用的方式可有效减少线程调度从而减少cpu使用率。isSwitchOn方法中可加入cms控制开关逻辑比如使用ducc开关,也可加入根据用户参数判断开关的逻辑,比如查询区域库存需要四级地址,若用户不传四级地址则关闭调用EventHandler(请求上游rpc)。代码实现如下:其中ducc开关在父类中的isSwitchOn中实现,sirector.begin方法接受可变参数列表参数,可将List<AbstractBenefitHandler>转化为AbstractBenefitHandler[]作为入参。
@Override
public boolean isSwitchOn() {
boolean superSwitchOn = super.isSwitchOn();
if (!superSwitchOn) {
return false;
} else {
//正常为四级地址,如果少于四级则关闭调用
String area = seckillBenefitRequest.getSeckillParam().getArea();
return !StringUtils.isBlank(area) && area.contains("_") && area.split("_").length >= 4;
}
}
List<String> handlerNames = Lists.newArrayList("areaStockHandler", "partitionProductsHandler");
List<AbstractBenefitHandler> handlerList = handlerNames.stream()
.map(handlerName -> applicationContext.getBean(handlerName, AbstractBenefitHandler.class).setBenefitRequestAndBizName(request, "demoAppName"))
.filter(AbstractBenefitHandler::isSwitchOn).collect(Collectors.toList());
Sirector<MiaoShaEvent> sirector = new Sirector<MiaoShaEvent>(bigSeckillEventProcessThreadPool);
AbstractBenefitHandler[] eventHandlersArr = new AbstractBenefitHandler[handlerList.size()];
handlerList.toArray(eventHandlersArr);
sirector.begin(eventHandlersArr);
sirector.ready();
sirector.publish(new MiaoShaEvent(), 500); //这里开始使用线程并行执行EventHandler的onEvent方法
2. 如何容易维护
减少一些模版代码(如ump监控):所有Handler的实现类的ump监控都写在父类中的onEvent中,父类的onEvent调用子类实现的onEvent0(处理具体利益点rpc请求处理)方法。
短小代码的实现:AbstractBenefitHandler提供fillResponseInfo方法以向“ResponseVO”中填数据,具体填利益点数据的代码则由相应handler实现类处理。因此各个handler填充利益点“ResponseVO”的代码都是短小的,避免了代码写在一起的长代码。单个handler填充利益点数据和批量统一填充利益点数据代码分别如下:
@Override
public void fillResponseInfo(List<BftInfo> bftInfoList) {
if (MapUtils.isNotEmpty(areaStockMap)) {
for (BftInfo result : bftInfoList) {
String skuId = result.getBaseInfo().getSkuId();
if (areaStockMap.containsKey(skuId)) {
result.getCommonInfo().setAreaStock(areaStockMap.get(skuId));
}
}
}
}
handlerList.forEach(h -> h.fillResponseInfo(bftInfoList));
减少一些硬编码:handler实现类配置为原型模式(scope="prototype")的spring bean,通过applicationContext.getBean方法统一获取,避免一些创建(new关键字)具体实现类的代码,若新增利益点调用只需编码AbstractBenefitHandler实现类并配置为spring bean即可。批量获取handler代码如下
List<String> handlerNames = Lists.newArrayList("areaStockHandler", "partitionProductsHandler");
List<AbstractBenefitHandler> handlerList = handlerNames.stream()
.map(handlerName -> applicationContext.getBean(handlerName, AbstractBenefitHandler.class).setBenefitRequestAndBizName(request, "demoAppName"))
.filter(AbstractBenefitHandler::isSwitchOn).collect(Collectors.toList());
- 应用健康度隐患刨析解决系列之数据库时区设置
- 对于Vue3和Ts的心得和思考
- 一文详解扩散模型:DDPM
- zookeeper的Leader选举源码解析
- 一文带你搞懂如何优化慢SQL
- 京东金融Android瘦身探索与实践
- 微前端框架single-spa子应用加载解析
- cookie时效无限延长方案
- 聊聊前端性能指标那些事儿
- Spring竟然可以创建“重复”名称的bean?—一次项目中存在多个bean名称重复问题的排查
- 京东金融Android瘦身探索与实践
- Spring源码核心剖析
- 深入浅出RPC服务 | 不同层的网络协议
- 安全测试之探索windows游戏扫雷
- 关于数据库分库分表的一点想法
- 对于Vue3和Ts的心得和思考
- Bitmap、RoaringBitmap原理分析
- 京东小程序CI工具实践
- 测试用例设计指南
- 当你对 redis 说你中意的女孩是 Mia