Koa-异步函数错误处理内的异步函数

问题描述

在我的app.js中，我有以下...

app.use(async (ctx,next) => {
  try {
    await next()
  } catch (err) {
    ctx.status = 400
    ctx.body = `Uh-oh: ${err.message}`
    console.log('Error handler:',err.message)
  }
});

app.use(router());

然后在routes中我定义了...

router.post('/',retrieve);

检索逻辑的结构如下...

const retrieve = async ctx => {
  Object.keys(ctx.request.files).forEach((key) => {
    process(files[key]);
  });
};

现在假设我在retrieve中抛出了一个错误...

const retrieve = async ctx => {
  throw new Error(`Error!`);
  Object.keys(ctx.request.files).forEach((key) => {
    process(files[key]);
  });
};

这将正常工作，并一直冒到app.js。但是，process函数也正在使用async，如果我在这里抛出错误...

const retrieve = async ctx => {
  Object.keys(ctx.request.files).forEach((key) => {
    process(files[key]);
  });
};

const process = async (file) => {
  throw new Error(`Error!`);
  ...

我收到以下错误信息...

UnhandledPromiseRejectionWarning：错误：错误！

我为什么得到UnhandledPromiseRejectionWarning？我该如何解决它并使它process内部引发的任何错误冒泡到app.js？

解决方法

由于forEach循环不是异步的，因此错误在执行后抛出，因此无法冒泡至app.js。现在有两种解决方案，要么可以使用for循环，要么可以映射承诺并等待所有承诺解决。根据您的问题的示例代码：

1. 用于依次调用process

const retrieve = async ctx => {
    const ctxKeys = Object.keys(ctx.request.files);
    for(let i = 0 ; i < ctxKeys.length ;++i){
        await process(files[ctxKeys[i]]);
    }
};

1. 用于异步调用process

const retrieve = async ctx => {
   await Promise.all(Object.keys(ctx.request.files).map(async (key) => {
     await process(files[key]);
   }));
};