欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

angular.js4使用 RxJS 處理多個(gè) Http 請求

 更新時(shí)間:2017年09月23日 10:03:45   作者:semlinker  
本篇文章主要介紹了angular.js使用 RxJS 處理多個(gè) Http 請求,小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧

有時(shí)候進(jìn)入某個(gè)頁面時(shí),我們需要從多個(gè) API 地址獲取數(shù)據(jù)然后進(jìn)行顯示。管理多個(gè)異步數(shù)據(jù)請求會比較困難,但我們可以借助 Angular Http 服務(wù)和 RxJS 庫提供的功能來實(shí)現(xiàn)上述的功能。處理多個(gè)請求有多種方式,使用串行或并行的方式。

基礎(chǔ)知識

mergeMap

mergeMap 操作符用于從內(nèi)部的 Observable 對象中獲取值,然后返回給父級流對象。

合并 Observable 對象

const source = Rx.Observable.of('Hello');
//map to inner observable and flatten
const example = source.mergeMap(val => Rx.Observable.of(`${val} World!`));

const subscribe = example.subscribe(val => console.log(val)); //output: 'Hello World!'

在上面示例中包含兩種 Observable 類型:

  • 源 Observable 對象 - 即 source 對象
  • 內(nèi)部 Observable 對象 - 即 Rx.Observable.of(`${val} World!`) 對象

僅當(dāng)內(nèi)部的 Observable 對象發(fā)出值后,才會合并源 Observable 對象輸出的值,并最終輸出合并的值。

forkJoin

forkJoin 是 Rx 版本的 Promise.all(),即表示等到所有的 Observable 都完成后,才一次性返回值。

合并多個(gè) Observable 對象

const getPostOne$ = Rx.Observable.timer(1000).mapTo({id: 1});
const getPostTwo$ = Rx.Observable.timer(2000).mapTo({id: 2});

Rx.Observable.forkJoin(getPostOne$, getPostTwo$).subscribe(
 res => console.log(res) // [{id: 1}, {id: 2}]
); 

處理 Http 請求

我們先來看一下 Angular Http 服務(wù)簡單示例。

import { Component, OnInit } from '@angular/core';
import { Http } from '@angular/http';

import 'rxjs/add/operator/map';

@Component({
 selector: 'app-root',
 template: `
  <p>HttpModule Demo</p>
 `
})
export class AppComponent implements OnInit {
 constructor(private http: Http) { }

 ngOnInit() {
  this.http.get('https://jsonplaceholder.typicode.com/users')
   .map(res => res.json())
   .subscribe(users => console.log(users));
 }
}

上面示例中,我們通過依賴注入方式注入 http 服務(wù),然后在 ngOnInit() 方法中調(diào)用 http 對象的 get() 方法來獲取數(shù)據(jù)。這個(gè)例子很簡單,它只處理一個(gè)請求,接下來我們來看一下如何處理兩個(gè)請求。

Map 和 Subscribe

有些時(shí)候,當(dāng)我們發(fā)送下一個(gè)請求時(shí),需要依賴于上一個(gè)請求的數(shù)據(jù)。即我們在需要在上一個(gè)請求的回調(diào)函數(shù)中獲取相應(yīng)數(shù)據(jù),然后在發(fā)起另一個(gè) HTTP 請求。

import { Component, OnInit } from '@angular/core';
import { Http } from '@angular/http';
import 'rxjs/add/operator/map';

@Component({
 selector: 'app-root',
 template: `
  <p>{{username}} Detail Info</p>
  {{user | json}}
 `
})
export class AppComponent implements OnInit {
 constructor(private http: Http) { }

 apiUrl = 'https://jsonplaceholder.typicode.com/users';
 username: string = '';
 user: any;

 ngOnInit() {
  this.http.get(this.apiUrl)
   .map(res => res.json())
   .subscribe(users => {
    let username = users[6].username;
    this.http.get(`${this.apiUrl}?username=${username}`)
     .map(res => res.json())
     .subscribe(
      user => {
       this.username = username;
       this.user = user;
      });
   });
 }
}

在上面示例中,我們先從 https://jsonplaceholder.typicode.com/users 地址獲取所有用戶的信息,然后再根據(jù)指定用戶的 username 進(jìn)一步獲取用戶的詳細(xì)信息。雖然功能實(shí)現(xiàn)了,但有沒有更好的解決方案呢?答案是有的,可以通過 RxJS 庫中提供的 mergeMap 操作符來優(yōu)化上述的流程。

mergeMap

import { Component, OnInit } from '@angular/core';
import { Http } from '@angular/http';
import 'rxjs/add/operator/map';
import 'rxjs/add/operator/mergeMap';

@Component({
 selector: 'app-root',
 template: `
  <p>{{username}} Detail Info</p>
  {{user | json}}
 `
})
export class AppComponent implements OnInit {
 constructor(private http: Http) { }

 apiUrl = 'https://jsonplaceholder.typicode.com/users';

 username: string = '';

 user: any;

 ngOnInit() {
  this.http.get(this.apiUrl)
   .map(res => res.json())
   .mergeMap(users => {
    this.username = users[6].username;
    return this.http.get(`${this.apiUrl}?username=${this.username}`)
     .map(res => res.json())
   })
   .subscribe(user => this.user = user);
 }
}

在上面示例中,我們通過 mergeMap 操作符,解決了嵌套訂閱的問題。最后我們來看一下如何處理多個(gè)并行的 Http 請求。

forkJoin

接下來的示例,我們將使用 forkJoin 操作符。如果你熟悉 Promises 的話,該操作符與 Promise.all() 實(shí)現(xiàn)的功能類似。forkJoin 操作符接收一個(gè) Observable 對象列表,然后并行地執(zhí)行它們。一旦列表的 Observable 對象都發(fā)出值后,forkJoin 操作符返回的 Observable 對象會發(fā)出新的值,即包含所有 Observable 對象輸出值的列表。具體示例如下:

