有時(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 flattenconst example = source.mergeMap(val => Rx.Observable.of(`${val} World!`));const subscribe = example.subscribe(val => console.log(val)); //output: 'Hello World!'在上面示例中包含兩種 Observable 類型：
僅當(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í)有所幫助，也希望大家多多支持武林網(wǎng)。
新聞熱點(diǎn)
疑難解答
