鸿蒙6.0应用开发——压缩与解压

文章目录

本文针对常见的几种压缩、解压场景，介绍相关函数的使用方法。

接口说明

以下是示例中使用的主要接口，更多接口及使用方式请见@ohos.zlib (Zip模块)(…/…/reference/apis-basic-services-kit/js-apis-zlib.md)。

接口名 接口描述
compressFile(inFile: string, outFile: string, options: Options): Promise 压缩文件。
decompressFile(inFile: string, outFile: string, options?: Options): Promise 解压文件。
compress(dest: ArrayBuffer, source: ArrayBuffer, sourceLen?: number): Promise 将源缓冲区压缩到目标缓冲区。
compressBound(sourceLen: number): Promise 计算返回压缩大小的上限。
uncompress(dest:ArrayBuffer, source: ArrayBuffer, sourceLen?: number): Promise 将压缩后的数据解压缩为原始的未压缩形式。
deflate(strm: ZStream, flush: CompressFlushMode): Promise 压缩数据。
inflate(strm: ZStream, flush: CompressFlushMode): Promise 解压数据。

开发步骤

环境准备

在应用沙箱目录下创建一个测试文件data.txt，并写入测试数据。示例代码如下。

import { fileIo as fs} from '@kit.CoreFileKit';

@Entry
@Component
struct Index {
  @State dataSize: number = 0;

  build() {
    Row() {
      Column() {
        // 在应用沙箱目录下创建文件data.txt，并写入测试数据
        Button('创建测试文件data.txt').onClick(() => {
          let path = this.getUIContext()?.getHostContext()?.filesDir;
          // 创建文件data.txt
          let inFile = fs.openSync(path + '/data.txt', fs.OpenMode.READ_WRITE | fs.OpenMode.CREATE);
          // 写入测试数据
          for (let index = 0; index < 100; index++) {
            fs.writeSync(inFile.fd, index + ': hello world, hello world, hello world, hello world, hello world.\n');
          }
          // 获取测试数据原始大小，并保存到dataSize中
          let stat = fs.statSync(inFile.path);
          this.dataSize = stat.size;
          console.info('dataSize: ' + this.dataSize);
          // 关闭文件
          fs.closeSync(inFile);
        })
      }
    }
    .height('100%')
    .width('100%')
  }
}

代码逻辑走读：

  1. 导入模块：代码首先从’@kit.CoreFileKit’中导入fileIo模块，别名为fs，用于文件操作。
  2. 组件定义：定义了一个名为Index的组件，该组件包含一个状态变量dataSize，初始值为0。
  3. 构建UI：在build方法中，定义了一个Row布局，内部包含一个Column布局。
  4. 按钮功能：在Column布局中，定义了一个按钮，按钮文本为"创建测试文件data.txt"。点击该按钮时，会执行按钮的点击事件处理函数。
  5. 文件操作：在点击事件处理函数中，首先获取应用的沙箱目录路径。
  6. 文件创建：使用fs.openSync方法以读写模式和创建模式打开或创建文件data.txt。
  7. 文件写入：使用fs.writeSync方法循环写入100行文本数据到文件中。
  8. 文件状态获取：使用fs.statSync方法获取文件的状态信息，并将文件大小保存到状态变量dataSize中。
  9. 控制台输出：在控制台输出dataSize的值。
  10. 文件关闭：使用fs.closeSync方法关闭文件。
  11. 布局设置：设置Row布局的高度和宽度为100%。

Zip文件的压缩与解压

采用接口zlib.compressFile()将文件data.txt压缩并归档到data.zip中，采用接口zlib.decompressFile()将data.zip解压到应用沙箱目录下，示例代码如下。

import { BusinessError, zlib } from '@kit.BasicServicesKit';

