前端大文件上传（分片上传）与下载

一、问题

日常业务中难免出现前端需要向后端传输大型文件的情况，这时单次的请求不能满足传输大文件的需求，就需要用到分片上传
业务需求为：用户可以上传小于20G的镜像文件，并进显示当前上传进度
前端：vue3.x+Element Plus组件+axios

二、思路

解决思路简单为前端选择文件后读取到文件的基本信息，包括：文件的大小、文件格式等信息，用于前端校验，校验完成后将文件进行切片并通过请求轮询把切片传递给后端

Vue的元素代码如下，主要借助el-upload组件：

<template>...<!-- 文件上传 --><el-upload:show-file-list="false"actionclass="mirror-upload":http-request="putinMirror"><button>上传环境镜像</button></el-upload>...<!-- 进度显示 --><el-progress:percentage="progress":indeterminate="true"/>...
</template>
<script setup>// 引入封装好的接口api，根据提供的接口文档自行封装即可import {// 普通get请求apicheckMirrorFileApi,// 普通post请求apiuploadShardFileApi,} from "@/assets/api/uploadApi.js"import { ref } from 'vue'// 文件输进度条const progress = ref(0)...
</script>

1、选择文件

配合组件选取需要上传的文件

/* 上传环境镜像 分片上传 */
const putinMirror = async (file) => {// 校验文件是否符合规范（注意这里的异步方法，因为调用了接口加上await，校验函数若不调用接口可以不写await，否则返回promise对象）if (await checkMirrorFile(file)) {// 文件相关信息let files = file.file// 从0开始的切片let shardIndex = 0// 调用切片方法uploadFile(files, shardIndex)}
}

2、校验文件是否符合规范

这一步可以根据需求来进行校验，这里需要通过接口校验当前服务器可用的磁盘容量来判断是否有足够的空间用于存放将要上传的文件

/* 校验上传镜像文件是否符合规范 */
const checkMirrorFile = async (file) => {// 校验文件格式是否正确，支持.acow2/.iso/.ovf/.zip/.tarlet fileType = file.file.name.split('.')if (fileType[fileType.length - 1] !== 'acow2' && fileType[fileType.length - 1] !== 'iso' && fileType[fileType.length - 1] !== 'ovf' && fileType[fileType.length - 1] !== 'zip' && fileType[fileType.length - 1] !== 'tar') {ElMessage.warning('文件格式错误，仅支持.acow2/.iso/.ovf/.zip/.tar')return false}// 校验文件大小是否满足let fileSize = file.file.size//文件大小是否超出20Gif (fileSize > 20 * 1024 * 1024 * 1024) {ElMessage.warning('上传文件大小不超过20G')return false}const res = await checkMirrorFileApi()if (res.code !== 200) {ElMessage.warning('暂时无法查看磁盘可用空间，请重试')return false}// 查看磁盘容量大小if (res.data.diskDevInfos && res.data.diskDevInfos.length > 0) {let saveSize = 0res.data.diskDevInfos.forEach(i => {// 磁盘空间赋值if (i.devName === '/dev/mapper/centos-root') {// 返回值为GB，转为字节BsaveSize = i.free * 1024 * 1024 * 1024}})// 上传的文件大小没有超出磁盘可用空间if (fileSize < saveSize) {return true} else {ElMessage.warning('文件大小超出磁盘可用空间容量')return false}} else {ElMessage.warning('文件大小超出磁盘可用空间容量')return false}
}

3、文件切片上传

校验完成后就可以进行文件的切片上传了，这里用的类似接口轮询的方式，每次携带一个切片信息给后端，后端接受到切片并返回成功状态码后再进行下一次切片的上传，代码如下：
当然这里后端没有过多的做切片的处理，可以通过前端使用多线程，或者不等接口响应成功就进行下一次传递切片的过程进行上传的提速，这里具体怎么实现看业务需求或者怎么配合上传。

/* 文件切片上传 */
const uploadFile = async (file, shardIndex, createTime, savePath, relativePath, timeMillis) => {// 文件名let name = file.name// 文件大小let size = file.size// 分片大小let shardSize = 1024 * 1024 * 5// 分片总数let shardTotal = Math.ceil(size / shardSize)if (shardIndex >= shardTotal) {isAlive.value = falseprogress.value = 100return}// 文件开始结束的位置let start = shardIndex * shardSizelet end = Math.min(start + shardSize, size)// 开始切割let packet = file.slice(start, end)let formData = new FormData()formData.append("file", packet)formData.append("fileName", name)formData.append("size", size)formData.append("shardIndex", shardIndex)formData.append("shardSize", shardSize)formData.append("shardTotal", shardTotal)// 下面这些值是后端组装切片时需要的，跟前端关系不大if (createTime) formData.append("createTime", createTime)if (savePath) formData.append("savePath", savePath)if (shardIndex < shardTotal) {// 进度条保留两位小数展示progress.value = ((shardIndex / shardTotal) * 100).toFixed(2) * 1const res = await uploadShardFileApi(formData)if (res.code !== 200) {ElMessage.error(res.msg)progress.value = 0return}if (res.msg == '上传成功' && res.data.fileName && res.data.filePath) {// 这里为所有切片上传成功后进行的操作...}shardIndex++uploadFile(file, shardIndex, res.data.createTime, res.data.savePath, res.data.relativePath, res.data.timeMillis)}
}

4、分片上传注意点

首先就是需要配置一下Nginx，我这里的每一个切片文件的大小为5MB，但是上传第一片的时候会报413的状态码，因为Nginx默认上传文件的大小是1M，所以叫运维或者后端同学改一下配置参数，保证文件传输时不会受到服务器的限制。

5、大文件下载

这里简单说一下业务中遇到的大文件下载，上述镜像文件上传之后是支持用户下载的，所以怎样处理20G文件的下载也是需要考虑的，我与后端小伙伴尝试过通过range推流的方式来处理大文件的下载，当下载时除了控制台能看到后一直在推流过来，界面上不会出现下载进度的窗口，而且当文件大小超过2G时会出现浏览器缓存不足导致推流的中断，这里没有系统研究具体原因
解决方法是后端直接将文件所存的地址返回给我，当然也可以通过Nginx配置访问到文件存储的位置也可以，前端则通过创建a标签的方式进行下载，这样可以直接调用到浏览器自带的下载直接显示出来当前文件下载的相关信息：下载进度、传输的速率和文件大小，用户体验更好，代码如下：

const downloadMirror = async (item) => {let t = {id: item.id,}const res = await downloadMirrorApi(t)if (res.headers["content-disposition"]) {let temp = res.headers["content-disposition"].split(";")[1].split("filename=")[1]let fileName = decodeURIComponent(temp)// 通过创建a标签实现文件下载let link = document.createElement('a')link.download = fileNamelink.style.display = 'none'link.href = res.data.msgdocument.body.appendChild(link)link.click()document.body.removeChild(link)} else {ElMessage({message: '该文件不存在',type: 'warning',})}
}