AES解密乱码问题求助：多线程场景下的异常复现与原因排查

这问题我之前做并发加密的时候也碰到过，核心原因其实是两个关键点，咱们一步步拆解：

1. 复用Cipher实例踩了线程安全的坑 #

Java里的Cipher类完全不是线程安全的，它内部维护了加密/解密的上下文状态（比如字节缓冲区、加密进度）。当多个线程同时用同一个Cipher对象干活时，线程之间会互相干扰对方的状态——比如A线程刚更新了缓冲区，B线程又覆盖了它，最后解密出来的自然就是乱码了，这就是你并发测试中偶尔出现乱码的直接原因。

2. 固定IV导致加密结果一成不变 #

你提到每次加密生成的字符串都一样，这是因为你硬编码了固定的初始化向量（IV）：

IvParameterSpec iv = new IvParameterSpec("RandomVector".getBytes(CHARSET));

在AES-CBC模式下，IV的核心作用就是让相同的明文+密钥每次生成不同的密文，固定IV不仅完全失去了这个安全保障，还会让加密结果毫无随机性，很容易被破解。

先解决线程安全问题 #

别再复用同一个Cipher实例了，每次加密/解密都创建新的Cipher对象。其实你写的getDefaultCipherInstance方法本身就是每次创建新Cipher的逻辑，只要确保不在多线程之间共享这个实例就行——比如在encryptText和decryptText里每次调用它获取新对象，而不是把Cipher存成全局变量复用。

再修复固定IV的问题 #

每次加密时生成一个随机的IV，然后把IV和密文绑在一起传输/存储（因为解密必须用同一个IV）。修改后的代码示例：

加密方法调整： #

public static String encryptText(String plainText) {
    try {
        // 生成16字节的随机IV（AES要求IV长度等于块大小，也就是16字节）
        byte[] ivBytes = new byte[16];
        new SecureRandom().nextBytes(ivBytes);
        IvParameterSpec iv = new IvParameterSpec(ivBytes);
        
        byte[] key = Base64.getDecoder().decode("encryptionKey".getBytes(CHARSET));
        SecretKeySpec skeySpec = new SecretKeySpec(key, "AES");
        Cipher cipher = Cipher.getInstance("AES/CBC/PKCS5PADDING");
        cipher.init(Cipher.ENCRYPT_MODE, skeySpec, iv);
        
        byte[] cipherText = cipher.doFinal(plainText.getBytes(CHARSET));
        
        // 把IV和密文拼接在一起，再Base64编码（前16字节是IV，后面是密文）
        byte[] result = new byte[ivBytes.length + cipherText.length];
        System.arraycopy(ivBytes, 0, result, 0, ivBytes.length);
        System.arraycopy(cipherText, 0, result, ivBytes.length, cipherText.length);
        
        return Base64.getEncoder().encodeToString(result);
    } catch (Exception ex) {
        LOG.error("Problem encryptingText",ex);
        return null;
    }
}

解密方法调整： #

import java.util.Arrays;

public static String decryptText(String cipherText) {
    try {
        byte[] decoded = Base64.getDecoder().decode(cipherText);
        
        // 拆分IV和密文：前16字节是IV，剩下的是加密后的内容
        byte[] ivBytes = Arrays.copyOfRange(decoded, 0, 16);
        byte[] cipherBytes = Arrays.copyOfRange(decoded, 16, decoded.length);
        
        byte[] key = Base64.getDecoder().decode("encryptionKey".getBytes(CHARSET));
        SecretKeySpec skeySpec = new SecretKeySpec(key, "AES");
        IvParameterSpec iv = new IvParameterSpec(ivBytes);
        
        Cipher cipher = Cipher.getInstance("AES/CBC/PKCS5PADDING");
        cipher.init(Cipher.DECRYPT_MODE, skeySpec, iv);
        
        byte[] decrypted = cipher.doFinal(cipherBytes);
        return new String(decrypted, CHARSET);
    } catch (Exception ex) {
        LOG.debug("Problem during decrypt text: " + cipherText, ex);
        return null;
    }
}

额外的小提醒 #

• 你的密钥encryptionKey得符合AES的长度要求：AES支持128位（16字节）、192位（24字节）、256位（32字节），如果Base64解码后长度不对，会直接抛InvalidKeyException，得调整密钥。
• 你的测试代码里Thread.currentThread().join()会让主线程无限等下去，应该改成关闭线程池并等待任务完成：

  executorService.shutdown();
  executorService.awaitTermination(1, TimeUnit.MINUTES);
  

内容的提问来源于stack exchange，提问作者Aman Kush