Node.js предоставляет мощный встроенный модуль под названием «stream», который позволяет эффективно обрабатывать потоки данных. Потоки являются важной частью Node.js, позволяя разработчикам обрабатывать данные порциями, а не загружать весь набор данных в память. В этой статье мы рассмотрим несколько методов работы с потоками в Node.js, сопровождаемые примерами кода.

1. Читаемые потоки.
   Читаемый поток представляет собой источник данных. Вот пример чтения данных из файла с использованием читаемого потока:

const fs = require('fs');
const readStream = fs.createReadStream('data.txt');
readStream.on('data', (chunk) => {
  console.log(`Received ${chunk.length} bytes of data.`);
});
readStream.on('end', () => {
  console.log('Data reading completed.');
});

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

const fs = require('fs');
const writeStream = fs.createWriteStream('output.txt');
writeStream.write('Hello, World!\n');
writeStream.write('This is a sample text.');
writeStream.end('Data writing completed.');

1. Дуплексные потоки:
   Дуплексные потоки могут быть доступны как для чтения, так и для записи одновременно. Вот пример создания дуплексного потока с использованием модуля net:

const net = require('net');
const duplex = net.createConnection(3000, 'localhost', () => {
  duplex.write('Hello, server!');
});
duplex.on('data', (chunk) => {
  console.log(`Received data from server: ${chunk}`);
});

1. Потоки преобразования.
   Потоки преобразования — это тип дуплексного потока, который позволяет изменять данные во время их чтения или записи. Вот пример преобразования данных с помощью модуля zlib:

const zlib = require('zlib');
const fs = require('fs');
const readStream = fs.createReadStream('input.txt');
const writeStream = fs.createWriteStream('output.txt');
const gzip = zlib.createGzip();
readStream.pipe(gzip).pipe(writeStream);

1. Конвейерные потоки.
   Пайпирование — это метод подключения вывода одного потока к входу другого, создавая конвейер потока данных. Вот пример передачи потока, доступного для чтения, в поток, доступный для записи:

const fs = require('fs');
const readStream = fs.createReadStream('input.txt');
const writeStream = fs.createWriteStream('output.txt');
readStream.pipe(writeStream);

В этой статье мы рассмотрели различные методы работы с потоками в Node.js. Мы рассмотрели читаемые потоки, записываемые потоки, дуплексные потоки, потоки преобразования и конвейерные потоки, предоставив примеры кода для каждого. Потоки — это мощная функция Node.js, обеспечивающая эффективную обработку и манипулирование данными. Понимая и используя эти потоковые методы, разработчики могут создавать высокопроизводительные приложения, которые с легкостью обрабатывают большие наборы данных.