dogonthemoon
恿粤晒话大致的实现流程
业务层-->系统拦截器-->数据库-->系统拦截器-->返回结果
加密注解设计
把需要加密的字段通过我们自定义的加密注解进行标识，所以我们需要先自定义一段加密注解的代码
@Target(ElementType.FIELD)
@Retention(RetentionPolicy.RUNTIME)
public @interface Encrypt {
}
实体类
在实体类上使用注解标记需要加密字段
@Data
public class User {
private Long id;
private String username;
@Encrypt
private String password;
@Encrypt
private String email;
@Encrypt
private String phone;
}
加密工具类
基于AES加密算法实现对字段名的加密，大家可以选择其他的加密算法
public class EncryptionUtil {
privatestaticfinal String ALGORITHM = "AES";
privatestaticfinal String TRANSFORMATION = "AES/ECB/PKCS5Padding";
// AES加密
public static String encrypt(String plainText, String key) {
try {
SecretKeySpec secretKey = new SecretKeySpec(key.getBytes(StandardCharsets.UTF_8), ALGORITHM);
Cipher cipher = Cipher.getInstance(TRANSFORMATION);
cipher.init(Cipher.ENCRYPT_MODE, secretKey);
byte[] encryptedBytes = cipher.doFinal(plainText.getBytes(StandardCharsets.UTF_8));
return Base64.getEncoder().encodeToString(encryptedBytes);
} catch (Exception e) {
thrownew RuntimeException("加密失败", e);
}
}
// AES解密
public static String decrypt(String cipherText, String key) {
try {
SecretKeySpec secretKey = new SecretKeySpec(key.getBytes(StandardCharsets.UTF_8), ALGORITHM);
Cipher cipher = Cipher.getInstance(TRANSFORMATION);
cipher.init(Cipher.DECRYPT_MODE, secretKey);
byte[] decryptedBytes = cipher.doFinal(Base64.getDecoder().decode(cipherText));
returnnew String(decryptedBytes, StandardCharsets.UTF_8);
} catch (Exception e) {
thrownew RuntimeException("解密失败", e);
}
}
}
系统拦截器设计
通过拦截实现自动加密和自动解密
// 加密拦截器
@Intercepts({
@Signature(type = Executor.class, method = "update", args = {MappedStatement.class, Object.class})
})
@Component
public class FieldEncryptionInterceptor implements Interceptor {
@Value("${encryption.key:mySecretKey12345}")
private String encryptionKey;
@Override
public Object intercept(Invocation invocation) throws Throwable {
Object[] args = invocation.getArgs();
MappedStatement mappedStatement = (MappedStatement) args[0];
Object parameter = args[1];
// 获取SQL命令类型
String sqlCommandType = mappedStatement.getSqlCommandType().toString();
// 对INSERT和UPDATE操作进行加密处理
if ("INSERT".equals(sqlCommandType) || "UPDATE".equals(sqlCommandType)) {
encryptFields(parameter);
}
return invocation.proceed();
}
// 解密拦截器
@Intercepts({
@Signature(type = ResultSetHandler.class, method = "handleResultSets", args = {Statement.class})
})
@Component
public class FieldDecryptionInterceptor implements Interceptor {
@Value("${encryption.key:mySecretKey12345}")
private String encryptionKey;
@Override
public Object intercept(Invocation invocation) throws Throwable {
// 执行原始方法
Object result = invocation.proceed();
// 对查询结果进行解密处理
if (result instanceof List) {
List list = (List) result;
for (Object item : list) {
decryptFields(item);
}
} else {
decryptFields(result);
}
return result;
}
}
}
测试场景
用户信息保护：在用户注册时，自动加密用户的密码、邮箱、手机号等敏感信息，即使数据库泄露也不会造成用户隐私泄露
金融数据保护：对用户的银行卡号、交易记录等金融数据进行加密存储，满足金融行业的合规要求
医疗医保数据保护：对患者的病历、诊断结果等医疗隐私数据进行加密，保护患者隐私
企业数据保护：对企业内部的商业机密、客户资料等重要数据进行加密保护