Nest - Rx.js在http請求中的應(yīng)用


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)
    );
  }
}

知識點:

  1. map 是 rxjs 里面的一個操作符秒际,官方解釋為對源 observable 的每個值應(yīng)用投射函數(shù)句伶。
    實際就是傳入一個函數(shù)律想,對返回值進(jìn)行修改减细。
  2. 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,
          };
        });
      }),
    );
  }

知識點:

  1. forkJoin的用法類似 promise.all
  2. 定義 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);
        }),
      );
  }

知識點:

  1. mergeMap 的用法
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末抽莱,一起剝皮案震驚了整個濱河市范抓,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌食铐,老刑警劉巖匕垫,帶你破解...
    沈念sama閱讀 211,265評論 6 490
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場離奇詭異璃岳,居然都是意外死亡年缎,警方通過查閱死者的電腦和手機,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 90,078評論 2 385
  • 文/潘曉璐 我一進(jìn)店門铃慷,熙熙樓的掌柜王于貴愁眉苦臉地迎上來单芜,“玉大人,你說我怎么就攤上這事犁柜≈摒” “怎么了?”我有些...
    開封第一講書人閱讀 156,852評論 0 347
  • 文/不壞的土叔 我叫張陵馋缅,是天一觀的道長扒腕。 經(jīng)常有香客問我,道長萤悴,這世上最難降的妖魔是什么瘾腰? 我笑而不...
    開封第一講書人閱讀 56,408評論 1 283
  • 正文 為了忘掉前任,我火速辦了婚禮覆履,結(jié)果婚禮上蹋盆,老公的妹妹穿的比我還像新娘。我一直安慰自己硝全,他們只是感情好栖雾,可當(dāng)我...
    茶點故事閱讀 65,445評論 5 384
  • 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著伟众,像睡著了一般析藕。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上凳厢,一...
    開封第一講書人閱讀 49,772評論 1 290
  • 那天账胧,我揣著相機與錄音,去河邊找鬼先紫。 笑死找爱,一個胖子當(dāng)著我的面吹牛,可吹牛的內(nèi)容都是我干的泡孩。 我是一名探鬼主播车摄,決...
    沈念sama閱讀 38,921評論 3 406
  • 文/蒼蘭香墨 我猛地睜開眼,長吁一口氣:“原來是場噩夢啊……” “哼!你這毒婦竟也來了吮播?” 一聲冷哼從身側(cè)響起变屁,我...
    開封第一講書人閱讀 37,688評論 0 266
  • 序言:老撾萬榮一對情侶失蹤,失蹤者是張志新(化名)和其女友劉穎意狠,沒想到半個月后粟关,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 44,130評論 1 303
  • 正文 獨居荒郊野嶺守林人離奇死亡环戈,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 36,467評論 2 325
  • 正文 我和宋清朗相戀三年闷板,在試婚紗的時候發(fā)現(xiàn)自己被綠了。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片院塞。...
    茶點故事閱讀 38,617評論 1 340
  • 序言:一個原本活蹦亂跳的男人離奇死亡遮晚,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出拦止,到底是詐尸還是另有隱情县遣,我是刑警寧澤,帶...
    沈念sama閱讀 34,276評論 4 329
  • 正文 年R本政府宣布汹族,位于F島的核電站萧求,受9級特大地震影響,放射性物質(zhì)發(fā)生泄漏顶瞒。R本人自食惡果不足惜夸政,卻給世界環(huán)境...
    茶點故事閱讀 39,882評論 3 312
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望榴徐。 院中可真熱鬧秒梳,春花似錦、人聲如沸箕速。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,740評論 0 21
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽盐茎。三九已至,卻和暖如春徙赢,著一層夾襖步出監(jiān)牢的瞬間字柠,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 31,967評論 1 265
  • 我被黑心中介騙來泰國打工狡赐, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留窑业,地道東北人。 一個月前我還...
    沈念sama閱讀 46,315評論 2 360
  • 正文 我出身青樓枕屉,卻偏偏與公主長得像常柄,于是被迫代替她去往敵國和親。 傳聞我的和親對象是個殘疾皇子,可洞房花燭夜當(dāng)晚...
    茶點故事閱讀 43,486評論 2 348

推薦閱讀更多精彩內(nèi)容