如何在MongoDB client-side field level encryption中保持密钥一致性？

你遇到的问题核心是每次重启程序都重新生成了数据加密密钥（DEK），导致旧数据用新密钥无法解密。要解决这个问题，核心是复用已生成的密钥材料，而非每次启动都重新创建。以下是具体操作步骤：

核心原理回顾 #

CSFLE依赖两层密钥：

1. 数据加密密钥（DEK）：直接加密业务字段，本身会被密钥加密密钥（KEK）加密后存储在MongoDB的keyVault集合中；
2. 密钥加密密钥（KEK）：用于加密/解密DEK，需要持久化存储，不能每次重新生成。

步骤1：持久化存储KEK和DEK #

首次生成KEK和DEK后，必须将它们的材料安全保存，后续启动程序时直接读取：

• 如果用本地KEK（社区版常用方案）：将KEK的二进制数据写入权限严格控制的本地文件（比如仅当前用户可读）；
• DEK无需单独存储，因为它会被KEK加密后存在MongoDB的keyVault集合里，只需记住DEK的标识（比如keyAltNames自定义标签）即可在启动时查询获取。

步骤2：启动时复用已有的DEK #

程序启动时，先检查keyVault集合中是否存在可用的DEK，而非直接创建新的：

1. 连接MongoDB后，访问encryption.__keyVault集合（默认keyVault命名空间）；
2. 通过自定义标签（比如keyAltNames）查询已存在的DEK；
3. 若找到，直接使用其ID初始化加密上下文；若未找到，再生成新DEK并存储到keyVault。

步骤3：确保加密配置完全一致 #

每次启动程序时，必须使用和首次加密时完全相同的配置：

• KEK的生成算法、密钥长度必须一致；
• 加密上下文的算法（比如AEAD_AES_256_CBC_HMAC_SHA_512-Deterministic）、密钥命名空间必须匹配；
• 字段加密规则（JSON Schema）不能修改，否则解密会失败。

关键代码示例（Go语言） #

import (
    "context"
    "log"
    "go.mongodb.org/mongo-driver/bson"
    "go.mongodb.org/mongo-driver/bson/primitive"
    "go.mongodb.org/mongo-driver/mongo"
    "go.mongodb.org/mongo-driver/mongo/options"
    "go.mongodb.org/mongo-driver/mongo/encrypt"
)

func initCSFLE(client *mongo.Client) (encrypt.ClientEncryption, primitive.Binary) {
    ctx := context.TODO()
    // 访问keyVault集合
    keyVaultColl := client.Database("encryption").Collection("__keyVault")

    // 查询已存在的DEK（通过自定义标签my-data-key）
    var existingKey bson.M
    err := keyVaultColl.FindOne(ctx, bson.D{{"keyAltNames", "my-data-key"}}).Decode(&existingKey)
    if err != nil {
        if err == mongo.ErrNoDocuments {
            // 未找到则生成新DEK
            kekBytes := []byte("your-persisted-kek-123456789012345678901234") // 从本地文件/环境变量读取
            kmsProviders := map[string]map[string]interface{}{
                "local": {"key": kekBytes},
            }
            clientEncOpts := options.ClientEncryption().SetKeyVaultNamespace("encryption.__keyVault").SetKmsProviders(kmsProviders)
            clientEncryption, err := encrypt.NewClientEncryption(client, clientEncOpts)
            if err != nil {
                log.Fatal(err)
            }
            dekID, err := clientEncryption.CreateDataKey(ctx, "local", options.CreateDataKey().SetKeyAltNames([]string{"my-data-key"}))
            if err != nil {
                log.Fatal(err)
            }
            return clientEncryption, dekID
        }
        log.Fatal(err)
    }

    // 使用已有的DEK
    kekBytes := []byte("your-persisted-kek-123456789012345678901234") // 从本地文件/环境变量读取
    kmsProviders := map[string]map[string]interface{}{
        "local": {"key": kekBytes},
    }
    clientEncOpts := options.ClientEncryption().SetKeyVaultNamespace("encryption.__keyVault").SetKmsProviders(kmsProviders)
    clientEncryption, err := encrypt.NewClientEncryption(client, clientEncOpts)
    if err != nil {
        log.Fatal(err)
    }
    dekID := existingKey["_id"].(primitive.Binary)
    return clientEncryption, dekID
}

注意事项 #

• 密钥存储安全：本地KEK文件必须设置严格权限（比如chmod 600），避免泄露；
• 禁止硬编码密钥：建议通过环境变量传递KEK路径，或用加密工具存储密钥材料；
• 社区版限制：MongoDB Community版不支持第三方KMS（如AWS KMS），只能用本地KEK方案，企业版可集成KMS提升安全性。

内容的提问来源于stack exchange，提问作者Muhammed Jishin Jamal TCP