Потоки. Работа с потоками

Сентябрь 6, 2022

Главная
Алгебра
Потоки. Работа с потоками

Содержание

2. Потоки Для работы с потоками в Node.js используется модуль stream Потоки делятся на четыре типа: Readable
3. Потоки. Чтение Пример наследника типа Readable, который представляет потоковое чтение данных из массива Для реализации читающего
4. Потоки. Чтение Создадим файл StreamArray.js: const stream = require("stream"); class StreamArray extends stream.Readable { constructor(array) {
5. Потоки. Чтение Для работы с потоками типа Readable нужно добавить обработчики на его события, основные события:
6. Потоки. Запись Пример наследника типа Writable, который выводит данные в консоль Для реализации записывающего потока нужно
7. Потоки. Запись Создадим файл ConsoleWriter.js: const stream = require("stream"); class ConsoleWriter extends stream.Writable { constructor() {
8. Потоки. Запись Для работы с потоками типа Writable используется метод write() для записи данных и метод
9. Потоки. Преобразование Пример наследника типа Transform, который преобразует данные в разные типы Для реализации преобразовывающего потока
10. Потоки. Преобразование Создадим файл TypeTransform.js: const stream = require("stream"); class TypeTransform extends stream.Transform { constructor(type) {
11. Потоки. Преобразование Для работы с потоками типа Transform используется метод write() для передачи исходных данных и
12. Потоки. Каналы Канал (pipe) – механизм, который связывает поток для чтения и поток для записи и
13. Потоки. Каналы /* Связывание потоков без каналов sa.on("data", (chunk) => { tt.write(chunk); }); tt.on("data", (chunk) =>
14. Потоки Пример использования потоков для работы с файловой системой Для создания потока для записи используется метод
15. Потоки Файл app.js: const fs = require("fs"); let writeableStream = fs.createWriteStream("./hello.txt"); writeableStream.write("Hello Tom!"); writeableStream.write("Hello Bob!"); writeableStream.end();
17. Скачать презентацию

Слайд 2

Потоки
Для работы с потоками в Node.js используется модуль stream
Потоки делятся на

четыре типа:
Readable – для чтения данных
Writable – для записи данных
Duplex – комбинация двух предыдущих типов, при этом процесс чтения и записи происходит независимо друг от друга
Transform – разновидность Duplex потоков, которые могут изменять данные при их записи и чтении в/из потока (чаще используется как промежуточное звено в цепочке передачи данных)
Все потоки являются наследниками EventEmitter, т.е. во всех потоках используется событийная система

Макс

Слайд 3

Потоки. Чтение
Пример наследника типа Readable, который представляет потоковое чтение данных из

массива
Для реализации читающего потока нужно реализовать метод _read(), который определяет какие данные нужно поместить в очередь для чтения
Для добавления данных в очередь используется метод родителя push()
Когда все данные будут прочитаны, в метод push() передается параметр null

Макс

Слайд 4

Потоки. Чтение
Создадим файл StreamArray.js:
const stream = require("stream");
class StreamArray extends stream.Readable {

constructor(array) {
super({objectMode: true});
this._array = array;
}
_read() {
this._array.forEach((value) => {
this.push(value);
});
this.push(null);
}
}
module.exports = StreamArray;

Макс

Слайд 5

Потоки. Чтение
Для работы с потоками типа Readable нужно добавить обработчики на

его события, основные события:
data – генерируется каждый раз, когда поток возвращает часть считанных данных
end – генерируется когда все данные были прочитаны
Создадим файл приложения app.js:
const StreamArray = require("./StreamArray");
let sa = new StreamArray([1, 5, 2, 4, 3]);
sa.on("data", (chunk) => {
console.log(`Data: ${chunk}`);
});
sa.on("end", () => {
console.log("Done");
});
Запуск app.js:

Макс

Слайд 6

Потоки. Запись
Пример наследника типа Writable, который выводит данные в консоль
Для реализации

записывающего потока нужно реализовать метод _write(), параметры:
chunk – порция данных для записи
encoding – кодировка
callback – функция обратного вызова, которую необходимо вызывать в конце обработки порции данных (знак того, что текущая порция данных обработана)

Макс

Слайд 7

Потоки. Запись
Создадим файл ConsoleWriter.js:
const stream = require("stream");
class ConsoleWriter extends stream.Writable {

constructor() {
super({objectMode: true});
}
_write(chunk, encoding, callback) {
console.log(`Data: ${chunk}`);
callback();
}
}
module.exports = ConsoleWriter;

Макс

Слайд 8

Потоки. Запись
Для работы с потоками типа Writable используется метод write() для

записи данных и метод end() для окончания записи
Файл app.js:
const ConsoleWriter = require("./ConsoleWriter");
let cw = new ConsoleWriter();
cw.write("Hello Tom!");
cw.write("Hello Bob!");
cw.end("Done");
Запуск app.js:

Макс

Слайд 9

Потоки. Преобразование
Пример наследника типа Transform, который преобразует данные в разные типы
Для

реализации преобразовывающего потока нужно реализовать метод _transform(), параметры:
chunk – порция данных для преобразования
encoding – кодировка
callback – функция обратного вызова, которую необходимо вызывать после преобразования порции данных
Для возврата преобразованных данных используется метод родителя push()

Макс

Слайд 10

Потоки. Преобразование
Создадим файл TypeTransform.js:
const stream = require("stream");
class TypeTransform extends stream.Transform {

constructor(type) {
super({objectMode: true});
this._type = type;
}
_transform(chunk, encoding, callback) {
let res = this._type.call(null, chunk);
this.push(res);
callback();
}
}
module.exports = TypeTransform;

Макс

Слайд 11

Потоки. Преобразование
Для работы с потоками типа Transform используется метод write() для

передачи исходных данных и событие data для получения обработанных данных
Файл app.js:
const TypeTransform = require("./TypeTransform");
let tt = new TypeTransform(Boolean);
tt.on("data", (chunk) => {
console.log(`Data: ${chunk}`);
});
tt.write("Hello Tom!");
tt.write("");
Запуск app.js:

Макс

Слайд 12

Потоки. Каналы
Канал (pipe) – механизм, который связывает поток для чтения и

поток для записи и позволяет сразу считать из потока чтения в поток записи
Задача записи в поток данных, считанных из другого потока, является довольно распространенной, и в этом случае каналы позволяют сократить объем кода. Для работы с каналами используется метод pipe()
Файл app.js:
const StreamArray = require("./StreamArray");
const ConsoleWriter = require("./ConsoleWriter");
const TypeTransform = require("./TypeTransform");
let sa = new StreamArray([1, 0, 1, 1, 0]);
let cw = new ConsoleWriter();
let tt = new TypeTransform(Boolean);
sa.pipe(tt).pipe(cw);

Макс

Слайд 13

Потоки. Каналы
/* Связывание потоков без каналов
sa.on("data", (chunk) => {
tt.write(chunk);

});
tt.on("data", (chunk) => {
cw.write(chunk);
});
*/
Запуск app.js:

Макс

Слайд 14

Потоки
Пример использования потоков для работы с файловой системой
Для создания потока для

записи используется метод createWriteStream(), в который передается название файла. Если такого файла нет, то он создается
Для создания потока для чтения используется метод createReadStream(), в который также передается название файла. В качестве опционального параметра здесь передается кодировка, что позволит сразу при чтении кодировать считанные данные в строку в указанной кодировке

Макс

Слайд 15

Потоки
Файл app.js:
const fs = require("fs");
let writeableStream = fs.createWriteStream("./hello.txt");
writeableStream.write("Hello Tom!");
writeableStream.write("Hello Bob!");
writeableStream.end();
let readableStream

= fs.createReadStream("./hello.txt", "utf8");
readableStream.on("data", (chunk) => {
console.log(chunk);
});
Запуск app.js:

Макс

Потоки. Работа с потоками

Содержание

ПотокиДля работы с потоками в Node.js используется модуль streamПотоки делятся на

Потоки. ЧтениеПример наследника типа Readable, который представляет потоковое чтение данных из

Потоки. ЧтениеСоздадим файл StreamArray.js:const stream = require("stream");class StreamArray extends stream.Readable {

Потоки. ЧтениеДля работы с потоками типа Readable нужно добавить обработчики на

Потоки. ЗаписьПример наследника типа Writable, который выводит данные в консольДля реализации

Потоки. ЗаписьСоздадим файл ConsoleWriter.js:const stream = require("stream");class ConsoleWriter extends stream.Writable {

Потоки. ЗаписьДля работы с потоками типа Writable используется метод write() для

Потоки. ПреобразованиеПример наследника типа Transform, который преобразует данные в разные типыДля

Потоки. ПреобразованиеСоздадим файл TypeTransform.js:const stream = require("stream");class TypeTransform extends stream.Transform {

Потоки. ПреобразованиеДля работы с потоками типа Transform используется метод write() для

Потоки. КаналыКанал (pipe) – механизм, который связывает поток для чтения и

Потоки. Каналы/* Связывание потоков без каналов sa.on("data", (chunk) => { tt.write(chunk);

ПотокиПример использования потоков для работы с файловой системойДля создания потока для

ПотокиФайл app.js:const fs = require("fs");let writeableStream = fs.createWriteStream("./hello.txt");writeableStream.write("Hello Tom!");writeableStream.write("Hello Bob!");writeableStream.end();let readableStream

Похожие презентации

Потоки
Для работы с потоками в Node.js используется модуль stream
Потоки делятся на

Потоки. Чтение
Пример наследника типа Readable, который представляет потоковое чтение данных из

Потоки. Чтение
Создадим файл StreamArray.js:
const stream = require("stream");
class StreamArray extends stream.Readable {

Потоки. Чтение
Для работы с потоками типа Readable нужно добавить обработчики на

Потоки. Запись
Пример наследника типа Writable, который выводит данные в консоль
Для реализации

Потоки. Запись
Создадим файл ConsoleWriter.js:
const stream = require("stream");
class ConsoleWriter extends stream.Writable {

Потоки. Запись
Для работы с потоками типа Writable используется метод write() для

Потоки. Преобразование
Пример наследника типа Transform, который преобразует данные в разные типы
Для

Потоки. Преобразование
Создадим файл TypeTransform.js:
const stream = require("stream");
class TypeTransform extends stream.Transform {

Потоки. Преобразование
Для работы с потоками типа Transform используется метод write() для

Потоки. Каналы
Канал (pipe) – механизм, который связывает поток для чтения и

Потоки. Каналы
/* Связывание потоков без каналов
sa.on("data", (chunk) => {
tt.write(chunk);

Потоки
Пример использования потоков для работы с файловой системой
Для создания потока для

Потоки
Файл app.js:
const fs = require("fs");
let writeableStream = fs.createWriteStream("./hello.txt");
writeableStream.write("Hello Tom!");
writeableStream.write("Hello Bob!");
writeableStream.end();
let readableStream