首先需要注意的是，之前从@nestjs/common导入的HttpService的方式已被废弃而不可用。
新方式是通过安装@nestjs/axios包来导入所需的模块和服务。
所有 HttpService 的方法都返回一个包裹在 Observable 对象内的 AxiosResponse 。例如get post put等。
通过返回 RxJS observable 流，Nest 路由处理程序将更加强大。 Nest 将自动订阅下面的源并获取最后发出的值（在流完成后）。
下面以一个简单地微信小程序服务端code2session接口为范例
app.module.ts
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
| import { Module } from '@nestjs/common';
import { AppController } from './app.controller';
import { AppService } from './app.service';
import { MongooseModule } from '@nestjs/mongoose'
import { ConfigModule, ConfigService } from '@nestjs/config';
import { TodoModule } from './todo/todo.module';
import { HttpModule } from '@nestjs/axios';
@Module({
imports: [
HttpModule,
TodoModule,
ConfigModule.forRoot(),
MongooseModule.forRoot(`mongodb://${new ConfigService().get('DATABASE_HOST')}`)
],
controllers: [AppController],
providers: [AppService],
})
export class AppModule { }
|
app.service.ts
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
| import { HttpService } from '@nestjs/axios';
import { Injectable } from '@nestjs/common';
import { ConfigService } from '@nestjs/config';
import { Observable } from 'rxjs';
import { AxiosResponse } from 'axios'
const errorCode: Map<number, string> = new Map([
[-1, '系统繁忙，此时请开发者稍候再试 '],
[0, '请求成功'],
[40029, 'code 无效'],
[45011, '频率限制，每个用户每分钟100次'],
[40226, '高风险等级用户，小程序登录拦截'],
])
@Injectable()
export class AppService {
private readonly wxAppId: string;
private readonly wxAppSecret: string;
constructor(private readonly httpService: HttpService, private readonly configService: ConfigService) {
this.wxAppId = configService.get('WX_APPID')
this.wxAppSecret = configService.get('WX_APPSECRET')
this.httpService.axiosRef.interceptors.response.use(({data}) => {
//设置Axios的拦截器，直接返回 AxiosResponse.data
data.tips = errorCode.get(data.errcode)
return data
})
}
login(): string {
return 'Hello World!';
}
wxLogin(code: string): Observable<AxiosResponse<{
errcode: number,
errmsg: string,
tips: string
}>> {
const api = `https://api.weixin.qq.com/sns/jscode2session?appid=${this.wxAppId}&secret=${this.wxAppSecret}&js_code=${code}&grant_type=authorization_code`
return this.httpService.get(api)//直接返回Observable对象
}
}
|
app.controller.ts
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
| import { Body, Controller, Get, Post, UsePipes, ValidationPipe } from '@nestjs/common';
import { AxiosResponse } from 'axios';
import { IsNotEmpty, IsString } from 'class-validator';
import { from, map, Observable, of } from 'rxjs';
import { AppService } from './app.service';
class code2sessionDto {
@IsString({
message: 'code 必须为字符串'
})
@IsNotEmpty({
message: 'code 不能为空'
})
code: string
}
@Controller()
export class AppController {
constructor(private readonly appService: AppService) { }
@Post('login')
login() {
return 'login'
}
@Post('wxlogin')
wxLogin(@Body() params: code2sessionDto) {
return this.appService.wxLogin(params.code)//nestjs会自动订阅
}
}
|
返回值
{
“errcode”: 40029,
“errmsg”: “invalid code, rid: 62aa10e4-53bc13f6-17909902”,
“tips”: “code 无效”
}