为什么 NodeJS 是构建微服务的最佳选择？

发布时间：2025-11-05 09:15:52 来源：云智核 作者：IT科技类资讯

什么是为什微服务微服务

微服务是一种应用架构，它将每个应用功能都放在自己的构建服务中，与其他服务隔离。最佳这些服务是选择松散耦合的，可独立部署。为什微服务

这种架构的构建出现是为了解决旧的 Web 应用开发的单体方法。在单体软件中，最佳所有的选择东西都是作为一个单元构建的，所有的为什微服务业务逻辑都被归入一个广泛的应用。

这种方法使更新代码库的构建过程变得复杂化，因为它影响到整个系统，最佳即使是选择最小的代码改动也需要构建和部署整个软件的新版本。此外，为什微服务哪怕你只想扩展应用的构建某个特定功能，却需要扩展整个应用来实现它。源码库最佳

微服务解决了单体系统所面临的这些挑战，它将应用从一个整体分割成几个小部分。

什么时候应该使用微服务？

从本质上讲，微服务架构解决了庞大、复杂应用的快速开发问题。

对于“哪个更好?”这一问题，目前还没有通用的答案。答案取决于各种情况，因为每一种情况都有其好处和缺点。

下面是一些微服务架构的优点和缺点，你可能对此已经有所了解：

要作为一个整体来管理是很困难的：凯撒大帝有一句名言“分而治之”(divide et impera，拉丁语)，即使在这里也可以大规模应用，但是要谨慎，因为过多的活动部分会变得难以管理。

在架构方面，SaaS 微服务非常适合，因为微服务是 SaaS 应用的免费信息发布网一个不错的选择。由于这类应用想要用户付钱买单，那么它就需要提供高可用的服务，因此将软件分成小块可以加快恢复速度。同时，SaaS 应用的发展主要是由其社区推动，所以，它也会受到很多变化的影响，而通过微服务和解耦，开发者可以获得了灵活性，这是单体架构无法提供的。

单体应用程序可能难以水平扩展，因为你必须复制整个应用程序，如果它依赖于单个数据库，这个过程将变得更加困难。另一边，微服务却可以根据单个服务进行扩展、复制或负载平衡。比如，如果你需要发送更多的电子邮件，你只需要扩展负责电子邮件功能的微服务。今天你有 10 个用户，明天你有 1000 个;SaaS 应用可以在短时间内维持大规模的增长，这就是为什么他们的架构必须要以最经济的方式进行轻松扩展的原因。

这样还可以减少资源的消耗，因此可以减少账单。所以，可以肯定地说，微服务是 SaaS 企业架构的下一个阶段。

弄清你是否需要微服务的最好方法是问自己：我有关于单体应用的问题吗?如果有的话，或许你应该考虑转向微服务。如果没有，那就坚持下去——没有必要把时间花在一个根本不存在的问题上。

微服务通信是如何工作的？

由于服务之间彼此独立，所以与微服务的通信需要好好选择。通信协议的使用不当会造成应用的性能下降，大家必须根据自己应用的具体需求来选择通信协议。

有两种通信方式可以选择：同步通信和异步通信，这是请求 - 响应和基于事件的模式的基础。

在第一种情况下，即同步方式，客户端发送请求并等待响应。这种方法有一个缺陷，那就是它是一个阻塞模式。但是，如果你有一个读操作非常多的应用时，那就不一定了，因为你的应用更倾向从外部读取和接受信息。在这种情况下，使用同步方式可能是一个很好的选择，特别是当它涉及实时数据时。

我们的另一个选择是异步通信，这是一个非阻塞模式。如果你想要一种有弹性的微服务，那么，与同步通信相比，异步通信是一种更好的选择。在这种情况下，客户端会发送一个请求，收到请求的确认，并将其遗忘。这种方法最适用于大量写操作、无法承受数据记录丢失的应用。

下面是一些涉及微服务通信的解决方案，你可以从中选择：

好好考虑最适合自身需求的通信协议，因为这将使应用响应更快、效率更高。

为什么 NodeJS 用于微服务？

在构建微服务时，有很多顶级编程语言可供选择。NodeJS 就是其中之一。那么，为什么 NodeJS 是最佳选择呢?

实施微服务架构

我们从创建用于用户管理的微服务开始，它将使用 TCP 数据包进行通信，并负责对用户进行 CRUD 操作。我们将使用 PacketSender 对其进行测试，PacketSender 是一个免费的工具，用于发送支持 TCP 的网络数据包。

微服务的架构和作用域被进一步界定。因此，从演示的角度来看，通过 HTTP 实现一个微服务与实现 NodeJS API 没有什么不同。

同时，通过 HTTP 来使用 REST 也很容易，但如果从这个协议切换到其他协议时，会出现一些问题。这也是本文中我们将会使用 TCP 包的异步模式来与微服务通信的原因。

