图片上传及数据库增加对应记录
发布于 11 年前 作者 sdfcbs91 4946 次浏览 最后一次编辑是 8 年前

这两天做了一个图片上传功能,很庆幸express 3.x版本文件上传及nodejs 1.0xx版本文件操作功能支持的很不错。 然后找社区有无现成代码例子,参考了 letonlife大神的例子,

前端(不能直接copy代码,直接转换html):

form method=“post” enctype=“multipart/form-data” action="/userimage_upload"

    div class="modal-body"

        input class="customfile-input" type="file" name="user_file"
    /div
    div class="modal-footer"
        button class="btn" data-dismiss="modal" aria-hidden="true"关闭/button
        button class="btn btn-primary" type="submit"上传/button
    /div
/form

后端(包括引用mongoose连接池全贴上来):

var status = require(’./…/status’); var mongoose = status.mongoose; var db = status.db; var Schema = mongoose.Schema;

var filter = require("./…/moudels/filter.js");

var Removes_userlogo = db.model(‘remove_user_logo’,new Schema({ innerdate:{type:Date, default: Date.now} ,update:{type:Date, default: Date.now} ,user:String ,name:String }));

// 移动文件需要使用fs模块 var fs = require(‘fs’); module.exports = function(app){

app.post('/userimage_upload',filter.authorize ,function(req,res){
     // 获得文件的临时路径
    var tmp_path = req.files.user_file.path;
    var target_file = './public/user/logo/'+req.session.name;
    var target_path = target_file+'/user';
    
    var newIname_arry = req.files.user_file.name.split('.');

    var tem_extension = newIname_arry[newIname_arry.length-1]; //后缀名

    fs.exists(target_file,function(exist){
        if(!exist){
            
            fs.mkdirSync(target_file);
        }
        fs.exists(target_path+'.'+tem_extension,function(exist){
            if(exist){
                fs.exists(target_file+"/remove",function(exist){
                    if(exist){
                        takefile(target_path,target_file,tmp_path,tem_extension,function(remove_name){
                            insertRemoves_userlogo(req,res,remove_name);
                            res.send({status:0}); 
                        });
                    }else{
                        fs.mkdirSync(target_file+"/remove");
                        takefile(target_path,target_file,tmp_path,tem_extension,function(remove_name){
                            insertRemoves_userlogo(req,res,remove_name);
                            res.send({status:0}); 
                        });
                    }

                });
                
            }else{
                // 移动文件
                fs.rename(tmp_path, target_path+'.'+tem_extension, function(err) {
                  if (err){
                           throw err;
                        res.send({status:1}); 
                    }              
                  fs.unlink(tmp_path, function() {
                     if (err) throw err;
                     
                     res.send({status:0});  //res.send('File uploaded to: ' + target_path + ' - ' + req.files.thumbnail.size + ' bytes');
                  });

                });
            }
        });
    });
    
    
    
});

};

//文件操作 具体操作 //保留文件地址 回收站文件夹地址 临时文件地址 临时文件后缀名 自定义回调函数 var takefile=function(target_path,target_file,tmp_path,tem_extension,func){ var now = new Date();

var rOption = {
  flags : 'r',
  encoding : null,
  mode : 0666
}

var wOption = {
  flags: 'a',
  encoding: null,
  mode: 0666   
}
var namefiles = fs.readdirSync(target_file);
var remove_extension = "";
for(i in namefiles){
    if(namefiles[i].indexOf("user.") == 0){
        var arr = namefiles[i].split(".");
        remove_extension = arr[arr.length-1];
        break;
    }
}
var remove_name = now.getFullYear() + "-" + (now.getMonth() + 1) + "-" + now.getDate() + 
    "  "+now.getHours()+"_"+now.getMinutes()+"_"+now.getSeconds()+"_"+now.getMilliseconds();
var old_file = fs.createReadStream(target_path+'.'+remove_extension,rOption);
var new_file = fs.createWriteStream(target_file+"/remove/"+ remove_name +"."+remove_extension,wOption);

old_file.on('data',function(data){
  new_file.write(data);
    
});

old_file.on('end',function(){
      
      new_file.end();
      fs.unlink(target_path+'.'+tem_extension,function(err){
        
    });
    
      // 移动文件
    fs.rename(tmp_path, target_path+'.'+tem_extension, function(err) {
      if (err){
               throw err;
            res.send({status:1}); 
        }              
      fs.unlink(tmp_path, function() {
         if (err) throw err;
         
         func(remove_name);
      });

    });
});

}

//remove数据库增加 var insertRemoves_userlogo = function(req,res,name){ var removes = new Removes_userlogo({user:req.session.name,name:name,innerdate:Date(),update:Date()}); removes.save(function(err){ if(err){ throw err; } }); }

在数据库处理跟发送send上采用了回调调用处理,经过严格测试完美通过。 请教社区大神:感觉nodeJS这些函数的异步运行及JS的回调使用不知道怎么运用更好? 不过很赞叹JS回调语法的好用。

回到顶部