node.jsストリームの基本

node.jsは、非同期でイベント駆動型であるため、I/Oバウンド操作に優れています。 Node.jsストリームのレバレッジは、小さなチャンクでデータを効率的に処理することにより、これらのタスクを大幅に簡素化します。ストリームの世界を掘り下げて、それらがI/Oを合理化する方法を見てみましょう。

重要な概念：

node.jsストリーム、非同期およびイベント駆動型、管理可能な部分でデータを処理することにより、I/Oを最適化します。
• ストリームは、読み取り可能、書き込み可能、​​または二重（読み取り可能かつ書き込み可能）として分類されます。 読み取り可能なストリームソースからデータを取得します。書き込み可能なストリームは、宛先にデータを送信します。
• 関数は非常に貴重で、手動の流れ管理なしでソースと宛先の間のシームレスなデータ転送を促進します。
• 、pipe()、
、
• のようなメソッドは、データフローのきめ細かい制御、ストリーム機能の強化。 Readable.pause() Readable.resume()readable.unpipe()ストリームの理解：

ストリームはUNIXパイプに類似しており、ソースから宛先への簡単なデータ転送を可能にします。 基本的に、ストリームは特殊な方法を備えたです。 実装されたメソッドは、ストリームが読みやすく、筆記可能なのか、二重であるかを決定します。 読み取り可能なストリームはデータ入力を提供します。書き込み可能なストリームは、データの出力を処理します。

node.jsでストリームが既に遭遇した可能性があります。 HTTPサーバーでは、リクエストは読み取り可能なストリームであり、応答は書き込み可能なストリームです。

モジュールは、読み取り可能なファイルストリーム機能の両方を提供します。 EventEmitterこの記事は、読みやすく書かれたストリームに焦点を当てています。二重ストリームはその範囲を超えています

読み取り可能なストリーム：fs

読み取り可能なストリームは、ソース（ファイル、インメモリバッファー、または別のストリーム）からデータを読み取ります。

sであるため、さまざまなイベントをトリガーします。これらのイベントを利用して、ストリームと対話します

ストリームからの読み取り：

最も一般的なアプローチは、EventEmitterイベントを聞き、コールバックを添付することです。 データが利用可能になったら、

イベントが発射され、コールバックが実行されます。

読み取り可能なストリームを作成します。 最初は静的で、イベントリスナーを取り付けると流れ始めます。 その後、データチャンクがコールバックに渡されます。 イベントの頻度は、ストリームの実装によって決定されます（たとえば、HTTP要求は数KBあたりのイベントを発する可能性がありますが、ファイルストリームは1行あたりに発生する可能性があります）。

dataイベントは、データの終了を示します。data あるいは、すべてのデータが読み取られるまで、ストリームインスタンスで

を繰り返し呼び出します：

const fs = require('fs');
const readableStream = fs.createReadStream('file.txt');
let data = '';
readableStream.on('data', (chunk) => { data += chunk; });
readableStream.on('end', () => { console.log(data); });

const fs = require('fs');
const readableStream = fs.createReadStream('file.txt');
let data = '';
readableStream.on('data', (chunk) => { data += chunk; });
readableStream.on('end', () => { console.log(data); });

read()内部バッファからデータを取得します。 データが残っていない場合、nullを返します。 readableイベントは、データの可用性を示しています

エンコードの設定：

データは通常、

オブジェクトです。 文字列の場合は、Buffer：Readable.setEncoding()を使用してください

const fs = require('fs');
const readableStream = fs.createReadStream('file.txt');
let data = '';
let chunk;
readableStream.on('readable', () => {
  while ((chunk = readableStream.read()) !== null) {
    data += chunk;
  }
});
readableStream.on('end', () => { console.log(data); });

これはデータをUTF-8として解釈し、コールバックに文字列として渡す。

配管：

配管により、ソースと宛先間のデータ転送が簡素化されます：

const fs = require('fs');
const readableStream = fs.createReadStream('file.txt');
let data = '';
readableStream.setEncoding('utf8');
readableStream.on('data', (chunk) => { data += chunk; });
readableStream.on('end', () => { console.log(data); });

データフローを自動的に処理します。

pipe()

チェーン：

ストリームはチェーンできます：

これは

const fs = require('fs');
const readableStream = fs.createReadStream('file1.txt');
const writableStream = fs.createWriteStream('file2.txt');
readableStream.pipe(writableStream);

input.txt.gz追加の読み取り可能なストリームメソッド：output.txt

：ストリームを一時停止します。

• ：一時停止したストリームを再開します。Readable.pause()
• ：パイプから宛先ストリームを削除します。Readable.resume()
• readable.unpipe()writableストリーム：

書き込みストリームは、宛先にデータを送信します。 読みやすいストリームと同様に、それらはs。です

ストリームへの書き込み：EventEmitter

データを送信するにはを使用してください：

write()成功を示すブール値を返します。 FALSEの場合、ストリームは一時的にいっぱいです。もっと書く前に

イベントを待ちます。

const fs = require('fs');
const zlib = require('zlib');
fs.createReadStream('input.txt.gz')
  .pipe(zlib.createGunzip())
  .pipe(fs.createWriteStream('output.txt'));

write()データの終わり：drain

データの終了を通知するには、に電話してください。 すべてのデータがフラッシュされた後、イベントが放出されます。 電話をかけた後に書くことはできません

重要な書き込みストリームイベント：end()finish end()

：エラーを示します。

：読み取り可能なストリームが配管されているときに放出されます。

• error：読み取り可能なストリームで
が呼び出されたときに放出されます。
• pipe
結論：
• unpipe unpipe()ストリームは、node.jsの強力な機能であり、I/O効率を向上させます。 ストリーム、配管、チェーンを理解することで、清潔でパフォーマンスのあるコードを書き込むことができます。

node.jsストリーミングFAQ：

node.jsストリームは何ですか？

データの効率的で増分処理を可能にし、データセット全体をメモリにロードすることを避けます。

node.jsストリームの主なタイプ？
• 読み取り可能、書き込み可能、​​二重、変換。
  読み取り可能なストリームを作成しますか？
• メソッドを実装してください。

  読みやすいストリームの一般的なユースケース？

大きなファイルの読み取り、HTTPリクエストからのデータの処理、リアルタイムデータ処理。

• 書き込み可能なストリームを作成しますか？stream.Readable_readメソッドを実装してください。

• 書き込み可能なストリームの一般的な用途？ファイルにデータを保存し、データをサービスに送信します。

• 二重ストリーム？読み取り可能な機能と書き込み可能な機能を組み合わせます

• ストリームを変換しますか？

  データが通過するときにデータを変更します（たとえば、圧縮、暗号化）。

ストリーム間のデータの配管？
• メソッドを使用してください。

  Node.jsストリームを操作するためのベストプラクティス？.pipe()大規模なデータセットに使用し、エラーとバックプレッシャーを処理し、約束ベースの操作を

  を検討します。

以上がnode.jsストリームの基本の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。