提问人:Merc 提问时间:4/5/2018 最后编辑:Himanshu BansalMerc 更新时间:5/15/2018 访问量:5249
Express 和 async/await:我应该用 try/catch 包装手吗?
Express and async/await: shall I wrap the lot with try/catch?
问:
我有以下代码:
app.post('/routes/passwordReset/:userId', async (req, res, next) => {
var userId = req.params.userId
let record = (await vars.connection.queryP('SELECT * FROM contacts WHERE id = ?', userId))[0]
if (!record) {
res.status(404).send('')
return
}
// Calculate token and expiry, update database
var token = require('crypto').randomBytes(48).toString('base64').replace(/[^a-zA-Z0-9]/g, '').substr(0, 28)
var now = new Date()
var inOneHour = new Date(now.getTime() + (1 * 1000 * 60 * 60))
await vars.connection.queryP('UPDATE contacts SET recoverToken = ?, recoverTokenExpiry = ? WHERE id = ?', [ token, inOneHour, userId ])
res.status(200).send('')
})
如果我创建一个人为错误(例如,字段 for 人为地太短),我最终会得到:recoverTokenExpiry
[[12:19:55.649]] [错误] (节点:11919) UnhandledPromiseRejectionWarning:未处理的 promise 拒绝 (拒绝 ID:4):错误:ER_DATA_TOO_LONG:数据对于列来说太长 第 1 行的“recoverToken”
我不知何故认为 Express 会尝试/捕获中间件,并在抛出错误时调用。也许不是这样?next(err)
那么,如果出现错误,我是否应该用 try/catch(e) 包装每个路由,执行 next(e) 操作?
答:
Express 不会为您做任何事情。这是非常裸露的骨头。
您有两种选择:
- 将所有内容包装在一个
try-catch
- 编写自己的错误处理中间件,如此处的文档所示。
调用会将 和 传递给堆栈中的下一个中间件。next()
req
res
调用 ,或者给它一个对象,将调用堆栈中的任何错误中间件。next(err)
Exception
在自己的文件中定义错误处理程序:
// error-middleware.js
/**
* Handler to catch `async` operation errors.
* Reduces having to write `try-catch` all the time.
*/
exports.catchErrors = action => (req, res, next) => action(req, res).catch(next)
/**
* Show useful information to client in development.
*/
exports.devErrorHandler = (err, req, res, next) => {
err.stack = err.stack || ''
const status = err.status || 500
const error = { message: err.message }
res.status(status)
res.json({ status, error })
}
然后,将密码重置逻辑移出并移入其自己的专用函数:app.post
// password-controller.js
exports.resetPassword = async (req, res) => {
// do work
// ...
}
这样可以更轻松地编写单元测试,并明确分离关注点。
接下来创建密码重置路由:
// password-reset-routes.js
const express = require('express')
const router = express.Router()
const passwordController = require('./password-controller')
const { catchErrors } = require('./error-middleware')
router.post('/routes/passwordReset/:userId', catchErrors(passwordController.resetPassword))
module.exports = router
请注意,此处导入并使用了上面定义的控制器。此外,您会看到控制器操作用 包装。这样就避免了一直写入,任何错误都会被中间件捕获。resetPassword
catchErrors
try-catch
catchErrors
最后,将它们全部连接到您的主文件中:app.js
// app.js
const express = require('express')
const { devErrorHandler } = require('./error-middleware')
const passwordResetRoutes = require('./password-reset-routes.js')
const app = express()
app.use(devErrorHandler)
app.use(passwordResetRoutes)
module.exports = app
评论
try { ... } catch (e) { next(err) }
catch
async
Promise
async
exports.catchErrors = action => (req, res, next) => action(req, res).catch(next)
好吧,当你使用 await 关键字时,这意味着执行流不再是异步的,这就是它失败的原因,是的,你每次都必须使用 try-catch 块。为了避免这种情况,你可以改为遵循异步流,分别使用 then() 和 catch(),这样你就可以做这样的事情:
...
.then((status)=>{
res.status(200).send('')
})
.catch((err)=>{
next(err);
});
...
评论
then()
catch
正如其他人所回应的那样,由于您使用的是 await,因此您可以将 promise 拒绝处理为
let record = await vars.connection.queryP('SELECT * FROM contacts WHERE id = ?', userId))[0].then(function () {
console.log("Promise Resolved");
}).catch((error)=>{
console.log("Promise rejected")
})
上一个:无法对拆解中的异常做出反应
下一个:可靠地重新连接到 MongoDB
评论
app.use(function (err, req, res, next) { console.error(err.stack) res.status(500).send('Something broke!') });