我们将使用 NestJS 作为应用的框架。它并非 NodeJS 微服务框架，而是一个用于构建服务器端应用的框架。但是，由于其内置了多个微服务特性，使得工作变得更加容易。

用 Node.js 构建微服务相当容易，尤其是用 NestJS 框架。开始时，可以使用 CLI 创建一个新的 NestJS 应用，使用如下命令：

该命令会创建并初始化一个新项目。要开始构建一个微服务，你需要安装以下软件包：

最后，为了让微服务启动和运行，我们需要用以下内容更新 main.ts 文件：

import { INestMicroservice } from @nestjs/common;

import { NestFactory } from @nestjs/core;

import { Transport } from @nestjs/microservices;

import { AppModule } from ./app.module;

async function bootstrap() {

const microservicesOptions: any = {

transport: Transport.TCP,

options: {

host: 127.0.0.1,

port: 8875,

},

};

const app: INestMicroservice = await NestFactory.createMicroservice(

AppModule,

microservicesOptions,

);

app.listen(() => console.log(Microservice is listening));

}

NestJS 支持几个内置的传输层实现，称为传输器。上面的代码将创建一个微服务，通过 TCP 传输层绑定到本地机器的 8875 端口进行通信。

我们可以使用消息模式或事件模式来与微服务通信。

消息模式的作用就像一个请求 - 响应方法，它适用于在服务之间交换消息，而当你只想发布事件而不等待响应时，就可以使用事件模式。

在我们的案例中，我们只实现根据给定的输入创建一个用户的功能，并且将获得创建的用户。因此，我们将在 app.controller.ts 文件中注册一个名为 create_user 的消息模式。

@Controller()

export class AppController {

constructor(private readonly appService: AppService) {}

@MessagePattern(create_user)

async createUser(@Payload() payload: CreateUserDto) {

const user = await this.appService.createUser(payload);

return user;

}

我们抽象出创建新用户的逻辑，因为它可以根据需求和使用的数据库以各种方式实现，我们将只关注与微服务相关的主题。

我们用来创建一个新用户的有效负载有以下格式：

import { IsString, IsEmail } from class-validator;

export class CreateUserDto {

@IsEmail()

email: string;

@IsString()

password: string;

一个带有 email 和 password 的简单对象

为了测试这个微服务，我们将使用 PacketSender 向应用发送一个 TCP 包。为此，将地址和端口设置为 127.0.0.1:8875，并从右侧的下拉菜单中选择 TCP。要对我们的信息进行编码，请使用 ASCII 字段，并用以下值来完成：

122#{"pattern":"create_user",

"data":{"email":"d@gmail.com","password":"12345678"},

pattern：是我们正在寻找的信息，create_user。

data：是我们要发送的 JSON 对象，一个带有 email 和 password 的对象。

值 122 代表我们的消息的长度，从第一个大括号开始到最后一个大括号(包括两个)。

数据包发送器配置

如果我们点击 Send 按钮，我们会看到如下日志：

日志活动

第二个是我们发送给微服务的内容，第一个是我们收到的内容。里面的响应是由我们的微服务返回的对象，即被创建的用户。

现在我们有了微服务，并进行了快速测试，看它是否能接收请求并返回响应，现在是时候创建一个 API 网关并将其连接到微服务上了。

为此，我们将使用上面描述的相同步骤创建一个新的 NestJS 应用，然后用以下内容更新 app.module.ts 文件。

import { Module } from @nestjs/common;

import { AppController } from ./app.controller;

import { AppService } from ./app.service;

import { ConfigService } from "./config/config.service";

@Module({

imports: [],

controllers: [AppController],

providers: [

{

provide: USER_MICROSERVICE,

useFactory: (configService: ConfigService) => {

const options = {

transport: Transport.TCP,

options: {

host: configService.get(USERS_MICROSERVICE_HOST),

port: Number(configService.get(USERS_MICROSERVICE_PORT)),

},

};

return ClientProxyFactory.create(options as ClientOptions);

},

inject: [ConfigService],

},

AppService,

],

})

我们将使用 .env 文件，我们将在其中存储任何与配置有关的值。这些文件将在一个配置服务的帮助下被读取。该微服务可以在 host 127.0.0.1:8875 处找到，其中 port 为 8875。

通过上面的代码，我们使用 ClientProxy 注入一个新的对象，代表与我们的用户 - 微服务的连接。这个 NestJS 类提供了几个内置的工具来与远程微服务交换信息。

为了使用这个链接对象，我们可以在 AppController 或 AppService 中注入它，如下所示：

@Controller()

export class AppController {

constructor(

@Inject(USER_MICROSERVICE) private readonly client: ClientProxy,

private readonly appService: AppService

) {}

@Post(create-user)

async createUser(@Body() payload: CreateUserDto) {

return this.client.send(create_user, payload).toPromise();

}

现在，每次 API 在路由 create-user 处受到 POST 请求时，API 网关将把请求和有效载荷一起转发给微服务，然后从微服务返回响应给用户。

相关文章