Angular2でPromiseを使って非同期にデータを取得

サービスを介してリモートサーバーからデータを取得する場合など、遅延が発生すると同期処理だと処理がブロックされてしまいます。Promiseを使って非同期にデータを取得する方法を確認し、サンプルを作成しました。
※Angular2の2.0.0版、TypeScriptを使って確認したものです。

(1)Promiseの使用方法


 
1)プロミスを生成
 
●構文
new Promise(function(resolve, reject) { … });
 
・new Promiseコンストラクタで生成。
・2つの引数resolveとrejectを持つハンドラーをリターン。
・1番目の引数はプロミスが成功した場合、2番目の引数は失敗した場合に実行されるメソッド。
 
例)”tf”がtrueの場合、3秒後にresolveメソッドを実行し、”処理成功”というメッセージ、falseの場合、同様に”処理失敗の”メッセージを渡す。

var p = new Promise(function(resolve, reject) {
  if (tf) {
    setTimeout(()=>resolve("処理成功"), 3000);
  } else {
    setTimeout(()=>reject("処理失敗"), 3000);
  }

※即、解決されるPromiseを生成する場合は、Promise.resolve()メソッドを使用する。
 
2)Promiseがresolve、rejectされた時の処理内容を定義
 
①thenメソッド
 
●構文(pはPromiseオブジェクト)
p.then(function(value) {
// Promiseが成功したとき呼ばれる関数。resolveの引数の値が渡される。
}, function(reason) {
// Promiseが失敗したとき呼ばれる関数。rejectの引数の値が渡される。
});
 
②catchメソッド
 
●構文(pはPromiseオブジェクト)
p.catch(function(reason) {
// Promiseが失敗したとき呼ばれる関数。rejectの引数の値が渡される。
});
例)resolve、rejectされて渡された値をthis.msg変数に保持
p.then(val => this.msg = val)
.catch(err => this.msg = err);
 

(2)HttpクライアントでPromiseを使用


 
Angular2のHTTPクライアントでは、Observableがリターンされますが、ObservableをPromiseに変換して、Promiseとして非同期処理を行うこともできます。
 
※Httpクライアントの使用方法はこちら

●Httpを処理するサービス

import {Injectable} from '@angular/core';
import {Http} from '@angular/http';
import {Observable} from 'rxjs/Observable';

@Injectable()
export class PromiseService {
  constructor (private _http: Http) {};
  get() {
    return this._http.get('/server.php').toPromise();
  }
};

 
●コンポーネント

  get() {
    this.msg = "処理中・・・";
    this._promiseService.get()
      .then(msg => this.msg = msg.json())
      .catch(err => this.msg = err);
  };

 

(3)デモ


 
コンポーネントからサービスに対しメッセージ取得の処理を依頼し、実行できる状態(タイムアウト後)になってからサービスからメッセージを非同期で受け取り、表示するサンプルを作成しました。
 
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,Input } from '@angular/core'; import { HttpModule } from '@angular/http'; import { PromiseService } from './promise.service.ts'; 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'; @Component({ selector: 'my-app', template: ` <strong>Promiseデモ</strong><br /> <button (click)="get(true)">msg取得(成功)</button> <button (click)="get(false)">msg取得(失敗)</button><br /> {{msg}}<br /> <strong>HttpクライアントでPromise使用</strong><br /> <button (click)="get_http()">msg取得</button><br /> {{msg_http}} `, providers: [PromiseService] }) export class AppComponent { public msg: string = '初期値'; public msg_http: string = '初期値'; constructor(private _promiseService: PromiseService) { }; get(tf: boolean) { this.msg = "処理中・・・"; this._promiseService.get(tf) .then(msg => this.msg = msg) .catch(err => this.msg = err); }; get_http() { this.msg_http = "処理中・・・"; this._promiseService.get_http() .then(msg => this.msg_http = msg.text()) .catch(err => this.msg_http = err); }; } @NgModule({ imports: [ BrowserModule, HttpModule ], declarations: [ AppComponent ], bootstrap: [ AppComponent ] }) export class AppModule { } platformBrowserDynamic().bootstrapModule(AppModule); サービス
import {Injectable} from '@angular/core'; import {Http} from '@angular/http'; import {Observable} from 'rxjs/Observable'; @Injectable() export class PromiseService { constructor (private _http: Http) {}; get(tf: boolean) { ++this._totalCount; return new Promise<string>(function(resolve, reject) { if (tf) { setTimeout(()=>resolve("処理成功 全回数:" + ++totalCount), 3000); } else { setTimeout(()=>reject("処理失敗 全回数:" + ++totalCount), 3000); } }); } get_http() { return this._http.get('/wp/server.php').toPromise(); } }; var totalCount: number = 0;

関連記事の目次

コメントを残す

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