JavaWeb开发经验谈:业务行为相似DAO接口的统一封装与使用

简介: 以对mybatis-plus的封装使用为例,给出一个在适用业务场景下大幅降低代码信息熵的解决方案

一个典型的web应用中可能会有很多DAO接口(也被称作mapper,以下皆称mapper),在某些业务场景中,我们会对不同的mapper进行高度相似的业务操作,这种情况下如果仍然裸用mapper进行CRUD,就可能制造出大批高信息熵的代码,久而久之,难以维护.

例如在笔者之前所开发的项目,它是一个云产品监控系统,通过组合阿里云的blink、datahub、TableStore以及一些java微服务,实现了对几十种阿里云产品的数百个监控项的统一配置实时监控和按规则报警.

为了便于blink服务分监控项计算受监控实例的某项指标是否突破阈值,我们存储实例阈值配置的表结构被设计以实例ID作为唯一标识,横向扩展监控项的横表结构:

实例ID

监控项1

监控项2

监控项3

更多监控项...

实例1

55

66

77

88

实例2

更多实例...

并且,让每一种产品都对应一张阈值横表,便于维护,也避免了给不同产品的同名监控项起别名(比方说,ECS和RDS都有内存使用率这个监控项)维护的成本.

在这个场景中,负责报警配置的业务开发人员事实上并不需要关心每个监控项的具体业务含义,他可以对监控项作一个统一的抽象:

// 由于历史原因,我们的项目为每一个监控项都创建了对应的VO,// 这样很繁琐,但是对于分类维护监控项或在domain层次针对性地扩展某个监控项则是有利的// 如果你偏好贫血模型,那么可以尝试用一个CommonMonitorConfig描述所有publicabstractclassCommonMonitorConfig {
// 超阈值状态超过此时间,则进行报警StringkeepTime;
// 自上一次发送报警后的沉默周期StringsilenceTime;
// 此监控项是否启用报警BooleanisOpen;
// 监控项对应的字段名称StringmonitorName;
//  配置阈值Doublevalue;
//  产品类型,贫血模型需要此字段StringproductType;
//  充血模型可以定义此方法,让处于产品及的监控类例如EcsMonitorConfig实现此方法    abstractTypeEnumgetTypeEnum();
publicCommonMonitorConfig(){
// 如果使用充血模型,你可以分门别类的在构造方法中按类型初始化一些默认配置    }
}

前端可以根据此抽象制作操作报警配置的表单界面并提交报警配置数据.在约束好CommonMonitorConfig的monitorName与阈值配置实例类相应字段的映射关系后,后端接口中可以使用反射方便规整地将VO对象的相应值映射统一到对应的DO对象中.

当然,在真正实现丝滑流畅无污染的反射之前还需要作一点点合理封装.

以实例阈值配置的存储和查询为例,首先给所有产品的entity类定义一个公共父类,并提取公共业务字段到父类中,使得子类实体只存放阈值:

publicclassCommonInsAlarmRule {
@TableIdpublicLongid;
/*** 规则编码*/publicStringruleUUID;
/*** 实例ID*/publicStringinstanceId;
publicStringmoduleCode;
}

然后,写一个ConfigUtil维护一些静态映射关系并封装常用方法:

/*** k: 产品类别* v: 报警规则实体类*/publicstaticfinalMap<TypeEnum, Class<?extendsCommonInsAlarmRule>>insClassMap=newImmutableMap.Builder<CloudProductTypeEnum, Class<?extendsCommonInsAlarmRule>>()
            .put(ECS, EcsAlarmRule.class)
            .put(EIP, EipAlarmRule.class)
            .put(RDS, RdsAlarmRule.class)
// ....            .build();
// 比方说,从上面的字典中获取insType,然后将其实例化为被标记为CommonInsAlarmRule的具体子类对象publicstatic<P, SextendsP>PnewInstance(Class<S>insType) {
try {
returninsType.newInstance();
        } catch (InstantiationException|IllegalAccessExceptione) {
        }
    }
// 这个方法直接定义在TypeEnum这个枚举类里publicstaticTypeEnumfindEnumByNameIgnoreCase(StringdisplayName){
returnArrays.stream(TypeEnum .values()).filter(e->e.displayName.equalsIgnoreCase(displayName)).findFirst().orElse(null);
    }

同样地,在ConfigUtil中注入并初始话各个产品mapper对象(这里以MybatisPlus为例)的映射关系:

privatestaticMap<String, BaseMapper<?extendsCommonInsAlarmRule>>instanceAlarmRuleMapperMap;
privatefinalEcsAlarmRuleMapperecsAlarmRuleMapper;
privatefinalRdsAlarmRuleMapperrdsAlarmRuleMapper;
privatefinalEipAlarmRuleMappereipAlarmRuleMapper;
//.... @PostConstructvoidinit(){
instanceAlarmRuleMapperMap=newImmutableMap.Builder<TypeEnum, BaseMapper<?extendsCommonInsAlarmRule>>()
                .put(EcsAlarmRule.class.getName(), ecsAlarmRuleMapper)
                .put(EipAlarmRule.class.getName(), eipAlarmRuleMapper)
                .put(RdsAlarmRule.class.getName(), rdsAlarmRuleMapper)
// .....                .build();
}

为了更好地利用MybatisPlus的LambdaQueryWrapper静态字段缓存进行代码中相关SQL的静态检查,需要为CommonInsAlarmRule创建一个无需对应任何数据库表的形式化mapper:

