han*_*ims 15 javascript asynchronous redis node.js
我对基于事件的编程很新(使用node.js).我相信有些东西我只是不喜欢它,因为有一个特殊的问题,我一次又一次地遇到.
简而言之,当问题似乎妨碍你时,这个问题正在处理异步性问题.在我的情况下,这通常表现在与第三方库一起工作时,第三方库在设计上是非阻塞的,并且提升了基于回调的API.
例如:现在我正在写一些大量使用mranney的node-redis库的东西.我的程序正在抓取RSS提要并将结果隐藏到redis中.我正在使用我认为是redis的常见策略:
feed:<feedId>:results:<timestamp>.feed:<feedId>:latest.
var redis = require("redis");
var client = redis.createClient();
var get_latest_results = function (feedId) {
client.get('feed:+ feedId + ':latest', function (err, res) {
var latest_reading_key = res.toString();
client.hgetall(latest_reading_key, function (err, res) {
var latest_reading = res;
});
});
// how do I specify a return value for this function?
}
放置return latest_reading在get_latest_results函数的底部失败,因为在函数准备退出之后才定义latest_reading .放置return latest_reading在hgetall调用中失败,因为它return引用了回调,并被忽略get_latest_results.
这只是我似乎不断写入的那种情况的一个例子.也许我正试图将方钉钉入圆孔,因为我不知道更好.似乎应该有一种解决这类问题的非黑客方式.
Dan*_*llo 28
您正在努力处理异步问题,因为您仍然在同步范例中编写函数.
在异步中,您应该将回调附加到事件.你不应该期望来自异步函数的结果get_latest_results(),但你应该传递一个回调函数作为在结果准备好时调用的参数.回调将对您的结果做任何需要做的事情:
var get_latest_results = function (feedId, readyCallback) {
client.get('feed:' + feedId + ':latest', function (err, res) {
var latest_reading_key = res.toString();
client.hgetall(latest_reading_key, function (err, res) {
readyCallback(res); //--- Trigger Callback
});
});
// how do I specify a return value for this function? //--- You don't
}
Run Code Online (Sandbox Code Playgroud)
然后你可以像这样调用你的函数:
get_latest_results(1000, function (result) {
//--- Do whatever needs to be done with the latest result...
});
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
1364 次 |
| 最近记录: |