Node.js の非同期イテレータの詳細な説明

Node.js の非同期イテレータの詳細な説明

序文

非同期イテレータは Node.js v10.0.0 から存在しており、最近コミュニティで注目を集めています。この記事では、非同期イテレータの役割について説明し、非同期イテレータが何に使用される可能性があるかという疑問にも取り組みます。

非同期イテレータとは何ですか?

では、非同期イテレータとは何でしょうか?これらは実質的に、以前使用可能だったイテレータの非同期バージョンです。反復の値と最終ステータスがわからない場合は、非同期イテレータを使用できます。最終的には、{value:any、done:boolean} オブジェクトに解決できる promise が得られます。また、非同期イテレータをループするのに役立つ for-await-of ループも用意しました。同期イテレータの for-of ループと同じです。

非同期イテレータの定数は[1, 2, 3]です。
asyncIterable[Symbol.asyncIterator] = 非同期関数*() {
  (i = 0 とします; i < asyncIterable.length; i++) {
    yield { 値: asyncIterable[i], 完了: false }
  }
  結果: true
};

(非同期関数() {
  for await (asyncIterable の const 部分) {
    console.log(一部);
  }
})();

通常の for-of ループとは対照的に、for-await-of ループは、受信した各 Promise が解決されるまで待機してから、次の Promise に進みます。

現在、ストリーム以外に非同期反復をサポートする構造は多くありませんが、ここに示すように、反復可能な構造に表記法を手動で追加できます。

非同期イテレータストリームとして

非同期イテレータはストリームを処理するときに非常に便利です。読み取り可能、書き込み可能、​​二重、および変換ストリームはすべて非同期イテレータをサポートします。

非同期関数 printFileToConsole(path) {
  試す {
    const readStream = fs.createReadStream(path, { エンコーディング: 'utf-8' });

    for await (const chunk of readStream) {
      console.log(チャンク);
    }

    console.log('EOF');
  } キャッチ(エラー) {
    コンソール.log(エラー);
  }
}

このようにコードを記述すると、反復処理して各データ チャンクを取得するときにデータ イベントと終了イベントをリッスンする必要がなくなり、ストリーム自体が終了すると for-await-of ループも終了します。

ページング機能を備えたAPIの呼び出し

非同期反復を使用して、ページネーションを使用するソースからデータを簡単に取得することもできます。これを行うには、Node https リクエスト メソッドが提供するストリームから応答本文を再構築する方法も必要です。 https リクエストとレスポンスは Node 内のストリームなので、ここで非同期イテレータを使用することもできます。

定数 https = require('https');

関数 homebrewFetch(url) {
  新しい Promise(async (resolve, reject) => { を返します。
    const req = https.get(url, 非同期関数(res) {
      (res.statusCode >= 400)の場合{
        拒否を返します(新しいエラー(`HTTP ステータス: ${res.statusCode}`));
      }

      試す {
        本文を '' とします。

        /*
          ストリーム内のデータをリッスンする代わりに、
          for-await-ofを使用してデータチャンクを追加することができます
          レスポンス本文の残りの部分*/
        for await (const chunk of res) {
          本体 += チャンク;
        }
    
        // 本文がない場合の処理​​ if (!body) resolve({});
        // 本文は文字列なので、JSON を取得するには解析する必要があります。const result = JSON.parse(body);
        解決(結果);
      } キャッチ(エラー) {
        拒否(エラー)
      }
    });

    要求を待機します。
    要求を終了します();
  });
}

Cat API にリクエストを送信して、10 匹ずつの猫の写真を取得します。また、cat API の過負荷を回避するために、リクエスト間に 7 秒の遅延を追加し、最大ページ数を 5 にします。

また、cat API の過負荷を回避するために、リクエスト間に 7 秒の遅延を追加し、最大ページ数を 5 にします (過負荷になると壊滅的な結果となるため)。

関数 fetchCatPics({ limit, page, done }) {
  homebrewFetch を返します(`https://api.thecatapi.com/v1/images/search?limit=${limit}&page=${page}&order=DESC`)
    .then(本文 => ({ 値: 本文、完了 }));
}

関数catPics({limit}){
  戻る {
    [Symbol.asyncIterator]: 非同期関数*() {
      現在のページを 0 にします。
      // 5ページ後に停止
      現在のページが 5 未満の場合
        試す {
          const cats = fetchCatPics({ currentPage, limit, done: false }) を待機します。
          console.log(`${limit} 匹の猫を取得しました`);
          猫を飼う;
          現在のページ++;
        } キャッチ(エラー) {
          console.log('すべての猫を取得中にエラーが発生しました!');
          コンソール.log(エラー);
        }
      }
    }
  };
}

(非同期関数() {
  試す {
    for await (let catPicPage of catPics({ limit: 10 })) {
      コンソールにログ出力します。
      // リクエスト間で7秒間待機する
      新しい Promise(resolve => setTimeout(resolve, 7000)) を待機します。
    }
  } キャッチ(エラー) {
    コンソール.log(エラー);
  }
})()

こうすることで、7 秒ごとに猫の写真のページ全体が自動的に取得され、お楽しみいただけます。

