1. const path = require('path');
    2. const fse  = require('fs-extra');//  fs的扩展包
    5. //  合并文件
    6. const UPLOAD_DIR = path.resolve(__dirname,'target');
    7. //  需要合成的文件名称
    8. const filename = 'yb'
    9. //  合成后的路径文件路径
    10. const filePath = path.resolve(__dirname,'img',`${filename}.jpeg`);
    11. /**
    12.  * 先读取出来然后写入文件
    13.  * @param {path} 写入路径 
    14.  * @param {writeStream} 写入流 
    15.  * @returns Promise
    16.  */
    17. const pipeStream = (path ,writeStream) => 
    18.   new Promise(resolve => {
    19.     //  想读出来 后写入
    20.     const readStream = fse.createReadStream(path);
    21.     //  结束之后就返回成功
    22.     readStream.on('end',()=>{
    23.       //  成功后就删除文件 逐个删除
    24.       fse.unlinkSync(path)
    25.       resolve()
    26.     })
    27.     readStream.pipe(writeStream)
    28.   })
    30. //
    31. const mergeFileChunk = async (filePath,filename,size) =>{
    32.   //  文件地址
    33.   const chunkDir = path.resolve(UPLOAD_DIR,filename);
    35.   //  读取目录下所有文件 返回一个数组类型
    36.   const chunkPaths = await fse.readdir(chunkDir)
    38.   //  因为获取的文件可能是无须的，所以需要排序
    39.   chunkPaths.sort((a,b)=> a.split('-')[1] - b.split('-')[1])
    41.   //  并发
    42.   await Promise.all(
    43.     //  编程一个Promise的写入数组
    44.     chunkPaths.map((chunkPath,index)=>{
    45.       //  返回一个promise
    46.       //  传入 1、每一块地址  2、创建写入流
    47.       pipeStream(
    48.         path.resolve(chunkDir,chunkPath),
    49.         //  写入文件名称  写文件大小(从哪个先开始)
    50.         fse.createWriteStream(filePath,{
    51.           start:index * size,
    52.           end:(index + 1) * size
    53.         })
    54.       )
    55.     })
    56.     )
    57.     //  成功后删除文件目录
    58.     fse.rmdirSync(chunkDirs)
    59. }
    60. mergeFileChunk(filePath,filename,0.5 * 1024 * 1024)