egg使用stream流上传文件

'use strict'

const Controller = require('egg').Controller;

const path = require('path')

const fs = require('fs')

class UploadController extends Controller {

  // 上传图片

  async img() {

    const { ctx } = this;

    // 接收到的流文件

    const stream = await ctx.getFileStream();

    // 文件存放路径

    const name = path.join(__dirname, '../public/img/' + stream.filename)

    // 创建一个写入文件流到name位置

    const writerStream = fs.createWriteStream(name);

    // 使用管道直接写入到存放路径

    stream.pipe(writerStream)

    // 响应请求

    ctx.body = {

      code: 200,

      msg: '上传成功',

      url: 'http://127.0.0.1:7001/public/img/' + stream.filename,

    }

  }

}

module.exports = UploadController;