node ftp上传

朴灿烈づ我的快乐病毒、 2023-03-06 08:11 15阅读 0赞

const fs = require('fs');
    const FTPClient = require('ftp');
    const path = require('path')
    
    const dirPath = path.join(__dirname, './dist'); // 本地FTP目录
    const remoteFtpPath = '/t1/star-pc-upload/test'; // 远程FTP目录
    const localFiles = []; // 本地文件
    let localFileLength = 0; // 上传文件个数
    let uploadTime = 0; // 上传耗时
    let ftp = null;
    
    readingFile().then(()=>{ 
        // console.log(localFiles);
        if(localFileLength) { 
            // 上传文件 - 覆盖
            console.log('连接10.41.41.168...');
            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:'服务器IP',
                port:21,
                user:'用户名',
                password:'密码',
                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();
                });
            })
        })
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，15人围观）

还没有评论，来说两句吧...

相关阅读

相关 FTP方式上传文件

FTP方式上传文件话不多说，直接贴代码，亲测可用（目前只在maven工程中测试使用） 1. 在pom文件中添加依赖 <dependency>

我就是我/ 2023年10月18日 23:49/ 0 赞/ 148 阅读

相关 node ftp上传

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

朴灿烈づ我的快乐病毒、/ 2023年03月06日 08:11/ 0 赞/ 16 阅读

相关 android ftp上传下载

new Thread(){ @Override public void run() {

柔光的暖阳◎/ 2023年01月14日 00:47/ 0 赞/ 172 阅读

相关 php通过ftp传文件,PHP通过FTP上传文件

上传时先传至本地对文件作必要的修改,如加水印等等操作,然后再通过FTP传至远程服务器. //上传图片 if ($\_FILES\['pic'\]\['name'\]) \

朴灿烈づ我的快乐病毒、/ 2022年11月17日 03:56/ 0 赞/ 252 阅读

相关 FTP上传文件

问题描述：在公司测试环境可以通过ftp上传文件至生产环境的ftp服务器上，当把应用程序发布到生产环境后，无法通过ftp上传文件至生产环境的ftp服务器上。了解到ftp上

古城微笑少年丶/ 2022年10月12日 15:55/ 0 赞/ 228 阅读

相关 ftp上传和下载

在java代码里面使用ftp，可以使用Apache 里面的一个common-net包，具体下载可以去官网下载。使用ftp最主要的类还是FTPClient。下面是ftp官方

阳光穿透心脏的1/2处/ 2022年06月10日 11:22/ 0 赞/ 358 阅读

相关 ftp上传工具类

public class FtpUtil { //ftp上传 public void upload(InputStream inputS

冷不防/ 2022年06月06日 00:55/ 0 赞/ 213 阅读

相关 bat+ftp 备份文件上传ftp

@echo for /f "tokens=4" %%a in ('route print^|findstr 0.0.0.0.\0.0.0.0') do ( set

╰+攻爆jí腚メ/ 2022年05月28日 11:43/ 0 赞/ 281 阅读

相关 Http上传 vs Ftp上传

1：Http上传 http上传就是通过http协议来向服务器上传文件，所以服务器端应该有一个处理客户端请求的页面。添加一个FileUploadHandler.ashx 的

缺乏、安全感/ 2022年05月15日 13:24/ 0 赞/ 225 阅读

相关 Java.ftp上传下载

1：jar的maven的引用： 1 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="htt

约定不等于承诺〃/ 2021年09月20日 13:38/ 0 赞/ 442 阅读