1.1 基本概念
微服務基本概念：微服務就是將一個項目拆分成多個服務。舉個簡單的例子：將網站的登錄功能可以拆分出來做成一個服務。
微服務分為提供者和消費者，如上“登錄服務”就是一個服務提供者，“網站服務器”就是一個服務消費者（服務客戶端）。
你可能注意到了客戶端和網站服務器通信使用的是http，為什么服務器之間使用的是tcp，這主要和性能、傳輸靈活度相關。
在nestjs中傳輸方式還有很多中，比如通過grpc、rabbitmq、redis等技術來傳輸數據。
補充：登錄服務可以部署在同一臺服務器也可以在其他服務器，但只要拆分出來了就稱之為微服務。
1.2 搭建提供者和消費者
首先保證你全局安裝了nestjs腳手架 npm i -g @nestjs/cli
創建nestjs項目，如下代碼我將會使用monorepo模式，如果你還不太熟悉這是官網地址：https://docs.nestjs.com/cli/monorepo#monorepo-mode
或者你也可以直接按照我如下步驟操作
nest new my-app：創建一個nestjs的項目，自行選擇包管理器cd my-app：進入my-app目錄nest generate app rpc-provider：把當前項目轉化為monorepo模式，并創建rpc-provider項目（提供者）nest generate app rpc-consumer：創建消費者pnpm i：安裝依賴pnpm i @nestjs/microservices：安裝微服務需要的包
補充啟動方式：npm run start:dev rpc-provider
1.3 實現微服務提供者
1.3.1 app/rpc-provider/src/main.ts
import { NestFactory } from '@nestjs/core';
import { RpcProviderModule } from './rpc-provider.module';
import { MicroserviceOptions, Transport } from '@nestjs/microservices';// 創建微服務
async function bootstrap() {const app = await NestFactory.createMicroservice<MicroserviceOptions>(RpcProviderModule,{transport: Transport.TCP,options: {host: '127.0.0.1',port: 2999,},},);await app.listen();
}
bootstrap();
1.3.2 app/rpc-provider/src/rpc-provider.controller.ts
說明：nestjs中微服務提供了兩種模式
- MessagePattern：基于請求-響應的消息處理程序
- EventPattern：基于發布-訂閱的消息處理程序，此方式是不需要做出響應的
import { Controller, Get } from '@nestjs/common';
import { RpcProviderService } from './rpc-provider.service';
import { EventPattern, MessagePattern } from '@nestjs/microservices';@Controller()
export class RpcProviderController {constructor(private readonly rpcProviderService: RpcProviderService) {}@MessagePattern('calc')async accumulate(nums: number[]): Promise<number> {console.log('微服務提供者 MessagePattern', nums);return await new Promise((resolve) => {setTimeout(() => {resolve(nums.reduce((pre, cur) => pre + cur, 0));}, 10);});}@EventPattern('notice')handleUserCreated(data: string): void {console.log('微服務提供者 EventPattern', data);}@Get()getHello(): string {return this.rpcProviderService.getHello();}
}
1.4 實現微服務消費者
1.4.1 app/rpc-consumer/src/rpc-consumer.module.ts
import { Module } from '@nestjs/common';
import { RpcConsumerController } from './rpc-consumer.controller';
import { RpcConsumerService } from './rpc-consumer.service';
import { ClientsModule, Transport } from '@nestjs/microservices';@Module({imports: [// 注冊服務ClientsModule.register([{name: 'MATH_SERVICE', //給該服務取一個名字transport: Transport.TCP, //服務傳輸方式options: {host: '127.0.0.1',port: 2999,},},]),],controllers: [RpcConsumerController],providers: [RpcConsumerService],
})
export class RpcConsumerModule {}
1.4.2 app/rpc-consumer/src/rpc-consumer.controller.ts
import { Body, Controller, Get, Inject, Post } from '@nestjs/common';
import { RpcConsumerService } from './rpc-consumer.service';
import { ClientProxy } from '@nestjs/microservices';
import { Observable } from 'rxjs';@Controller()
export class RpcConsumerController {constructor(private readonly rpcConsumerService: RpcConsumerService,@Inject('MATH_SERVICE') private client: ClientProxy,) {}@Post()// 說明：Observable是一個可被觀察的流，需要安裝rxjs(pnpm i rxjs)callService(@Body('nums') nums: number[]): Observable<number> {// emit調用EventPatternthis.client.emit('notice', 'xxx');// 返回的是一個Observable對象return this.client.send<number>('calc', nums);}@Get()getHello(): string {return this.rpcConsumerService.getHello();}
}
有疑問歡迎在文章下留言，看到了我就會回答
)