@Entry
@Component
struct Index {
  build() {
    Row() {
      // 示例一：将测试文件data.txt压缩并归档到data.zip中。
      Button('compressFile').onClick(() => {
        let path = this.getUIContext()?.getHostContext()?.filesDir;
        let inFile = path + '/data.txt';
        let outFile = path + '/data.zip';
        let options: zlib.Options = {};
        zlib.compressFile(inFile, outFile, options).then((data: void) => {
          console.info('compressFile success, data: ' + JSON.stringify(data));
        }).catch((errData: BusinessError) => {
          console.error(`compressFile errCode: ${errData.code}, message: ${errData.message}`);
        })
      })

      // 示例二：将data.zip文件解压到应用沙箱目录下。
      Button('decompressFile').onClick(() => {
        let path = this.getUIContext()?.getHostContext()?.filesDir;
        let inFile = path + '/data.zip';
        let outFile = path;
        let options: zlib.Options = {};
        zlib.decompressFile(inFile, outFile, options).then((data: void) => {
          console.info('decompressFile success, data: ' + JSON.stringify(data));
        }).catch((errData: BusinessError) => {
          console.error(`decompressFile errCode: ${errData.code}, message: ${errData.message}`);
        })
      })
    }
    .height('100%')
    .width('100%')
  }
}

代码逻辑走读：

  1. 导入必要的模块：
    • 从@kit.BasicServicesKit导入BusinessError和zlib。
  2. 定义组件Index：
    • 使用@Entry和@Component装饰器标记Index为入口组件。
  3. 构建UI结构：
    • 使用Row布局容器来放置按钮。
  4. 压缩文件按钮逻辑：
    • 创建一个按钮，文本为compressFile。
    • 点击按钮时，获取应用的沙箱目录路径。
    • 定义输入文件路径inFile和输出文件路径outFile。
    • 使用zlib.compressFile方法进行文件压缩，成功时打印日志，失败时捕获并打印错误信息。
  5. 解压缩文件按钮逻辑：
    • 创建一个按钮，文本为decompressFile。
    • 点击按钮时，获取应用的沙箱目录路径。
    • 定义输入文件路径inFile和输出目录outFile。
    • 使用zlib.decompressFile方法进行文件解压，成功时打印日志，失败时捕获并打印错误信息。
  6. 设置布局尺寸：
    • 设置Row的高度和宽度为100%。

已知大小缓冲区的压缩与解压

针对一个已知大小的缓冲区中的数据，使用接口compress()将其压缩到一个目标缓冲区中，使用接口compressBound()计算压缩目标缓冲区大小的上限值，使用接口uncompress()对存储压缩数据的缓冲区进行解压。由于解压时无法获取解压后原始数据的大小，为了确认解压后目标缓冲区的大小，需要在压缩前获取原始数据的大小并保存，示例代码如下。

import { fileIo as fs} from '@kit.CoreFileKit';
import { BusinessError, zlib } from '@kit.BasicServicesKit';

@Entry
@Component
struct Index {
  @State dataSize: number = 0;  // 用于保存原始数据的大小

