node.js中express框架怎么實現文件上傳與下載的功能
這篇文章主要介紹了node.js中express框架怎么實現文件上傳與下載的功能，具有一定借鑒價值，感興趣的朋友可以參考下，希望大家閱讀完這篇文章之后大有收獲，下面讓小編帶著大家一起了解一下。
公司主營業務：網站設計、成都網站制作、移動網站開發等業務。幫助企業客戶真正實現互聯網宣傳，提高企業的競爭能力。成都創新互聯是一支青春激揚、勤奮敬業、活力青春激揚、勤奮敬業、活力澎湃、和諧高效的團隊。公司秉承以“開放、自由、嚴謹、自律”為核心的企業文化，感謝他們對我們的高要求，感謝他們從不同領域給我們帶來的挑戰，讓我們激情的團隊有機會用頭腦與智慧不斷的給客戶帶來驚喜。成都創新互聯推出靈武免費做網站回饋大家。
功能實現
前臺部分
前臺使用webUploader插件即可，這是百度開發的一款文件上傳組件，具體使用查看它的API即可。這個項目之前開發的時候前臺使用了angular.js。
$scope.fileName = "";
//創建上傳附件的對象
var $list = $("#thelist");
var uploader = WebUploader.create({
// 選完文件后，是否自動上傳。
auto: false,
// swf文件路徑
swf: '../../../lib/webUploader/Uploader.swf',
// 文件接收服務端。
server: '/publishUploadFile',
// 內部根據當前運行是創建，可能是input元素，也可能是flash.
pick : {
id : '#filePicker',
//只能選擇一個文件上傳
multiple: false
},
// pick :'#filePicker',
method: 'POST',
});
uploader.on('fileQueued', function (file) {
$scope.fileName = file.name;
$list.html("");
$list.html(file.name);
});當用戶選擇文件的時候我創建了文件上傳的對象，而在用戶真正發送消息的時候我添加了相應的參數并將附件真正的上傳上去，符合我這個項目的業務邏輯。
if($scope.fileName){
//添加參數
uploader.options.formData.fileId = fileId;
uploader.options.formData.fileName = $scope.fileName;
uploader.upload();
}后臺部分
路由就不詳細說明了，主要注意的是下載的接口我都是使用的get請求，這樣前臺在請求的時候直接新打開一個窗口拼接了相應的參數就能下載文件了。下面貼一下action層的代碼：
//發布端上傳附件
exports.publishUploadFile = function (req, res) {
messageMng.publishUploadFile(req, function (err, datas) {
res.json(datas);
});
};
//下載發布端上傳的附件
exports.exportPublishFile = function (req, res) {
messageMng.exportPublishFile(req, function (err, datas) {
if (err) {
res.set({
"Content-Disposition": "attachment;filename=" + encodeURI("error.txt")
});
res.write(err.message);
res.end();
} else {
res.download(datas.path, encodeURI(datas.name));
}
});
};
//接收端上傳附件
exports.uploadFile = function (req, res) {
messageMng.uploadFile(req, function (err, datas) {
res.json(datas);
});
};
//發布端導出附件
exports.exportFile = function (req, res) {
messageMng.exportFile(req, function (err, datas) {
if (err) {
res.set({
"Content-Disposition": "attachment;filename=" + encodeURI("error.txt")
});
res.write(err.message);
res.end();
} else {
//第一種方式 下載完的zip解壓報錯
// res.download(datas.path, datas.name + ".zip");
//第二種方式
// var path="D:/maven介紹.ppt";
var f = fs.createReadStream(datas.path);
res.writeHead(200, {
'Content-Type': 'application/force-download',
'Content-Disposition': 'attachment; filename='+ encodeURI(datas.name) + '.zip'
});
f.pipe(res);
}
});
};這里著重說一下下載zip時使用download下載完的壓縮包解壓會報錯，使用第二種方法完美解決。
然后是service層的代碼：
/**
* 發布端上傳附件
* @param req
* @param fn
*/
MessageManager.prototype.publishUploadFile = function (req, fn) {
try {
//消息ID
var fileId = req.body.fileId;
var file = req.file;
//文件上傳的目錄
var uploadFolder = path.join(__dirname, '../../upload/publishUploadFile/' + fileId);
//判斷文件夾是否存在 不存在則創建
toolUtil.mkdirSync(uploadFolder);
//將上傳的文件從臨時目錄拷貝到指定的目錄下
var fileReadStream = fs.createReadStream(file.path);
var fileWriteStream = fs.createWriteStream(uploadFolder + "/" + file.originalname);
fileReadStream.pipe(fileWriteStream);
fileWriteStream.on('close', function () {
// 刪除臨時目錄下面的文件
toolUtil.emptyDir(file.destination);
});
fn(null, {"data": "", "message": "上傳成功", "error_code": 200});
} catch (e) {
fn(e, {"data": "", "message": "上傳失敗", "error_code": e.message});
}
};
/**
* 下載發布端上傳的附件
* @param req
* @param fn
*/
MessageManager.prototype.exportPublishFile = function (req, fn) {
try {
//附件ID
var id = req.query.id;
//附件名稱或標題
var name = req.query.name;
if (id && name) {
//名稱過長的話，截取前25個字符
if (name.length > 25) {
name = name.substr(0, 24);
}
//將要壓縮得文件夾路徑
var filePath = path.join(__dirname, '../../upload/publishUploadFile/' + id + '/' + name);
if (!fs.existsSync(filePath)) {
fn(new Error("沒有附件！"), null);
} else {
fn(null, {"name": name, "path": filePath});
}
} else {
fn(new Error("id或name不能為空"), null);
}
} catch (e) {
fn(new Error(e.message), null);
}
};
/**
* 接收端上傳附件
* @param req
* @param fn
*/
MessageManager.prototype.uploadFile = function (req, fn) {
try {
//消息ID
var msgId = req.body.msgId;
//消息發送的時間
var msgSendTime = req.body.msgSendTime.slice(0, 10);
//消息的標題
var title = req.body.title;
var replyId = req.body.replyId;
var replyName = req.body.replyName;
var file = req.file;
//文件上傳的目錄
var uploadFolder = path.join(__dirname, '../../upload/messages/' + msgId + '/' + replyName);
//判斷文件夾是否存在 不存在則創建
toolUtil.mkdirSync(uploadFolder);
//組裝文件的名稱 原名稱+消息發送時間
var index = file.originalname.lastIndexOf(".");
var fileName = file.originalname.substr(0, index) + '-' + msgSendTime + "";
var suffix = file.originalname.substr(index, file.originalname.length - 1);
//將上傳的文件從臨時目錄拷貝到指定的目錄下
var fileReadStream = fs.createReadStream(file.path);
var fileWriteStream = fs.createWriteStream(uploadFolder + "/" + fileName + "." + suffix);
fileReadStream.pipe(fileWriteStream);
fileWriteStream.on('close', function () {
//刪除臨時目錄下面的文件
toolUtil.emptyDir(file.destination);
});
fn(null, {"data": "", "message": "上傳成功", "error_code": 200});
} catch (e) {
fn(e, {"data": "", "message": "上傳失敗", "error_code": e.message});
}
};
/**
* 導出消息的附件文件
* @param req
* @param fn
*/
MessageManager.prototype.exportFile = function (req, fn) {
try {
//消息ID
var id = req.query.id;
//消息名稱或標題
var name = req.query.name;
if (id && name) {
//名稱過長的話，截取前25個字符
if (name.length > 25) {
name = name.substr(0, 24);
}
//將要壓縮得文件夾路徑
var messagePath = path.join(__dirname, '../../upload/messages/' + id);
if (!fs.existsSync(messagePath)) {
fn(new Error("沒有附件！"), null);
} else {
//生成得臨時zip文件目錄
var zipPath = path.join(__dirname, '../../upload/temp.zip');
var archive = archiver('zip', {
// Sets the compression level.
zlib: {level: 9}
});
//創建臨時zip文件
var output = fs.createWriteStream(zipPath);
archive.pipe(output);
//設置需要壓縮得文件夾目錄 以及替換得名稱
archive.directory(messagePath, name);
archive.finalize();
archive.on('end', function (err) {
fn(null, {"name": name, "path": zipPath});
});
archive.on('error', function (err) {
fn(new Error("壓縮文件異常"), null);
});
}
} else {
fn(new Error("id或name不能為空"), null);
}
} catch (e) {
fn(new Error(e.message), null);
}
};最后是提出的公共方法toolUtil的代碼，這個單獨做為一個js文件維護。
const path = require('path');
const fs = require('fs');
/**
* 創建目錄
* @param dirpath
*/
exports.mkdirSync = function (dirpath){
if (!fs.existsSync(dirpath)) {
var pathtmp;
dirpath.split(path.sep).forEach(function(dirname) {
if (pathtmp) {
pathtmp = path.join(pathtmp, dirname);
}
else {
pathtmp = dirname;
}
if (!fs.existsSync(pathtmp)) {
fs.mkdirSync(pathtmp);
}
});
}
};
//刪除所有的文件(將所有文件夾置空)
exports.emptyDir = function(dirpath){
var self = this;
//讀取該文件夾
var files = fs.readdirSync(dirpath);
files.forEach(function(file){
var filePath = dirpath + '/' + file;
var stats = fs.statSync(filePath);
if(stats.isDirectory()){
self.emptyDir(filePath);
}else{
fs.unlinkSync(filePath);
}
});
};感謝你能夠認真閱讀完這篇文章，希望小編分享的“node.js中express框架怎么實現文件上傳與下載的功能”這篇文章對大家有幫助，同時也希望大家多多支持創新互聯，關注創新互聯行業資訊頻道，更多相關知識等著你來學習!
網頁標題：node.js中express框架怎么實現文件上傳與下載的功能
URL地址：http://m.newbst.com/article34/jodhse.html
成都網站建設公司_創新互聯，為您提供全網營銷推廣、企業建站、外貿建站、品牌網站制作、搜索引擎優化、定制開發
聲明：本網站發布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創新互聯
- 網站改版項目主要包含的內容。 2018-09-27
- 如何避免網站改版導致的權重下降？ 2016-09-16
- 網站開發中網站改版他的優勢在哪里？ 2016-10-27
- 門戶網站改版應該做些什么？ 2022-11-11
- 如何讓網站改版變得更合理更有范兒 2022-05-15
- 企業網站改版 2023-02-17
- 鄭州網站設計公司網站改版的那點事 2023-03-14
- 網站改版后，還需要做那些工作 2019-10-13
- 網站改版需要考慮什么因素？ 2023-02-14
- 網站建設之如何恰當的進行網站改版 2016-11-05
- 網站改版了，權重和排名如何自處？ 2022-05-05
- 企業網站改版要怎么做 2021-09-07