10) Файловый поток, Трубы

var events = require('events');
var eventEmitter = new events.EventEmitter();
eventEmitter.on('data_received', function() {
    console.log('data received succesfully.');
});

eventEmitter.emit('data_received'); 

Объяснение кода: —

1. Используйте функцию require, чтобы включить модуль ‘events’. С помощью этого модуля вы сможете создавать события в Node.js.
2. Создать новый источник событий. Это используется для привязки события, которое в нашем случае «data_received», к функции обратного вызова, определенной в шаге 3.
3. Мы определяем управляемую событиями функцию, которая говорит, что если в случае срабатывания события «data_received» мы должны вывести текст «data_received» на консоль.
4. Наконец, у нас есть ручной запуск нашего события с использованием функции eventEmiter.emit. Это вызовет событие data_received.

При запуске программы текст «полученные данные» будет отправлен на консоль, как показано ниже.

Излучение событий

Объяснение кода: —

1. Здесь мы используем метод «Once», чтобы сказать, что для события «data_received» функция обратного вызова должна выполняться только один раз.
2. Здесь мы вручную запускаем событие data_received.
3. Когда событие data_received снова запускается, на этот раз ничего не произойдет. Это из-за первого шага, когда мы сказали, что событие может быть инициировано только один раз.

Если код выполняется правильно, вывод в журнале будет «data_received успешно». Это сообщение появится в консоли только один раз.

2. Проверка прослушивателей событий

В любой момент своей жизни к источнику событий может быть подключено ноль или более слушателей. Слушатели для каждого типа события могут быть проверены несколькими способами.

Если вас интересует только определение количества подключенных слушателей, тогда не ищите ничего, кроме метода EventEmitter.listenerCount ().

( Примечание: слушатели важны, потому что основная программа должна знать, добавляются ли слушатели на лету к событию, иначе программа будет работать неправильно, потому что будут вызваны дополнительные слушатели.)

Объяснение кода: —

1. Мы определяем тип eventEmitter, который требуется для использования методов, связанных с событиями.
2. Затем мы определяем объект с именем emitter, который будет использоваться для определения наших обработчиков событий.
3. Мы создаем 2 обработчика событий, которые в основном ничего не делают. Это просто для нашего примера, чтобы показать, как работает метод listenerCount.
4. Теперь, когда вы вызываете метод listenerCount для нашего события data_received, он отправляет число прослушивателей событий, связанных с этим событием, в журнале консоли.

Если код выполняется правильно, значение 2 будет показано в журнале консоли.

3. Событие newListener

Каждый раз, когда регистрируется новый обработчик события, отправитель события генерирует событие newListener. Это событие используется для обнаружения новых обработчиков событий. Обычно вы используете событие newListener, когда вам нужно выделить ресурсы или выполнить какое-то действие для каждого нового обработчика событий.

var events = require('events');
var eventEmitter = events.EventEmitter;
var emitter = new eventEmitter();
emitter.on("newListener", function(eventName, listener) {
    console.log("Added listener for " + eventName + " events");
});
emitter.on('data_received', function() {});
emitter.on('data_received', function() {}); 

Объяснение кода: —

1. Мы создаем новый обработчик событий для события ‘newListener’. Поэтому всякий раз, когда регистрируется новый обработчик событий, в консоли будет отображаться текст «Добавлен прослушиватель для» + имя события.
2. Здесь мы пишем в консоль текст «Добавлен прослушиватель для» + имя события для каждого зарегистрированного события.
3. Мы определяем 2 обработчика событий для нашего события data_received.

Если приведенный выше код выполнен правильно, приведенный ниже текст будет отображаться в консоли. Это просто показывает, что обработчик события ‘newListener’ был запущен дважды.

Добавлен слушатель событий data_received

Добавлен слушатель событий data_received

Резюме

• Потоки используются в Node.js для чтения и записи данных с устройств ввода-вывода. Node.js использует библиотеку ‘fs’ для создания читаемых и записываемых потоков в файлы. Эти потоки могут использоваться для чтения и записи данных из файлов.
• Трубы могут быть использованы для соединения нескольких потоков вместе. Один из наиболее распространенных примеров — это объединение потоков чтения и записи для передачи данных из одного файла в другой.
• Node.js часто также помечается как управляемая событиями среда, и очень легко определять события в Node.js. Можно определить функции, которые отвечают на эти события.
• События также предоставляют методы реагирования на ключевые события. Например, мы видели обработчик события Once (), который можно использовать, чтобы убедиться, что функция обратного вызова выполняется только один раз, когда событие инициируется.