NFS

通过浏览器上传到ftp，因为ftp和我们的node server部署在同一台服务器上，这里，我们直接通过前台文件上传到后台server 设置后台路径是ftp存储文件的路径即可

var express = require('express');

var fs = require('fs');

var path = require('path');

var fstool = require('../utils/fsTool.js');

var cp = require('child_process');

var exec = cp.execFile;

var moment = require('moment');

var dbcon = require("./mysqlconn.js");

var multiparty = require('connect-multiparty')({

uploadDir: process.env.TMPDIR

});

fstool.clearDir(process.env.TMPDIR);

function uploadFiles(req) {

// console.log(req.files,req.body);

var f = req.files.file || {};

var pt = require('path').relative(process.env.WEBROOT, f.path || "");

return {

url: pt,

file:f

};

}

function sendResult(res,status,data,msg){

var d = {status:status};

if(data) d.data = data;

if(msg) d.msg = d.error = msg;

res.status(status?200:500).send(d);

}

router.post('/default', multiparty, function(req, res) {

var file = uploadFiles(req);

if (file && file.url){

// var ext = path.extname(file.url)

// var timestamp = moment().format("YYYYMMDDHHmm");

var fname = req.files.file.originalFilename;

var sqlstr = "SELECT * FROM t_user WHERE nId='" + req.session.userId + "'";

dbcon(sqlstr, function(err, vals, fields) {

if (err) {

sendResult(res,0,null,'上传失败！数据库查询错误');

console.log(err);

} else {

// fstool.mkDirs(targetPath);

var uri = "mnt/bigdata/"+vals[0].strUserId + '/' + req.query.id +'/'+ fname;

console.log(uri);

var targetPath = process.env.MNTROOT+uri;

fstool.moveFile(file.file.path,targetPath,function(errs){

if(errs){

console.log(errs);

sendResult(res,0,null,'上传失败！移动文件失败');

} else {

var sliceExe = "./gpu_change_authority.sh";

exec(sliceExe, [vals[0].strUserId, req.query.id], {

cwd: getScriptPath()

},

function(error, stdout, stderr) {

sendResult(res,1,uri);

}

);

sendResult(res,1,uri);

}

});

}

});

}else {

sendResult(res,0,null,'上传失败！文件为空');

}

});

module.exports = router;

sendResult是给前台返回值的function，因为我这里存放的文件夹是前台传值来查询SQL来确定的，所以，我这里文件上传还查询了一句SQL。同时，这里文件上传到服务器上，因为这里是通过前台http上传直接传输到这里文件路径下，上传上的文件所有的权限是只有W和R，所以这里执行了一个脚本，来更改上传文件的权限。

FTP

没有办法直接使用浏览器上传FTP，如果FTP服务和server服务不在一台机器上的时候，我们只有通过前台上传文件到后台server，然后在将文件上传到ftp，然后删除server上的临时文件，来完成此功能

var express = require('express');

var router = express.Router();

var fs = require('fs');

var path = require('path');

var fstool = require('../utils/fsTool.js');

var moment = require('moment');

var dbcon = require("./mysqlconn.js");

var _ = require("lodash");

var JSFtp = require("jsftp");

var multiparty = require('connect-multiparty')({

uploadDir: process.env.TMPDIR

});

fstool.clearDir(process.env.TMPDIR);

function uploadFiles(req) {

// console.log(req.files,req.body);

var f = req.files.file || {};

var pt = require('path').relative(process.env.WEBROOT, f.path || "");

return {

url: pt,

file:f

};

}

function sendResult(res,status,data,msg){

var d = {status:status};

if(data) d.data = data;

if(msg) d.msg = d.error = msg;

res.status(status?200:500).send(d);

}

function getScriptPath() {

return process.env.ROOT + "/externaltools/";

}

router.post('/special', multiparty, function(req, res) {

var file = uploadFiles(req);

if (file && file.url){

// var ext = path.extname(file.url)

// var timestamp = moment().format("YYYYMMDDHHmm");

var fname = req.files.file.originalFilename;

var uri = "store/temp/"+fname;

var targetPath = process.env.WEBROOT+uri;

console.log(targetPath);

var sqlstr = "SELECT * FROM t_user WHERE nId='" + req.session.userId + "'";

dbcon(sqlstr, function(err, vals, fields) {

if (err) {

sendResult(res,0,null,'上传失败！数据库查询错误');

console.log(err);

} else {

// fstool.mkDirs(targetPath);

fstool.moveFile(file.file.path,targetPath,function(){

var Ftp = new JSFtp({

host: "10.42.10.34",

user: vals[0].strUserId,

pass: vals[0].strFtpPassword

});

var url = './'+req.query.id+'/'+fname;

Ftp.put(targetPath, url, function(hadError) {

if (!hadError){

console.log("File transferred successfully!");

fs.unlink(targetPath,function(error){

if(error){

console.log('删除失败');

sendResult(res,0,null,'上传失败！移除临时文件失败');

}else{

console.log('删除成功');

sendResult(res,1,uri);

}

});

}else{

console.log(hadError);

sendResult(res,0,null,'上传失败！ftp上传失败');

}

});

});

}

});

}else {

sendResult(res,0,null,'上传失败！文件为空');

}

});

这里文件从后台server上传到ftp这里使用了node的jsFTP模块，来完成这个功能,先将文件通过浏览器走http上传到后台的临时文件夹，然后ftp上传，最后删除临时文件，整个上传结束。