  build() {
    Row() {
      // 示例一：读取data.txt文件内容并存入一个缓冲区，调用compress接口压缩缓冲区中的数据到目标缓冲区，并将目标缓冲区的内容写入文件data.bin
      Button('compress buffer').onClick(() => {
        let path = this.getUIContext()?.getHostContext()?.filesDir;
        let inFile = fs.openSync(path + '/data.txt', fs.OpenMode.READ_WRITE | fs.OpenMode.CREATE);
        let outFile = fs.openSync(path + '/data.bin', fs.OpenMode.READ_WRITE | fs.OpenMode.CREATE);
        // 读取data.txt文件的内容，并存入缓冲区inBuf
        let stat = fs.statSync(inFile.path);
        let inBuf = new ArrayBuffer(stat.size);
        let readLen = fs.readSync(inFile.fd, inBuf);
        console.info(`original size: ${stat.size}, read len: ${readLen}`);
        // 获取原始数据的大小，并保存
        this.dataSize = stat.size;
        // 创建一个压缩对象实例
        let zip = zlib.createZipSync();
        // 获取一个目标缓冲区的上限
        zip.compressBound(stat.size).then((data) => {
          console.info(`the max dest buf len is ${data}`);
          // 目标缓冲区outBuf
          let outBuf = new ArrayBuffer(data);
          // 将inBuf中的数据压缩到outBuf中
          zip.compress(outBuf, inBuf, readLen).then((zipOutInfo) => {
            console.info(`compress success, status ${zipOutInfo.status}, destLen  ${zipOutInfo.destLen}`);
            // 将outBuf中的数据写入到data.bin文件
            let writeLen = fs.writeSync(outFile.fd, outBuf, { length: zipOutInfo.destLen });
            console.info(`write destBuf to data.bin, writeLen ${writeLen}`);
            // 关闭文件
            fs.closeSync(inFile.fd);
            fs.closeSync(outFile.fd);
          }).catch((errData: BusinessError) => {
            console.error(`errData is errCode:${errData.code}  message:${errData.message}`);
          })
        }).catch((errData: BusinessError) => {
          console.error(`errData is errCode:${errData.code}  message:${errData.message}`);
        })
      })

      // 示例二：读取data.bin文件中的压缩数据并存入一个缓冲区，调用uncompress接口将缓冲区中的数据解压到目标缓冲区，并将目标缓冲区的内容写入文件data.txt
      Button('uncompress buffer').onClick(() => {
        let path = this.getUIContext()?.getHostContext()?.filesDir;
        let inFile = fs.openSync(path + '/data.bin', fs.OpenMode.READ_WRITE | fs.OpenMode.CREATE);
        let outFile = fs.openSync(path + '/data.txt', fs.OpenMode.READ_WRITE | fs.OpenMode.CREATE);
        // 读取data.bin文件中的压缩数据，并存入缓冲区inBuf
        let stat = fs.statSync(inFile.path);
        let inBuf = new ArrayBuffer(stat.size);
        let readLen = fs.readSync(inFile.fd, inBuf);
        console.info(`compressed data size: ${stat.size}, read len: ${readLen}`);
        // 创建一个目标缓冲区，此处的dataSize是我们进行数据压缩前保存的数据的原始大小
        let outBuf = new ArrayBuffer(this.dataSize);
        console.info(`the dest buf size is ${this.dataSize}`);
        // 创建一个压缩对象实例
        let zip = zlib.createZipSync();
        // 将inBuf中的数据解压缩outBuf中
        zip.uncompress(outBuf, inBuf, readLen).then((zipOutInfo) => {
          console.info(`uncompress success, status ${zipOutInfo.status}, destLen  ${zipOutInfo.destLen}`);
          // 将outBuf中的数据写入到data.txt文件
          let writeLen = fs.writeSync(outFile.fd, outBuf, { length: zipOutInfo.destLen });
          console.info(`write destBuf to data.txt, writeLen ${writeLen}`);
          // 关闭文件
          fs.closeSync(inFile.fd);
          fs.closeSync(outFile.fd);
        }).catch((errData: BusinessError) => {
          console.error(`errData is errCode:${errData.code}  message:${errData.message}`);
        })
      })
    }
    .height('100%')
    .width('100%')
  }
}

代码逻辑走读：

  1. 导入模块：
    • 导入fileIo模块作为fs，用于文件操作。
    • 导入BusinessError和zlib模块，用于错误处理和压缩操作。
  2. 组件定义：
    • 定义一个名为Index的组件，包含一个状态变量dataSize用于保存原始数据的大小。
  3. UI构建：
    • 使用Row布局包含两个按钮。
  4. 示例一：压缩缓冲区操作：
    • 定义一个按钮compress buffer，点击时执行压缩操作。
    • 获取文件路径，打开data.txt和data.bin文件。
    • 读取data.txt文件内容到缓冲区inBuf。
    • 获取原始数据大小并保存。
    • 创建压缩对象实例，获取目标缓冲区上限。
    • 将inBuf中的数据压缩到outBuf中。
    • 将outBuf中的数据写入data.bin文件。
    • 关闭文件。
  5. 示例二：解压缩缓冲区操作：
    • 定义一个按钮uncompress buffer，点击时执行解压缩操作。
    • 获取文件路径，打开data.bin和data.txt文件。
    • 读取data.bin文件中的压缩数据到缓冲区inBuf。
    • 创建目标缓冲区outBuf，其大小为dataSize。
    • 创建压缩对象实例，将inBuf中的数据解压缩到outBuf中。
    • 将outBuf中的数据写入data.txt文件。
    • 关闭文件。
  6. 布局设置：
    • 设置组件的高度和宽度为100%。

未知大小缓冲区的压缩与解压（zlib格式）

针对一个未知大小的缓冲区中的数据，使用接口deflate()将从一个原始输入流中读取的数据进行压缩，使用接口inflate()将从一个压缩输入流中读取的数据进行解压，示例代码如下。

import { fileIo as fs} from '@kit.CoreFileKit';
import { zlib } from '@kit.BasicServicesKit';

