1.1 基本概念

微服務基本概念：微服務就是將一個項目拆分成多個服務。舉個簡單的例子：將網(wǎng)站的登錄功能可以拆分出來做成一個服務。

微服務分為提供者和消費者，如上“登錄服務”就是一個服務提供者，“網(wǎng)站服務器”就是一個服務消費者（服務客戶端）。

你可能注意到了客戶端和網(wǎng)站服務器通信使用的是http，為什么服務器之間使用的是tcp，這主要和性能、傳輸靈活度相關(guān)。

在nestjs中傳輸方式還有很多中，比如通過grpc、rabbitmq、redis等技術(shù)來傳輸數(shù)據(jù)。

補充：登錄服務可以部署在同一臺服務器也可以在其他服務器，但只要拆分出來了就稱之為微服務。

1.2 搭建提供者和消費者

首先保證你全局安裝了nestjs腳手架 npm i -g @nestjs/cli

創(chuàng)建nestjs項目，如下代碼我將會使用monorepo模式，如果你還不太熟悉這是官網(wǎng)地址：https://docs.nestjs.com/cli/monorepo#monorepo-mode

或者你也可以直接按照我如下步驟操作

1. nest new my-app：創(chuàng)建一個nestjs的項目，自行選擇包管理器
2. cd my-app：進入my-app目錄
3. nest generate app rpc-provider：把當前項目轉(zhuǎn)化為monorepo模式，并創(chuàng)建rpc-provider項目（提供者）
4. nest generate app rpc-consumer：創(chuàng)建消費者
5. pnpm i：安裝依賴
6. pnpm i @nestjs/microservices：安裝微服務需要的包

補充啟動方式：npm run start:dev rpc-provider

1.3 實現(xiàn)微服務提供者

1.3.1 apps/rpc-provider/src/main.ts

import { NestFactory } from '@nestjs/core';
import { RpcProviderModule } from './rpc-provider.module';
import { MicroserviceOptions, Transport } from '@nestjs/microservices';// 創(chuàng)建微服務
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 apps/rpc-provider/src/rpc-provider.controller.ts

說明：nestjs中微服務提供了兩種模式

• MessagePattern：基于請求-響應的消息處理程序
• EventPattern：基于發(fā)布-訂閱的消息處理程序，此方式是不需要做出響應的

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 實現(xiàn)微服務消費者

1.4.1 apps/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 apps/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調(diào)用EventPatternthis.client.emit('notice', 'xxx');// 返回的是一個Observable對象return this.client.send<number>('calc', nums);}@Get()getHello(): string {return this.rpcConsumerService.getHello();}
}

有疑問歡迎在文章下留言，看到了我就會回答