Spring Boot 框架中使用自定义注解 + 拦截器实现身份证等敏感数据加解密

>>号外：关注“Java精选”公众号，回复“2021面试题”关键词，领取全套500多份Java面试题文件。

在实际生产项目中，经常需要对如身份证信息、手机号、真实姓名等的敏感数据进行加密数据库存储，但在业务代码中对敏感信息进行手动加解密则十分不优雅，甚至会存在错加密、漏加密、业务人员需要知道实际的加密规则等的情况。

本文将介绍使用springboot+mybatis拦截器+自定义注解的形式对敏感数据进行存储前拦截加密的详细过程。

一、什么是Mybatis Plugin

在mybatis官方文档中，对于Mybatis plugin的的介绍是这样的：

MyBatis 允许你在已映射语句执行过程中的某一点进行拦截调用。默认情况下，MyBatis 允许使用插件来拦截的方法调用包括：

//语句执行拦截
Executor (update, query, flushStatements, commit, rollback, getTransaction, close, isClosed)// 参数获取、设置时进行拦截
ParameterHandler (getParameterObject, setParameters)// 对返回结果进行拦截
ResultSetHandler (handleResultSets, handleOutputParameters)//sql语句拦截
StatementHandler (prepare, parameterize, batch, update, query)

简而言之，即在执行sql的整个周期中，我们可以任意切入到某一点对sql的参数、sql执行结果集、sql语句本身等进行切面处理。基于这个特性，我们便可以使用其对我们需要进行加密的数据进行切面统一加密处理了（分页插件 pageHelper 就是这样实现数据库分页查询的）。

二、实现基于注解的敏感信息加解密拦截器

2.1 实现思路

对于数据的加密与解密，应当存在两个拦截器对数据进行拦截操作

参照官方文档，因此此处我们应当使用ParameterHandler拦截器对入参进行加密

使用ResultSetHandler拦截器对出参进行解密操作。

目标需要加密、解密的字段可能需要灵活变更，此时我们定义一个注解，对需要加密的字段进行注解，那么便可以配合拦截器对需要的数据进行加密与解密操作了。

mybatis的interceptor接口有以下方法需要实现。