@Entry
@Component
struct Index {
  build() {
    Row() {
      // 示例一：从文件中不断读取数据进行压缩
      Button('deflateFile').onClick(() => {
        let path = this.getUIContext()?.getHostContext()?.filesDir;
        let inFile = fs.openSync(path + '/data.txt', fs.OpenMode.READ_WRITE | fs.OpenMode.CREATE);
        let outFile = fs.openSync(path + '/data.bin', fs.OpenMode.READ_WRITE | fs.OpenMode.CREATE);
        deflateFile(inFile, outFile).then(() => {
          console.info('deflateFile success');
          fs.closeSync(inFile.fd);
          fs.closeSync(outFile.fd);
        })
      })

      // 示例二：从文件中不断读取压缩数据进行解压
      Button('inflateFile').onClick(() => {
        let path = this.getUIContext()?.getHostContext()?.filesDir;
        let inFile = fs.openSync(path + '/data.bin', fs.OpenMode.READ_WRITE | fs.OpenMode.CREATE);
        let outFile = fs.openSync(path + '/data.txt', fs.OpenMode.READ_WRITE | fs.OpenMode.CREATE);
        inflateFile(inFile, outFile).then(() => {
          console.info('inflateFile success');
          fs.closeSync(inFile.fd);
          fs.closeSync(outFile.fd);
        })
      })
    }
    .height('100%')
    .width('100%')
  }
}

// 从一个文件中，不断的读入数据，进行压缩，并写入到另一个文件中
async function deflateFile(src: fs.File, dest: fs.File) {
  let flush = zlib.CompressFlushMode.NO_FLUSH;
  let strm: zlib.ZStream = {};  // 初始化一个压缩流
  const BUFLEN = 4096;
  let inBuf = new ArrayBuffer(BUFLEN);  // 初始化一个输入缓冲区
  let outBuf = new ArrayBuffer(BUFLEN); // 初始化一个输出缓冲区
  // 创建一个压缩对象实例
  let zip = zlib.createZipSync();
  // 初始化流的状态
  let initStatus = zip.deflateInit(strm, zlib.CompressLevel.COMPRESS_LEVEL_BEST_SPEED);
  console.info('deflateInit ret: ' + (await initStatus).valueOf());
  do {
    // 从文件中读取数据到缓冲区
    let readLen = fs.readSync(src.fd, inBuf);
    console.info('readSync readLen: ' + readLen);
    flush = readLen == 0 ? zlib.CompressFlushMode.FINISH : zlib.CompressFlushMode.NO_FLUSH;
    // 设置输入缓冲区
    strm.availableIn = readLen;
    strm.nextIn = inBuf;
    do {
      // 设置输出缓冲区
      strm.availableOut = BUFLEN;
      strm.nextOut = outBuf;
      try {
        // 压缩输入缓冲区中数据到输出缓冲区
        let deflateStatus = zip.deflate(strm, flush);
        console.info('deflate ret: ' + (await deflateStatus).valueOf());
        // 更新流的状态
        let innerStrm = zip.getZStream();
        strm.availableIn = (await innerStrm).availableIn;
        strm.nextIn = (await innerStrm).nextIn;
        strm.availableOut = (await innerStrm).availableOut;
        strm.nextOut = (await innerStrm).nextOut;
        strm.totalIn = (await innerStrm).totalIn;
        strm.totalOut = (await innerStrm).totalOut;

        if (strm.availableOut != undefined) {
          // 将已完成压缩的数据，写入到输出文件中
          let have = BUFLEN - strm.availableOut;
          let writeLen = fs.writeSync(dest.fd, outBuf, { length: have });
          console.info(`writeSync writeLen: ${writeLen}`);
        }
      } catch (err) {
        console.error('deflate err: ' + JSON.stringify(err));
      }
    } while (strm.availableOut == 0); // 循环压缩输入缓冲区中剩余的数据，直到全部完成压缩
  } while (flush != zlib.CompressFlushMode.FINISH); // 循环从文件中读取数据，直到数据全部读取
  // 释放资源
  zip.deflateEnd(strm);
}

