angular.js4使用 RxJS 處理多個(gè) Http 請(qǐng)求
有時(shí)候進(jìn)入某個(gè)頁(yè)面時(shí)，我們需要從多個(gè) API 地址獲取數(shù)據(jù)然后進(jìn)行顯示。管理多個(gè)異步數(shù)據(jù)請(qǐng)求會(huì)比較困難，但我們可以借助 Angular Http 服務(wù)和 RxJS 庫(kù)提供的功能來(lái)實(shí)現(xiàn)上述的功能。處理多個(gè)請(qǐng)求有多種方式，使用串行或并行的方式。
基礎(chǔ)知識(shí)
mergeMap
mergeMap 操作符用于從內(nèi)部的 Observable 對(duì)象中獲取值，然后返回給父級(jí)流對(duì)象。
合并 Observable 對(duì)象
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 對(duì)象 - 即 source 對(duì)象
- 內(nèi)部 Observable 對(duì)象 - 即 Rx.Observable.of(`${val} World!`) 對(duì)象
僅當(dāng)內(nèi)部的 Observable 對(duì)象發(fā)出值后，才會(huì)合并源 Observable 對(duì)象輸出的值，并最終輸出合并的值。
forkJoin
forkJoin 是 Rx 版本的 Promise.all()，即表示等到所有的 Observable 都完成后，才一次性返回值。
合并多個(gè) Observable 對(duì)象
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 請(qǐng)求
我們先來(lái)看一下 Angular Http 服務(wù)簡(jiǎn)單示例。
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));
}
}
上面示例中，我們通過(guò)依賴注入方式注入 http 服務(wù)，然后在 ngOnInit() 方法中調(diào)用 http 對(duì)象的 get() 方法來(lái)獲取數(shù)據(jù)。這個(gè)例子很簡(jiǎn)單，它只處理一個(gè)請(qǐng)求，接下來(lái)我們來(lái)看一下如何處理兩個(gè)請(qǐng)求。
Map 和 Subscribe
有些時(shí)候，當(dāng)我們發(fā)送下一個(gè)請(qǐng)求時(shí)，需要依賴于上一個(gè)請(qǐng)求的數(shù)據(jù)。即我們?cè)谛枰谏弦粋€(gè)請(qǐng)求的回調(diào)函數(shù)中獲取相應(yīng)數(shù)據(jù)，然后在發(fā)起另一個(gè) HTTP 請(qǐng)求。
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)了，但有沒(méi)有更好的解決方案呢？答案是有的，可以通過(guò) RxJS 庫(kù)中提供的 mergeMap 操作符來(lái)優(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);
}
}
在上面示例中，我們通過(guò) mergeMap 操作符，解決了嵌套訂閱的問(wèn)題。最后我們來(lái)看一下如何處理多個(gè)并行的 Http 請(qǐng)求。
forkJoin
接下來(lái)的示例，我們將使用 forkJoin 操作符。如果你熟悉 Promises 的話，該操作符與 Promise.all() 實(shí)現(xiàn)的功能類似。forkJoin 操作符接收一個(gè) Observable 對(duì)象列表，然后并行地執(zhí)行它們。一旦列表的 Observable 對(duì)象都發(fā)出值后，forkJoin 操作符返回的 Observable 對(duì)象會(huì)發(fā)出新的值，即包含所有 Observable 對(duì)象輸出值的列表。具體示例如下：
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];
});
}
}
我有話說(shuō)
除了 mergeMap 外，RxJS 中的 switchMap 有什么用？
switchMap 操作符用于對(duì)源 Observable 對(duì)象發(fā)出的值，做映射處理。若有新的 Observable 對(duì)象出現(xiàn)，會(huì)在新的 Observable 對(duì)象發(fā)出新值后，退訂前一個(gè)未處理完的 Observable 對(duì)象。
使用示例：
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)行后，控制臺(tái)的輸出結(jié)果：
0
0
1
2
而在實(shí)際使用 Http 服務(wù)的場(chǎng)景中，比如實(shí)現(xiàn) AutoComplete 功能，我們可以利用 switchMap 操作符，來(lái)取消無(wú)用的 Http 請(qǐng)求。
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
這篇文章主要給大家介紹了關(guān)于Angular封裝表單控件及一些思想的相關(guān)資料，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者使用Angular具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2019-12-12
AngularJS自定義表單驗(yàn)證功能實(shí)例詳解
這篇文章主要介紹了AngularJS自定義表單驗(yàn)證功能,結(jié)合完整實(shí)例形式詳細(xì)分析了AngularJS實(shí)現(xiàn)表單驗(yàn)證的相關(guān)指令、模型綁定、數(shù)據(jù)驗(yàn)證等操作技巧,需要的朋友可以參考下2018-08-08
Angularjs單選改為多選的開(kāi)發(fā)過(guò)程及問(wèn)題解析
在項(xiàng)目中遇到這樣的需求想把下拉框的單選改為多選，怎么實(shí)現(xiàn)呢？下面小編通過(guò)本文給大家分享angularjs單選改為多選的開(kāi)發(fā)過(guò)程及問(wèn)題解析，需要的朋友參考下2017-02-02
如何使用AngularJs打造權(quán)限管理系統(tǒng)【簡(jiǎn)易型】
這篇文章主要介紹了使用AngularJs打造權(quán)限管理系統(tǒng)【簡(jiǎn)易型】的相關(guān)資料,需要的朋友可以參考下2016-05-05
Angular.js初始化之ng-app的自動(dòng)綁定與手動(dòng)綁定詳解
這篇文章主要給大家介紹了關(guān)于Angular.js初始化之ng-app的自動(dòng)綁定與手動(dòng)綁定的相關(guān)資料，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面跟著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧。2017-07-07
關(guān)于AngularJS中幾種Providers的區(qū)別總結(jié)
這篇文章主要給大家介紹了關(guān)于AngularJS中幾種Providers的區(qū)別的相關(guān)資料，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家學(xué)習(xí)或者使用AngularJS具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2020-05-05
Angular2平滑升級(jí)到Angular4的步驟詳解
最近Angular項(xiàng)目組終于發(fā)布了新版——正式版 Angular 4.0.0。所以想著就來(lái)嘗試下升級(jí)，記錄下整個(gè)升級(jí)過(guò)程分享給大家，所以這篇文章主要介紹了Angular2升級(jí)到Angular4的詳細(xì)步驟，需要的朋友可以參考下。2017-03-03
Angular 4環(huán)境準(zhǔn)備與Angular cli創(chuàng)建項(xiàng)目詳解
Angular4.0來(lái)了，更小，更快，改動(dòng)少，所以下面這篇文章主要給大家介紹了關(guān)于Angular 4環(huán)境準(zhǔn)備與學(xué)會(huì)使用Angular cli創(chuàng)建項(xiàng)目的相關(guān)資料，文中給出了詳細(xì)的示例代碼供大家參考學(xué)習(xí)，需要的朋友們下面來(lái)一起看看吧。2017-05-05
這篇文章主要介紹了Angular2進(jìn)階之如何避免Dom誤區(qū),小編覺(jué)得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2018-04-04
AngularJS模塊學(xué)習(xí)之Anchor Scroll
這篇文章主要介紹了AngularJS模塊學(xué)習(xí)之Anchor Scroll 的相關(guān)資料,需要的朋友可以參考下2016-01-01