这两天在研究node + koa + koa-formiable 上传图片和文件
最简单的使用方法
const Koa = require('koa')
const app = new Koa()
const formidable = require('koa-formidable')
app.use(formidable({
uploadDir: config.uploadDir, // 上传目录
keepExtensions: true, // 保持原有后缀名
}))
然后在文件中使用
let filePath = ctx.request.files.file.path;
let net_filePath = '/public/files/' + path.parse(filePath).base;
文件已经上传到指定的目录，非常方便。 但是我们不可能所有文件都上传到一个文件夹吧。 这时候需要按需自定义上传路径
但是koa-formable 的文档说明少之又少，没办法只能硬着头皮研究， 网上找到一个例子
// 这个是一个异步,在路由里面前面是有async的
const upkoafile = async (ctx, next) => {
var fs = require('fs');
var formidable = require('koa-formidable'); // 这里用koa下的formidable模块,如果直接套用会出现关于req.on 的报错
// 直接new formidable.IncomingForm() 也会报错它不能new,或者说下面这句已经帮我们new好了
var form = formidable.parse(ctx.request);
/*
这里的form是一个函数,具体如下
function (done) {
var form = opts instanceof formidable.IncomingForm
? opts
: new formidable.IncomingForm(opts)
form.parse(ctx.req, function (err, fields, files) {
if (err) return done(err)
done(null, { fields: fields, files: files })
})
}
看到这里,我想有人应该明白了,koa-formidable只不过在原来的模块基础上加了一点东西,甚至可以不用这个模块
var formidable = require('formidable');
var form = new formidable.IncomingForm();
form.parse(ctx.req,function(){...})
*/
var p = new Promise((resolve, reject) => {
form((opt, obj) => {
var file = obj.files.file;
var filename = file.name;
var buffer = fs.readFileSync(file.path); // 读取文件,此时就可以上传了
//... 到这里就已经回到之前的步骤了,后面的http只需要在合适的地方返回promise就行了
var opts = {
//...上面一样
}
http.request(opts, function (resp) {
resp.setEncoding('utf8');
resp.on('data', function (chunk) {
body += chunk; // 这个是上传的服务器返回的结果
})
resp.on('end', function () {
try {
var result = JSON.parse(body);
return resolve(result); //上传结束客户端返回
} catch (e) {
return reject(e);
}
})
}).on('error', function (e) {
return reject(e); //出错后返回
}).write(buffer) // http上次
.end();
})
})
var body = await p; //上面的promise返回
return ctx.body = body;
}
看到这里思路清晰了很多，但是我觉得我的需求不需要用到 像上面代码中的 http 模块，
于是我尝试直接使用 formidable 模块，
var formidable = require('formidable')
var form = new formidable.IncomingForm()
form.uploadDir = uploadPath
form.keepExtensions = true
form.parse(ctx.req, function (err, fields, files) {
console.log('files', files)
})
这时出现恶心的找不到文件路劲
image.png
但是如果配置修改了的话：
var formidable = require('formidable')
var form = new formidable.IncomingForm()
// form.uploadDir = uploadPath
// form.keepExtensions = true
form.parse(ctx.req, function (err, fields, files) {
console.log('files', files)
})
文件就会自动上传到一个莫名其妙的目录
image.png
结合上面两个情况想了很久，发现一个规律。 有可能是我指定的上传的目录文件没有新建。 所以就会报没有找到路径的错误， 但如果没有设置 uploadDir 属性，文件就上传到默认的路径了。 最后用fs模块, 每次上传图片之后就新建目录，然后问题就解决了
fs.mkdir(uploadPath, function(err) {
if(err) {
return console.log(err)
}
console.log('创建文件夹成功')
})
接下来就是异步问题了, 这里详细记录我的思考过程，日后反思。
参考文章 https://blog.csdn.net/u011782108/article/details/68062603
但是连接的作者并没有上传设置路径，所以我跟他的还不太一样
操作步骤
exports.addCover = async (ctx) => {
let uploadPath = `${config.uploadDir}/public/files/server/coverimg/${moment().format('YYYYMMDD')}`
let timeStamp = `${moment().format('YYYY-MM-DD')} ${moment().hours()}:${moment().minutes()}:${moment().seconds()}`
function isExistFile() {
return new Promise(function(resolve, reject) {
fs.exists(uploadPath, function (exists) {
if (exists) return resolve(true)
if (!exists) {
fs.mkdir(uploadPath, function (err) {
if (err) {
return reject(false)
}
resolve(true)
})
}
})
})
}
// function createFile() {
// return new Promise(function(resolve, reject) {
// console.log('uploadPath', uploadPath)
// fs.mkdir(uploadPath, function (err) {
// if (err) {
// reject(err)
// }
// resolve()
// })
// }).catch(error => console.log('caught2', error))
// }
function cb(err, fields, files) {
return new Promise((resolve, reject) => {
console.log('files', files)
let file = files.file;
let filename = file.name;
resolve(filename)
})
}
function opeFile() {
return new Promise(function(resolve, reject) {
let form = new formidable.IncomingForm()
form.uploadDir = uploadPath //上传路径
form.keepExtensions = true //是否保持拓展名
form.parse(ctx.req, function (err, fields, files) {
// resolve('sssss')
// if(err) return reject(err)
// console.log('ssssssss')
// let file = files.file
// filePath = file.path
// fileName = file.name
// console.log(fileName)
// console.log(filePath)
// resolve({
// code: '001',
// msg: '上传成功',
// filePath,
// fileName
// })
})
})
}
// 如果promise函数没有添加 .catch 捕捉错误，会弹出提示
// (node:42811) UnhandledPromiseRejectionWarning: undefined
// (node: 42811) UnhandledPromiseRejectionWarning: Unhandled promise rejection.This error originated either by throwing inside of an async function without a catch block, or by rejecting a promise which was not handled with .catch(). (rejection id: 1)
// (node: 42811)[DEP0018] DeprecationWarning: Unhandled promise rejections are deprecated.In the future, promise rejections that are not handled will terminate the Node.js process with a non - zero exit code.
async function handleAsync() {
try {
const isExist = await isExistFile()
console.log('isExist', isExist)
return isExist
// if (isExist) {
// let form = new formidable.IncomingForm()
// form.uploadDir = uploadPath //上传路径
// form.keepExtensions = true //是否保持拓展名
// console.log('form', form)
// // console.log('uploadPath', uploadPath)
// // const v = form.parse(ctx.req, function (err, fields, files) {
// // return 'sssss'
// // })
// // const v = await cb(formCb)
// // console.log('v', v)
// }
} catch (e) {
console.log(e)
}
}
const p = await handleAsync()
console.log('p', p)
ctx.body = p
// let result = checkFs.then(function(data) {
// return opeFile
// })
// let { filePath, fileName } = result
// await user_db.sqlQuery('INSERT INTO server_article_addcover (filepath, filename, created_at) values (?,?,?)', [filePath, fileName, timeStamp])
// ctx.body = result
// 将数据保存进数据库
// let result = await user_db.sqlQuery('INSERT INTO server_article_addcover (filepath, filename, created_at) values (?,?,?)', [filePath, fileName, timeStamp])
// return ctx.body = {
// code: '001',
// msg: '上传成功',
// filepath: filePath.replace(/^\/public/, ''),
// filename: fileName
// }
// fs.exists(uploadPath, function(exists) {
// if (!exists) {
// fs.mkdir(uploadPath, function (err) {
// if (err) {
// return console.log(err)
// }
// console.log('创建文件夹成功')
// })
// }
// const formidable = require('formidable')
// let filePath, fileName
// let form = new formidable.IncomingForm()
// form.uploadDir = uploadPath //上传路径
// form.keepExtensions = true //是否保持拓展名
// form.parse(ctx.req, async function (err, fields, files) {
// let file = files.file
// filePath = file.path
// fileName = file.name
// // 将数据保存进数据库
// let result = await user_db.sqlQuery('INSERT INTO server_article_addcover (filepath, filename, created_at) values (?,?,?)', [filePath, fileName, timeStamp])
// return ctx.body = {
// code: '001',
// msg: '上传成功',
// filepath: filePath.replace(/^\/public/, ''),
// filename: fileName
// }
// })
// })
}
