node實現FTP上傳

const fs = require('fs');
const FTPClient = require('ftp');

const dirPath = 'C:\\Users\\Ai_power04\\Desktop\\monit\\dist'; // 本地FTP目錄
const remoteFtpPath = 'yc-monit'; // 遠程FTP目錄
const localFiles = []; // 本地文件
let localFileLength = 0; // 上傳文件個數
let uploadTime = 0; // 上傳耗時
let ftp = null;

readingFile().then(()=>{
    // console.log(localFiles);
    if(localFileLength) {
        // 上傳文件 - 覆蓋
        console.log('鏈接192.168.10.107...');
        ftp = new FTPClient();
        ftp.on('ready', () => {
            // 清理文件
            console.log('鏈接成功，清理舊文件...');
            ftp.rmdir(remoteFtpPath,true,err=>{
                if(err) console.log('目錄不存在，無需清理');
                console.log('開始上傳...');
                uploadingFile().then(()=>{
                    console.log(`上傳結束，本次上傳${localFiles.length}個文件`);
                }).catch(err=>{
                    console.log(err);
                })
            });
        });
        // 鏈接服務器
        ftp.connect({
            host:'192.168.10.107',
            port:21,
            user:'Administrator',
            password:'1234',
            connTimeout: 1000*10, // 鏈接超時時間
            pasvTimeout: 1000*10, // PASV data 鏈接超時時間
            keepalive: 1000* 10, // 多久發送一次請求，以保持鏈接
        });
    } else {
        console.log('本地文件爲空，取消上傳');
    }
}).catch(err=>{
    console.log(err);
});

// 正在獲取本地文件
function readingFile() {
    return new Promise((resolve,reject)=>{
        readFiles(dirPath).catch(err=>reject(err));
        // 判斷是否讀取完畢（1s內 localFiles長度再也不變化）
        console.log('正在讀取本地文件，請稍後...');
        let timer = setInterval(() => {
            if(localFileLength == localFiles.length) {
                clearInterval(timer);
                resolve();
                return console.log('讀取完成');
            }
        }, 1000);
    })
}
// 遞歸讀取文件
function readFiles(filepath) {
    return new Promise((resolve,reject)=>{
        fs.readdir(filepath,{withFileTypes:true},(err,files)=>{
            if(err) throw err;
            if(files.length>0) {
                files.map(file=>{
                    if(file.isFile()) { // 文件
                        const child_filepath = filepath + '\\' + file.name;
                        fs.readFile(child_filepath,(err,data)=>{
                            if(err) throw err;
                            const dir = remoteFtpPath + filepath.replace(dirPath,'').replace('\\','/') ;
                            localFiles.push({
                                dir,
                                filepath: dir + '/' +file.name,
                                filedata: data
                            })
                            localFileLength = localFiles.length;
                        });
                    } else { // 目錄
                        const child_filepath = filepath + '\\' + file.name;
                        readFiles(child_filepath);
                    }
                });
            }
        });
    });
}

// 正在上傳文件
function uploadingFile() {
    return new Promise((resolve,reject)=>{
        localFiles.map(file=>{
            uploadFiles(file.dir,file.filepath,file.filedata).catch(err=>reject(err));
        })
        console.log('正在上傳，請稍後...');
        let timer = setInterval(() => {
            if(localFileLength == 0) {
                clearInterval(timer);
                resolve();
                return console.log('上傳完成');
            }
            uploadTime++;
            console.log(`已用時：${uploadTime}s`);
        }, 1000);
    })
}
// 覆蓋上傳文件
function uploadFiles(dir,filepath,filedata) {
    return new Promise((resolve,reject)=>{
        ftp.mkdir(dir,true,err1=>{
            if(err1) reject(err1);
            ftp.put(filedata,filepath,err2 => {
                if (err2) reject(err2);
                localFileLength--;
                ftp.end();
                resolve();
            });
        })
    })
}

複製代碼