node.js прослушиватель событий в другом исходном файле

Question

Я пытаюсь создать сценарий, в котором при запуске определенного события я хотел, чтобы несколько слушателей выполнили какую-то задачу. Пытаясь также управлять кодом S.R.P, я хочу, чтобы слушатели находились в другом исходном файле. Я хочу знать, возможно ли это с помощью события Emitter. Является ли событие эмиттером только для одного исходного файла?

var events = require('events'); 
var em = new events.EventEmitter(); 

exports.saveScheme = function (req, res) { 

var dal = dalFactory.createDAL(constants.SCHEME); 
return new Promise.resolve(dal.PromiseSave(req.body)) 
    .then(function(data){ 
     var schemeId = data._id; 

     em.addListener('FirstEvent', function (data) { 
      console.log('First subscriber: ' + data); 
     }); 
     em.emit('FirstEvent', 'Test event emitter'); 

    }).catch(function(error){ 
     console.log(error); 
    }); 
}; 

Мой другой исходный файл

var emitter = require('events').EventEmitter; 
var em = new emitter(); 

//Subscribe FirstEvent 
em.on('FirstEvent', function (data) { 
    console.log('First subscriber: ' + data); 
}); 

Answer 1

Каждый EventEmitter объект создается новый экземпляр, чтобы мероприятия, выпущенные из первого не будет запущен во втором, так что ответ на ваш вопрос это - нет, это невозможно. Однако, есть и другие решения:

Я думаю, что лучше один является создание централизованной общей EventEmitter, например, так:

//firstFile.js 
var common = require('./common'); 
var commonEmitter = common.commonEmitter; 

exports.saveScheme = function (req, res) { 

var dal = dalFactory.createDAL(constants.SCHEME); 
return new Promise.resolve(dal.PromiseSave(req.body)) 
    .then(function(data){ 
     var schemeId = data._id; 

     commonEmitter.addListener('FirstEvent', function (data) { 
      console.log('First subscriber: ' + data); 
     }); 
     commonEmitter.emit('FirstEvent', 'Test event emitter'); 

    }).catch(function(error){ 
     console.log(error); 
    }); 
}; 



//secondFile.js 
var common = require('./common'); 
var commonEmitter = common.commonEmitter; 

//Subscribe FirstEvent 
commonEmitter.on('FirstEvent', function (data) { 
    console.log('First subscriber: ' + data); 
}); 


//common.js 
var events = require('events'); 
var em = new events.EventEmitter(); 
module.exports.commonEmitter = em; 

Но если вы хотите, чтобы исходный файл «знать» друг друга - You может сделать что-то вроде этого:

//firstFile.js 
var events = require('events'); 
var em = new events.EventEmitter(); 

exports.saveScheme = function (req, res) { 

var dal = dalFactory.createDAL(constants.SCHEME); 
return new Promise.resolve(dal.PromiseSave(req.body)) 
    .then(function(data){ 
     var schemeId = data._id; 

     em.addListener('FirstEvent', function (data) { 
      console.log('First subscriber: ' + data); 
     }); 
     em.emit('FirstEvent', 'Test event emitter'); 

    }).catch(function(error){ 
     console.log(error); 
    }); 
}; 
exports.emitter = em; 



//secondFile.js 
var firstFile = require('./firstFile'); 
var firstFileEmitter = firstFile.emitter; 

//Subscribe FirstEvent 
firstFileEmitter.on('FirstEvent', function (data) { 
    console.log('First subscriber: ' + data); 
}); 

Answer 2

Мой первый файл

var events = require('events'); 
var em = new events.EventEmitter(); 

module.exports.saveScheme = function (req, res) { 
em.emit('FirstEvent', 'Rahul event emitter'); 
}; 

exports.emitter = em; 

Второй файл:

var firstFile = require('./abc'); 
var firstFileEmitter = firstFile.emitter; 


//Subscribe FirstEvent 
firstFileEmitter.on('FirstEvent', function (data) { 
console.log('First subscriber: ' + data); 
}); 

Answer 3

Слушатель событий и излучатель могут находиться в двух разных файлах. Пожалуйста, смотрите простой пример ниже:

Первый файл, назовем его eventEx.js

var EventEmitter = require('events').EventEmitter 

    var myEmitter = new EventEmitter(); 

    myEmitter.on('print', (arg) => { 
    console.log(arg); 
    }) 

    exports.myEmitter = myEmitter 

И второй файл следующим образом:

var emitter = require('./eventEx.js') 
var printEmitter = emitter.myEmitter 

printEmitter.emit('print', 'how was Dunkirk?') 
printEmitter.emit('print', 'Dunkirk was awesome!!')