当前位置：首页 > 笔记 > node.js > [原创] 关于koa文件上传(文件去重)

[原创] 关于koa文件上传(文件去重)

🐥🐥🐥🐥🐥🐥🐥3年前 (2022-09-17)node.js533

> 首先这篇文章可以解决文件上传的大部分问题，我为了提高代码的可用性，拆分成为中间件(不要为了解耦合而解耦合)。实际根据自己的业务去操作！！！

## 1.了解什么是crypto
加密js库
链接[crypto](https://www.npmjs.com/package/crypto-js "crypto") 不多赘述
## 2.fs以及path
这两个都是nodedjs自带的包，自行度娘

```javascript
const path = require('path')
const fs = require('fs')
const crypto = require('crypto')
//封装的错误码
const { unCorrectFileError } = require('../exception/error.type')
//这是上传文件的servic层
const { getFileInfoBySha1, uploadFile } = require('../service/upload.service')

const upload = async (ctx, next) => {
    const { file } = ctx.request.files
    if (file) {
        //预定义的文件类型
        const fileTypes = ['image/png', 'image/jpeg']
        //验证文件类型
        if (!fileTypes.includes(file.mimetype)) {
            return ctx.app.emit('error', unCorrectFileError, ctx)
        }
        const fmd5 = crypto.createHash('md5');
        //创建文件读取流
        const rs = fs.createReadStream(file.filepath);
		//文件读取中事件·····
        rs.on('data', chunk => {
            fmd5.update(chunk, 'utf8');
        });
        //读取完成文件以后执行---->获取哈希 (Promise可以拿到回调函数中的数据)
        let md5Generate = async () => {
            return new Promise((resolve, reject) => {
                rs.on('end', () => {
                    const md5 = fmd5.digest('hex').toUpperCase();
                    resolve(md5);
                });
            });
        }
        //这就是上一步
        const sha1 = await md5Generate()
        //判断哈希是否存在与数据库记录
        const res = await getFileInfoBySha1({ sha1 })
        //如果文件存在就返回到前端
        if (res) {
            ctx.body = {
                code: 0,
                message: '文件上传成功',
                result: res.url
            }
        }
        else {
            const filePath = path.join(__dirname, '../upload/') + `/${file.newFilename}`;
			//创建写入流
            const upStream = fs.createWriteStream(filePath);
            const render = fs.createReadStream(file.filepath)
            render.pipe(upStream)
			//获取file中的属性
            const { originalFilename, size, mimetype } = file
            const url = '你的服务器ip:端口号/' + `${file.newFilename}`;
			//插入记录到数据库
            const res1 = await uploadFile({ originalFilename, url, size, mimetype, sha1 })
			//响应到前端
            ctx.body = {
                code: 0,
                message: '文件上传成功',
                result: res1.url
            }
        }
}
```

扫描二维码推送至手机访问。

版权声明：本文由一段神奇的代码发布，如需转载请注明出处。

分享给朋友：

返回列表

上一篇：【转载】Koa2.js router 异步返回ctx.body失效的问题

下一篇：[原创] koa2(nodejs)+vue3+xtermjs打造一个前端终端

相关文章

【转载】Koa2.js router 异步返回ctx.body失效的问题

【转载】Koa2.js router 异步返回ctx.body失效的问题

koa2.js，用router返回数据时，正常写法如下（我是将接口封装了） //一个很普通的koa2.js get请求 router.put('/getUserInfo', (ctx, next) => { const data = ctx.request.body...

发表评论