title: Nest中的Http請求
Nest 底層使用的 Http 模塊為 axios,又使用了 rxjs 添加了流程控制牵舱。
下面我們會介紹一些 Http 請求中通常碰到的一些場景贼穆。
city 接口返回值:
{
result: true,
data: [
{
id: 'a',
val: '上海',
},
{
id: 'b',
val: '蘇州',
},
{
id: 'c',
val: '南京',
},
]
}
position 接口返回值:
{
result: true,
data: [
{
value: 'a',
label: '經(jīng)理',
location: {
city: '北京',
},
},
{
value: 'b',
label: '員工',
location: {
city: '上海',
},
},
]
}
發(fā)送 city 請求
import { Controller, Get, HttpService } from '@nestjs/common';
import { Observable } from 'rxjs';
import { map } from 'rxjs/operators';
interface ICity {
id: string;
val: string;
}
interface IReturn {
result: boolean;
data: ICity[];
}
@Controller()
export class AppController {
constructor(private readonly httpService: HttpService) {}
@Get('/city')
city(): Observable<IReturn> {
return this.httpService.get('/example/city').pipe(
map(res => res.data)
);
}
}
知識點:
-
map 是 rxjs 里面的一個操作符秒际，官方解釋為對源 observable 的每個值應(yīng)用投射函數(shù)句伶。
實際就是傳入一個函數(shù)律想，對返回值進(jìn)行修改减细。 - map 里面的 res 并不是 city 接口的返回值在岂，而且 axios 請求的返回體奔则。里面的 data 才是真正的接口返回值,部分打印片段:
{
status: 200,
statusText: 'OK',
headers: {
'x-powered-by': 'Express',
'access-control-allow-origin': '*',
'content-type': 'application/json; charset=utf-8',
'content-length': '136',
etag: 'W/"88-FSoOKRSwMXq6BELiU+RK55SLx/8"',
date: 'Wed, 28 Apr 2021 09:41:52 GMT',
connection: 'close'
},
config: {
url: '/example/city',
method: 'get',
headers: {
Accept: 'application/json, text/plain, */*',
'User-Agent': 'axios/0.19.2'
},
baseURL: 'http://127.0.0.1:3001',
transformRequest: [ [
....
},
data: {
result: true,
data: [ [Object], [Object], [Object] ],
time: '2021-04-28T09:41:52.821Z'
}
}
并發(fā)請求 city 和 position 接口并返回
@Get('/forkJoin')
combine() {
const cityAjax = this.httpService.get('/example/city').pipe(
map(res => res.data),
catchError(e => {
throw new HttpException(`city請求錯誤`, 400);
}),
);
const positionAjax = this.httpService.get('/example/position').pipe(
map(res => res.data),
catchError(e => {
throw new HttpException(`position請求錯誤`, 400);
}),
);
return forkJoin([cityAjax, positionAjax]).pipe(
map(res => {
return ['city', 'position'].map((key, index) => {
if (res[index].result === false)
throw new HttpException(`${key}請求錯誤`, 400);
return {
key,
data: res[index].data,
};
});
}),
);
}
知識點:
- forkJoin的用法類似 promise.all
- 定義 ajax 請求時 catchError 捕獲的錯誤是 http 請求的錯誤，也就是 http statusCode 非 200 時的報錯蔽午，
對于自定義錯誤易茬，我們則需要在 pipe(map)的返回值里面判斷并且拋錯
有順序依賴的多個請求
先請求 city，拿到它的返回值及老，再請求 position
@Get('/mergeMap')
mergeMap() {
return this.httpService
.get('/example/city')
.pipe(
map(res => res.data),
catchError(e => {
throw new HttpException('city請求錯誤', 400);
}),
)
.pipe(
mergeMap(cityRes => {
if (cityRes.result === false)
throw new HttpException(`city請求錯誤`, 400);
return this.httpService.get('/example/position', { params: {} });
}),
)
.pipe(
map(res => res.data),
catchError(e => {
throw new HttpException('position請求錯誤', 400);
}),
);
}
知識點:
