1

对于我的 web 应用程序，我使用 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() {...});

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

如何将事件发射器分配给这些功能？

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

4

1 回答 1

0

通过将方法重新定义为以下内容来解决问题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);
        });
    });
};

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

于 2013-07-28T09:20:48.163 回答