javascript - Redis 异步查询过早完成的可能解决方案

Question

对于我的网络应用程序，我使用 Redis 来存储数据，但我无法让我的函数(其中包含对 Redis 的异步调用)在查询完成时发出事件。

我已将所有数据库配置放在一个模块中，并在同一位置定义方法。

这是我的代码:

/* Redis config and connect */
var REDIS_URL = 'REDIS_CONFIG_STRING';
var rtg = require('url').parse(REDIS_URL);
var redis = require('redis').createClient(rtg.port, rtg.hostname);
redis.auth(rtg.auth.split(":")[1]);

/* Read the users.json file into redis */
var loadJson = function(JSON) {
    if (JSON === 'DEFAULT') JSON = DEFAULT_JSON;
    var users = require(JSON);
    for (var key in users) {
        if(users.hasOwnProperty(key)) {
            redis.set(key, JSON.stringify(users[key]));
        }
    }
};

/* Do something to all keys in redis */
var allKey = function(callback) {
    callback = callback || console.log;
    redis.keys('*', function (err, keys) {
        if (err) return console.log(err);
        for(var i = 0, len = keys.length; i < len; i++) {
            callback(keys[i]);
        }
    });
};

/* Get a key and something to it */
var getKey = function(key, callback) {
    redis.get(key, function(err, result) {
        callback(result);
    });
};

/* Set a key to the value */
var setKey = function(key, value) {
    redis.set(key, value);
};

/* Read the whole redis db into a json */
var toJson = function(obj) {
    allKey(function(key) {
        getKey(key, function(result) {
            obj[key] = JSON.parse(result);
        });
    });
};

exports.client = redis;                                                                                                                                                            
exports.loadJson = loadJson;                                                                                                                                                       
exports.allKey = allKey;                                                                                                                                                           
exports.getKey = getKey;                                                                                                                                                           
exports.setKey = setKey;                                                                                                                                                           
exports.toJson = toJson;

这个想法是有一些类似的东西:

db = require('./models/redis.js');
db.toJson(obj).on('complete', function() {...});

并对其他导出函数执行相同的操作，以便所有数据库连接在其自己的模块中保持干净且独立。

如何将事件发射器分配给这些函数？

我现在遇到的问题是，在从 Redis 数据库填充新创建的 JS 对象(使用 toJson())之前，我最终使用了它。

Answer 1

通过将 toJson() 方法重新定义为以下内容解决了该问题:

var toJson = function(cb) {                                                               
    //Retrieve all keys                                                                                                                                                            
    client.keys('*', function (err, keys) {                                               
        //Error check                                                                                                                                                              
        if (err) return console.log(err);                                                 
        //Retrieve all values for the array of keys                                                                                                                                
        client.mget(keys, function(err, reply) {                                          
            //Create a new object to enter the data into                                                                                                                           
            var obj = {};                                                                 
            //Fill the obj with key-value pairs                                                                                                                                    
            for (var i = 0; i < keys.length; i++) {                                       
                obj[keys[i]] = JSON.parse(reply[i]);                                      
            }
            //console.log(obj);                                                                                                                                                    
            //Execute callback which makes use of the object                                                                                                                       
            cb(obj);
        });
    });
};

但是，我仍然不确定这是否是最好的解决方案。定义事件发射器是更好的方法吗？