Сколько типов потоков существует в Node.js?

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

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

   const fs = require('fs');
   
   const readableStream = fs.createReadStream('example.txt');
   
   readableStream.on('data', (chunk) => {
       console.log(`Получен кусок данных: ${chunk}`);
   });
   
   readableStream.on('end', () => {
       console.log('Чтение завершено');
   });
   

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

   const fs = require('fs');
   
   const writableStream = fs.createWriteStream('output.txt');
   
   writableStream.write('Запись первой строки\n');
   writableStream.write('Запись второй строки\n');
   writableStream.end('Запись завершена\n');
   

3. 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');
   

4. 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 является ключевым для эффективной работы с данными. Потоки помогают обрабатывать большие объемы данных с минимальным использованием памяти, что особенно важно для веб-приложений и серверного программирования. Осваивайте потоки, и ваше приложение будет работать быстрее и эффективнее!