Nodejs 关于EventProxy 事件代理

Nodejs 关于EventProxy 事件代理

看了文档之后，有很多不解， 比如 var proxy = EventProxy.create(‘relation_saved’, ‘message_saved’, function () { res.json({status: ‘success’}); }); 是每一次 proxy.emit(‘relation_saved’) 或者 proxy.emit(‘message_saved’); 都会触发呢，还是说 其中任何一个就会触发， 在看了 cnode源码，在window上面安装出错，无法测试，但是看了这些代码，感觉很混淆， 有没用过的人出来解释下呀。


4 回复

Node.js 关于EventProxy 事件代理

问题描述

在使用 EventProxy 这个库时，我遇到了一些困惑。特别是关于 EventProxy.create 方法的使用。比如：

var proxy = EventProxy.create('relation_saved', 'message_saved', function() {
    res.json({ status: 'success' });
});

我不清楚当调用 proxy.emit('relation_saved') 或 proxy.emit('message_saved') 时会发生什么。是必须同时触发两个事件才会执行回调函数，还是只需要其中一个事件被触发？

解释与示例

EventProxy 是一个用于处理异步操作和事件驱动编程的库。它允许你定义一组事件，并且只有在所有这些事件都被触发后才执行回调函数。

让我们通过一个具体的例子来理解 EventProxy 的工作原理。

假设我们有两个异步操作：一个是保存关系（relation_saved），另一个是保存消息（message_saved）。我们需要确保这两个操作都成功完成后才能返回响应。

示例代码

首先，你需要安装 eventproxy 库：

npm install eventproxy --save

然后，你可以编写如下的代码：

const EventProxy = require('eventproxy');

function saveRelation(callback) {
    setTimeout(() => {
        console.log("Relation saved");
        callback(null, "relation_data");
    }, 1000);
}

function saveMessage(callback) {
    setTimeout(() => {
        console.log("Message saved");
        callback(null, "message_data");
    }, 2000);
}

app.post('/save', (req, res) => {
    const proxy = EventProxy.create('relation_saved', 'message_saved', (relationData, messageData) => {
        console.log("All operations completed successfully.");
        res.json({ status: 'success' });
    });

    // 异步操作
    saveRelation(proxy.done('relation_saved'));
    saveMessage(proxy.done('message_saved'));
});

在这个例子中：

  • saveRelation 和 saveMessage 分别代表两个异步操作。
  • proxy.done('relation_saved') 和 proxy.done('message_saved') 用于捕获这些异步操作的结果，并将它们传递给 EventProxy。
  • 当 relation_saved 和 message_saved 两个事件都被触发后，EventProxy 的回调函数会被执行，返回成功的 JSON 响应。

总结

EventProxy 确保了只有在所有指定的事件都被触发后，回调函数才会被执行。因此，上述代码中的回调函数只会在一个条件下触发：relation_saved 和 message_saved 两个事件都被成功触发。


两个事件都 emit 了之后才会触发。如果持续触发的话，我也不懂会怎样。。反正一般一个事件都是只 emit 一次的。

cnode 不支持 windows

不支持，伤，最近只剩下window电脑了，哪个模块不支持呢？ 有没解决window下的方法呢？

关于EventProxy中的事件代理机制，它的主要目的是帮助开发者更好地管理异步操作之间的依赖关系。当你创建一个EventProxy实例时，你可以指定它监听哪些事件。当所有指定的事件都被触发后，EventProxy内部的回调函数会被调用。

具体来说，对于你提供的示例：

var proxy = EventProxy.create('relation_saved', 'message_saved', function () {
    res.json({ status: 'success' });
});

这里EventProxy.create方法创建了一个名为proxy的事件代理对象，并且它将监听两个事件：relation_saved 和 message_saved。只有当这两个事件都已经被触发后，内部的回调函数才会被调用，执行res.json({ status: 'success' })。

这意味着，每次单独调用proxy.emit('relation_saved')或proxy.emit('message_saved')不会立即触发回调函数。只有当relation_saved和message_saved两个事件都已被触发后，回调函数才会被执行。

如果你只想在任一事件触发时就执行某些操作，可以稍微修改一下你的逻辑。例如，你可以使用EventEmitter的内置机制来实现这种行为：

const EventEmitter = require('events');
const eventEmitter = new EventEmitter();

eventEmitter.on('relation_saved', () => {
    console.log('Relation saved!');
    checkAndDoSomething();
});

eventEmitter.on('message_saved', () => {
    console.log('Message saved!');
    checkAndDoSomething();
});

function checkAndDoSomething() {
    if (eventEmitter.listenerCount('relation_saved') > 0 && eventEmitter.listenerCount('message_saved') > 0) {
        // 当两个事件都被监听时执行某些操作
        console.log('All events are ready!');
    }
}

在这个例子中，每次任何一个事件被触发都会执行相应的回调，并且通过checkAndDoSomething函数来检查是否所有的事件都被监听了。这样可以根据实际情况调整逻辑。

希望这能解答你的疑惑！如果你有更多的问题或者需要进一步的帮助，请随时告诉我。

回到顶部