HarmonyOS 实战开发-Worker子线程中解压文件

harmonyos,worker · 浏览次数 : 0

小编点评

**代码说明** 本示例使用 `@ohos.zlib` 提供的 `zlib.decompressfile` 接口对沙箱目录中的压缩文件进行解压操作，并将解压路径返回主线程，获取解压文件列表。 **流程概述** 1. 创建一个 `Worker` 对象，绑定 `workerPort` 的监听器。 2. 在主线程中创建一个 `worker` 对象，传入 `Worker.ets` 的加载路径。 3. 主线程使用 `postMessage` 方法向 `worker` 发送应用沙箱路径和压缩文件名称。 4. `Worker` 对象在 `onmessage` 方法中接收主线程发送的路径和文件名。 5. `Worker` 使用 `zlib.decompressfile` 接口对压缩文件进行解压，并将解压结果输出到指定的目录。 6. 确保解压后的文件或文件夹已经存在，如果不存在，则创建空目录。 7. 解压完成后，将解压路径返回主线程，获取解压文件列表。 **性能优化** * 使用 `LazyForEach` 进行数据懒加载，以减少内存占用。 * 使用 `fs.mkdirSync()` 创建输出目录，避免频繁创建目录操作。 * 使用 `zlib.decompressfile` 接口进行高效解压。 **依赖库** * `@ohos.zlib` **其他说明** * `pathDir` 是解压的目录路径。 * `rawfileZipName` 是压缩文件名称。 * `outFileDir` 是解压后的文件输出目录。 * `logger` 是用于日志记录的对象。

正文

介绍

本示例介绍在Worker子线程使用@ohos.zlib提供的zlib.decompressfile接口对沙箱目录中的压缩文件进行解压操作，解压成功后将解压路径返回主线程，获取解压文件列表。

效果图预览

使用说明

点击解压按钮，解压test.zip文件，显示解压结果。

实现思路

在/src/main/ets/workers目录下创建Worker.ets线程文件，绑定Worker对象。

const workerPort: ThreadWorkerGlobalScope = worker.workerPort;

在build-profile.json5中进行配置Worker线程文件路径，Worker线程文件才能确保被打包到应用中。

"buildOption": {
  "sourceOption": {
    "workers": [
      "./src/main/ets/workers/Worker.ets"
    ]
  }
}

在主线程创建一个Worker线程，通过new worker.ThreadWorker()创建Worker实例，传入Worker.ets的加载路径。

let workerInstance: worker.ThreadWorker = new worker.ThreadWorker('@decompressFile/ets/workers/Worker.ets');

主线程使用postMessage()向worker线程发送应用沙箱路径和压缩文件名称。

workerInstance.postMessage({ pathDir: this.pathDir, rawfileZipName: rawfileZipName });

在Worker.ets文件中通过调用onmessage()方法接收主线程发送的应用沙箱路径和压缩文件名称。

workerPort.onmessage = (e: MessageEvents): void => {
  logger.info(TAG, `Worker onmessage：${JSON.stringify(e.data)}`);
  let pathDir: string = e.data.pathDir; // 沙箱目录
  let rawfileZipName: string = e.data.rawfileZipName; // 带.zip后缀的压缩文件名称
}

使用fs.access判断输出目录是否已经存在，如果不存在使用fs.mkdirSync()创建空目录用于放置解压后的文件。空目录创建成功后使用zlib.decompressFile接口解压压缩文件，输出到空目录中。

fs.access(outFileDir).then((res: boolean) => {
  if (!res) {
    // TODO：知识点：使用fs.mkdirSync创建目录，用于存放解压后的文件。
    fs.mkdirSync(outFileDir);
    logger.info(TAG, 'mkdirSync succeed');
  }
  // TODO：知识点：使用zlib.decompressfile接口对沙箱目录中的压缩文件进行解压操作，解压至指定沙箱目录outFileDir。
  // 如果待解压的文件或文件夹在解压后的路径下已经存在，则会直接覆盖同名文件或同名文件夹中的同名文件。
  zlib.decompressFile(`${pathDir}/${rawfileZipName}`, outFileDir, (errData: BusinessError) => {
    if (errData !== null) {
      logger.error(TAG, `decompressFile failed. code is ${errData.code}, message is ${errData.message}`);
    } else {
      logger.info(TAG, `decompressFile succeed. outFileDir is ${outFileDir}`);
      // TODO：知识点：Worker线程向主线程发送信息。
      workerPort.postMessage(outFileDir);
    }
  })
}).catch((err: BusinessError) => {
  logger.error(TAG, `access failed with error message: ${err.message}, error code: ${err.code}`);
});

高性能知识点

本示例使用了LazyForEach进行数据懒加载，List布局时会根据可视区域按需创建ListItem组件，并在ListItem滑出可视区域外时销毁以降低内存占用。
本示例使用在Work子线程中使用zlib.decompressFile解压文件，避免阻塞主线程的运行。

工程结构&模块类型

   decompressFile                                // har类型
   |---/src/main/ets/model                        
   |   |---FileListDataSource.ets                // 数据模型层-列表数据模型 
   |   |---FileItemModel.ets                     // 数据模型层-列表项数据模型
   |---/src/main/ets/view                        
   |   |---MainPage.ets                          // 视图层-场景列表页面
   |---/src/main/ets/workers                        
   |   |---Worker.ets                            // Worker线程

写在最后

如果你觉得这篇内容对你还蛮有帮助，我想邀请你帮我三个小忙：
点赞，转发，有你们的『点赞和评论』，才是我创造的动力。
关注小编，同时可以期待后续文章ing🚀，不定期分享原创知识。
想要获取更多完整鸿蒙最新VIP学习资源，请移步前往小编：https://qr21.cn/FV7h05