nodekoa2实现上传图片并且同步上传到七牛云存储-创新互联
因为升级到新的node版本,之前的通过很多上传图片的方式都已经不适用了,所以自己就写了一个对于 koa2上传图片的小demo,记录一下心得。
成都创新互联公司专注于宁县企业网站建设,响应式网站设计,商城网站开发。宁县网站建设公司,为宁县等地区提供建站服务。全流程定制设计,专业设计,全程项目跟踪,成都创新互联公司专业和态度为您提供的服务废话不多说,下面直接上代码,里面都有注释。
const Koa = require('koa'); const route = require('koa-route'); const serve = require('koa-static'); const inspect = require('util').inspect const path = require('path') const os = require('os') const fs = require('fs') const Busboy = require('busboy') const qiniu = require('qiniu') const qiniuConfig = require('./qiniuconfig') const app = new Koa(); app.use(serve(__dirname + '/public/')); // 写入目录 const mkdirsSync = (dirname) => { if (fs.existsSync(dirname)) { return true } else { if (mkdirsSync(path.dirname(dirname))) { fs.mkdirSync(dirname) return true } } return false } function getSuffix (fileName) { return fileName.split('.').pop() } // 重命名 function Rename (fileName) { return Math.random().toString(16).substr(2) + '.' + getSuffix(fileName) } // 删除文件 function removeTemImage (path) { fs.unlink(path, (err) => { if (err) { throw err } }) } // 上传到七牛 function upToQiniu (filePath, key) { const accessKey = qiniuConfig.accessKey // 你的七牛的accessKey const secretKey = qiniuConfig.secretKey // 你的七牛的secretKey const mac = new qiniu.auth.digest.Mac(accessKey, secretKey) const options = { scope: qiniuConfig.scope // 你的七牛存储对象 } const putPolicy = new qiniu.rs.PutPolicy(options) const uploadToken = putPolicy.uploadToken(mac) const config = new qiniu.conf.Config() // 空间对应的机房 config.zone = qiniu.zone.Zone_z2 const localFile = filePath const formUploader = new qiniu.form_up.FormUploader(config) const putExtra = new qiniu.form_up.PutExtra() // 文件上传 return new Promise((resolved, reject) => { formUploader.putFile(uploadToken, key, localFile, putExtra, function (respErr, respBody, respInfo) { if (respErr) { reject(respErr) } if (respInfo.statusCode == 200) { resolved(respBody) } else { resolved(respBody) } }) }) } // 上传到本地服务器 function uploadFile (ctx, options) { const _emmiter = new Busboy({headers: ctx.req.headers}) const fileType = options.fileType const filePath = path.join(options.path, fileType) const confirm = mkdirsSync(filePath) if (!confirm) { return } console.log('start uploading...') return new Promise((resolve, reject) => { _emmiter.on('file', function (fieldname, file, filename, encoding, mimetype) { const fileName = Rename(filename) const saveTo = path.join(path.join(filePath, fileName)) file.pipe(fs.createWriteStream(saveTo)) file.on('end', function () { resolve({ imgPath: `/${fileType}/${fileName}`, imgKey: fileName }) }) }) _emmiter.on('finish', function () { console.log('finished...') }) _emmiter.on('error', function (err) { console.log('err...') reject(err) }) ctx.req.pipe(_emmiter) }) } app.use(route.post('/upload', async function(ctx, next) { const serverPath = path.join(__dirname, './uploads/') // 获取上存图片 const result = await uploadFile(ctx, { fileType: 'album', path: serverPath }) const imgPath = path.join(serverPath, result.imgPath) // 上传到七牛 const qiniu = await upToQiniu(imgPath, result.imgKey) // 上存到七牛之后 删除原来的缓存图片 removeTemImage(imgPath) ctx.body = { imgUrl: `http://xxxxx(你的外链或者解析后七牛的路径)/${qiniu.key}` } })); app.listen(3001); console.log('listening on port 3001');
另外有需要云服务器可以了解下创新互联建站www.cdcxhl.com,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。
本文标题:nodekoa2实现上传图片并且同步上传到七牛云存储-创新互联
当前链接:http://scyanting.com/article/dhsdis.html