Node.js实现分片上传断点续传示例详解

首先，为了实现分片上传断点续传，我们需要使用Node.js提供的相关模块和技术。具体来说，我们需要用到http模块和fs模块。

步骤如下：

1.创建一个基于http模块的服务器，用于接收上传的文件，并为每一个上传的文件创建一个唯一的标识（例如文件名、UUID等），并将这些标识保存到一个数组中，以便用于断点续传。

示例代码：

const http = require('http');
const fs = require('fs');
const server = http.createServer((req, res) => {
  // 处理文件上传请求
  if (req.url === '/upload') {
    let file = req.headers['x-file-name']; // 获取上传的文件名
    let fileSize = parseInt(req.headers['content-length']); // 获取上传的文件大小
    let fileId = generateFileId(file); // 为文件生成唯一标识
    // 将文件标识添加到数组中，以便用于断点续传
    fileIds.push(fileId); 
    // 保存为临时文件
    let tempFile = fs.createWriteStream(`./temp/${fileId}.temp`);
    req.pipe(tempFile);
    // 响应客户端上传成功
    res.writeHead(200, { 'Content-Type': 'text/plain' });
    res.end(`Uploaded ${file}`);
  }
});

2.使用fs模块将上传完整的文件进行合并保存。在合并时需要采用从添加到数组中的文件标识中分离出文件名的方式获取到上传的文件名，并将所有上传的分片文件按照顺序进行合并。

示例代码：

const fs = require('fs');
const mergeFiles = (fileId) => {
  let parts = fileIds.filter(id => id.startsWith(fileId));
  let file = parts[0].split('.')[0]; // 获取上传的文件名
  let writeStream = fs.createWriteStream(`./uploads/${file}`);
  for (let part of parts) {
    let readStream = fs.createReadStream(`./temp/${part}`);
    readStream.pipe(writeStream, { end: false });
    readStream.on('end', () => {
      fs.unlink(`./temp/${part}`, (err) => {
        if (err) throw err;
      });
    });
  }
};

3.为了实现断点续传，我们可以使用下面的步骤：

• 如果客户端在上传时发生中断，则需要在客户端保存上传的进度信息，例如已经上传的字节数、上传的总字节数等信息。

• 当客户端重新上传时，通过请求头中的信息告诉服务器从哪一个字节开始上传。

• 服务器收到请求后，需要将上传的文件按照指定位置（从已上传的字节数处）进行写入，从而实现断点续传。

示例代码：

const http = require('http');
const fs = require('fs');
const server = http.createServer((req, res) => {
  // 处理文件上传请求
  if (req.url === '/upload') {
    let file = req.headers['x-file-name']; // 获取上传的文件名
    let fileSize = parseInt(req.headers['content-length']); // 获取上传的文件大小
    let fileId = generateFileId(file); // 为文件生成唯一标识
    // 如果有上传进度，则从已经上传了多少字节的位置开始上传
    let start = parseInt(req.headers['x-start'] || 0);
    // 如果已经上传完成，则直接返回成功
    if (start >= fileSize) {
      res.writeHead(200, { 'Content-Type': 'text/plain' });
      res.end(`Uploaded ${file}`);
      return;
    }
    // 将文件标识添加到数组中，以便用于断点续传
    fileIds.push(fileId); 
    // 保存为临时文件
    let tempFile = fs.createWriteStream(`./temp/${fileId}.temp`, { flags: 'a' });
    req.pipe(tempFile, { end: false });
    // 在上传完成后将文件合并
    req.on('end', () => {
      if (fileSize == start + tempFile.bytesWritten) {
        mergeFiles(fileId);
        // 响应客户端上传成功
        res.writeHead(200, { 'Content-Type': 'text/plain' });
        res.end(`Uploaded ${file}`);
      }
    });
  }
});

总的而言，实现分片上传断点续传的过程比较复杂，需要仔细考虑每一步的实现细节。但如果能够认真理解每一步的实现原理并掌握相关技术，就能够写出一个高效稳定的分片上传断点续传应用。