延迟事件直到调用回调 (Node.js)

Question

我将 Node.js 与 Express 结合使用，并且在我的路线中具有与此类似的代码：

requireLogin: function(req, res, next) {
    User.find(req.session.userId)
        .on('success', function(user) {
             req.addListener('data', function(chunk) {
                 console.log("DATA: " + chunk);
             }
             next()
        }
}

我正在使用 Sequelize，并且 User.find 方法正在访问数据库。问题是，我绑定的请求“数据”事件永远不会被触发。当用户从数据库返回时，数据事件似乎已经被触发和处理，现在用它做任何事情都为时已晚。在上面的示例中，我可以将 req.addListener 移动到数据库回调之外，但实际上我在这里调用了无法移动的 next() 。

接下来由 next() 调用的所有路由中间件都无法访问请求数据，因为这些事件已经被触发。更糟糕的是，它们只是挂起等待来自 req 的数据事件，因为它已经发生了。

如何以某种方式延迟数据事件，以便可以将其绑定到数据库回调中？或者我是否误解了一些根本性的东西并且需要改变我的处理方式？

多谢。

编辑：我在 nodejs Google 群组中找到了相关讨论，其中建议没有适合我的解决方案。

Answer 1

var cache = new function () {
    var arr = [],
        cbs = [];

    this.add = function(data) {
        arr.push(data);
        cbs.forEach(function(cb) {
            cb(arr);
        });
    }

    this.get = function(cb) {
        cbs.push(arr);
        if (arr.length > 0) {
            cb(arr);
        }
    }
};

req.addListener('data', function(chunk) {
    cache.add(chunk);
};

User.find(
    req.session.userId
).on('success', function(user) {
    cache.get(function(data) {
        // stuff
        next();
    });

};

我认为您真正想要的是某种消息缓存。现在这是一个模糊的概念证明。你真正想要什么取决于你的代码。

如果您有任何类型的延迟库/抽象可用，那么代码将变得小很多。