// 从一个文件中，不断的读入已压缩的数据，进行解压，并写入到另一个文件中
async function inflateFile(src: fs.File, dest: fs.File) {
  let status: zlib.ReturnStatus = zlib.ReturnStatus.OK;
  let strm: zlib.ZStream = {};  // 初始化一个压缩流
  const BUFLEN = 4096;
  let inBuf = new ArrayBuffer(BUFLEN);  // 初始化一个输入缓冲区
  let outBuf = new ArrayBuffer(BUFLEN); // 初始化一个输出缓冲区
  // 创建一个压缩对象实例
  let zip = zlib.createZipSync();
  // 初始化流的状态
  let initStatus = zip.inflateInit(strm);
  console.info('inflateInit ret: ' + (await initStatus).valueOf());
  do {
    // 从文件中读取已压缩的数据到缓冲区
    let readLen = fs.readSync(src.fd, inBuf);
    console.info('readSync readLen: ' + readLen);
    if (readLen == 0) {
      break;
    }
    // 设置输入缓冲区
    strm.availableIn = readLen;
    strm.nextIn = inBuf;
    do {
      // 设置输出缓冲区
      strm.availableOut = BUFLEN;
      strm.nextOut = outBuf;
      try {
        // 解压输入缓冲区中数据到输出缓冲区
        let inflateStatus = zip.inflate(strm, zlib.CompressFlushMode.NO_FLUSH);
        console.info('inflate ret: ' + (await inflateStatus).valueOf());
        status = await inflateStatus;
        // 更新流的状态
        let innerStrm = zip.getZStream();
        strm.availableIn = (await innerStrm).availableIn;
        strm.nextIn = (await innerStrm).nextIn;
        strm.availableOut = (await innerStrm).availableOut;
        strm.nextOut = (await innerStrm).nextOut;
        strm.totalIn = (await innerStrm).totalIn;
        strm.totalOut = (await innerStrm).totalOut;

        if (strm.availableOut != undefined) {
          // 将已完成解压的数据，写入到输出文件中
          let have = BUFLEN - strm.availableOut;
          let writeLen = fs.writeSync(dest.fd, outBuf, { length: have });
          console.info(`writeSync writeLen: ${writeLen}`);
        }
      } catch (err) {
        console.error('inflate err: ' + JSON.stringify(err));
      }
    } while (strm.availableOut == 0)  // 循环解压输入缓冲区中剩余的数据，直到全部完成解压
  } while (status != zlib.ReturnStatus.STREAM_END.valueOf())  // 循环从文件中读取数据，直到数据全部读取
  // 释放资源
  zip.inflateEnd(strm);
}

代码逻辑走读：

  1. 导入模块：
    • 导入fileIo为fs，用于文件操作。
    • 导入zlib用于压缩和解压缩。
  2. 组件定义：
    • 使用@Entry和@Component装饰器定义了一个名为Index的组件。
  3. UI构建：
    • 在build方法中，使用Row布局组件创建了一个行。
    • 在行中，定义了两个按钮：deflateFile和inflateFile。
  4. 按钮功能：
    • deflateFile按钮：点击时，打开两个文件（输入和输出），调用deflateFile函数进行压缩，并在压缩完成后关闭文件。
    • inflateFile按钮：点击时，打开两个文件（输入和输出），调用inflateFile函数进行解压缩，并在解压缩完成后关闭文件。
  5. 压缩函数：
    • deflateFile函数：读取源文件数据，使用zlib库进行压缩，并将压缩后的数据写入目标文件。
    • inflateFile函数：读取源文件数据，使用zlib库进行解压缩，并将解压缩后的数据写入目标文件。
  6. 文件操作：
    • 使用fs.openSync打开文件。
    • 使用fs.readSync和fs.writeSync读取和写入文件数据。
    • 使用fs.closeSync关闭文件。
  7. 压缩和解压缩逻辑：
    • 初始化压缩或解压缩流。
    • 循环读取文件数据，进行压缩或解压缩。
    • 将处理后的数据写入目标文件。
    • 循环直到所有数据处理完毕。
    • 释放压缩流资源。
  8. 错误处理：
    • 使用try-catch块捕获并记录可能的错误。

未知大小缓冲区的压缩与解压（gzip格式）

采用gzip格式，针对一个未知大小的缓冲区中的数据，使用接口deflate()将从一个原始输入流中读取的数据进行压缩，使用接口inflate()将从一个压缩输入流中读取的数据进行解压，示例代码如下。

import { fileIo as fs} from '@kit.CoreFileKit';
import { zlib } from '@kit.BasicServicesKit';

