Angular2でObservableを使ってHTTPリクエストを複数送信

Observableを使ってhttpリクエストを複数実行する方法を確認しました。
※Angular2の2.0.0版、TypeScriptを使って確認したものです。

※ライブラリ、サービス、依存性の指定などは以下の記事参照。
Angular2でHTTPでサーバーからJSONデータ取得
 

(1)3つのhttpリクエストをチェインして実行


 
Angular2のHTTPクライアントはObservableをリターンします。ObservableのflatMapメソッドを使ってHTTPクライアントをチェーンして実行しています。
※ObservableのflatMapメソッド
 
例)3つのhttpリクエストを順番に実行

chain() {
  this._http.get("/wp/q_chain_server.php?first=5")
  .do((res1)  => {
    this._results1.push(res1.text());
  })
  .flatMap(() => {
      return this._http.get("/wp/q_chain_server.php?second=1")
                 .do((res2) => {
                   this._results1.push(res2.text());
                 })
  })
  .flatMap(() => {
      return this._http.get("/wp/q_chain_server.php?third=3")
                 .map((res3) => {
                   this._results1.push(res3.text());
                   return this._results1;
                 })
  })
  .subscribe(res => this.results1 = res);
}

(2)3つのhttpリクエストをパラレルに実行


 
ObservableのforkJoinを使って、3つのhttpリクエストをパラレルに実行し、実行結果を集約してリターンしています。
※ObservableのforkJoinメソッド
 
例)3つのhttpリクエストを集約してまとめて実行

para() {
  Observable.forkJoin(
    this._http.get("/wp/q_chain_server.php?first=5")
      .map((res) => res.text()),
    this._http.get("/wp/q_chain_server.php?second=1")
      .map((res) => res.text()),
    this._http.get("/wp/q_chain_server.php?third=3")
      .map((res) => res.text())
  ).subscribe(res => this.results2 = res );
}

(3)デモ


 
①3つのhttpリクエストをチェインして実行
3つのhttpリクエストを1つずつ順番に実行し、1つのhttpリクエストの実行結果取得後に次のhttpリクエストを実行。
 
②3つのhttpリクエストパラレルに実行し、結果を集約して表示
3つのhttpリクエストを結果の取得を待たずに続けて実行し、3つのhttpリクエストの実行結果を取得した段階で3つ結果を順番に集約して結果表示。
 
③httpリクエストをループ処理
 
1つ目のhttpリクエストで配列データ取得。取得した配列データを使ってループ処理で動的にhttpリクエストの配列を生成し、このhttpリクエストの配列をObservableのforkJoinに渡して実行。
 
Angular : 2.0.0
Bootstrap : 3.2.0

Loading…

<html>
  <head>
    <title>Angular 2 Demo</title>
    <script src="https://npmcdn.com/core-js/client/shim.min.js"></script>
    <script src="https://npmcdn.com/zone.js@0.6.23?main=browser"></script>
    <script src="https://npmcdn.com/reflect-metadata@0.1.3"></script>
    <script src="https://npmcdn.com/systemjs@0.19.27/dist/system.src.js"></script>
    <script src="./js/systemjs.config.js"></script>
    <script>
      System.import('./ts/app.ts').catch(function(err){ console.error(err);  });    </script>
    <link rel="stylesheet" href="./css/bootstrap.min.css">
    <link rel="stylesheet" href="./css/styles.css">
  </head>
  <body>
    <div class="container">
      <my-app>Loading...</my-app>
    </div>
  </body>
</html>

(systemjs.config.js)
(function(global) {

  var ngVer = '@2.0.0';
  var routerVer = '@3.0.0';
  var formsVer = '@2.0.0';
  var routerDeprecatedVer = '@2.0.0-rc.2';
  var map = {
    'app':                        'app',
    '@angular':                   'https://npmcdn.com/@angular',
    '@angular/router':            'https://npmcdn.com/@angular/router' + routerVer,
    '@angular/forms':             'https://npmcdn.com/@angular/forms' + formsVer,
    '@angular/router-deprecated': 'https://npmcdn.com/@angular/router-deprecated' + routerDeprecatedVer,
    'angular2-in-memory-web-api': 'https://npmcdn.com/angular2-in-memory-web-api',
    'rxjs':                       'https://npmcdn.com/rxjs@5.0.0-beta.12',
    'ts':                         'https://npmcdn.com/plugin-typescript@4.0.10/lib/plugin.js',
    'typescript':                 'https://npmcdn.com/typescript@1.9.0-dev.20160409/lib/typescript.js',
 };
  var packages = {
    'app':                        { main: 'main.ts',  defaultExtension: 'ts' },
    'rxjs':                       { defaultExtension: 'js' },
    'angular2-in-memory-web-api': { main: 'index.js', defaultExtension: 'js' },
  };

  var ngPackageNames = [
    'common',
    'compiler',
    'core',
    'http',
    'platform-browser',
    'platform-browser-dynamic',
    'upgrade',
  ];
  ngPackageNames.forEach(function(pkgName) {
    map['@angular/'+pkgName] = 'https://npmcdn.com/@angular/' + pkgName + ngVer;
  });
  ngPackageNames.concat(['forms', 'router', 'router-deprecated']).forEach(function(pkgName) {
    packages['@angular/'+pkgName] = { main: '/bundles/' + pkgName + '.umd.js', defaultExtension: 'js' };
  });

  var config = {
    transpiler: 'ts',
    meta: {
      'typescript': {
        "exports": "ts"
      }
    },
    map: map,
    packages: packages
  };

  System.config(config);

})(this);

