关于Nodejs异常处理的一个教训,再次理解什么是异步回调.

关于Nodejs异常处理的一个教训，再次理解什么是异步回调

在Node.js中，处理异常的方式与传统的同步代码有所不同。尤其是在涉及到异步回调时，异常处理变得更加复杂。本文通过一个实际的例子来说明这个问题，并提出解决方案。

环境

本例使用的是express框架配合sequelize ORM。

问题描述

我们的目标是在路由处理中统一处理异常。最初的想法是使用try/catch块来捕获异常：

var m = ['get', 'post', 'put', 'delete'];
m.forEach(function (type) {
  var handlers = app.routes[type];
  if (handlers) {
    handlers.forEach(function (handler) {
      if (handler.path !== '/' && handler.path !== '/auth') {
        handler.callbacks = [authIdentity].concat(handler.callbacks);
      }
      handler.callbacks.forEach(function (callback) {
        var packageCallback = function (req, res, next) {
          try {
            callback(req, res, next);
          } catch (e) {
            debugger;
            if (e instanceof AppError) {
              res.send(e);
            }
            next(e);
          }
        };
        callback = packageCallback;
      });
    });
  }
});

然而，在处理请求的方法中，我们发现即使在try/catch块内抛出异常，也无法被捕获：

exports.authenticate = function (req, res, next) {
  var daos = app.get('models'),
      user = daos.user,
      _value = {};

  user.find({ where: { login: req.param('login') } }).success(
    function (value) {
      if (value) {
        var result = md5.validate(value.hashed_password, req.param('passwd'));
        if (result) {
          req.session.userinfo = value.login;
          var url = req.param('url');
          if (url) {
            res.redirect(url);
          }
        } else {
          throw new AppError('invalid user or passwd.');
          // next(new AppError('invalid user or passwd.'));
        }
      } else {
        throw new AppError('the user does not exist.');
        // next(new AppError('the user does not exist.'));
      }
    }
  );
};

原因分析

在异步回调中抛出的异常并不会被try/catch捕获。这是因为异步回调是在事件循环的其他阶段执行的，而此时try/catch已经结束了。

解决方案

正确的做法是使用next函数将异常传递给Express中间件链。例如：

exports.authenticate = function (req, res, next) {
  var daos = app.get('models'),
      user = daos.user,
      _value = {};

  user.find({ where: { login: req.param('login') } }).success(
    function (value) {
      if (value) {
        var result = md5.validate(value.hashed_password, req.param('passwd'));
        if (result) {
          req.session.userinfo = value.login;
          var url = req.param('url');
          if (url) {
            res.redirect(url);
          }
        } else {
          return next(new AppError('invalid user or passwd.'));
        }
      } else {
        return next(new AppError('the user does not exist.'));
      }
    },
    function (err) {
      if (err) {
        return next(err);
      }
    }
  );
};

这样，Express会自动处理这些异常并调用相应的错误处理中间件。

总结

在Node.js中，处理异步回调中的异常需要特别注意。直接抛出异常通常不会被try/catch捕获，而是应该使用next函数来传递异常。这不仅符合Node.js的设计理念，还能更好地管理应用的错误处理逻辑。