节点 js async.map 尝试失败，结果为空

Question

背景信息

这是我第一次尝试节点......现在是异步模块。我很难对我的 redis 数据库进行同步调用。

目标 最终，我需要做的是当用户调用我的 REST API 的 GET 方法时，我想返回如下所示的 json 对象：

 [ { '10.123': '1111111111' },
  { '10.126': '2222222222' },
  { '10.125': '3333333333' },
  { '10.222': '4444444444' },
  { '10.131.90': '5555555555' },
  { '10.18': '6666666666' },
  { '10.19': '7777777777' },
  { '10.44': '8888888888' } ]

您在上面看到的键是使用主 GET 方法中的 SCAN 命令查询的。然后对于redis SCAN返回的每个键，我转身运行“HGETGALL”命令来找出你在上面看到的值

问题

尽管在主 GET 方法中返回的每个键都正确调用了一次 queryhgetall 函数……但从该方法返回的数据是空的。这是我的代码：

代码

25 //async test start ====================================================================================
 26 var async = require('async');
 27 
 28 var queryhgetall = function (redis_key, doneCallBack) {
 29         var tempObject = {};
 30         redis.hgetall(redis_key, function (err, data) {
 31                 if (err) {
 32                         console.log("hgetall method fails: " + err);
 33                 }
 34                 if (data) { 
 35                         var key = redis_key.split(":");
 36                         tempObject[key[1]]=data.callerid;
 37                         console.log(tempObject);
 38                 }       
 39         });
 40         return doneCallBack(null,tempObject);
 41 };
 42 
 43 router.get('/', function (req, res, next) {
 44     redis.send_command("SCAN", [0, "MATCH", "emergency:*"], function (err, reply) {
 45         if (reply) {
 46             var retdata = [];
 47             async.map(reply[1], queryhgetall, function (err, results) {
 48                 console.log("finished");
 49                 console.log("results start");
 50                 console.log(results);
 51                 console.log("results stop");
 52             });
 53             }
 54      });    
 55 });  
 56 
 57 //async test finish =====================================================================================================

代码输出

这是我在控制台输出中看到的：

GET /emergency/ - - ms - -
finished
results start
[ {}, {}, {}, {}, {}, {}, {}, {} ]
results stop
{ '10.123': '1111111111' }
{ '10.126': '2222222222' }
{ '10.125': '3333333333' }
{ '10.222': '4444444444' }
{ '10.131.90': '5555555555' }
{ '10.18': '6666666666' }
{ '10.19': '7777777777' }
{ '10.44': '8888888888' }

从输出中可以看出，第 37 行的 console.log 命令证明我已经正确查询了每个键的 callerid 值，但是我将这些数据返回到 GET 方法的方式可能不正确，因为一切都是空的。

你能告诉我我错过了什么吗？我试图按照这里的例子： http://javascriptplayground.com/blog/2013/06/think-async/

Answer 1

我想我明白了。我改变了这个：

 28 var queryhgetall = function (redis_key, doneCallBack) {
 29         var tempObject = {};
 30         redis.hgetall(redis_key, function (err, data) {
 31                 if (err) {
 32                         console.log("hgetall method fails: " + err);
 33                 }
 34                 if (data) { 
 35                         var key = redis_key.split(":");
 36                         tempObject[key[1]]=data.callerid;
 37                         console.log(tempObject);
 38                 }       
 39         });
 40         return doneCallBack(null,tempObject);
 41 };

对此：

 28 var queryhgetall = function (redis_key, doneCallBack) {
 29         var tempObject = {};
 30         redis.hgetall(redis_key, function (err, data) {
 31                 if (err) {
 32                         console.log("hgetall method fails: " + err);
 33                 }
 34                 if (data) { 
 35                         var key = redis_key.split(":");
 36                         tempObject[key[1]]=data.callerid;
 37                         console.log(tempObject);
 38                         return doneCallBack(null, tempObject);
 39                 }
 40         });
 41 //      console.log(tempObject);
 42 //      return doneCallBack(null,tempObject);
 43 };

Answer 2

将return doneCallBack 向上移动到其他函数中，如第 38-39 行，以便在调用回调之前等待 redia 数据。