import { platformBrowserDynamic } from '@angular/platform-browser-dynamic';
import { NgModule } from '@angular/core';
import { BrowserModule }  from '@angular/platform-browser';
import { Component } from '@angular/core';
import { HttpModule } from '@angular/http';
import { Http } from '@angular/http';

import 'rxjs/add/observable/throw';
import 'rxjs/add/operator/catch';
import 'rxjs/add/operator/debounceTime';
import 'rxjs/add/operator/distinctUntilChanged';
import 'rxjs/add/operator/map';
import 'rxjs/add/operator/switchMap';
import 'rxjs/add/operator/toPromise';
import 'rxjs/add/operator/do';
import 'rxjs/add/operator/mergeMap';
import 'rxjs/add/observable/forkJoin';
import {Observable} from 'rxjs/Observable';

@Component({
  selector: 'my-app',
  template: `
    <strong>3つのhttpリクエストをチェインして実行</strong><br />
    <button (click)="chain()">実行</button><br />
    <ul>
      <li *ngFor="let item of results1">
        <span>{{item}}</span>
      </li>
    </ul>
    <strong>3つのhttpリクエストをパラレルに実行</strong><br />
    <button (click)="para()">実行</button><br />
    <ul>
      <li *ngFor="let item of results2">
        <span>{{item}}</span>
      </li>
    </ul>
    <strong>httpリクエストをループ処理</strong><br />
    <button (click)="loop()">実行</button><br />
    <ul>
      <li *ngFor="let item of results3">
        <span>{{item|json}}</span>
      </li>
    </ul>
  `
})
export class AppComponent {
  constructor (private _http: Http) {}
  public results1 = [];
  public results2 = [];
  public results3 = [];
  private _results1 = [];
  private _results3 = [];
  private _https = [];
  chain() {
    this._http.get("/wp/q_chain_server.php?first=5")
    .do((res1)  => {
      this._results1.push(res1.text());
    })
    .flatMap(() => {
        return this._http.get("/wp/q_chain_server.php?second=1")
                   .do((res2) => {
                     this._results1.push(res2.text());
                   })
    })
    .flatMap(() => {
        return this._http.get("/wp/q_chain_server.php?third=3")
                   .map((res3) => {
                     this._results1.push(res3.text());
                     return this._results1;
                   })
    })
    .subscribe(res => this.results1 = res);
  }
  para() {
    Observable.forkJoin(
      this._http.get("/wp/q_chain_server.php?first=5")
        .map((res) => res.text()),
      this._http.get("/wp/q_chain_server.php?second=1")
        .map((res) => res.text()),
      this._http.get("/wp/q_chain_server.php?third=3")
        .map((res) => res.text())
    ).subscribe(res => this.results2 = res );
  }

  loop() {
    this._http.get("/wp/q_loop_server.php?init=1")
    .map((res3) => {
      var total = res3.json().length;
      for(var i=0; i < total;i++) {
        var url = "/wp/q_loop_server.php?" + res3.json()[i][0];
        var http = this._http.get(url).map(res => res.json());
        this._https.push(http);
      };
      return this._https;
    })
    .flatMap((https) => Observable.forkJoin(https))
    .subscribe(res => this.results3 = res );
  };
}

@NgModule({
  imports: [
    BrowserModule,
    HttpModule
  ],
  declarations: [ AppComponent ],
  bootstrap: [ AppComponent ]
})
export class AppModule { }

platformBrowserDynamic().bootstrapModule(AppModule);

関連記事の目次

コメントを残す

メールアドレスが公開されることはありません。 * が付いている欄は必須項目です