spring cloud实战与思考(五) JWT之携带敏感信息

时间:2022-04-11 09:42:11

需求:

需要将一些敏感信息保存在JWT中,以便提高业务处理效率。

众所周知JWT协议RFC7519使用Base64Url对Header和Payload的Json字符串进行编解码。A JWT is represented as a sequence of URL-safe parts separated by period ('.') characters. Each part contains a base64url-encoded value.

不幸地的是Base64Url编码方式不是加密手段。任何得到JWT的人都可以使用公开的解码方式将JWT的原文解析出来。所以很多介绍JWT的文章都提醒不要在JWT中携带敏感信息。但是在特定业务场景下,如果JWT中含有某些关键信息,就可以节省后台很多额外操作,例如数据库查询、服务接口访问等。进而缩短后台响应时间,改善用户体验。

既然在JWT中携带敏感信息能带来这么大的好处,那么花点精力实现这个功能看起来是值得的。提到敏感信息的保密,自然会想到加密和解密。将敏感信息的密文放入JWT中,即使JWT泄露,由于没有密钥,获得JWT的人也无法对其进行解密。而服务器端只要增加一个解密过程就能提取出敏感信息,提高后续业务处理效率。

加密算法主要分两大类:对称加密和非对称加密。因为JWT是由服务端创建,客户端转手后又发回服务端使用。所以加密和解密都发生在服务端,不涉及到密钥的分发,相较其他加密场景要简单很多。所以我选择了加解密运算速度快的对称加密算法AES作为敏感信息的加密方式。

项目中使用JJWT java库创建和校验JWT,将AES加解密过程放入对JJWT封装的接口中。复用创建JWT的数字签名密钥作为AES的加密密钥和初始向量。加解密过程对调用者是透明的。

Maven依赖:

        <!--Java JWT 依赖库-->
<dependency>
<groupId>io.jsonwebtoken</groupId>
<artifactId>jjwt</artifactId>
<version>0.9.0</version>
</dependency>

JJWT封装接口:

import io.jsonwebtoken.JwtBuilder;
import io.jsonwebtoken.Jwts;
import io.jsonwebtoken.SignatureAlgorithm; import javax.crypto.spec.SecretKeySpec;
import javax.xml.bind.DatatypeConverter;
import java.security.Key;
import java.util.Date;
import java.util.HashMap;
import java.util.Map; public class JWTUtil {
/**
* 生成JWT签名字符串
*
* @param publicClaims 无需加密保持明文方式的JWT claims
* @param privateClaims: 需要加密的JWT claims
* @param ttlMillis: JWT过期时长(毫秒)
* @param key: JWT HS256签名的密钥,也是AES加密的密钥
*
* @return JWT字符串
*
*/
public static String createJWT(Map<String, Object> publicClaims, Map<String, Object> privateClaims,long ttlMillis, String key) { SignatureAlgorithm signatureAlgorithm = SignatureAlgorithm.HS256;
long nowMillis = System.currentTimeMillis(); byte[] apiKeySecretBytes = DatatypeConverter.parseBase64Binary(key);
Key signingKey = new SecretKeySpec(apiKeySecretBytes, signatureAlgorithm.getJcaName()); if(null != privateClaims && !privateClaims.isEmpty()) {
String jsonStr = JsonUtil.map2JsonStr(privateClaims);
//使用同一个密钥对私有声明进行加密
String encrypteClaims = AesEncryptUtil.encrypt(jsonStr, key, key);
if(null != encrypteClaims) {
if(null == publicClaims) {
publicClaims = new HashMap<>();
}
publicClaims.put("privateClaims", encrypteClaims);
}
} JwtBuilder builder = Jwts.builder().signWith(signatureAlgorithm, signingKey);
if(null != publicClaims && publicClaims.size() > 0) {
builder.setClaims(publicClaims);
} if (ttlMillis >= 0) {
long expMillis = nowMillis + ttlMillis;
Date exp = new Date(expMillis);
builder.setExpiration(exp);
} return builder.compact();
} /**
* 解析并校验JWT, 校验过程是JJWT内部实现的,会校验JWT是否过期,是否被篡改。
*
* @param jwt JWT字符串
* @param key: JWT HS256签名的密钥,也是AES加密的密钥
*
* @return JWT claims的Map对象
*
*/
public static Map<String, Object> parseJWT(String jwt, String key){ Map<String, Object> privateMap = null; //parser函数会在参数缺失、校验失败、token过期等情况下抛出runtime异常,所以调用者需要捕获该runtime异常
Map<String, Object> originalMap = Jwts.parser()
.setSigningKey(DatatypeConverter.parseBase64Binary(key))
.parseClaimsJws(jwt).getBody(); //解析私有声明
if(null != originalMap && originalMap.containsKey("privateClaims")) {
String encryptedStr = (String)originalMap.get("privateClaims");
if(null != encryptedStr && !encryptedStr.isEmpty()) {
String decryptedStr = AesEncryptUtil.decrypt(encryptedStr, key, key);
if(null != decryptedStr && !decryptedStr.isEmpty()) {
privateMap = JsonUtil.jsonStr2Map(decryptedStr);
}
} originalMap.remove("privateClaims");
if(null != privateMap && privateMap.size() > 0) {
originalMap.putAll(privateMap);
}
} return originalMap;
}
}

AES加密和解密接口:

