HarmonyOS鸿蒙Next中下载大文件导致卡死闪退问题

import {
    DownloadFile,
    DownloadFileFail,
    DownloadFileOptions,
    DownloadFileSuccess,
    DownloadFileComplete,
    DownloadFileProgress
} from '../interface.uts'

export {
    DownloadFile,
    DownloadFileFail,
    DownloadFileOptions,
    DownloadFileSuccess,
    DownloadFileComplete
}

import fs from '@ohos.file.fs';
import http from '@ohos.net.http';
import { common } from '@kit.AbilityKit';
import { BusinessError } from '@kit.BasicServicesKit';

export function hmDownloadFile(url : string, filePath : string, options : DownloadFileOptions, isGetData : Boolean = false, isOverwrite : Boolean = false) {
    function success() : void {
        let result : DownloadFileSuccess = {
            errMsg: "ok",
            fileData: fileData,
            filePath: DOWNLOAD_TO_PATH
        };
        const completeResult : DownloadFileComplete = {
            errMsg: "ok"
        }
        options?.success?.(result);
        options?.complete?.(completeResult);
    }
    function error(err : BusinessError<void>) : void {
        console.error('$$`' + `failed. code is ${err.code}, message is ${err.message}`);
        let result : DownloadFileFail = {
            errMsg: err.message ?? ""
        };
        const completeResult : DownloadFileComplete = {
            errMsg: err.message ?? ""
        }
        options?.fail?.(result);
        options?.complete?.(completeResult);
    }
    let fileData = '';
    let contentLength = 0;
    let cuContentLength = 0;
    let arrayBuffer = new ArrayBuffer(0);
    let context = UTSHarmony.getUIAbilityContext() as common.UIAbilityContext;
    let DOWNLOAD_TO_PATH = `${context.filesDir}/save_path/${filePath}`;
    console.info('$$`' + `即将下载：${DOWNLOAD_TO_PATH}`)
    // 检查目标路径是否存在
    if (fs.accessSync(DOWNLOAD_TO_PATH)) {
        if (isOverwrite) {
            fs.rmdirSync(DOWNLOAD_TO_PATH.replace(DOWNLOAD_TO_PATH.split("/").pop(), ''));
        }
        else {
            console.info('$$`' + `已存在 ${DOWNLOAD_TO_PATH}，直接返回路径`)
            if (isGetData) fileData = fs.readTextSync(DOWNLOAD_TO_PATH); // 读取文本    
            success()
            return
        }
    }
    let httpRequest = http.createHttp();
    try {
        let requestOptions : http.HttpRequestOptions = {
            method: http.RequestMethod.GET, // 可选，默认为http.RequestMethod.GET。
            expectDataType: http.HttpDataType.ARRAY_BUFFER, // 可选，指定返回数据的类型。
            // 当使用POST请求时此字段用于传递请求体内容，具体格式与服务端协商确定。
            // extraData: 'data to send',
            // usingCache: true, // 可选，默认为true。
            // priority: 1, // 可选，默认为1。
            // 开发者根据自身业务需要添加header字段。
            // header: new Header('application/json'),
            readTimeout: 600000, // 可选，默认为60000ms。
            connectTimeout: 600000, // 可选，默认为60000ms。
            // usingProtocol: http.HttpProtocol.HTTP1_1, // 可选，协议类型默认值由系统自动指定。
            // usingProxy: false, //可选，默认不使用网络代理，自API 10开始支持该属性。
        };
        httpRequest.on('headersReceive', (header : Object) => {
            let _header = JSON.stringify(header)
            let _contentLength : number = Number(_header.split(`"content-length":"`)[1].split(`","`)[0]);
            if (_contentLength) {
                contentLength = _contentLength;
                console.log('$$`' + '数据总大小:', contentLength + ' bytes');
            }
        });
        httpRequest.on("dataReceive", (data : ArrayBuffer) => {
            cuContentLength += data.byteLength;
            arrayBuffer = mergeArrayBuffers([arrayBuffer, data]);
            // console.info('$$`' + "dataReceive length: " + JSON.stringify(data.byteLength));
            const progress : DownloadFileProgress = {
                progress: ((cuContentLength / contentLength) * 100).toFixed(0)
            }
            options?.progress?.(progress);
        });
        httpRequest.on("dataEnd", () => {
            console.info('$$`' + "Receive dataEnd !");
            fs.mkdirSync(DOWNLOAD_TO_PATH.replace(DOWNLOAD_TO_PATH.split("/").pop(), ''), true);
            let file = fs.openSync(DOWNLOAD_TO_PATH, fs.OpenMode.CREATE | fs.OpenMode.READ_WRITE)
            fs.writeSync(file.fd, arrayBuffer);
            if (isGetData) fileData = fs.readTextSync(DOWNLOAD_TO_PATH); // 读取文本    
            fs.closeSync(file.fd);
            success()
            httpRequest.destroy();
            console.log('$$`' + '文件已保存至：' + DOWNLOAD_TO_PATH);
        });
        httpRequest.requestInStream(url, requestOptions, (err : BusinessError<void>, data : number) => {
            if (!err) {
                console.info('$$`' + "requestInStream OK! ResponseCode is " + JSON.stringify(data));
            } else {
                error(err);
            }
        })
    }
    catch (err) {
        error(err);
    }
}

export function hmDeleteFile(fileName : string) {
    let context = UTSHarmony.getUIAbilityContext() as common.UIAbilityContext;
    let filePath = `${context.filesDir}/save_path/${fileName}`;
    try {
        fs.unlinkSync(filePath);
        console.info('$$`' + `delete File ${filePath} OK!`);
        return true;
    }
    catch (err) {
        console.info('$$`' + `delete File ${filePath} fail! error：${err}`);
        return false;
    }
}

function mergeArrayBuffers(buffers : ArrayBuffer[]) : ArrayBuffer {
    // 计算总长度
    let totalLength = buffers.reduce((acc, buf) => acc + buf.byteLength, 0);
    // 创建目标ArrayBuffer和视图
    let mergedArray = new Uint8Array(totalLength);
    let offset = 0;
    // 合并每个片段
    buffers.forEach(buf => {
        let uint8View = new Uint8Array(buf);
        mergedArray.set(uint8View, offset);
        offset += uint8View.length;
    });
    return mergedArray.buffer;
}

以上是源码 uniapp开发的 uts插件 鸿蒙系统下载几十兆的音频时会卡死