関連する推奨事項: 「nodejs チュートリアル 」
バックエンドの経験を持つほとんどの学生にとって、Stream オブジェクトは合理的で一般的なオブジェクトです。しかし、フロントエンドのクラスメートである Stream は、それほど当たり前のことではありません。github には、Stream とは何かを紹介する 9,000 個以上のスターが付いた記事もあります - stream-handbook (https://link.zhihu.com/?target=https: / /github.com/substack/stream-handbook)。 Streamをより深く理解するために、この記事をもとに簡単にまとめてみましょう。
ストリームは Unix システムでは非常に一般的で重要な概念であり、用語的には入出力デバイスを抽象化したものです。
ls | grep *.js
スクリプトを作成するときに、このようなコードによく遭遇します。|
を使用して 2 つのコマンドを接続し、前のコマンドの結果を次のコマンドとして使用します。のコマンドが渡されるため、データはパイプライン内の水のように送信されます。各コマンドはプロセッサのようなもので、データに対して何らかの処理を行うため、| は「パイプライン シンボル#」と呼ばれます。 ##」。
方向性データであり、フローの方向に応じて 3 つのタイプに分類できます
config.json を読み込む必要が生じます。このとき、## を簡単に分析します。
# データ : config.json の内容const fs = require('fs'); const FILEPATH = '...'; const rs = fs.createReadStream(FILEPATH);
fs モジュールが提供する
createReadStream() メソッドを使用して、読み取り可能なストリームを簡単に作成します。このとき、config.json
のコンテンツは次から流れてきます。デバイスをプログラムに接続します。 fs は既に内部で Stream モジュールを参照し、それをカプセル化しているため、Stream モジュールを直接使用しません。 データを取得したら、それを処理する必要があります。たとえば、特定のパス DEST に書き込む必要があります。このとき、データがプログラムからデータに流れることを可能にする書き込み可能なストリームが必要です。デバイス。
const ws = fs.createWriteStream(DEST);
2 つのストリーム、つまり 2 つのデータ プロセッサがあるので、Unix のようなパイプ記号
| を介してストリームをどのように接続すればよいでしょうか? NodeJS のパイプ シンボルは pipe()
メソッドです。 <div class="code" style="position:relative; padding:0px; margin:0px;"><pre class="brush:php;toolbar:false">const fs = require('fs');
const FILEPATH = '...';
const rs = fs.createReadStream(FILEPATH);
const ws = fs.createWriteStream(DEST);
rs.pipe(ws);</pre><div class="contentsignin">ログイン後にコピー</div></div>
このように、ストリームを使用して単純なファイルコピー機能を実装しています。pipe()メソッドの実装原理については後述しますが、注意すべき点が1つあります。データはパイプされる必要があります。上流から下流へ、つまり読み取り可能なストリームから書き込み可能なストリームへパイプします。
データを処理する
必要に応じて、ローカルの
package.jsonファイル内のすべての文字を小文字に変更し、同じディレクトリ内の package- lower.json ファイルに保存します。 現時点では、双方向ストリームを使用する必要があります。文字を小文字に変換することを特に処理するストリーム lower があると仮定します。その場合、記述されるコードはおそらく次のようになります
const fs = require('fs'); const rs = fs.createReadStream('./package.json'); const ws = fs.createWriteStream('./package-lower.json'); rs.pipe(lower).pipe(ws);
At Pipe() で接続されたストリームがプロセッサと呼ばれる理由がわかります。上記によると、パイプは読み取り可能なストリームから書き込み可能なストリームに到達する必要があります:
rs -> lower: lower はダウンストリームであるため、 lower は書き込み可能なストリームである必要がありますもちろん、ASCII ストリームがあると仮定して、ASCII コードに変換する必要がある文字などの追加の処理アクションがある場合、コードは
rs.pipe(lower).pipe(acsii).pipe(ws);
同様に、 ascii も双方向ストリームである必要があります。この処理のロジックは非常に明確です。コードが明確であることに加えて、ストリームを使用する利点は何でしょうか?
ストリームを使用する理由
const http = require('http'); const fs = require('fs'); http.createServer((req, res) => { fs.readFile(moviePath, (err, data) => { res.end(data); }); }).listen(8080);
这样的代码又两个明显的问题
电影文件需要读完之后才能返回给客户,等待时间超长
电影文件需要一次放入内存中,相似动作多了,内存吃不消
用流可以讲电影文件一点点的放入内存中,然后一点点的返回给客户(利用了 HTTP 协议的 Transfer-Encoding: chunked 分段传输特性),用户体验得到优化,同时对内存的开销明显下降
const http = require('http'); const fs = require('fs'); http.createServer((req, res) => { fs.createReadStream(moviePath).pipe(res); }).listen(8080);
除了上述好处,代码优雅了很多,拓展也比较简单。比如需要对视频内容压缩,我们可以引入一个专门做此事的流,这个流不用关心其它部分做了什么,只要是接入管道中就可以了
const http = require('http'); const fs = require('fs'); const oppressor = require(oppressor); http.createServer((req, res) => { fs.createReadStream(moviePath) .pipe(oppressor) .pipe(res); }).listen(8080);
可以看出来,使用流后,我们的代码逻辑变得相对独立,可维护性也会有一定的改善,关于几种流的具体使用方式且听下回分解。
更多编程相关知识,请访问:编程视频课程!!
以上がNode.js のストリームを理解するの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。