import javax.crypto.Cipher;
import javax.crypto.spec.IvParameterSpec;
import javax.crypto.spec.SecretKeySpec;
import java.io.UnsupportedEncodingException; public class AesEncryptUtil {
private static final String encode = "UTF-8";
private static final String mode = "AES/CBC/PKCS5Padding"; /**
* JDK只支持AES-128加密,也就是密钥长度必须是128bit;参数为密钥key,key的长度小于16字符时用"0"补充,key长度大于16字符时截取前16位
**/
private static SecretKeySpec get128BitsKey(String key) {
if (key == null) {
key = "";
}
byte[] data = null;
StringBuffer buffer = new StringBuffer(16);
buffer.append(key);
//小于16后面补0
while (buffer.length() < 16) {
buffer.append("0");
}
//大于16,截取前16个字符
if (buffer.length() > 16) {
buffer.setLength(16);
}
try {
data = buffer.toString().getBytes(encode);
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}
return new SecretKeySpec(data, "AES");
} /**
* 创建128位的偏移量,iv的长度小于16时后面补0,大于16,截取前16个字符;
*
* @param iv
* @return
*/
private static IvParameterSpec get128BitsIV(String iv) {
if (iv == null) {
iv = "";
}
byte[] data = null;
StringBuffer buffer = new StringBuffer(16);
buffer.append(iv);
while (buffer.length() < 16) {
buffer.append("0");
}
if (buffer.length() > 16) {
buffer.setLength(16);
}
try {
data = buffer.toString().getBytes(encode);
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}
return new IvParameterSpec(data);
} /**
* 填充方式为Pkcs5Padding的加密函数
* 填充方式为Pkcs5Padding时,最后一个块需要填充χ个字节,填充的值就是χ,也就是填充内容由JDK确定
*
* @param srcContent: 明文
* @param password: 加密密钥(不足128bits时,填"0"补足)
* @param iv: 初始向量(不足128bits时,填"0"补足)
*
* @return 密文(16进制表示)
*
*/
public static String encrypt(String srcContent, String password, String iv) {
SecretKeySpec key = get128BitsKey(password);
IvParameterSpec ivParameterSpec = get128BitsIV(iv);
try {
Cipher cipher = Cipher.getInstance(mode);
cipher.init(Cipher.ENCRYPT_MODE, key, ivParameterSpec);
byte[] byteContent = srcContent.getBytes(encode);
byte[] encryptedContent = cipher.doFinal(byteContent);
String result = HexUtil.byte2HexStr(encryptedContent);
return result;
} catch (Exception e) {
e.printStackTrace();
}
return null;
} /**
* 填充方式为Pkcs5Padding的解密函数
* 填充方式为Pkcs5Padding时,最后一个块需要填充χ个字节,填充的值就是χ,也就是填充内容由JDK确定
*
* @param encryptedContent: 密文
* @param password: 加密密钥(不足128bits时,填"0"补足)
* @param iv: 初始向量(不足128bits时,填"0"补足)
*
* @return 密文(16进制表示)
*
*/
public static String decrypt(String encryptedContent, String password, String iv) {
SecretKeySpec key = get128BitsKey(password);
IvParameterSpec ivParameterSpec = get128BitsIV(iv);
try {
byte[] content = HexUtil.hexStr2Byte(encryptedContent);
Cipher cipher = Cipher.getInstance(mode);
cipher.init(Cipher.DECRYPT_MODE, key, ivParameterSpec);
byte[] decryptedContent = cipher.doFinal(content);
String result = new String(decryptedContent);
return result;
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
}

WTUtil的创建接口“createJWT()”允许调用者指定那些JWT的声明需要加密,那些声明保持为明文的状态。例如JWT的过期时间“exp”,客户端可能需要这个值进行Token有效性判断,所以该claim就需要保持为明文。在调用者解析JWT的时候,JWTUtil的解析接口会将公开明文的publicClaims和解密后的privateClaims放到一个Map中,所以publicClaims和privateClaims Map的key值不要有重名的现象。相信实际的应用场景也不需要重名的Claims。

将以下3个claims生成JWT:

{
"groupId": "6fd5a193016d",
"userName": "test123",
"exp": 1528771799
}

未使用AES加密的JWT字符串:

eyJhbGciOiJIUzI1NiJ9.eyJncm91cElkIjoiNmZkNWExOTMwMTZkIiwidXNlck5hbWUiOiJ0ZXN0MTIzIiwiZXhwIjoxNTI4NzcxNzk5fQ.vJQ4CeYKx3n6B709w35Xdv4fVB2YTr-tsAWr3tCe6A8

使用https://jwt.io/#debugger解析后的原文:

spring cloud实战与思考(五) JWT之携带敏感信息

将“groupId”和“userName”作为敏感信息使用AES加密后的JWT字符串:

eyJhbGciOiJIUzI1NiJ9.eyJwcml2YXRlQ2xhaW1zIjoiMUYyOTMxNjM2NzlBMDM2NDI5RkE3NzMwRTc2OUQyQUY0NjdEMkM3M0Y1NDQxNEExMTVCQUI4MzdCQTEwODQ2NjU0QjA2MTE0OTEzQkJGOUNDMkRCQjdFQzM0RTc2NjIwIiwiZXhwIjoxNTI4Nzc5NjAzfQ.5xb_uxBHMAPvShsOC-pQIS746OjW5XMjj5tAcxwFCq8

使用https://jwt.io/#debugger解析后的JWT原文:

spring cloud实战与思考(五) JWT之携带敏感信息

使用“JWTUtil.parseJWT()”接口解析后的JWT原文Map对象:

{groupId=6fd5a193016d, userName=test123, exp=1528771799}

可以看到AES加密后,“groupId”和“userName”变成了JWT中“privateClaims”对应的密文。这样敏感信息就不怕泄露了。这个方法的缺点主要就是JWT字符串的长度从151增加到了243。如果JWT长度增加的太多,JJWT的接口还可以使用压缩算法对JWT字符串进行压缩。