前几天碰到需求要去其他服务器读取文件返回至前端，卡了几天查了好多但还是找不到有效的办法，就按照自己的想法写了下，总算是搞出来了。
因为接触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") // 路径操作模块
- 先从另外一台服务器上读取到文件列表信息，并返回前端生成文件下载列表
// 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");
