如何解决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
循环,要么可以映射承诺并等待所有承诺解决。根据您的问题的示例代码:
- 用于依次调用
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]]);
}
};
- 用于异步调用
process
const retrieve = async ctx => {
await Promise.all(Object.keys(ctx.request.files).map(async (key) => {
await process(files[key]);
}));
};
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。