node ftp上傳文件夾到服務(wù)器案例詳解
更新時間：2023年04月07日 09:15:29 作者：我說的馬是黑馬
這篇文章主要介紹了node ftp上傳文件夾到服務(wù)器的視線方法,結(jié)合具體實例分析了node.js調(diào)用ftp模塊進行文件上傳的相關(guān)配置、連接、path路徑操作與文件傳輸實現(xiàn)方法,需要的朋友可以參考下
完整代碼示例如下：
const ftp = require('ftp');//連接FTP
const path = require('path');
const client = new ftp();
const fs = require('fs');
//本地文件夾路徑；
const localDirPath = '/test/';
//遠程地址，打開ftp以后的地址，不需要加入host；
const remotePath = '/';
const uploadFiles = [];
const mkDirPromiseArr = [];
const connectionProperties = {
host: '', //ftp地址；
user: '', //用戶名；
password: '', //密碼；
port: 21 //端口；
};
client.connect(connectionProperties);
client.on('ready', () => {
console.log('ftp client is ready');
start();
});
async function start() {
const { err: ea, dir } = await cwd(remotePath);//此處應(yīng)對err做處理
if (ea) {
client.mkdir(remotePath, true, (err) => {
if (err) {
console.log('創(chuàng)建' + remotePath + '文件夾失敗');
upload();
} else {
console.log('創(chuàng)建' + remotePath + '成功');
upload();
}
});
} else {
upload();
}
function upload() {
const filesPath = { files: [] };
getDirAllFilePath(localDirPath, filesPath);
remoteMkDir(filesPath, '');
console.log('準備上傳...');
setTimeout(() => {
Promise.all(mkDirPromiseArr).then(() => {
console.log('開始上傳...');
const tasks = uploadFile();
runPromiseArray(tasks).then(() => {
client.end();
console.warn('上傳完成～');
});
});
}, 3000);
}
}
// 獲取本地的文件地址和路徑;
function getDirAllFilePath(paths, parent) {
const files = fs.readdirSync(paths);
files.forEach(item => {
if (item != '.DS_Store') {
const path = `${paths}/${item}`;
if (isDir(path)) {
getDirAllFilePath(path, parent[item] = { files: [] });
} else if (isFile(path)) {
parent.files.push(item);
}
}
})
}
//創(chuàng)建遠程確實的文件夾；
async function remoteMkDir(obj, _path) {
for (const key in obj) {
if (key === 'files') {
for (let i = 0, len = obj[key].length; i < len; i++) {
const promise = new Promise(async resolve => {
let p = '';
if (_path) {
p = _path + '/';
}
const filePathName = p + obj[key][i];
uploadFiles.push({ path: filePathName, fileName: obj[key][i] });
const ph = remotePath + filePathName.substring(0, filePathName.lastIndexOf('/') + 1);
let { err: ea, dir } = await cwd(ph);//此處應(yīng)對err做處理
if (ea) {
client.mkdir(ph, true, (err) => {
if (err) {
console.log('mkdir' + ph + 'err', err);
resolve(null);
return;
}
console.log('mkdir ' + ph + ' success');
resolve(null);
});
} else {
resolve(null);
}
});
mkDirPromiseArr.push(promise);
}
} else {
let p = '';
if (_path) {
p = _path + '/';
}
remoteMkDir(obj[key], p + key);
}
}
}
//上傳文件；
function uploadFile() {
const tasks = [];
const resourcesPath = localDirPath;
//目標路徑文件夾;
const checkPath = remotePath;
for (let i = 0, len = uploadFiles.length; i < len; i++) {
const task = () => {
return new Promise(async (resolve, reject) => {
const _path = uploadFiles[i].path;
const targetPath = checkPath + _path;
const putPath = resourcesPath + '/' + _path;
const dirpath = path.dirname(targetPath);
const fileName = path.basename(targetPath);
client.cwd(dirpath, (cwdErr, dir) => {
client.pwd((pwdErr, cwd) => {
if (pwdErr) {
resolve(pwdErr)
} else {
client.get(fileName, (err, res) => {
if (res) {
console.log(`${targetPath} =====================已經(jīng)存在了`);
resolve(true);
} else {
const rs = fs.createReadStream(putPath);
client.put(rs, fileName, (putErr, data) => {
if (putErr) {
resolve(err);
} else {
console.log(targetPath + '文件上傳成功');
resolve(true);
}
})
}
});
}
});
})
});
}
tasks.push(task);
}
return tasks;
}
//執(zhí)行Promise的隊列動作;
function runPromiseArray(parray) { //這個方法可以放到G里
let p = Promise.resolve();
for (let promise of parray) {
p = p.then(promise);
}
return p;
}
//切換目錄
async function cwd(dirpath) {
return new Promise((resolve, reject) => {
client.cwd(dirpath, (err, dir) => {
resolve({ err: err, dir: dir });
})
});
}
function isFile(filepath) { //判斷是否是文件 Boolean
let stat = fs.statSync(filepath)
return stat.isFile()
}
function isDir(filepath) { //判斷是否是文件夾 Boolean
let stat = fs.statSync(filepath);
return stat.isDirectory();
}
筆者解讀一下：代碼中的localDirPath為本地需要讀取其中文件，并使用ftp上傳的文件夾。
注意：這里的上傳是針對文件夾中所有的文件夾與文件進行遍歷后的上傳，實際應(yīng)用中，我們可能只需要上傳指定的文件，對此，筆者修改后的腳本如下：
const ftp = require('ftp');//連接FTP
const path = require('path');
const client = new ftp();
const fs = require('fs');
//本地文件夾路徑；
const localDirPath = path.join(__dirname,'/imgtmp/');//待遍歷的本地目錄
//遠程ftp服務(wù)器文件路徑
let remotePath = '/yourweb/images/';
const upFileList = ["202304/202304061415075072.png","202304/202304061415075073.png"];//手動設(shè)置需要上傳的文件
const uploadFiles = [];
const mkDirPromiseArr = [];
client.on('ready',()=>{
console.log('ftp client is ready');
});
const connconfig = {
host: '', //ftp地址；
user: '', //用戶名；
password: '', //密碼；
port: 21 //端口；
}
client.connect(connconfig);
client.on('ready', () => {
console.log('ftp client is ready');
start();
});
async function start() {
const { err: ea, dir } = await cwd(remotePath);//此處應(yīng)對err做處理
if (ea) {
client.mkdir(remotePath, true, (err) => {
if (err) {
console.log('創(chuàng)建' + remotePath + '文件夾失敗');
upload();
} else {
console.log('創(chuàng)建' + remotePath + '成功');
upload();
}
});
} else {
upload();
}
function upload() {
console.log("mkDirPromiseArr==>",mkDirPromiseArr);
// const filesPath = { files: [] };
// getDirAllFilePath(localDirPath, filesPath);
const filesPath = { files: upFileList };//直接給定需要上傳的文件列表
// console.log("遍歷之后的filesPath===>",filesPath);
remoteMkDir(filesPath, '');
console.log('準備上傳...');
setTimeout(() => {
Promise.all(mkDirPromiseArr).then(() => {
console.log('開始上傳...');
const tasks = uploadFile();
runPromiseArray(tasks).then(() => {
client.end();
console.warn('上傳完成～');
});
});
}, 1000);
}
}
// 獲取本地的文件地址和路徑;
function getDirAllFilePath(paths, parent) {
const files = fs.readdirSync(paths);
files.forEach(item => {
if (item != '.DS_Store') {
const path = `${paths}/${item}`;
if (isDir(path)) {
getDirAllFilePath(path, parent[item] = { files: [] });
} else if (isFile(path)) {
parent.files.push(item);
}
}
})
}
//創(chuàng)建遠程缺失的文件夾；
async function remoteMkDir(obj, _path) {
for (const key in obj) {
if (key === 'files') {
for (let i = 0, len = obj[key].length; i < len; i++) {
const promise = new Promise(async resolve => {
let p = '';
if (_path) {
p = _path + '/';
}
const filePathName = p + obj[key][i];
// const filePathName = path.dirname(obj[key][i]);
const fileName = path.basename(obj[key][i]);
// uploadFiles.push({ path: filePathName, fileName: obj[key][i] });
uploadFiles.push({ path: filePathName, fileName: fileName });
const ph = remotePath + filePathName.substring(0, filePathName.lastIndexOf('/') + 1);
let { err: ea, dir } = await cwd(ph);//此處應(yīng)對err做處理
if (ea) {
client.mkdir(ph, true, (err) => {
if (err) {
console.log('mkdir' + ph + 'err', err);
resolve(null);
return;
}
console.log('mkdir ' + ph + ' success');
resolve(null);
});
} else {
resolve(null);
}
});
mkDirPromiseArr.push(promise);
}
} else {
let p = '';
if (_path) {
p = _path + '/';
}
remoteMkDir(obj[key], p + key);
}
}
}
//上傳文件；
function uploadFile() {
const tasks = [];
const resourcesPath = localDirPath;
//目標路徑文件夾;
const checkPath = remotePath;
for (let i = 0, len = uploadFiles.length; i < len; i++) {
const task = () => {
return new Promise(async (resolve, reject) => {
const _path = uploadFiles[i].path;
// const _path = uploadFiles[i];
const targetPath = checkPath + _path;
const putPath = resourcesPath + '/' + _path;
const dirpath = path.dirname(targetPath);
const fileName = path.basename(targetPath);
client.cwd(dirpath, (cwdErr, dir) => {
client.pwd((pwdErr, cwd) => {
if (pwdErr) {
resolve(pwdErr)
} else {
client.get(fileName, (err, res) => {
if (res) {
console.log(`${targetPath} =====================已經(jīng)存在了`);
resolve(true);
} else {
const rs = fs.createReadStream(putPath);
client.put(rs, fileName, (putErr, data) => {
if (putErr) {
resolve(err);
} else {
console.log(targetPath + '文件上傳成功');
resolve(true);
}
})
}
});
}
});
})
});
}
tasks.push(task);
}
return tasks;
}
//執(zhí)行Promise的隊列動作;
function runPromiseArray(parray) { //這個方法可以放到G里
let p = Promise.resolve();
for (let promise of parray) {
p = p.then(promise);
}
return p;
}
//切換目錄
async function cwd(dirpath) {
return new Promise((resolve, reject) => {
client.cwd(dirpath, (err, dir) => {
resolve({ err: err, dir: dir });
})
});
}
function isFile(filepath) { //判斷是否是文件 Boolean
let stat = fs.statSync(filepath)
return stat.isFile()
}
function isDir(filepath) { //判斷是否是文件夾 Boolean
let stat = fs.statSync(filepath);
return stat.isDirectory();
}PS:筆者此處使用了一個upFileList數(shù)組保存了需要上傳到服務(wù)器的圖片文件路徑（包括文件夾與文件名），感興趣的朋友可以測試一下看看效果~
相關(guān)文章
package-lock.json解決依賴的版本管理使用詳解
這篇文章主要為大家介紹了package-lock.json解決依賴的版本管理使用詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-08-08
今天小編就為大家分享一篇解決修復(fù)npm安裝全局模塊權(quán)限的問題，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2018-05-05
在使用Node.js處理文件或文件夾時,我們有時需要遍歷文件夾中的所有文件和子文件夾以查找特定的文件或執(zhí)行某些操作,這里將提供一些基本的例子來演示如何使用Node.js遍歷文件夾,需要的朋友可以參考下2023-08-08
Node.js?網(wǎng)絡(luò)框架koa?compose中間件使用解析
這篇文章主要為大家介紹了Node.js?網(wǎng)絡(luò)框架koa?compose中間件使用解析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2022-12-12
fs模塊是nodejs官方提供用來操作文件的模塊,下面這篇文章主要給大家介紹了關(guān)于nodejs讀取本地mp3和mp4等媒體文件并播放的相關(guān)資料,文中通過實例代碼介紹的非常詳細,需要的朋友可以參考下2022-09-09
這篇文章主要給大家介紹了一些你或許不知道的npm實用技巧，分享一些 npm 包管理工具的實用小竅門，希望能夠略微提高下前端、Node.js 開發(fā)者的生活質(zhì)量，需要的朋友可以參考下2019-07-07
這篇文章主要為大家介紹了package.json的版本號更新優(yōu)化方法詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2023-04-04
追求更高的效率是碼農(nóng)不斷的追求。選擇合適的工具，合理搭配使用，既能提高一部分開發(fā)效率，又能改善寫代碼時的心情。使用Node.js開發(fā)命令行工具是開發(fā)者應(yīng)該掌握的一項技能，適當(dāng)編寫命令行工具以提高開發(fā)效率。2016-08-08
Node.js是一個基于Chrome JavaScript運行時建立的平臺， 用于方便地搭建響應(yīng)速度快、易于擴展的網(wǎng)絡(luò)應(yīng)用。本文給大家介紹Node.js插件安裝的教程，非常實用，特此分享給大家，需要的朋友一起學(xué)習(xí)吧2016-05-05
下面這篇文章主要給大家介紹了在Node.js中如何合并兩個復(fù)雜對象的方法,文中給出了詳細的示例代碼，相信對大家的理解和學(xué)習(xí)具有一定的參考借鑒價值，有需要的朋友可以參考，下面來一起看看吧。2016-12-12