const router = require('koa-router')();const fs = require('fs');
router.post('/upload', async (ctx){    const file = ctx.request.body.files.file;    // 获取上传文件
    const reader = fs.createReadStream(file.path);    // 创建可读流
    const ext = file.name.split('.').pop();        // 获取上传文件扩展名
    const upStream = fs.createWriteStream(`upload/${Math.random().toString()}.${ext}`);        // 创建可写流
    reader.pipe(upStream);    // 可读流通过管道写入可写流 
    return ctx.body = '上传成功';
})上面代码是上传文件,其中这段不理解:reader.pipe(upStream);    // 可读流通过管道写入可写流 return ctx.body = '上传成功'; //这里直接返回结果我的疑惑是:stream执行完需要一定时间,而且它又是异步的,可以说这里是直接return '上传成功',我们都知道,return就相当于结束了这次的http请求,那么没有执行完的stream怎么办?
                    
                    
                1 回答
                            交互式爱情
                            
                                
                            
                        
                        
                                                
                    TA贡献1712条经验 获得超3个赞
利用EventEmitter提供的事件
然后你可以把上面的代码 我这里简单写一下 类似这样封装一下
function getFile (reader, upStream) { return new Promise(function (resolve, reject) {  let stream = reader.pipe(upStream); 
  stream.on('finish', function () {   console.log('文件上传成功!');
  });
 });
}- 1 回答
 - 0 关注
 - 957 浏览
 
添加回答
举报
0/150
	提交
		取消
	