angular.js4使用 RxJS 处理多个 Http 请求
有时候进入某个页面时，我们需要从多个API地址获取数据然后进行显示。管理多个异步数据请求会比较困难，但我们可以借助AngularHttp服务和RxJS库提供的功能来实现上述的功能。处理多个请求有多种方式，使用串行或并行的方式。
基础知识
mergeMap
mergeMap操作符用于从内部的Observable对象中获取值，然后返回给父级流对象。
合并Observable对象
constsource=Rx.Observable.of('Hello');
//maptoinnerobservableandflatten
constexample=source.mergeMap(val=>Rx.Observable.of(`${val}World!`));
constsubscribe=example.subscribe(val=>console.log(val));//output:'HelloWorld!'
在上面示例中包含两种Observable类型：
- 源Observable对象-即source对象
- 内部Observable对象-即Rx.Observable.of(`${val}World!`)对象
仅当内部的Observable对象发出值后，才会合并源Observable对象输出的值，并最终输出合并的值。
forkJoin
forkJoin是Rx版本的Promise.all()，即表示等到所有的Observable都完成后，才一次性返回值。
合并多个Observable对象
constgetPostOne$=Rx.Observable.timer(1000).mapTo({id:1});
constgetPostTwo$=Rx.Observable.timer(2000).mapTo({id:2});
Rx.Observable.forkJoin(getPostOne$,getPostTwo$).subscribe(
res=>console.log(res)//[{id:1},{id:2}]
);
处理Http请求
我们先来看一下AngularHttp服务简单示例。
import{Component,OnInit}from'@angular/core';
import{Http}from'@angular/http';
import'rxjs/add/operator/map';
@Component({
selector:'app-root',
template:`
HttpModuleDemo
`
})
exportclassAppComponentimplementsOnInit{
constructor(privatehttp: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:`
{{username}}DetailInfo
{{user|json}}
`
})
exportclassAppComponentimplementsOnInit{
constructor(privatehttp:Http){}
apiUrl='https://jsonplaceholder.typicode.com/users';
username:string='';
user:any;
ngOnInit(){
this.http.get(this.apiUrl)
.map(res=>res.json())
.subscribe(users=>{
letusername=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:`
{{username}}DetailInfo
{{user|json}}
`
})
exportclassAppComponentimplementsOnInit{
constructor(privatehttp: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;
returnthis.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:`
PostDetailInfo
- {{post1|json}}
- {{post2|json}}
我有话说
除了mergeMap外，RxJS中的switchMap有什么用？
switchMap操作符用于对源Observable对象发出的值，做映射处理。若有新的Observable对象出现，会在新的Observable对象发出新值后，退订前一个未处理完的Observable对象。
使用示例：
varsource=Rx.Observable.fromEvent(document.body,'click');
varexample=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请求。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。