ページ間を移動するより一般的な方法は、 next メソッドと previous メソッドを実装し、それらをコントロールとして公開することです。

関数actualCatPics({limit}){
  戻る {
    [シンボル.asyncIterator]: () => {
      ページを 0 にします。
      戻る {
        次へ: 関数() {
          ページ++;
          fetchCatPics({page,limit,done:false}) を返します。
        },
        前: 関数() {
          (ページ > 0) {
            ページ - ;
            fetchCatPics({page,limit,done:false}) を返します。
          }
          fetchCatPics({ page: 0, limit, done: true }); を返します。
        }
      }
    }
  };
}

試す {
    const someCatPics = 実際のCatPics({ 制限: 5 });
    const { next, previous } = someCatPics[Symbol.asyncIterator]();
    次に()します。その後(console.log);
    次に()します。その後(console.log);
    前回の().その後(console.log);
} キャッチ(エラー) {
  コンソール.log(エラー);
}

ご覧のとおり、非同期イテレータは、データのページを取得したり、アプリケーションの UI で無限スクロールなどの操作を実行したりするときに非常に便利です。

これらの機能はしばらく前からブラウザに搭載されており、Chrome v63 以降、Firefox v57 以降、Safari v11.1 で利用できます。ただし、現在 IE と Edge では利用できません。

上記は、Node.js の非同期イテレータの詳細な説明です。Node.js の非同期イテレータの詳細については、123WORDPRESS.COM の他の関連記事に注目してください。

以下もご興味があるかもしれません:
  • NodeJs の高メモリ使用量のトラブルシューティング実戦記録
  • Nodejs 組み込み暗号化モジュールを使用してピアツーピアの暗号化と復号化を実現する詳細な説明
  • Node.js組み込みモジュールの詳細な説明
  • Nodejs モジュール システムのソースコード分析
  • JS と Nodejs におけるイベント駆動型開発についての簡単な説明
  • Nodejs でモジュール fs ファイルシステムを使用する方法
  • Node.js コード実行をバイパスするためのヒントのまとめ
  • Nodejs 探索: シングルスレッドの高並行性の原理を深く理解する
  • Nodejs エラー処理プロセス記録
  • Node.js を使用して C# のデータ テーブル エンティティ クラス生成ツールを作成する方法

<<:  Tomcat の構成と最適化ソリューションの詳細な説明

>>:  CentOS 7.4 にソースコードから MySQL 8.0 をインストールするための詳細なチュートリアル

推薦する

Linux の GRUB ブート プログラムの暗号化の概要

目次1. GRUB暗号化とは何か2. grub暗号化手順3. grub暗号化のロック属性1. GRU...

意外と知らないJSのループ速度テストのいろいろを徹底解説

目次序文1. forループ2. whileループとdo-whileループ3. forEach、map...

docker-composeの詳細なインストールと使用方法

Docker Compose は、複雑なアプリケーションを定義および実行するための Docker ツ...

CSS3は、大きな円のドット分布と回転効果を実現するためにtransform-originを使用します。

まず、transform-origin 属性を使用する必要があります。transform 属性は必ず...

Linux インデックスノード inode の詳細な説明

1. inodeの紹介inode を理解するには、まずファイル ストレージから始める必要があります。...

Vue のトランジション効果とアニメーショントランジションの使用例の詳細な説明

目次遷移フック関数カスタム遷移クラス名遷移グループの使用まとめまずは例を見てみましょうコードは次のと...

nestjs における例外フィルター Exceptionfilter の具体的な使用法

Nestjs 例外フィルターといえば、非常に強力な .Net のグローバル フィルターについて触れな...

コンピュータが予期せずシャットダウンした後、VMware で Linux がインターネットに接続できない問題の解決策

問題の説明: Linux システムのネットワーク カード ファイル /etc/sysconfig/n...

MySqlは、外部ネットワーク接続クライアントの低速問題を解決するためにskip-name-resolveを使用します。

Tencent Cloud上に構築されたMySQLは、開発用コンピュータでNavicatを使用して...

よく使用される MySQL 関数の完全なリスト (分類および要約)

1. 数学関数ABS(x) xの絶対値を返します。 BIN(x) xの2進値を返します(OCTは8...

LinuxにNginxを素早くインストールする方法

目次nginxとは1. 必要な依存関係をダウンロードする2. nginxの圧縮パッケージをダウンロー...

CSS3 と JavaScript を使用して Web カラー ピッカーのサンプル コードを開発する

この例の Web カラー ピッカー機能は、ページ効果を実現するために CSS3 を使用します。つまり...

HTMLのテーブルの内容は中央に水平と垂直に表示されます

CSSスタイルファイルで指定 #class td /*表のテキストを左右上下に揃えるように設定する*...

初心者向けMySQLインデックス

序文MySQL インデックスで最も重要なデータ構造は B+ ツリーなので、まずは B+ ツリーの原理...

MySql マスタースレーブレプリケーションの実装原理と構成

データベースの読み取りと書き込みの分離は、トラフィック量の多い大規模システムやインターネット アプリ...