public interface Interceptor {//主要参数拦截方法Object intercept(Invocation invocation) throws Throwable;//mybatis插件链default Object plugin(Object target) {return Plugin.wrap(target, this);}//自定义插件配置文件方法default void setProperties(Properties properties) {}}

2.2 定义需要加密解密的敏感信息注解

定义注解敏感信息类（如实体类POJO\PO）的注解

/*** 注解敏感信息类的注解*/
@Inherited
@Target({ ElementType.TYPE })
@Retention(RetentionPolicy.RUNTIME)
public @interface SensitiveData {
}

定义注解敏感信息类中敏感字段的注解

/*** 注解敏感信息类中敏感字段的注解*/
@Inherited
@Target({ ElementType.Field })
@Retention(RetentionPolicy.RUNTIME)
public @interface SensitiveField {
}

2.3 定义加密接口及其实现类

定义加密接口，方便以后拓展加密方法（如AES加密算法拓展支持PBE算法，只需要注入时指定一下便可）

public interface EncryptUtil {/*** 加密** @param declaredFields paramsObject所声明的字段* @param paramsObject   mapper中paramsType的实例* @return T* @throws IllegalAccessException 字段不可访问异常*/<T> T encrypt(Field[] declaredFields, T paramsObject) throws IllegalAccessException;
}

EncryptUtil 的AES加密实现类，此处AESUtil为自封装的AES加密工具，需要的小伙伴可以自行封装，本文不提供。

@Component
public class AESEncrypt implements EncryptUtil {@AutowiredAESUtil aesUtil;/*** 加密** @param declaredFields paramsObject所声明的字段* @param paramsObject   mapper中paramsType的实例* @return T* @throws IllegalAccessException 字段不可访问异常*/@Overridepublic <T> T encrypt(Field[] declaredFields, T paramsObject) throws IllegalAccessException {for (Field field : declaredFields) {//取出所有被EncryptDecryptField注解的字段SensitiveField sensitiveField = field.getAnnotation(SensitiveField.class);if (!Objects.isNull(sensitiveField)) {field.setAccessible(true);Object object = field.get(paramsObject);//暂时只实现String类型的加密if (object instanceof String) {String value = (String) object;//加密  这里我使用自定义的AES加密工具field.set(paramsObject, aesUtil.encrypt(value));}}}return paramsObject;}
}

2.4 实现入参加密拦截器

Myabtis包中的org.apache.ibatis.plugin.Interceptor拦截器接口要求我们实现以下三个方法

public interface Interceptor {//核心拦截逻辑Object intercept(Invocation invocation) throws Throwable;//拦截器链default Object plugin(Object target) {return Plugin.wrap(target, this);}//自定义配置文件操作default void setProperties(Properties properties) { }}

因此，参考官方文档的示例，我们自定义一个入参加密拦截器。

@Intercepts 注解开启拦截器，@Signature 注解定义拦截器的实际类型。

@Signature中

• type 属性指定当前拦截器使用StatementHandler 、ResultSetHandler、ParameterHandler，Executor的一种

• method 属性指定使用以上四种类型的具体方法（可进入class内部查看其方法）。

• args 属性指定预编译语句

此处我们使用了 ParameterHandler.setParamters()方法，拦截mapper.xml中paramsType的实例（即在每个含有paramsType属性mapper语句中，都执行该拦截器，对paramsType的实例进行拦截处理）

/*** 加密拦截器* 注意@Component注解一定要加上** @author : tanzj* @date : 2020/1/19.*/
@Slf4j
@Component
@Intercepts({@Signature(type = ParameterHandler.class, method = "setParameters", args = PreparedStatement.class),
})
public class EncryptInterceptor implements Interceptor {private final EncryptDecryptUtil encryptUtil;@Autowiredpublic EncryptInterceptor(EncryptDecryptUtil encryptUtil) {this.encryptUtil = encryptUtil;}@Override@Overridepublic Object intercept(Invocation invocation) throws Throwable {//@Signature 指定了 type= parameterHandler 后，这里的 invocation.getTarget() 便是parameterHandler //若指定ResultSetHandler ，这里则能强转为ResultSetHandlerParameterHandler parameterHandler = (ParameterHandler) invocation.getTarget();// 获取参数对像，即 mapper 中 paramsType 的实例Field parameterField = parameterHandler.getClass().getDeclaredField("parameterObject");parameterField.setAccessible(true);//取出实例Object parameterObject = parameterField.get(parameterHandler);if (parameterObject != null) {Class<?> parameterObjectClass = parameterObject.getClass();//校验该实例的类是否被@SensitiveData所注解SensitiveData sensitiveData = AnnotationUtils.findAnnotation(parameterObjectClass, SensitiveData.class);if (Objects.nonNull(sensitiveData)) {//取出当前当前类所有字段，传入加密方法Field[] declaredFields = parameterObjectClass.getDeclaredFields();encryptUtil.encrypt(declaredFields, parameterObject);}}return invocation.proceed();}/*** 切记配置，否则当前拦截器不会加入拦截器链*/@Overridepublic Object plugin(Object o) {return Plugin.wrap(o, this);}//自定义配置写入，没有自定义配置的可以直接置空此方法@Overridepublic void setProperties(Properties properties) {}
}

至此完成自定义加密拦截加密。

2.5 定义解密接口及其实现类

解密接口，其中result为mapper.xml中resultType的实例。

public interface DecryptUtil {/*** 解密** @param result resultType的实例* @return T* @throws IllegalAccessException 字段不可访问异常*/<T> T decrypt(T result) throws IllegalAccessException;}

解密接口AES工具解密实现类

public class AESDecrypt implements DecryptUtil {@AutowiredAESUtil aesUtil;/*** 解密** @param result resultType的实例* @return T* @throws IllegalAccessException 字段不可访问异常*/@Overridepublic <T> T decrypt(T result) throws IllegalAccessException {//取出resultType的类Class<?> resultClass = result.getClass();Field[] declaredFields = resultClass.getDeclaredFields();for (Field field : declaredFields) {//取出所有被EncryptDecryptField注解的字段SensitiveField sensitiveField = field.getAnnotation(SensitiveField.class);if (!Objects.isNull(sensitiveField)) {field.setAccessible(true);Object object = field.get(result);//只支持String的解密if (object instanceof String) {String value = (String) object;//对注解的字段进行逐一解密field.set(result, aesUtil.decrypt(value));}}}return result;}
}

2.6 定义出参解密拦截器

@Slf4j
@Component
@Intercepts({@Signature(type = ResultSetHandler.class, method = "handleResultSets", args = {Statement.class})
})
public class DecryptInterceptor implements Interceptor {@AutowiredDecryptUtil aesDecrypt;@Overridepublic Object intercept(Invocation invocation) throws Throwable {//取出查询的结果Object resultObject = invocation.proceed();if (Objects.isNull(resultObject)) {return null;}//基于selectListif (resultObject instanceof ArrayList) {ArrayList resultList = (ArrayList) resultObject;if (!CollectionUtils.isEmpty(resultList) && needToDecrypt(resultList.get(0))) {for (Object result : resultList) {//逐一解密aesDecrypt.decrypt(result);}}//基于selectOne} else {if (needToDecrypt(resultObject)) {aesDecrypt.decrypt(resultObject);}}return resultObject;}private boolean needToDecrypt(Object object) {Class<?> objectClass = object.getClass();SensitiveData sensitiveData = AnnotationUtils.findAnnotation(objectClass, SensitiveData.class);return Objects.nonNull(sensitiveData);}@Overridepublic Object plugin(Object target) {return Plugin.wrap(target, this);}@Overridepublic void setProperties(Properties properties) {}
}

至此完成解密拦截器的配置工作。

3、注解实体类中需要加解密的字段

此时在mapper中，指定paramType=User resultType=User 便可实现脱离业务层，基于mybatis拦截器的加解密操作。

作者：CoderTanzJ

blog.csdn.net/bbcckkl/article/details/104069487

往期精选  点击标题可跳转

Java 中处理 Exception 的 9 种实践，曾被很多团队认可采纳，值得收藏！

Java 中 ThreadPoolExecutor 线程池必备知识点：工作流程、常见参数、性能调优及监控

Java 中统计代码执行耗时，列举 4 种优雅的解决方案

MySQL 分页使用 limit 和 offset 参数为什么会导致执行变慢？

全网可能是最全的 JAVA 日志框架适配、冲突解决方案

数据库在哪些场景下导致索引失效，索引何时会失效？

为什么 Redis 越来越慢了？延迟问题定位排查与分析

Spring 框架中导致 @Transactional 事务注解 3 种失效场景分析及解决方法

放弃 JDK8 中 StringBuilder，使用 StringJoiner 辅助类，真香！

面试时这样回答 Java 应用性能调优，回报是更多 Money！

面试官问：你说一说 HashMap 是如何解决 hash 冲突的？

点个赞，就知道你“在看”！