摘要:基于的大文件分片上傳我們?cè)谧鑫募蟼鞯臅r(shí)候,如果文件過大,可能會(huì)導(dǎo)致請(qǐng)求超時(shí)的情況。所以,在遇到需要對(duì)大文件進(jìn)行上傳的時(shí)候,就需要對(duì)文件進(jìn)行分片上傳的操作。所以把文件名稱加上。后續(xù)延伸斷點(diǎn)續(xù)傳多文件多批次上傳
基于Node.js的大文件分片上傳
我們?cè)谧鑫募蟼鞯臅r(shí)候,如果文件過大,可能會(huì)導(dǎo)致請(qǐng)求超時(shí)的情況。所以,在遇到需要對(duì)大文件進(jìn)行上傳的時(shí)候,就需要對(duì)文件進(jìn)行分片上傳的操作。同時(shí)如果文件過大,在網(wǎng)絡(luò)不佳的情況下,如何做到斷點(diǎn)續(xù)傳?也是需要記錄當(dāng)前上傳文件,然后在下一次進(jìn)行上傳請(qǐng)求的時(shí)候去做判斷。
先上代碼:代碼倉(cāng)庫(kù)地址
前端 1. index.html
文件上傳
大文件上傳測(cè)試
自定義上傳文件
2. 依賴的文件
axios.js
jquery
spark-md5.js
const Koa = require("koa");
const app = new Koa();
const Router = require("koa-router");
const multer = require("koa-multer");
const serve = require("koa-static");
const path = require("path");
const fs = require("fs-extra");
const koaBody = require("koa-body");
const { mkdirsSync } = require("./utils/dir");
const uploadPath = path.join(__dirname, "uploads");
const uploadTempPath = path.join(uploadPath, "temp");
const upload = multer({ dest: uploadTempPath });
const router = new Router();
app.use(koaBody());
/**
* single(fieldname)
* Accept a single file with the name fieldname. The single file will be stored in req.file.
*/
router.post("/file/upload", upload.single("file"), async (ctx, next) => {
console.log("file upload...")
// 根據(jù)文件hash創(chuàng)建文件夾,把默認(rèn)上傳的文件移動(dòng)當(dāng)前hash文件夾下。方便后續(xù)文件合并。
const {
name,
total,
index,
size,
hash
} = ctx.req.body;
const chunksPath = path.join(uploadPath, hash, "/");
if(!fs.existsSync(chunksPath)) mkdirsSync(chunksPath);
fs.renameSync(ctx.req.file.path, chunksPath + hash + "-" + index);
ctx.status = 200;
ctx.res.end("Success");
})
router.post("/file/merge_chunks", async (ctx, next) => {
const {
size, name, total, hash
} = ctx.request.body;
// 根據(jù)hash值,獲取分片文件。
// 創(chuàng)建存儲(chǔ)文件
// 合并
const chunksPath = path.join(uploadPath, hash, "/");
const filePath = path.join(uploadPath, name);
// 讀取所有的chunks 文件名存放在數(shù)組中
const chunks = fs.readdirSync(chunksPath);
// 創(chuàng)建存儲(chǔ)文件
fs.writeFileSync(filePath, "");
if(chunks.length !== total || chunks.length === 0) {
ctx.status = 200;
ctx.res.end("切片文件數(shù)量不符合");
return;
}
for (let i = 0; i < total; i++) {
// 追加寫入到文件中
fs.appendFileSync(filePath, fs.readFileSync(chunksPath + hash + "-" +i));
// 刪除本次使用的chunk
fs.unlinkSync(chunksPath + hash + "-" +i);
}
fs.rmdirSync(chunksPath);
// 文件合并成功,可以把文件信息進(jìn)行入庫(kù)。
ctx.status = 200;
ctx.res.end("合并成功");
})
app.use(router.routes());
app.use(router.allowedMethods());
app.use(serve(__dirname + "/static"));
app.listen(9000);
2. utils/dir.js
const path = require("path");
const fs = require("fs-extra");
const mkdirsSync = (dirname) =>?{
if(fs.existsSync(dirname))?{
return true;
} else {
if (mkdirsSync(path.dirname(dirname)))?{
fs.mkdirSync(dirname);
return true;
}
}
}
module.exports = {
mkdirsSync
};
操作步驟說(shuō)明
服務(wù)端的搭建
我們以下的操作都是保證在已經(jīng)安裝node以及npm的前提下進(jìn)行。node的安裝以及使用可以參考官方網(wǎng)站。
新建項(xiàng)目文件夾file-upload
使用npm初始化一個(gè)項(xiàng)目:cd file-upload && npm init
安裝相關(guān)依賴
npm i koa npm i koa-router --save // Koa路由 npm i koa-multer --save // 文件上傳處理模塊 npm i koa-static --save // Koa靜態(tài)資源處理模塊 npm i fs-extra --save // 文件處理 npm i koa-body --save // 請(qǐng)求參數(shù)解析
創(chuàng)建項(xiàng)目結(jié)構(gòu)
file-upload
- static
- index.html
- spark-md5.min.js
- uploads
- temp
- utils
- dir.js
- app.js
復(fù)制相應(yīng)的代碼到指定位置即可
項(xiàng)目啟動(dòng):node app.js (可以使用 nodemon 來(lái)對(duì)服務(wù)進(jìn)行管理)
訪問:http://localhost:9000/index.html
其中細(xì)節(jié)部分代碼里有相應(yīng)的注釋說(shuō)明,瀏覽代碼就一目了然。
后續(xù)延伸:斷點(diǎn)續(xù)傳、多文件多批次上傳
文章版權(quán)歸作者所有,未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請(qǐng)注明本文地址:http://m.hztianpu.com/yun/114848.html
摘要:基于的大文件分片上傳我們?cè)谧鑫募蟼鞯臅r(shí)候,如果文件過大,可能會(huì)導(dǎo)致請(qǐng)求超時(shí)的情況。所以,在遇到需要對(duì)大文件進(jìn)行上傳的時(shí)候,就需要對(duì)文件進(jìn)行分片上傳的操作。所以把文件名稱加上。后續(xù)延伸斷點(diǎn)續(xù)傳多文件多批次上傳 基于Node.js的大文件分片上傳 我們?cè)谧鑫募蟼鞯臅r(shí)候,如果文件過大,可能會(huì)導(dǎo)致請(qǐng)求超時(shí)的情況。所以,在遇到需要對(duì)大文件進(jìn)行上傳的時(shí)候,就需要對(duì)文件進(jìn)行分片上傳的操作。同時(shí)如...
摘要:基于的大文件分片上傳我們?cè)谧鑫募蟼鞯臅r(shí)候,如果文件過大,可能會(huì)導(dǎo)致請(qǐng)求超時(shí)的情況。所以,在遇到需要對(duì)大文件進(jìn)行上傳的時(shí)候,就需要對(duì)文件進(jìn)行分片上傳的操作。所以把文件名稱加上。后續(xù)延伸斷點(diǎn)續(xù)傳多文件多批次上傳 基于Node.js的大文件分片上傳 我們?cè)谧鑫募蟼鞯臅r(shí)候,如果文件過大,可能會(huì)導(dǎo)致請(qǐng)求超時(shí)的情況。所以,在遇到需要對(duì)大文件進(jìn)行上傳的時(shí)候,就需要對(duì)文件進(jìn)行分片上傳的操作。同時(shí)如...
摘要:基于的大文件分片上傳我們?cè)谧鑫募蟼鞯臅r(shí)候,如果文件過大,可能會(huì)導(dǎo)致請(qǐng)求超時(shí)的情況。所以,在遇到需要對(duì)大文件進(jìn)行上傳的時(shí)候,就需要對(duì)文件進(jìn)行分片上傳的操作。所以把文件名稱加上。方便后續(xù)文件合并。 基于Node.js的大文件分片上傳 我們?cè)谧鑫募蟼鞯臅r(shí)候,如果文件過大,可能會(huì)導(dǎo)致請(qǐng)求超時(shí)的情況。所以,在遇到需要對(duì)大文件進(jìn)行上傳的時(shí)候,就需要對(duì)文件進(jìn)行分片上傳的操作。同時(shí)如果文件過大,在...
摘要:基于的大文件分片上傳我們?cè)谧鑫募蟼鞯臅r(shí)候,如果文件過大,可能會(huì)導(dǎo)致請(qǐng)求超時(shí)的情況。所以,在遇到需要對(duì)大文件進(jìn)行上傳的時(shí)候,就需要對(duì)文件進(jìn)行分片上傳的操作。所以把文件名稱加上。方便后續(xù)文件合并。 基于Node.js的大文件分片上傳 我們?cè)谧鑫募蟼鞯臅r(shí)候,如果文件過大,可能會(huì)導(dǎo)致請(qǐng)求超時(shí)的情況。所以,在遇到需要對(duì)大文件進(jìn)行上傳的時(shí)候,就需要對(duì)文件進(jìn)行分片上傳的操作。同時(shí)如果文件過大,在...
摘要:基于的大文件分片上傳我們?cè)谧鑫募蟼鞯臅r(shí)候,如果文件過大,可能會(huì)導(dǎo)致請(qǐng)求超時(shí)的情況。所以,在遇到需要對(duì)大文件進(jìn)行上傳的時(shí)候,就需要對(duì)文件進(jìn)行分片上傳的操作。所以把文件名稱加上。方便后續(xù)文件合并。 基于Node.js的大文件分片上傳 我們?cè)谧鑫募蟼鞯臅r(shí)候,如果文件過大,可能會(huì)導(dǎo)致請(qǐng)求超時(shí)的情況。所以,在遇到需要對(duì)大文件進(jìn)行上傳的時(shí)候,就需要對(duì)文件進(jìn)行分片上傳的操作。同時(shí)如果文件過大,在...
閱讀 2948·2021-11-24 09:39
閱讀 2313·2021-11-24 09:38
閱讀 872·2021-11-22 14:44
閱讀 2158·2021-11-18 10:02
閱讀 3430·2021-11-18 10:02
閱讀 1435·2021-10-14 09:43
閱讀 6044·2021-09-29 09:35
閱讀 810·2021-07-30 15:30