使用 Node.js，我需要通过从 Cassandra 获取文件路径，使用 require() 函数动态加载三个文件。我需要从每个文件中获取 Redis 中的数据，并在从 Cassandra 加载另一个文件之前进行一些验证。这里的问题是:在验证逻辑执行并提供结果之前，下一个文件开始并行加载。验证结果在加载第二个文件之后出现，这是不应该发生的。第二次文件加载应该等待第一个文件验证逻辑完成，并且只有在验证结果成功时才加载。请帮助我...如何在 node.js 中暂停或等待 Redis 完成查询？？？

node.js

"use strict";
var express = require('express');
var cassandra = require('cassandra-driver');
var app = express();
var Promise = require('bluebird');
var redis = Promise.promisifyAll(require('redis'));
var redisClient = redis.createClient(6379, '127.0.0.1');
var client = new cassandra.Client({contactPoints: ['127.0.0.1'], keyspace: 'poc'});
client.execute("SELECT  file FROM testqry1", function (err, result) {
    if (!err){
        if ( result.rows.length > 0 ) {
            for(var i=0; i< result.rows.length; i++){
                var filePath=result.rows[i].get('file');
                var newdat=Promise.promisifyAll(require(filePath));
                var res = newdat(redisClient);
                console.log('res:::'+res);
                if (res=='failed'){
                    return;
                }
            }
        } else {
            console.log("No results");
        }
    }
});

file1.js

var crypto = require('crypto');
var redisValue='';
module.exports = function(redisclient){

redisclient.hmgetAsync("testdata", "text1").then(function(redisValue){
      console.log('value from redis::'+redisValue) 
  }).then(function(){
    var hashedUserID = crypto.createHmac('sha256', 'sample')
                   .update('helloworld')
                   .digest('hex'); 

    function disp(value) {
        console.log('value::'+value);
      }
      disp(hashedUserID);

      console.log('redisValue::'+redisValue);
      if(hashedUserID =='e043e7e68058c8a4cd686db38f01771bd7a04b8bb9a658d3cb40d0be45935094'){
        redata='true';
      }else{
        redata='false';
      }

      console.log('redata::'+redata)
})
}

file2.js & file3.js 内容相同

var result1='';
module.exports = function(redisclient){
    redisclient.hmget("testdata", "text1" , function(err, redisValue){  
      console.log('redisValue2 == %s',redisValue);
      if(redisValue == 'test value'){
        result1 = "success";
      }else{
        result1="failed";
      }
    });

    return result1;
} 

输出:

res:::undefined
res:::
res:::
value from redis::test data here
value::e043e7e68058c8a4cd686db38f01771bd7a04b8bb9a658d3cb40d0be45935094
redisValue::
redata::true
redisValue2 == test data here
redisValue3 == hello world test data

最佳答案

你说 file2/3 是“相同的内容”，但它们不在一个关键区域。根据 Bluebird 的 promisifyAll 文档(参见 http://bluebirdjs.com/docs/api/promise.promisifyall.html )，此功能为 Redis 客户端中的每个核心功能创建了一个 ...Async 版本。您在第一种情况下调用了 hmgetAsync，但在其他情况下您只调用了 hmget。

这很重要，因为您使用的是异步模式但具有非异步代码结构。在 file2/3 中，您在异步回调中设置了 result1，然后在调用可能返回之前在每次调用下方返回它。

你有两个选择:

1:除了redis客户端之外，你还可以通过传入回调将file2/3/etc转换为完全传统的模式:

module.exports = function(redisclient, callback){

而不是返回 result1，然后您将使用此值调用回调:

if(redisValue == 'test value'){
    callback(null, "success");
} else {
    callback("failed", null);
}

2:您可以将 file2/3/..N 转换为基于 Promise 的，在这种情况下您不需要 promisifyAll(require(...)) 它们 - 您可以简单地require() 它们。这样的模式可能看起来像:

module.exports = function(redisclient){
    return redisclient.hmgetAsync("testdata", "text1");
};

这是一个更简单、更清晰的选项，如果你继续使用它，你会发现你甚至可以消除 require() 并简单地在 file1 中执行 hmgetAsync 并返回适当的数据 Cassandra 。但如果不了解您的具体应用需求，就很难知道。无论如何，基于 Promise 的模式通常更短更简洁，但并不总是更好——使用它们会产生适度的性能开销。走哪条路由您决定 - 两者都行。

关于node.js - Nodejs，在继续执行之前不等待 Redis 查询完成，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/37053484/