importcom.baomidou.mybatisplus.core.mapper.BaseMapper;
importorg.springframework.stereotype.Repository;
@RepositorypublicinterfaceAbstractInsMapperextendsBaseMapper<CommonInsAlarmRule> {
}


最后,在ConfigUtil中封装增删查改的常用方法:

publicstatic<TextendsCommonInsAlarmRule>BaseMapper<T>getInsAlarmRuleMapperByInsType(TypeEnumproductType) {
Class<T>clazz= (Class<T>) insClassMap.get(productType);
return (BaseMapper<T>) instanceAlarmRuleMapperMap.get(clazz.getName());
    }
publicstaticList<CommonInsAlarmRule>selectList(CloudProductTypeEnumproductType, LambdaQueryWrapper<CommonInsAlarmRule>wrapper) {
returngetInsAlarmRuleMapperByInsType(productType).selectList(wrapper);
    }
publicstaticCommonInsAlarmRuleselectOne(CloudProductTypeEnumproductType, LambdaQueryWrapper<CommonInsAlarmRule>wrapper) {
returngetInsAlarmRuleMapperByInsType(productType).selectOne(wrapper);
    }
publicintinsertOne(CloudProductTypeEnumproductType, CommonInsAlarmRulerule){
returngetInsAlarmRuleMapperByInsType(productType).insert(rule);
    }

举个例子,下图是一段根据实例ID及产品类型查询指定实例的配置阈值的代码,可以明显看出,这段代码的信息熵会随着产品数量的增加而逐渐升高:

1.png

使用统一封装之后的接口来替代原先的这段代码,只需三行,且可在后续迭代中保持信息密度不变:

2.png

相关文章
|
4天前
|
Java
Java 封装
5月更文挑战第5天
|
1天前
|
Java ice
【Java开发指南 | 第二十九篇】Java接口
【Java开发指南 | 第二十九篇】Java接口
6 0
|
1天前
|
Java ice
【Java开发指南 | 第二十八篇】Java封装
【Java开发指南 | 第二十八篇】Java封装
7 0
|
1天前
|
Java ice
【Java开发指南 | 第九篇】访问实例变量和方法、继承、接口
【Java开发指南 | 第九篇】访问实例变量和方法、继承、接口
10 4
|
2天前
|
Java 开发者
Java一分钟之-Lambda表达式与函数式接口
【5月更文挑战第12天】Java 8引入的Lambda表达式简化了函数式编程,与函数式接口结合,实现了代码高效编写。本文介绍了Lambda的基本语法,如参数列表、箭头符号和函数体,并展示了如何使用Lambda实现`Runnable`接口。函数式接口仅有一个抽象方法,可与Lambda搭配使用。`@FunctionalInterface`注解用于确保接口具有单一抽象方法。文章还讨论了常见的问题和易错点,如非函数式接口、类型冲突以及Lambda表达式的局部变量可见性,并提供了避免这些问题的策略。通过理解Lambda和函数式接口,开发者能提高代码可读性和效率。
37 4
|
3天前
|
安全 Java 调度
Java一分钟:多线程编程初步:Thread类与Runnable接口
【5月更文挑战第11天】本文介绍了Java中创建线程的两种方式:继承Thread类和实现Runnable接口,并讨论了多线程编程中的常见问题,如资源浪费、线程安全、死锁和优先级问题,提出了解决策略。示例展示了线程通信的生产者-消费者模型,强调理解和掌握线程操作对编写高效并发程序的重要性。
43 3
|
3天前
|
Java API
Java 接口
5月更文挑战第6天
|
4天前
|
存储 安全 Java
Java一分钟之-Map接口与HashMap详解
【5月更文挑战第10天】Java集合框架中的`Map`接口用于存储唯一键值对,而`HashMap`是其快速实现,基于哈希表支持高效查找、添加和删除。本文介绍了`Map`的核心方法,如`put`、`get`和`remove`,以及`HashMap`的特性:快速访问、无序和非线程安全。讨论了键的唯一性、`equals()`和`hashCode()`的正确实现以及线程安全问题。通过示例展示了基本操作和自定义键的使用,强调理解这些概念对编写健壮代码的重要性。
6 0
|
4天前
|
存储 安全 Java
Java一分钟之-集合框架进阶:Set接口与HashSet
【5月更文挑战第10天】本文介绍了Java集合框架中的`Set`接口和`HashSet`类。`Set`接口继承自`Collection`,特征是不允许重复元素,顺序不确定。`HashSet`是`Set`的实现,基于哈希表,提供快速添加、删除和查找操作,但无序且非线程安全。文章讨论了`HashSet`的特性、常见问题(如元素比较规则、非唯一性和线程安全性)以及如何避免这些问题,并提供了代码示例展示基本操作和自定义对象的使用。理解这些概念和注意事项能提升代码效率和可维护性。
9 0
|
4天前
|
存储 安全 算法
Java一分钟之-Java集合框架入门:List接口与ArrayList
【5月更文挑战第10天】本文介绍了Java集合框架中的`List`接口和`ArrayList`实现类。`List`是有序集合,支持元素重复并能按索引访问。核心方法包括添加、删除、获取和设置元素。`ArrayList`基于动态数组,提供高效随机访问和自动扩容,但非线程安全。文章讨论了三个常见问题:索引越界、遍历时修改集合和并发修改,并给出避免策略。通过示例代码展示了基本操作和安全遍历删除。理解并正确使用`List`和`ArrayList`能提升程序效率和稳定性。
7 0