import { Component, OnInit } from '@angular/core';
import { Http } from '@angular/http';

import { Observable } from 'rxjs/Observable';
import 'rxjs/add/operator/map';
import 'rxjs/add/observable/forkJoin';

@Component({
 selector: 'app-root',
 template: `
  <p>Post Detail Info</p>
  <ul>
   <li>{{post1 | json}}</li>
   <li>{{post2 | json}}</li>
  </ul>
 `
})
export class AppComponent implements OnInit {
 constructor(private http: Http) { }

 apiUrl = 'https://jsonplaceholder.typicode.com/posts';

 post1: any;

 post2: any;

 ngOnInit() {
  let post1 = this.http.get(`${this.apiUrl}/1`);
  let post2 = this.http.get(`${this.apiUrl}/2`);

  Observable.forkJoin([post1, post2])
   .subscribe(results => {
    this.post1 = results[0];
    this.post2 = results[1];
   });
 }
}

我有話說

除了 mergeMap 外,RxJS 中的 switchMap 有什么用?

switchMap 操作符用于對源 Observable 對象發(fā)出的值,做映射處理。若有新的 Observable 對象出現(xiàn),會在新的 Observable 對象發(fā)出新值后,退訂前一個(gè)未處理完的 Observable 對象。

使用示例:

var source = Rx.Observable.fromEvent(document.body, 'click');
var example = source.switchMap(e => Rx.Observable.interval(100).take(3));

example.subscribe({
  next: (value) => { console.log(value); },
  error: (err) => { console.log('Error: ' + err); },
  complete: () => { console.log('complete'); }
});

示例 marble 圖:

source : -----------c--c-----------------...
    concatMap(c => Rx.Observable.interval(100).take(3))
example: -------------0--0-1-2-----------...

以上代碼運(yùn)行后,控制臺的輸出結(jié)果:

0
0
1
2

而在實(shí)際使用 Http 服務(wù)的場景中,比如實(shí)現(xiàn) AutoComplete 功能,我們可以利用 switchMap 操作符,來取消無用的 Http 請求。

以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。

相關(guān)文章

  • Angular搜索場景中使用rxjs的操作符處理思路

    Angular搜索場景中使用rxjs的操作符處理思路

    這篇文章主要介紹了Angular搜索場景中使用rxjs的操作符處理思路,主要的思路就是通過Subject來發(fā)送過濾條件,這樣就可以使用rxjs的各種操作符,可以快捷很多。需要的朋友可以參考下
    2018-05-05
  • 淺談angular.copy() 深拷貝

    淺談angular.copy() 深拷貝

    本篇文章主要介紹了淺談angular.copy() 深拷貝,小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧
    2017-09-09
  • 詳解Angular2中的編程對象Observable

    詳解Angular2中的編程對象Observable

    大家都是在Reactive Extensions for Javascript誕生于幾年前,隨著angular2正式版的發(fā)布,它將會被更多開發(fā)者所認(rèn)知。這篇文章我們來詳細(xì)介紹RxJs提供的Observable對象,有需要的朋友們可以參考借鑒。
    2016-09-09
  • AngularJS模塊學(xué)習(xí)之Anchor Scroll

    AngularJS模塊學(xué)習(xí)之Anchor Scroll

    這篇文章主要介紹了AngularJS模塊學(xué)習(xí)之Anchor Scroll 的相關(guān)資料,需要的朋友可以參考下
    2016-01-01
  • AngularJS實(shí)現(xiàn)星星等級評分功能

    AngularJS實(shí)現(xiàn)星星等級評分功能

    這篇文章主要為大家詳細(xì)介紹了AngularJS實(shí)現(xiàn)星星等級評分功能,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2016-09-09
  • angularjs請求數(shù)據(jù)的方法示例

    angularjs請求數(shù)據(jù)的方法示例

    這篇文章主要給大家介紹了關(guān)于angularjs請求數(shù)據(jù)的相關(guān)資料,文中通過示例代碼介紹的非常詳細(xì),對大家學(xué)習(xí)或者使用angularjs具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面來一起學(xué)習(xí)學(xué)習(xí)吧
    2019-08-08
  • angularjs實(shí)現(xiàn)猜大小功能

    angularjs實(shí)現(xiàn)猜大小功能

    這篇文章主要為大家詳細(xì)介紹了angularjs實(shí)現(xiàn)猜大小功能,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2017-10-10
  • Angular中的結(jié)構(gòu)指令模式及使用詳解

    Angular中的結(jié)構(gòu)指令模式及使用詳解

    這篇文章主要為大家介紹了Angular中的結(jié)構(gòu)指令模式及使用示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2022-08-08
  • Angular中的$watch、$watchGroup、$watchCollection

    Angular中的$watch、$watchGroup、$watchCollection

    這篇文章主要介紹了Angular中的$watch、$watchGroup、$watchCollection ,需要的朋友可以參考下
    2017-06-06
  • AngularJS實(shí)現(xiàn)的select二級聯(lián)動下拉菜單功能示例

    AngularJS實(shí)現(xiàn)的select二級聯(lián)動下拉菜單功能示例

    這篇文章主要介紹了AngularJS實(shí)現(xiàn)的select二級聯(lián)動下拉菜單功能,結(jié)合完整實(shí)例形式分析了AngularJS實(shí)現(xiàn)二級聯(lián)動菜單的具體操作步驟與相關(guān)實(shí)現(xiàn)技巧,需要的朋友可以參考下
    2017-10-10

最新評論