使Node Redis的get()方法同步化

Question

我刚开始使用Node实现Redis。在实现身份验证方法时，我需要检查令牌是否存在于Redis中，如果不存在则将新令牌更新到Redis和我的MongoDB中，为此我需要编写一个大的回调块，但没有得到正确的结果。我们如何使Redis摆脱回调？如何使它同步？以下是示例代码。

module.exports.authenticate = function(request, response)   {
    var reply = {};

    if(UserSchema)  {
        var UserModel, attributes;

        /** Registering User Model; **/
        mongoose.model('user', UserSchema);
        UserModel = mongoose.model('user');

        attributes = request.params;

        UserModel.findOne(attributes, "_id name email token", function(error, user) {

            if(!error && user)  {
                var token;

                //delete user.password;
                token = user.token;

                /** Checking token exists in redis; **/
                redisClient.get(token, function(error, value)   {
                    if(value === null && error === null)    {

                        /** Creating new token; **/
                        token = require('crypto').createHash('md5').update("" + (new Date()).getTime()).digest("hex");
                        user.token = token;

                        /** Storing new token on redis; **/
                        setTokenOnRedis(token);

                        /** Updating token in the user model; **/
                        UserModel.update({ _id : user._id}, { token : token }, function(error, user)    {
                            if(error !== null && user === null) {
                                deleteTokenOnRedis(token);

                                /** Error message; **/
                                reply = {
                                    error : true,
                                    code : "AUTH#001",
                                    msg : "User authentication failed, Please check user credentials."
                                }
                                response.send(reply);

                            }else if(error === null && user !== null)   {
                                reply = user;
                                response.send(reply);
                            }
                        });
                    }else if(value !== null)    {
                        reply = user;
                        response.send(reply);
                    }else   {
                        /** Error message; **/
                        reply = {
                            error : true,
                            code : "AUTH#001",
                            msg : "User authentication failed, Please check user credentials."
                        };
                        response.send(reply);
                    }
                });
            }else   {
                /** Error message; **/
                reply = {
                    error : true,
                    code : "AUTH#001",
                    msg : "User authentication failed, Please check user credentials."
                }
            }       
        });
    }else   {

        /** Error message; **/
        reply = {
            error : true,
            code : "AUTH#001",
            msg : "User authentication failed, Please check user credentials."
        }

        response.send(reply);
    }
};

- Jaison Justus

Answer 1

不，您将不能使任何io调用同步，包括redis。我所知道的唯一可用的同步io调用是文件系统和控制台。

但是，有一些编码技巧可以使异步编码更加可管理。

• 通过首先检查err并返回来尽早退出。
• 将重复的代码移动到单独的函数中，例如创建错误结构。
• 使用此异步库：https://github.com/caolan/async。特别是，waterfall函数可能在这里很方便。

我还认为您需要将回调方法传递给这些函数，因为它们是异步的。

• setTokenOnRedis(token);
• deleteTokenOnRedis(token);

我已经重构了您的示例代码，希望它不太缩进，更易读/可维护。我没有使用async，这留给您。

个人而言，最初整个node异步编码模型让我非常沮丧，但是您会习惯它。过一段时间，您会学会使用各种异步编码模式，然后它就变得仅仅是可以忍受的 :)

您可能会发现以下链接有帮助：

• 异步node.js调用的错误处理
• Node.js最佳实践异常处理
• 如何避免在Node.js中长时间嵌套异步函数

重构后的代码：

module.exports.authenticate = function(request, response){
  authenticate(request, response, function(err, reply){
    if(err){
       reply = authenticationError(err);
    }
    response.send(reply);
  });
};

var authenticationError = function(internalmsg){
  return {
    internalmsg : internalmsg,
    error : true,
    code : "AUTH#001",
    msg : "User authentication failed, Please check user credentials."
  };
};

var authenticate = function(request, response, callback)   {
  if(UserSchema)  {
    var UserModel, attributes;

    /** Registering User Model; **/
    mongoose.model('user', UserSchema);
    UserModel = mongoose.model('user');

    attributes = request.params;

    UserModel.findOne(attributes, "_id name email token", function(err, user) {
      if(err || !user){
        return callback(err || "UserModel.findOne, no user");
      }

      var token;

      //delete user.password;
      token = user.token;

      /** Checking token exists in redis; **/
      redisClient.get(token, function(err, value){
        if(err){
          return callback(err);
        }
        if(value){
          return callback(null, value);
        }

        /** Creating new token; **/
        token = require('crypto').createHash('md5').update("" + (new Date()).getTime()).digest("hex");
        user.token = token;

        /** Storing new token on redis; **/
        setTokenOnRedis(token);

        /** Updating token in the user model; **/
        UserModel.update({ _id : user._id}, { token : token }, function(err, user) {
          if(err || !user) {
            deleteTokenOnRedis(token);
            return callback(err || "UserModel.update, no user found");
          }
          callback(null, user);
        });
      });
    });
  }
};

- AndyD

---

感谢您提供的重构代码。您绘制的点正是我所需要的。谢谢。 - Jaison Justus

Answer 2

原问题提出多年后，Node.js的Redis客户端仍然是异步的，并且不太可能改变。

但为了更方便地处理这种工作方式，该软件包支持Promise，如http://redis.js.org/#redis-a-nodejs-redis-client-usage-example-promises所述。

这并没有使Node.js更同步，也没有使Redis客户端更同步，但它比注册回调函数有所改进，使您的代码更易读。

- Jochem Schulenklopper