nodejs怎么连接ftp实现上传下载

这篇文章主要介绍“nodejs怎么连接ftp实现上传下载”的相关知识，小编通过实际案例向大家展示操作过程，操作方法简单快捷，实用性强，希望这篇“nodejs怎么连接ftp实现上传下载”文章能帮助大家解决问题。

依赖

//ftp 模块是目前找到的还不错的，对于ftp的基本功能都支持npm install ftp

连接ftp

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

ftp 获取列表 list

//列出目标目录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 : 这里提醒下，在本示例中的所有代码都在同一个文件中，后面会给出完整示例代码。

有了目录切换，那么在list函数中的dirpath就可以使用啦。如下：

//列出目标目录//列出目标目录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目标地址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);//此处应对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');//连接FTPconst 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 : '***',//这个就不提供啦    port : '***',    user : '***',    password : '***',    keepalive : 1000});//列出目标目录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目标地址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);//此处应对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();

踩坑记录：

测试过程中发现，有的ftp服务器传输速度正常，而有的ftp服务器传输速度则是非常慢！慢到平均一张十几K的图片都能传十几秒的程度！经过检查发现，这类ftp是采用的被动连接模式。

对此，查找GitHub官方文档https://github.com/mscdex/node-ftp ， 发现connect函数中有一个pasvTimeout选项涉及到被动连接超时设置，于是测试了一下，将上面的连接代码改成如下：

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

再次测试，传输速度慢的问题得到解决！

关于“nodejs怎么连接ftp实现上传下载”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识，可以关注编程网精选频道，小编每天都会为大家更新不同的知识点。