2

我似乎找不到这个问题的通用解决方案，即使我觉得我不能成为第一个遇到这个问题的人。我也怀疑这可能是我首先在这里采取了错误的方法。让我知道。

我有一个 Expressjs 应用程序，它与各种 API（主要是 OAuth2）交互。一旦请求进入应用程序，就会检查它是否具有访问令牌以从 API 获取数据。如果令牌过期，它将请求一个新令牌。

现在，当我的应用同时收到第二个请求时，需要完全相同的 API，我想避免再次调用访问令牌。

我所做的是使用“收集器”，其中可以为给定键存储回调。存储键回调的第一个请求会在完成任务后调用收集器回调。所有后续回调都被排入队列并稍后使用收集器回调调用。

这是简单的收集器类（CoffeeScript）

# Collect callbacks for tasks and execute all once the job is done
module.exports = class Collector
  constructor: ()->
    @tasks = {}
  add: (key, callback)->
    unless @tasks[key]
      # Initiate callback list for the key with first callback
      @tasks[key] = [callback]
      return ()=>
        # Call all collected callbacks for the key
        (callback.apply {}, arguments for callback in @tasks[key])
        # Reset callback list
        @tasks[key] = null
    else
      # Add callback to existing list
      @tasks[key].push callback
      return false

我不确定在这个类中存储回调是否正确，但是要使用数据库（Redis），我必须找到一种存储回调的方法......</p>

完成工作后是否有更好的方法来调用多个回调？

4

2 回答 2

3

为什么不将回调聚合到一个循环中的数组中，在原始调用完成时执行每个包含的函数？

它可能很简单：

var dones = [];

dones.push(function (err, res) { console.log('hoo'); });
dones.push(function (err, res) { console.log('ray!'); });

function whenDone(err, res) { 
   _.each(dones, function (done) { done(err, res); } }); 
}

myWhateverFunction(whenDone);

如果你想让它更漂亮，你可以将它包装到你想要的任何数据结构中。

于 2012-04-25T10:59:12.323 回答
0

对于您的问题，我没有具体的答案，但您应该查看异步模块。我认为这是朝着正确方向迈出的一步：https ://github.com/caolan/async

于 2012-04-24T15:11:29.230 回答