@Entry
@Component
struct Index {
  build() {
    Row() {
      // 示例一：从文件中不断读取数据进行压缩
      Button('deflateGzipFile').onClick(() => {
        let path = this.getUIContext()?.getHostContext()?.filesDir;
        let inFile = fs.openSync(path + '/data.txt', fs.OpenMode.READ_WRITE | fs.OpenMode.CREATE);
        let outFile = fs.openSync(path + '/data.gz', fs.OpenMode.READ_WRITE | fs.OpenMode.CREATE);
        deflateGzipFile(inFile, outFile).then(() => {
          console.info('deflateGzipFile success');
          fs.closeSync(inFile.fd);
          fs.closeSync(outFile.fd);
        })
      })

      // 示例二：从文件中不断读取压缩数据进行解压
      Button('inflateGzipFile').onClick(() => {
        let path = this.getUIContext()?.getHostContext()?.filesDir;
        let inFile = fs.openSync(path + '/data.gz', fs.OpenMode.READ_WRITE | fs.OpenMode.CREATE);
        let outFile = fs.openSync(path + '/data.txt', fs.OpenMode.READ_WRITE | fs.OpenMode.CREATE);
        inflateGzipFile(inFile, outFile).then(() => {
          console.info('inflateGzipFile success');
          fs.closeSync(inFile.fd);
          fs.closeSync(outFile.fd);
        })
      })
    }
    .height('100%')
    .width('100%')
  }
}

// 从一个文件中，不断的读入数据，进行压缩，并写入到另一个文件中
async function deflateGzipFile(src: fs.File, dest: fs.File) {
  let flush = zlib.CompressFlushMode.NO_FLUSH;
  let strm: zlib.ZStream = {};  // 初始化一个压缩流
  const BUFLEN = 4096;
  let inBuf = new ArrayBuffer(BUFLEN);  // 初始化一个输入缓冲区
  let outBuf = new ArrayBuffer(BUFLEN); // 初始化一个输出缓冲区
  // 创建一个压缩对象实例
  let zip = zlib.createZipSync();
  // 初始化流的状态，windowBits > 15时，启用gzip格式
  let windowBits = 15 + 16;
  let initStatus = zip.deflateInit2(strm, zlib.CompressLevel.COMPRESS_LEVEL_BEST_SPEED,
    zlib.CompressMethod.DEFLATED, windowBits, zlib.MemLevel.MEM_LEVEL_DEFAULT,
    zlib.CompressStrategy.COMPRESS_STRATEGY_DEFAULT_STRATEGY);
  console.info('deflateInit2 ret: ' + (await initStatus).valueOf());
  do {
    // 从文件中读取数据到缓冲区
    let readLen = fs.readSync(src.fd, inBuf);
    console.info('readSync readLen: ' + readLen);
    flush = readLen == 0 ? zlib.CompressFlushMode.FINISH : zlib.CompressFlushMode.NO_FLUSH;
    // 设置输入缓冲区
    strm.availableIn = readLen;
    strm.nextIn = inBuf;
    do {
      // 设置输出缓冲区
      strm.availableOut = BUFLEN;
      strm.nextOut = outBuf;
      try {
        // 压缩输入缓冲区中数据到输出缓冲区
        let deflateStatus = zip.deflate(strm, flush);
        console.info('deflate ret: ' + (await deflateStatus).valueOf());
        // 更新流的状态
        let innerStrm = zip.getZStream();
        strm.availableIn = (await innerStrm).availableIn;
        strm.nextIn = (await innerStrm).nextIn;
        strm.availableOut = (await innerStrm).availableOut;
        strm.nextOut = (await innerStrm).nextOut;
        strm.totalIn = (await innerStrm).totalIn;
        strm.totalOut = (await innerStrm).totalOut;

        if (strm.availableOut != undefined) {
          // 将已完成压缩的数据，写入到输出文件中
          let have = BUFLEN - strm.availableOut;
          let writeLen = fs.writeSync(dest.fd, outBuf, { length: have });
          console.info(`writeSync writeLen: ${writeLen}`);
        }
      } catch (err) {
        console.error('deflate err: ' + JSON.stringify(err));
      }
    } while (strm.availableOut == 0); // 循环压缩输入缓冲区中剩余的数据，直到全部完成压缩
  } while (flush != zlib.CompressFlushMode.FINISH); // 循环从文件中读取数据，直到数据全部读取
  // 释放资源
  zip.deflateEnd(strm);
}

