Посібник Node js Streams: Filestream, Pipes
Джеймс Гартман
Файловий потік у Node.js
Node широко використовує потоки як механізм передачі даних.
Наприклад, коли ви виводите щось на консоль за допомогою функції console.log, ви фактично використовуєте потік для надсилання даних на консоль.
Node.js також має можливість передавати дані з файлів, щоб їх можна було читати та записувати належним чином. Зараз ми розглянемо приклад того, як ми можемо використовувати потоки для читання та запису з файлів. Нам потрібно виконати наведені нижче дії для цього прикладу
Крок 1) Створіть файл під назвою data.txt із наведеними нижче даними. Припустимо, що цей файл зберігається на диску D нашої локальної машини.
Підручник з Node.js
Вступ
Події
Підключення даних
Використання жасмину
Крок 2) Напишіть відповідний код, який використовуватиме потоки для читання даних із файлу.
var fs = require("fs");
var stream;
stream = fs.createReadStream("D://data.txt");
stream.on("data", function(data) {
var chunk = data.toString();
console.log(chunk);
});
Пояснення коду: -
- Спочатку нам потрібно включити модулі 'fs', які містять усі функції, необхідні для створення потоків.
- Далі ми створюємо читабельний потік за допомогою методу createReadStream. Як вхідні дані ми вказуємо розташування нашого файлу data.txt.
- Функція steam.on є обробником подій, і в ній ми вказуємо перший параметр як «дані». Це означає, що щоразу, коли дані надходять у потік із файлу, виконується функція зворотного виклику. У нашому випадку ми визначаємо функцію зворотного виклику, яка виконуватиме 2 основні кроки. По-перше, це перетворити дані, зчитані з файлу, як рядок. Другим буде надсилання перетвореного рядка як виведення на консоль.
- Ми беремо кожен фрагмент даних, який зчитується з потоку даних, і перетворюємо його на рядок.
- Нарешті, ми надсилаємо вихідні дані кожного фрагмента, перетвореного в рядок, на консоль.
вихід:
- Якщо код виконано належним чином, ви побачите наведений вище вихід у консолі. Цей результат буде таким самим, як і у файлі data.txt.
Запис у файл
Так само, як ми створюємо потік читання, ми також можемо створити потік запису для запису даних у файл. Давайте спочатку створимо порожній файл без вмісту під назвою data.txt. Припустімо, що цей файл розміщено на диску D нашого комп’ютера.
Наведений нижче код показує, як ми можемо записати дані у файл.
var fs = require("fs");
var stream;
stream = fs.createWriteStream("D://data.txt");
stream.write("Tutorial on Node.js")
stream.write("Introduction")
stream.write("Events")
stream.write("Generators")
stream.write("Data Connectivity")
stream.write("Using Jasmine")
Пояснення коду: -
- Ми створюємо записуваний потік за допомогою методу createWriteStream. Як вхідні дані ми вказуємо розташування нашого файлу data.txt.
- Далі ми використали метод stream.write для запису різних рядків тексту в наш текстовий файл. Потік подбає про запис цих даних у файл data.txt.
Якщо ви відкриєте файл data.txt, ви побачите у ньому такі дані
Підручник з Node.js
Вступ
Події
Generators
Підключення даних
використання жасмин
Канали в Node.js
У програмах Node потоки можуть об’єднуватися разом за допомогою методу pipe(), який приймає два аргументи:
- Необхідний потік із можливістю запису, який діє як адресат для даних і
- Необов'язковий об'єкт, який використовується для передачі параметрів.
Типовий приклад використання каналів, якщо ви хочете перенести дані з одного файлу в інший.
Отже, давайте розглянемо приклад того, як ми можемо передавати дані з одного файлу в інший за допомогою каналів.
Крок 1) Створіть файл під назвою datainput.txt із наведеними нижче даними. Припустимо, що цей файл зберігається на диску D нашої локальної машини.
Підручник з Node.js
Вступ
Події
Generators
Підключення даних
Використання жасмину
Крок 2) Створіть порожній порожній файл під назвою dataOutput.txt і розмістіть його на диску D вашої локальної машини.
Крок 3) Напишіть наведений нижче код, щоб перенести дані з файлу dataOutput.txt у файл dataOutput.txt.
var fs = require("fs");
var readStream = fs.createReadStream("D://datainput.txt");
var writeStream = fs.createWriteStream("D://dataOutput.txt");
readStream.pipe(writeStream);
Пояснення коду: -
- Спочатку ми створюємо «потік читання» для нашого файлу datainput.txt, який містить усі наші дані, які потрібно перенести в новий файл.
- Потім нам потрібно створити «потік запису» до нашого файлу dataOutput.txt, який є нашим порожнім файлом і є місцем призначення для передачі даних із файлу datainput.txt.
- Потім ми використовуємо команду pipe для передачі даних із потоку читання в потік запису. Команда pipe візьме всі дані, які надходять у потік читання, і перемістить їх у потік запису.
Якщо ви зараз відкриєте файл dataOutput.txt, ви побачите всі дані, які містилися у файлі dataOutput.txt.
Події в Node.js
Події є одним із ключових понять у Node.js, і іноді Node.js називають структурою, керованою подіями.
По суті, подія - це те, що відбувається. Наприклад, якщо встановлено з’єднання з базою даних, запускається подія підключення до бази даних. Програмування, кероване подіями, полягає у створенні функцій, які запускатимуться, коли запускаються певні події.
Давайте розглянемо базовий приклад визначення події в Node.js.
Ми збираємося створити подію під назвою "data_received". Коли ця подія запускається, на консоль надсилається текст «дані отримані».
var events = require('events');
var eventEmitter = new events.EventEmitter();
eventEmitter.on('data_received', function() {
console.log('data received succesfully.');
});
eventEmitter.emit('data_received');
Пояснення коду: -
- Використовуйте функцію require, щоб включити модуль «події». За допомогою цього модуля ви зможете створювати події в Node.js.
- Створіть новий джерело подій. Це використовується для прив’язки події, яка в нашому випадку є «data_received», до функції зворотного виклику, яка визначена в кроці 3.
- Ми визначаємо керовану подіями функцію, яка каже, що якщо у разі запуску події “data_received”, ми повинні вивести на консоль текст “data_received”.
- Нарешті, у нас є ручний тригер нашої події за допомогою функції eventEmiter.emit. Це ініціює подію data_received.
Під час запуску програми текст «дані отримані» буде надіслано на консоль, як показано нижче.
Випромінюючі події
Під час визначення подій існують різні методи для подій, які можна викликати. Ця тема присвячена детальному розгляду кожного з них.
- Одноразові обробники подій
Іноді вам може бути цікаво відреагувати на подію лише тоді, коли вона відбувається вперше. У таких ситуаціях можна використовувати метод once().
Давайте подивимося, як ми можемо використовувати метод once для обробників подій.
Пояснення коду: -
- Тут ми використовуємо метод «один раз», щоб сказати, що для події «data_received» функція зворотного виклику має бути виконана лише один раз.
- Тут ми вручну запускаємо подію data_received.
- Коли подія data_received запускається знову, цього разу нічого не станеться. Це пов’язано з першим кроком, де ми сказали, що подія може бути ініційована лише один раз.
Якщо код виконано належним чином, у журналі виведеться «data_received successfully». Це повідомлення з’явиться на консолі лише один раз.
- Перевірка слухачів подій
У будь-який момент свого життя джерело подій може мати нуль або більше слухачів, приєднаних до нього. Слухачів для кожного типу події можна перевірити кількома способами.
Якщо ви зацікавлені лише у визначенні кількості приєднаних слухачів, тоді шукайте не далі, ніж метод EventEmitter.listenerCount().
(Примітка: Слухачі важливі, тому що основна програма повинна знати, чи додаються слухачі на льоту до події, інакше програма працюватиме неправильно, оскільки будуть викликані додаткові слухачі.)
Пояснення коду: -
- Ми визначаємо тип eventEmitter, який необхідний для використання методів, пов’язаних із подіями.
- Потім ми визначаємо об’єкт під назвою emitter, який використовуватиметься для визначення наших обробників подій.
- Ми створюємо 2 обробники подій, які практично нічого не роблять. У нашому прикладі це просто, щоб показати, як працює метод listenerCount.
- Тепер, коли ви викликаєте метод listenerCount для нашої події data_received, він надішле кількість слухачів подій, приєднаних до цієї події, у журнал консолі.
Якщо код виконано належним чином, у журналі консолі буде показано значення 2.
- Подія 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() {});
Пояснення коду: -
- Ми створюємо новий обробник події для події newListener. Тож щоразу, коли реєструється новий обробник подій, на консолі відображатиметься текст «Додано слухач для» + назва події.
- Тут ми пишемо на консоль текст «Added listener for» + назву події для кожної зареєстрованої події.
- Ми визначаємо 2 обробники подій для нашої події data_received.
Якщо наведений вище код виконано належним чином, у консолі буде показано наведений нижче текст. Це лише показує, що обробник події newListener було запущено двічі.
Додано слухач подій data_received
Додано слухач подій data_received
Підсумки
- Потоки використовуються в Node.js для читання та запису даних із пристроїв введення-виведення. Node.js використовує бібліотеку 'fs' для створення доступних для читання та запису потоків до файлів. Ці потоки можна використовувати для читання та запису даних із файлів.
- Труби можна використовувати для з’єднання кількох потоків. Одним із найпоширеніших прикладів є поєднання потоків читання та запису разом для передачі даних з одного файлу в інший.
- Node.js також часто позначається як фреймворк, керований подіями, і в Node.js дуже легко визначати події. Можна визначити функції, які реагують на ці події.
- Події також розкривають методи реагування на ключові події. Наприклад, ми бачили обробник події once(), який можна використовувати, щоб переконатися, що функція зворотного виклику виконується лише один раз, коли спрацьовує подія.
