美文网首页
nodejs从其他服务器读取文件到并返回给前端

nodejs从其他服务器读取文件到并返回给前端

作者: 不靠谱青年_Vip12 | 来源:发表于2019-10-01 12:53 被阅读0次

    前几天碰到需求要去其他服务器读取文件返回至前端,卡了几天查了好多但还是找不到有效的办法,就按照自己的想法写了下,总算是搞出来了。
    因为接触node的时间过短,可能存在很多的问题,欢迎大佬指出问题或可优化的地方,谢谢。
    思路大体如下:
    1.收到前端请求后先用node去ftp上拿到相关目录下文件列表,
    2.把文件列表返回到前端,前端需要下载时将文件名带目录传给node,node去ftp上下载至node文件目录下
    3.下载完成后创建下载url地址并返回给前端下载完成的消息,
    4.前端拿到node下载完成消息后打开node创建的url完成下载
    记录一下步骤方便之后查看,改进。
    1.先引入相关的模块

    const fs = require('fs');    // 文件操作模块
    const sftp_client = require('ssh2-sftp-client');   //  操作ftp模块
    const path = require("path")   // 路径操作模块
    
    1. 先从另外一台服务器上读取到文件列表信息,并返回前端生成文件下载列表
      // post接口
    app.post('/get_delay_dl_tm_file_list', get_delay_dl_tm_file_list); 
    function get_delay_dl_tm_file_list(req, res) {
        var param = req.body;  // 获取前端传过来的请求信息
        if (param.sat_name == undefined) {
            res.send({
                status: -1,
                data: "信息格式错误。"
            });
            return;
        }
        let sftp = new sftp_client();
        sftp.connect({    // 这块是地址配置
            host: config.delay_tm_ftp.host,            // ftp 地址
            port: config.delay_tm_ftp.port,              // 端口号
            username: config.delay_tm_ftp.user,     // 用户名
            password: config.delay_tm_ftp.password    // 密码
        }).then(() => {
            // 这块是ftp上的文件目录路径
            return sftp.list('/opt/nscc/data/' + param.sat_name + '/DTM');
        }).then((data) => {
            if (!data) {
                res.send({
                    status: -1,
                    data: 'get file error'
                });
            } else {
                var res_data = [];
                // 拿到目录里的文件遍历找到需要的文件,将文件信息放入数组内返回给前端做选择
                for (let i = 0; i < data.length; i++) {
                    if (!data[i].name) continue;
                    let name = data[i].name;
                    let size = data[i].size;
                    if (name.length < 3) continue;
                    let type = name.slice(name.length - 3, name.length);
                    if (type != 'csv') continue;
                    res_data.push({
                        name: '/opt/nscc/data/' + param.sat_name + '/DTM/' + name,
                        size,
                    });
                }
                res.send({
                    status: 2,
                    data: res_data
                });
            }
            sftp.end();
        }).catch((err) => {
            res.send({
                status: -1,
                data: err
            });
            sftp.end();
        });
    }
    

    3.前端发送需要下载的文件路径完成下载
    前端拿到获取到的文件列表,点击将要下载的文件名传给node


    image.png

    前端传输下载单文件信息接口

    app.post('/dl_ser_delay_tm_file', s_route_tc.dl_ser_delay_tm_file); 
    
    // 下载地址的get接口
    app.get('/dl_delay_tm_file', s_route_tc.dl_delay_tm_file);
    
    let paramDelayFileName = "" // 下载后保存至node目录下的文件信息
    function dl_ser_delay_tm_file(req, res) {
        var param = req.body;
        let sftp = new sftp_client();
        if (!param.file) {
            res.send({
                status: -1,
                data: "信息格式错误。"
            });
            return;
        }
        sftp.connect({
          // sftp模块的相关配置
            host: config.delay_tm_ftp.host,
            port: config.delay_tm_ftp.port,
            username: config.delay_tm_ftp.user,
            password: config.delay_tm_ftp.password
        }).then(() => {
            // 使用路径拼接,防止node根目录下的download文件夹下,注意要先在根目录下创建这个文件夹,不然找不到会报错
            return sftp.fastGet(param.file, path.join(__dirname, "../download",param.fileName))
        }).then((stream) => {
          // 下载至node完成后发送给前端成功的消息,这块我没判断,一般得先判断下
            res.send({
                status: 2,
            });
    
            paramDelayFileName = param.fileName
        }).catch((err) => {
            console.log(err, 'catch error');
        });
    }
    //  前端调用时候node开始创建下载地址
    function dl_delay_tm_file(req, res, next) {
        var route = path.join(__dirname, "../download",paramDelayFileName);
        var size = fs.statSync(route).size;
        var f = fs.createReadStream(route);
        res.writeHead(200, {
            'Content-Type': 'application/force-download',
            'Content-Disposition': 'attachment; filename=' + paramDelayFileName,
            'Content-Length': size
        });
        f.pipe(res);
      // 此处是前端下载后删除node本地目录下的文件,可加可不加,文件名相同时候默认就给覆盖掉了
        //     fs.unlink( './download/' + paramFileName, function(err){
        //         if(err){
        //              throw err;
        //         }
        //         console.log('文件:'+'./download/' + paramFileName+'删除成功!');
        //    })
    }
    // 最后完成前端部分拼接地址并完成下载。
     let downloadURL = "127.0.0.1:3008" +  "/dl_delay_tm_file/?key=" +  encodeURIComponent(JSON.stringify(name));   // name为文件的带后缀的名称
     window.open(downloadURL, "_self");
    

    相关文章

      网友评论

          本文标题:nodejs从其他服务器读取文件到并返回给前端

          本文链接:https://www.haomeiwen.com/subject/jcdoectx.html