10

ノードでredisの実装を始めたところです。認証方法の実装中に、トークンがredisに存在するかどうかを確認する必要があります。存在しない場合は、redisとmongo dbで新しいトークンを更新する必要があります。そのために、大きなコールバックブロックを記述し、結果が正しく取得されないようにする必要があります。どうすれば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);
    }
};
4

2 に答える 2

15

いいえ、redis を含む io 呼び出しを同期させることはできません。私が認識している唯一の同期 io 呼び出しは、ファイルシステムとコンソールのものです。

ただし、非同期コーディングをもう少し管理しやすくするために使用できるコーディング手法がいくつかあります。

  • 最初に err をチェックして、早期に戻ります。
  • エラー構造の作成など、繰り返しコードを別の関数に移動します。
  • この非同期ライブラリを使用します: https://github.com/caolan/async。特に、ここではウォーターフォール機能が便利かもしれません。

また、これらの関数は非同期であるため、コールバック メソッドを渡す必要があると思います。

  • setTokenOnRedis(トークン);
  • deleteTokenOnRedis(トークン);

サンプルコードをリファクタリングしました。これにより、インデントが少なくなり、読みやすく、保守しやすくなることを願っています。私は非同期を使用していません。それはあなたに任せます。

個人的には、ノードの非同期コーディング モデル全体が最初は非常にイライラすることがわかりましたが、慣れれば慣れます。しばらくすると、さまざまな非同期コーディング パターンの使用方法を学習し、ほぼ許容できるようになります :)

役に立つと思われるいくつかのリンク:

リファクタリングされたコード:

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);
        });
      });
    });
  }
};
于 2012-12-12T13:22:41.827 に答える