文件上传到alioss遇到的问题

背景

自己开发一个小程序，还有pc页面，用户能够上传文件到alioss，然后返回oss链接给前端使用。

流程

pc或者小程序文件---->后端服务器(腾讯云容器)---->alioss

过程

问题一： 请求内容超过100k，腾讯云容器会自动拦截不给上传，这个地方当初调试了好多次。

解决的话只能再搞一个oss服务器，专门用来存放图片的，因此流程转换成

第一步：pc或者小程序文件---->后端服务器(阿里云ESC)--->alioss 第二步：pc或者小程序文件链接---->后端服务器(腾讯云容器) 这样应该就能解决问题了。 问题二：

文件上传超过2M就非常慢，2M大小传输时间就是6s，这时候我怀疑是我的阿里云ecs主机带宽不够，就想着超过2M就切片吧，毕竟便宜的主机嘛。 简单的demo

// 文件切片
const createfileChunkList = (file, size) => {
  const fileChunkList = [];
  let cur = 0;
  let index = 1;
  const fileHash = uuid();
  const total = Math.ceil(file.size / size);
  while (cur < file.size) {
    const blob = file.slice(cur, cur + size, file.type)
    fileChunkList.push({ file: blob , index: index, fileHash, name: file.name, total});
    index++;
    cur += size;
  }
  return fileChunkList;
};
// 文件上传
export async function fileUpload({isH5, id, successCb, file}) {
  const chunkList = createfileChunkList(file, 1000*1000 * 1);
  let count = 0;
  for (const item of chunkList) {
   await new Promise(resolve => {
    uni.uploadFile({
      url: ‘url’
      file: item.file,
      name: 'file',
      header: {
        id,
      },
      formData: {
        fileName: item.name,
        hash: item.fileHash,
        index: item.index,
        total: item.total,
      },
      success: async (uploadFileRes) => {
        count++;
        resolve(1);
        if (item.total === count) {
         const data = await request({
            url: '合片的url',
            method: 'POST',
            data: {
              fileName: item.name,
              hash: item.fileHash,
            }
        })
      }
    });
   }) 
  }

}

在服务端获取

// 是将上传文件存储在一个本地文件夹中
  public async fileUpload() {
    const ctx = this.ctx;
    const file = ctx.request.files[0];
    const { fileName, hash, index } = ctx.request.body;
    function mkdirsSync(hash) {
      if (fs.existsSync(hash)) {
        return true;
      }
      if (mkdirsSync(path.dirname(hash))) {
        fs.mkdirSync(hash);
        return true;
      }
    }
    try {
      const pathDir = path.join(__dirname, '../static', hash);
      mkdirsSync(pathDir);
      const reader = await fs.createReadStream(file.filepath);
      const upStream = await fs.createWriteStream(`${pathDir}/${index}.${fileName}`);
      await reader.pipe(upStream);
      ctx.body = {
        success: true,
        messsage: '上传成功',
      };
    } catch (error) {
      ctx.body = {
        success: false,
        messsage: '上传失败',
      };
    }

  }
  // 等全部上传完成以后，有前端发起合片请求
  public async uploadComplete() {
    const ctx = this.ctx;
    const { fileName, hash } = ctx.request.body;
    const pathDir = path.join(__dirname, '../static', hash);
    const targetPath = path.join(__dirname, '../static', hash, fileName);
    try {
    // 这边需要将文件排序
      const files = fs.readdirSync(pathDir).sort();
      const targetStream = await fs.createWriteStream(targetPath);

      for (const name of files) {
        const filePath = path.join(pathDir, name);
        const originStream = fs.createReadStream(filePath);
        // 依次将流写入通道
        originStream.pipe(targetStream, { end: false });
        await new Promise(resolve => {
          originStream.on('end', async function() {
            fs.unlinkSync(filePath);
            resolve(1);
            originStream.close();
          });
        })
      }
      targetStream.close();
      // 合片完成上传阿里云oss
      const { url } = await ctx.oss.put('test/' + fileName, targetPath);
      fs.unlinkSync(targetPath);
      fs.rmdirSync(pathDir);
      ctx.body = {
        success: true,
        result: url,
      };
    } catch (error) {
      ctx.body = {
        success: false,
        result: '上传出错',
      };
    }

  }

看似解决问题了，一个30M的文件需要的时长接近2分钟，太慢了，而且在最后上传alioss的时候，提示超时，我研究半天也没明白哪里超时，网关，nginx设置等等，最后发现，有应该是阿里云ESC带宽限制了，猝！！！！。 问题三： 这怎么解决问题二，难道不能上传了，阿里云的aksk等不可能写在前端，不然就泄漏了，随后去看看官网 官网链接： help.aliyun.com/document_de…

      const client = new OSS({
        // yourRegion填写Bucket所在地域。以华东1（杭州）为例，yourRegion填写为oss-cn-hangzhou。
       region: 'xxxxx',
       accessKeyId: sts.AccessKeyId,
       accessKeySecret: sts.AccessKeySecret,
       stsToken: sts.SecurityToken,
       // 填写Bucket名称。
       bucket: "xxxxx",
       // 刷新临时访问凭证。
       refreshSTSToken: async () => {
         const refreshToken = await getStsTemporary();
         return {
           accessKeyId: refreshToken.AccessKeyId,
           accessKeySecret: refreshToken.AccessKeySecret,
           stsToken: refreshToken.SecurityToken,
         };
       },
     });
     res = await client.put(file.name, file);

因此流程就变成

1. pc或者小程序文件链接--->alioss(拿临时sts上传)
2. alioss链接---->后端服务器(腾讯云容器)

结果

搞了好几天，终于解决了这个问题，避免以后踩坑吧