這篇文章將為大家詳細(xì)講解有關(guān)angular.js4如何使用RxJS處理多個(gè)Http請(qǐng)求，小編覺得挺實(shí)用的，因此分享給大家做個(gè)參考，希望大家閱讀完這篇文章后可以有所收獲。

創(chuàng)新互聯(lián)建站主營(yíng)臺(tái)江網(wǎng)站建設(shè)的網(wǎng)絡(luò)公司,主營(yíng)網(wǎng)站建設(shè)方案,app軟件開發(fā),臺(tái)江h(huán)5微信小程序定制開發(fā)搭建,臺(tái)江網(wǎng)站營(yíng)銷推廣歡迎臺(tái)江等地區(qū)企業(yè)咨詢

有時(shí)候進(jìn)入某個(gè)頁面時(shí)，我們需要從多個(gè) API 地址獲取數(shù)據(jù)然后進(jìn)行顯示。管理多個(gè)異步數(shù)據(jù)請(qǐng)求會(huì)比較困難，但我們可以借助 Angular Http 服務(wù)和 RxJS 庫提供的功能來實(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)求

我們先來看一下 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));
 }
}

上面示例中，我們通過依賴注入方式注入 http 服務(wù)，然后在 ngOnInit() 方法中調(diào)用 http 對(duì)象的 get() 方法來獲取數(shù)據(jù)。這個(gè)例子很簡(jiǎn)單，它只處理一個(gè)請(qǐng)求，接下來我們來看一下如何處理兩個(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)了，但有沒有更好的解決方案呢？答案是有的，可以通過 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 請(qǐng)求。

forkJoin

接下來的示例，我們將使用 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];
   });
 }
}

我有話說

除了 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 操作符，來取消無用的 Http 請(qǐng)求。

關(guān)于“angular.js4如何使用RxJS處理多個(gè)Http請(qǐng)求”這篇文章就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，使各位可以學(xué)到更多知識(shí)，如果覺得文章不錯(cuò)，請(qǐng)把它分享出去讓更多的人看到。

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn，海內(nèi)外云服務(wù)器15元起步，三天無理由+7*72小時(shí)售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國(guó)服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡(jiǎn)單易用、服務(wù)可用性高、性價(jià)比高”等特點(diǎn)與優(yōu)勢(shì)，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場(chǎng)景需求。

分享標(biāo)題：angular.js4如何使用RxJS處理多個(gè)Http請(qǐng)求-創(chuàng)新互聯(lián)
本文網(wǎng)址：http://aaarwkj.com/article36/hoosg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供ChatGPT、網(wǎng)站制作、外貿(mào)建站、關(guān)鍵詞優(yōu)化、定制網(wǎng)站、網(wǎng)站內(nèi)鏈

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)