如何在Node.js中使用JavaScript模块文件之间的事件处理程序？

Question

如何在Node.js中使用JavaScript模块文件之间的事件处理程序？

17

我目前正在使用 socket.io 在客户端JavaScript文件和Node.js服务器文件之间进行事件的发送和接收，但我希望能够在Node服务器及其模块之间进行事件的发送和接收。我的想法是它可能看起来像这样：

Node 服务器：

var module1 = require('./module1');

//Some code to launch and run the server

module1.emit('eventToModule');
module1.emit('moduleResponse', function(moduleVariable) {
   //server action based on module response
}

模块文件：

var server = require('./server.js');

server.on('eventToModule', function() {
   //module response to server request
}
server.emit('moduleResponse', moduleVariable);

这显然是一个简化版本，但我认为应该有这个功能。我需要将模块文件设置为第二个服务器吗？如果是这样的话，它会是什么样子？

我还尝试过使用 var socket = io.connect('http://localhost:3000'); （这是我用来允许客户端连接到Node服务器的代码）代替 server 并且让 module1 监听和发出 socket 但那也没用。

第二次尝试（仍然不起作用）：

server.js

//other requirements
var module1 = require('./module');
const EventEmitter = require('events');
var emitter = new EventEmitter();

io.on('connection', function(client) {
   client.on('emitterTester', function() {
      emitter.emit('toModule');
      emitter.on('toServer', function() {
         console.log("Emitter successful.");
      });
   });
});

module.exports = emitter;

模块.js

var server1 = require('./server');
const EventEmitter = require('events');
var emitter = new EventEmitter();

emitter.on('toModule', function() {
   console.log("Emitter heard by module.");
   emitter.emit('toServer');         
});

module.exports = emitter;

同时，当我尝试使用server1.on时，我收到了消息server1.on不是一个函数。

- SuperCodeBrah

3个回答

26

为了让操作更为简单，我新建了一个名为Notifier.js的js文件，内容如下：

let EventEmitter = require('events').EventEmitter
let notifier = new EventEmitter()
module.exports = notifier

当我想要使用发射器时，我只需要要求导入Notifier.js文件并访问导出的值。例如：

randomFile.js

var notifier = require('Notifier.js')
notifier.on('myEvent', (message) => {
    console.log(message)
})

randomFile2.js

var notifier = require('Notifier.js')
notifier.emit('myEvent', 'Test Message')

- Matthew Cawley

0

我使用了上方@Mattew Cawley的回复来创建这个模块，对我来说效果很好。

import EventEmitter from "events";

class Notifer {
    #eventEmitter: EventEmitter;
    #DATA_BASE_CONNECTED = "DATABASE_CONNECTED";

    constructor() {
        this.#eventEmitter = new EventEmitter();
    }

    emitDbConnected(args: any) {
        this.#eventEmitter.emit(this.#DATA_BASE_CONNECTED, args);
    }
    onDbConnected(handler: EventListener) {
        this.#eventEmitter.on(this.#DATA_BASE_CONNECTED, handler);
    }
}

export default new Notifer();

现在这个模块可以像这样使用：

// module 1

import notifier from "path/to/notifier";
notifier.emitDbConnected("some args");

&

// module 2

import notifier from "path/to/notifier";
notifier.onDbConnected((args) => {});

- Gnopor

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- jfriend00 · Accepted Answer

在node.js中，如果你想创建一个拥有事件监听器并能触发事件的对象，通常会使用EventEmitter对象。你可以直接使用EventEmitter对象，也可以从它继承并创建自己的对象，拥有所有EventEmitter功能。

因此，如果你想创建一个其他模块可以侦听事件的模块，你需要像这样操作：

// module1.js
// module that has events

// create EventEmitter object
var obj = new EventEmitter();

// export the EventEmitter object so others can use it
module.exports = obj;

// other code in the module that does something to trigger events
// this is just one example using a timer
setInterval(function() {
    obj.emit("someEvent", someData);
}, 10 * 1000);

然后，您可以有另一个模块使用第一个模块并监听从其传出的某些事件：

// module2.js
var m1 = require('module1.js');

// register event listener
m1.on("someEvent", function(data) {
    // process data when someEvent occurs
});

这里的关键点是：

如果你想让一个模块允许人们监听事件并触发事件，你可能想创建一个EventEmitter对象。
要共享该 EventEmitter 对象，你将其分配给module.exports或module.exports的属性，以便其他代码可以通过使用require()来访问EventEmitter对象。
一旦调用代码从require()获取了EventEmitter对象，它就可以使用.on()方法注册以侦听事件。
当原始模块或任何模块想要触发事件时，可以使用.emit()方法。

请记住，有时事件是很好的架构选择，但不是所有模块之间的通信都适合于事件。有时，只需导出函数并允许一个模块调用另一个模块的函数可能会更合理。因此，事件并不是模块之间通信的唯一方式。

你的问题似乎表明你认为socket.io是两个同一服务器进程中的模块进行通信的一种方式。虽然这可能是可能的，但这不是socket.io通常被使用的方式。通常，基于TCP/IP的socket.io会被用于在两个分离的进程之间进行通信，这样您就无法在进程内直接进行函数调用或注册事件处理程序。后两种方案通常更容易实现进程内通信，而socket.io通常用于在同一计算机上的进程之间或在不同计算机上的进程之间进行通信。