// 从一个文件中，不断的读入已压缩的数据，进行解压，并写入到另一个文件中
async function inflateGzipFile(src: fs.File, dest: fs.File) {
  let status: zlib.ReturnStatus = zlib.ReturnStatus.OK;
  let strm: zlib.ZStream = {};  // 初始化一个压缩流
  const BUFLEN = 4096;
  let inBuf = new ArrayBuffer(BUFLEN);  // 初始化一个输入缓冲区
  let outBuf = new ArrayBuffer(BUFLEN); // 初始化一个输出缓冲区
  // 创建一个压缩对象实例
  let zip = zlib.createZipSync();
  // 初始化流的状态，windowBits > 15时，启用gzip格式
  let windowBits = 15 + 16;
  let initStatus = zip.inflateInit2(strm, windowBits);
  console.info('inflateInit2 ret: ' + (await initStatus).valueOf());
  do {
    // 从文件中读取已压缩的数据到缓冲区
    let readLen = fs.readSync(src.fd, inBuf);
    console.info('readSync readLen: ' + readLen);
    if (readLen == 0) {
      break;
    }
    // 设置输入缓冲区
    strm.availableIn = readLen;
    strm.nextIn = inBuf;
    do {
      // 设置输出缓冲区
      strm.availableOut = BUFLEN;
      strm.nextOut = outBuf;
      try {
        // 解压输入缓冲区中数据到输出缓冲区
        let inflateStatus = zip.inflate(strm, zlib.CompressFlushMode.NO_FLUSH);
        console.info('inflate ret: ' + (await inflateStatus).valueOf());
        status = await inflateStatus;
        // 更新流的状态
        let innerStrm = zip.getZStream();
        strm.availableIn = (await innerStrm).availableIn;
        strm.nextIn = (await innerStrm).nextIn;
        strm.availableOut = (await innerStrm).availableOut;
        strm.nextOut = (await innerStrm).nextOut;
        strm.totalIn = (await innerStrm).totalIn;
        strm.totalOut = (await innerStrm).totalOut;

        if (strm.availableOut != undefined) {
          // 将已完成解压的数据，写入到输出文件中
          let have = BUFLEN - strm.availableOut;
          let writeLen = fs.writeSync(dest.fd, outBuf, { length: have });
          console.info(`writeSync writeLen: ${writeLen}`);
        }
      } catch (err) {
        console.error('inflate err: ' + JSON.stringify(err));
      }
    } while (strm.availableOut == 0)  // 循环解压输入缓冲区中剩余的数据，直到全部完成解压
  } while (status != zlib.ReturnStatus.STREAM_END.valueOf())  // 循环从文件中读取数据，直到数据全部读取
  // 释放资源
  zip.inflateEnd(strm);
}

代码逻辑走读：

  1. 导入模块：
    • 导入fileIo和zlib模块，用于文件操作和压缩解压缩功能。
  2. 组件定义：
    • 定义一个名为Index的组件，使用@Entry和@Component装饰器标记为入口组件。
  3. UI构建：
    • 在build方法中构建UI，使用Row布局包含两个按钮。
  4. 按钮事件处理：
    • 第一个按钮deflateGzipFile：点击时，调用deflateGzipFile函数，将文件data.txt压缩为data.gz。
    • 第二个按钮inflateGzipFile：点击时，调用inflateGzipFile函数，从data.gz解压为data.txt。
  5. 文件操作：
    • 使用fs.openSync打开文件，fs.readSync和fs.writeSync读取和写入文件数据。
    • 使用fs.closeSync关闭文件描述符。
  6. 压缩和解压缩函数：
    • deflateGzipFile：初始化压缩流，循环读取文件数据，压缩并写入输出文件。
    • inflateGzipFile：初始化解压缩流，循环读取压缩文件数据，解压并写入输出文件。
  7. 资源释放：
    • 使用zip.deflateEnd和zip.inflateEnd释放压缩流资源。
# 华为 # 鸿蒙6.0
Logo
HarmonyOS开发者社区

讨论HarmonyOS开发技术，专注于API与组件、DevEco Studio、测试、元服务和应用上架分发等。

更多推荐

cover

第41篇｜补光与水印：效果选项如何参与最终照片记录

avatar HarmonyOS开发者社区
cover

HarmonyOS 6.1 开发者盛宴｜《灵犀厨房》实战（二十三）：【交互动效】转场、列表动画与趣味反馈——让每一次点击都有温度

avatar HarmonyOS开发者社区
cover

基于HarmonyOS的英语学习应用技术实现与价值分析

avatar HarmonyOS开发者社区