使用TaskPool在子线程使用AES加密
=====================

#### 问题现象

开发者希望在子线程（TaskPool）中执行AES加密操作，但遇到以下问题：

*   cryptoFramework加密对象（如密钥、加密器）无法直接跨线程传递。
*   自定义函数在并发任务中被识别为闭包，导致序列化失败。
*   加密操作阻塞主线程，影响UI流畅性。

#### 背景知识

*   [使用AES对称密钥加解密](https://developer.huawei.com/consumer/cn/doc/harmonyos-guides/crypto-aes-sym-encrypt-decrypt-ccm)：cryptoFramework支持在子线程（TaskPool）中操作，但需满足特定条件；加密操作涉及的对象（如密钥、加密器）必须是Sendable类型（可序列化对象）。
*   [TaskPool](https://developer.huawei.com/consumer/cn/doc/harmonyos-guides/taskpool-introduction)：TaskPool为应用程序提供多线程环境，降低资源消耗并提高系统性能。

#### 解决方案

1.  在[并发函数](https://developer.huawei.com/consumer/cn/doc/harmonyos-guides/taskpool-introduction#并发函数中使用自定义类或函数)中使用自定义类或函数时，需将其定义在单独的文件中，否则可能被视为闭包。加解密逻辑拆分为独立文件，确保所有对象可序列化。
    
    _// utils/Func.ets_
    import { cryptoFramework } from '@kit.CryptoArchitectureKit';
    import { buffer } from '@kit.ArkTS';
    
    export function genIvParamsSpec() {
      let ivBlob: cryptoFramework.DataBlob = { data: new Uint8Array(buffer.from('0123456789101112', 'utf-8').buffer) };
      let ivParamsSpec: cryptoFramework.IvParamsSpec = {
        algName: 'IvParamsSpec',
        iv: ivBlob
      };
      return ivParamsSpec;
    }
    
    function genkey() {
     _ // 子线程内生成密钥（避免传递非Sendable对象）_
      let symKeyGenerator = cryptoFramework.createSymKeyGenerator('AES256');
      return symKeyGenerator.generateSymKeySync();
    }
    
    export const key: cryptoFramework.SymKey = genkey();
    
    export const CIPHER\_TRANSFORMATION = 'AES256|CBC|PKCS7';
    
2.  通过TaskPool分发任务，主函数调用并发函数并获取结果。
    
    _// Index.ets_
    import { taskpool } from '@kit.ArkTS';
    import { cryptoFramework } from '@kit.CryptoArchitectureKit';
    import { genIvParamsSpec, key, CIPHER\_TRANSFORMATION } from '../utils/Func';
    
    _// 步骤1：定义并发函数（内部创建加密对象）_
    @Concurrent
    function aesEncrypt(src: Uint8Array): Uint8Array {
      let cipher = cryptoFramework.createCipher(CIPHER\_TRANSFORMATION);
      const iv = genIvParamsSpec();
      cipher.initSync(cryptoFramework.CryptoMode.ENCRYPT\_MODE, key, iv);
      const plaintext: cryptoFramework.DataBlob = { data: src };
      return cipher.doFinalSync(plaintext).data;
    }
    
    _// 步骤2：主线程调用taskpool_
    async function startEncryption() {
      let task = new taskpool.Task(aesEncrypt, new Uint8Array(\[0x01, 0x02\])); _// 传递原始数据_
      let encryptedData = await taskpool.execute(task) as Uint8Array;
      console.info('Encryption succeeded:', encryptedData.toString());
    }
    
    @Entry
    @Component
    struct Index {
      build() {
        RelativeContainer() {
          Button('AES加密')
            .fontSize($r('app.float.page\_text\_font\_size'))
            .fontWeight(FontWeight.Bold)
            .onClick(() => {
              startEncryption();
            });
        }
        .height('100%')
        .width('100%');
      }
    }