对于我的网络应用程序，我使用 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())之前，我最终使用了它。
最佳答案
通过将 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);
});
});
};
但是，我仍然不确定这是否是最好的解决方案。定义事件发射器是更好的方法吗？
关于javascript - Redis 异步查询过早完成的可能解决方案，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/17898731/