nodejs連接ftp上傳下載實(shí)現(xiàn)方法詳解【附：踩坑記錄】

更新時(shí)間：2023年04月10日 14:34:17 作者：他強(qiáng)任他強(qiáng)03

這篇文章主要介紹了nodejs連接ftp上傳下載實(shí)現(xiàn)方法,結(jié)合實(shí)例形式詳細(xì)分析了node.js使用ftp模塊實(shí)現(xiàn)針對(duì)ftp上傳、下載相關(guān)操作的方法,并附帶記錄了傳輸速度慢的解決方法,需要的朋友可以參考下

依賴

//ftp 模塊是目前找到的還不錯(cuò)的，對(duì)于ftp的基本功能都支持
npm install ftp

連接ftp

const ftp = require('ftp');//連接FTP
const client = new ftp();
client.on('ready',()=>{
    console.log('ftp client is ready');
});
client.connect({
    host : '***.***.***.***',
    port : '****',
    user : '***',
    password : '***',
    keepalive : 1000
});

ftp 獲取列表 list

//列出目標(biāo)目錄
function list(dirpath){
    return new Promise((resolve,reject)=>{
        client.list((err,files)=>{
            resolve({err : err,files : files});
        })
    });
}
async function test (){
    //list 列表功能
    let {err,files} = await list();
    if(err){
        console.log(err);
        return
    }
    console.log(`獲得文件列表:`+files.length);
    console.log(files);
}
test();

在這里插入圖片描述

ftp 目錄切換

//切換目錄
function cwd(dirpath){
    return new Promise((resolve,reject)=>{
        client.cwd(dirpath,(err,dir)=>{
            resolve({err : err,dir : dir});
        })
    });
}

FBI WARNING : 這里提醒下，在本示例中的所有代碼都在同一個(gè)文件中，后面會(huì)給出完整示例代碼。

有了目錄切換，那么在list函數(shù)中的dirpath就可以使用啦。如下：

//列出目標(biāo)目錄
//列出目標(biāo)目錄
async function list(dirpath){
    let {err : ea,dir } = await cwd(dirpath);
    return new Promise((resolve,reject)=>{
        client.list((err,files)=>{
            resolve({err : err,files : files})
        })
    });
}

ftp下載文件

//下載文件
async function get(filePath){
    const dirpath = path.dirname(filePath);
    const fileName = path.basename(filePath);
    let {err : ea,dir} = await cwd(dirpath);
    return new Promise((resolve,reject)=>{
        client.get(fileName,(err,rs)=>{
            let ws = fs.createWriteStream(fileName);
            rs.pipe(ws);
            resolve({err : err});
        });
    });
}

ftp上傳文件

//將文件上傳到ftp目標(biāo)地址
async function put(currentFile,targetFilePath){
    const dirpath = path.dirname(targetFilePath);
    const fileName = path.basename(targetFilePath);
    const rs = fs.createReadStream(currentFile);
    let {err : ea,dir} = await cwd(dirpath);//此處應(yīng)對(duì)err做處理
    if(ea){
        return Promise.resolve({err : ea});
    }
    return new Promise((resolve,reject)=>{
        client.put(rs,fileName,(err)=>{
            resolve({err : err});
        })
    });
}

完整代碼

const ftp = require('ftp');//連接FTP
const path = require('path');
const client = new ftp();
const fs = require('fs');
client.on('ready',()=>{
    console.log('ftp client is ready');
});
client.on('close',()=>{
    console.log('ftp client has close')
});
client.on('end',()=>{
    console.log('ftp client has end')
});
client.on('error',(err)=>{
    console.log('ftp client has an error : '+ JSON.stringify(err))
});
client.connect({
    host : '***',//這個(gè)就不提供啦
    port : '***',
    user : '***',
    password : '***',
    keepalive : 1000
});
//列出目標(biāo)目錄
async function list(dirpath){
    let {err : ea,dir } = await cwd(dirpath);
    return new Promise((resolve,reject)=>{
        client.list((err,files)=>{
            resolve({err : err,files : files})
        })
    });
}
//切換目錄
function cwd(dirpath){
    return new Promise((resolve,reject)=>{
        client.cwd(dirpath,(err,dir)=>{
            resolve({err : err,dir : dir});
        })
    });
}
//下載文件
async function get(filePath){
    const dirpath = path.dirname(filePath);
    const fileName = path.basename(filePath);
    let {err : ea,dir} = await cwd(dirpath);
    return new Promise((resolve,reject)=>{
        client.get(fileName,(err,rs)=>{
            let ws = fs.createWriteStream(fileName);
            rs.pipe(ws);
            resolve({err : err});
        });
    });
}
//將文件上傳到ftp目標(biāo)地址
async function put(currentFile,targetFilePath){
    const dirpath = path.dirname(targetFilePath);
    const fileName = path.basename(targetFilePath);
    const rs = fs.createReadStream(currentFile);
    let {err : ea,dir} = await cwd(dirpath);//此處應(yīng)對(duì)err做處理
    if(ea){
        return Promise.resolve({err : ea});
    }
    return new Promise((resolve,reject)=>{
        client.put(rs,fileName,(err)=>{
            resolve({err : err});
        })
    });
}
async function test (){
    //list 列表功能
    let {err,files} = await list('/attachment/byycampus/resource');
    if(err){
        console.log(err);
        return
    }
    console.log(`獲得文件列表:`+files.length);
    console.log(files);
    //下載文件
    let {err : ea} = await get('/attachment/byycampus/resource/201812/14/201812141035222541381967.jpg');
    if(ea){
        console.log(ea);
        return;
    }
    console.log('文件下載成功')
    //文件上傳
    let {err : eb} = await put('201812141035222541381967.jpg','/attachment/a.jpg');
    if(eb){
        console.log(eb);
        return;
    }
    console.log('文件上傳成功')
}
test();

踩坑記錄：

筆者測(cè)試過(guò)程中發(fā)現(xiàn)，有的ftp服務(wù)器傳輸速度正常，而有的ftp服務(wù)器傳輸速度則是非常慢！慢到平均一張十幾K的圖片都能傳十幾秒的程度！經(jīng)過(guò)檢查發(fā)現(xiàn)，這類ftp是采用的被動(dòng)連接模式。

對(duì)此，查找github官方文檔https://github.com/mscdex/node-ftp ，發(fā)現(xiàn)connect函數(shù)中有一個(gè)pasvTimeout選項(xiàng)涉及到被動(dòng)連接超時(shí)設(shè)置，于是筆者測(cè)試了一下，將上面的連接代碼改成如下：

const ftp = require('ftp');//連接FTP
const client = new ftp();
client.on('ready',()=>{
    console.log('ftp client is ready');
});
client.connect({
    host : '***.***.***.***',
    port : '****',
    user : '***',
    password : '***',
    keepalive : 1000,
    pasvTimeout:1000
});

再次測(cè)試，傳輸速度慢的問(wèn)題得到解決！

您可能感興趣的文章: