В Node.js потоки (streams) представляют собой мощный способ работы с данными, позволяя обрабатывать данные более эффективно и с меньшими затратами памяти, чем с использованием больших объемов данных сразу. Существует четыре основных типа потоков в Node.js:

Readable (Читаемые потоки): Эти потоки позволяют вам читать данные из источника. Например, они могут принимать данные из файловой системы, HTTP-запросов или любого другого источника данных.
Пример использования читаемого потока:

const fs = require('fs');

const readableStream = fs.createReadStream('example.txt');

readableStream.on('data', (chunk) => {
    console.log(`Получен кусок данных: ${chunk}`);
});

readableStream.on('end', () => {
    console.log('Чтение завершено');
});

Writable (Записываемые потоки): Эти потоки позволяют вам писать данные в конечный пункт, например, в файл или сетевое соединение.
Пример использования записываемого потока:

const fs = require('fs');

const writableStream = fs.createWriteStream('output.txt');

writableStream.write('Запись первой строки\n');
writableStream.write('Запись второй строки\n');
writableStream.end('Запись завершена\n');

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

const { Duplex } = require('stream');

const duplexStream = new Duplex({
    read(size) {
        this.push('Данные для чтения\n');
        this.push(null); // Завершение потока
    },
    write(chunk, encoding, callback) {
        console.log(`Получены данные: ${chunk.toString()}`);
        callback();
    }
});

duplexStream.pipe(process.stdout); // Читаем из потока и выводим в консоль
duplexStream.write('Запись производится\n');

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

const { Transform } = require('stream');

const transformStream = new Transform({
    transform(chunk, encoding, callback) {
        const upperCaseChunk = chunk.toString().toUpperCase();
        this.push(upperCaseChunk);
        callback();
    }
});

process.stdin.pipe(transformStream).pipe(process.stdout); // Читаем из stdin, преобразуем и выводим в stdout

Заключение

Понимание типов потоков в Node.js является ключевым для эффективной работы с данными. Потоки помогают обрабатывать большие объемы данных с минимальным использованием памяти, что особенно важно для веб-приложений и серверного программирования. Осваивайте потоки, и ваше приложение будет работать быстрее и эффективнее!

Предыдущий вопрос

Назовите типы функций API, поддерживаемые Node.js

Следующий вопрос

Что такое libuv?

Содержание:

Заключение

Редактировать