欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

angular.js4使用 RxJS 处理多个 Http 请求

程序员文章站 2022-06-25 13:39:49
有时候进入某个页面时,我们需要从多个 api 地址获取数据然后进行显示。管理多个异步数据请求会比较困难,但我们可以借助 angular http 服务和 rxjs 库提供的...

有时候进入某个页面时,我们需要从多个 api 地址获取数据然后进行显示。管理多个异步数据请求会比较困难,但我们可以借助 angular http 服务和 rxjs 库提供的功能来实现上述的功能。处理多个请求有多种方式,使用串行或并行的方式。

基础知识

mergemap

mergemap 操作符用于从内部的 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 对象
  • 内部 observable 对象 - 即 rx.observable.of(`${val} world!`) 对象

仅当内部的 observable 对象发出值后,才会合并源 observable 对象输出的值,并最终输出合并的值。

forkjoin

forkjoin 是 rx 版本的 promise.all(),即表示等到所有的 observable 都完成后,才一次性返回值。

合并多个 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 服务简单示例。

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 服务,然后在 ngoninit() 方法中调用 http 对象的 get() 方法来获取数据。这个例子很简单,它只处理一个请求,接下来我们来看一下如何处理两个请求。

map 和 subscribe

有些时候,当我们发送下一个请求时,需要依赖于上一个请求的数据。即我们在需要在上一个请求的回调函数中获取相应数据,然后在发起另一个 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 地址获取所有用户的信息,然后再根据指定用户的 username 进一步获取用户的详细信息。虽然功能实现了,但有没有更好的解决方案呢?答案是有的,可以通过 rxjs 库中提供的 mergemap 操作符来优化上述的流程。

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 操作符,解决了嵌套订阅的问题。最后我们来看一下如何处理多个并行的 http 请求。

forkjoin

接下来的示例,我们将使用 forkjoin 操作符。如果你熟悉 promises 的话,该操作符与 promise.all() 实现的功能类似。forkjoin 操作符接收一个 observable 对象列表,然后并行地执行它们。一旦列表的 observable 对象都发出值后,forkjoin 操作符返回的 observable 对象会发出新的值,即包含所有 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 对象发出的值,做映射处理。若有新的 observable 对象出现,会在新的 observable 对象发出新值后,退订前一个未处理完的 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-----------...

以上代码运行后,控制台的输出结果:

0
0
1
2

而在实际使用 http 服务的场景中,比如实现 autocomplete 功能,我们可以利用 switchmap 操作符,来取消无用的 http 请求。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。