NestJS -在微服务中结合使用RabbitMQ和HTTP
NestJS是一个基于Node.js的开发框架，它提供了一种优雅且高效的方式来构建可扩展的服务器端应用程序。NestJS结合了Angular的开发风格和Express的灵活性，使得开发人员可以轻松地构建可维护和可测试的应用程序。
在微服务架构中，NestJS可以与RabbitMQ和HTTP协议结合使用。RabbitMQ是一个开源的消息代理，它实现了高效的消息传递机制，可以在分布式系统中实现可靠的消息传递。HTTP协议是一种常用的网络通信协议，用于在客户端和服务器之间传输数据。
结合使用RabbitMQ和HTTP可以实现微服务之间的异步通信和同步通信。异步通信可以提高系统的可伸缩性和可靠性，而同步通信可以简化系统的开发和维护。通过使用NestJS，开发人员可以轻松地集成RabbitMQ和HTTP，并实现高效的微服务架构。
以下是NestJS结合使用RabbitMQ和HTTP的一些优势和应用场景：
优势：
- 可扩展性：NestJS提供了一种模块化的开发方式，可以轻松地扩展和组织代码，使得应用程序可以适应不断增长的需求。
- 可测试性：NestJS鼓励使用依赖注入和模块化的开发方式，使得应用程序的各个组件可以独立地进行单元测试，保证代码的质量和可靠性。
- 灵活性：NestJS支持多种通信协议和消息代理，开发人员可以根据实际需求选择合适的通信方式，提高系统的灵活性和适应性。
应用场景：
- 微服务架构：NestJS结合使用RabbitMQ和HTTP可以实现高效的微服务架构，提供可靠的消息传递和通信机制，适用于复杂的分布式系统。
- 实时通信：通过结合使用RabbitMQ和HTTP，可以实现实时的消息传递和通信，适用于聊天应用、实时监控系统等场景。
- 异步任务处理：NestJS可以将耗时的任务发送到RabbitMQ队列中进行处理，提高系统的响应速度和并发能力，适用于后台任务处理、数据处理等场景。
推荐的腾讯云相关产品和产品介绍链接地址：
- 腾讯云消息队列 CMQ：https://cloud.tencent.com/product/cmq 腾讯云消息队列（CMQ）是一种高可靠、高可用的分布式消息队列服务，可以实现消息的可靠传递和通信。
- 腾讯云云服务器 CVM：https://cloud.tencent.com/product/cvm 腾讯云云服务器（CVM）是一种弹性计算服务，提供可靠的云服务器实例，用于托管应用程序和数据。
- 腾讯云云函数 SCF：https://cloud.tencent.com/product/scf 腾讯云云函数（SCF）是一种事件驱动的无服务器计算服务，可以实现按需运行代码，无需管理服务器。
请注意，以上推荐的腾讯云产品仅供参考，具体选择应根据实际需求和项目要求进行评估。
相关·内容
1回答
正如标题所述，我有一个关于客户端、NestJS后端和的体系结构和交互的问题。我需要发展一项识别服务。我有一个客户端应用程序需要向NestJS后端发送带有图像的HTTP，该后端应该与第三方联系，该服务将识别图像中的文本(这可能需要很长时间)，并且我们应该在客户端应用程序上收到这个响应。实现这一点的最佳方法是什么？我有一个想法通过RabbitMQ将RabbitMQ与连接起来，客户端向NestJS后端发送一个POST HTTP请求，后端通过RPC向发送一条创建任务的消息，后者与任务一起创建一个Redis队列，将后端返回到任务的NestJS id并开始执行一个长期运行的任务，我们从NestJS后端将任
浏览 9提问于2022-09-13得票数 1
回答已采纳
2回答
我正在NestJS中创建一个微服务。现在，我想使用RabbitMQ向另一个服务发送消息。
我的问题是:可以基于一个RabbitmqModule变量导入.env吗？如：USE_BROKER=false.如果此变量为false，则不导入该模块？
RabbitMQ是在下面的GraphQLModule中导入的。
@Module({
imports: [
GraphQLFederationModule.forRoot({
autoSchemaFile: true,
context: ({ req }) => ({ req }),
}),
Data
浏览 12提问于2020-12-18得票数 8
回答已采纳
1回答
我想要一个混合的NestJS应用程序，HTTP + RabbitMQ。但是不要知道我是否应该为每个队列创建不同的微服务。
我遵循了NestJS的RabbitMQ指南()和GitHub示例()。
main.ts
app.connectMicroservice({
transport: Transport.RMQ,
options: {
urls: [`amqp://user:user@hostname:5672`],
queue: "cats_queue",
queueOptions: { durable: false },
浏览 5提问于2019-11-10得票数 3
1回答
这里我有一个单独的模块，它代表RabbitMQ客户端模块
import { Module } from '@nestjs/common';
import { Transport, ClientsModule } from '@nestjs/microservices';
import { ServiceConfig } from '../config/service.config';
import { RmqSubscriberServiceToken } from '../../constants/token.constant'
浏览 2提问于2021-03-01得票数 0
使用@golevelup/nestjs-rabbitmq，我尝试连接管理器不等待连接。根据的说法，它可以处理重新连接，等待连接而不会破坏应用程序。但是，当我如前所述地使用connectionInitOptions并将wait设置为false时，我会得到一个连接错误。当我不使用它(默认行为将wait设置为true)时，它将连接到RabbitMQ服务器。下面是在RabbitMQModule模块中导入NestJS的示例。
这可以工作，并连接到RabbitMQ服务器。
RabbitMQModule.forRoot(RabbitMQModule, {
exchanges: [{ type:
浏览 47提问于2022-02-17得票数 0
回答已采纳
在我的团队中，我们使用NestJS作为后端。我们希望使用微服务体系结构，我已经看到在NestJS中有内置的微服务支持。在阅读了文档之后，我有一些关于这个特性的问题：
我应该在同一个项目或单独的项目中创建微服务吗？为什么甚至使用createMicroservice而不是NestFactory.create？使用createMicroservice还使我可以使用@MessagePattern并使用发射器发送消息如果我的微服务使用队列(如RabbitMQ)获取消息，但是我不能在我的微服务中创建REST，因此它使从非NestJS微服务调用NestJS微服务变得更加困难(或不可能)，因为它依赖于Nest
浏览 13提问于2022-10-11得票数 0
回答已采纳
我正在用NestJS创建一个微服务。现在我想使用RabbitMQ向另一个服务发送消息。 我创建了这个功能，它工作得非常好。但是当我想要合并它的时候，当CircleCI测试正在运行时，问题就出现了。10分钟后，我收到消息：Too long with no output (exceeded 10m0s): context deadline exceeded 这只发生在带有生产者的服务上。消费服务运行良好。 有没有人能解释一下为什么会发生这种情况，以及我如何解决这个问题？ 在下面的GraphQLModule中导入RabbitMQ。 @Module({
imports: [
GraphQ
浏览 79提问于2021-01-15得票数 0
假设我有NestJs项目，它由以下部分组成，每个部分都有自己的git存储库，并部署在不同的机器上：
Api服务
消息队列处理工作人员服务
这两个服务都需要第3部分-访问RabbitMq的库。假设#3是围绕定义实体和服务、访问MQ的RabbitMq客户机的一些抽象，所以模块#1和#2甚至不知道，它们正在使用RabbitMq。#3计划作为图书馆列入/使用在#1和#2中，而不是作为一项微型服务。
如何将其结合在一起？让我们从API服务的角度来假设：
它在RabbitMq文件夹中有node_modules模块。
我想在RabbitMq库中使用例如依赖注入。理想情况下，将其公开为
浏览 3提问于2019-12-14得票数 5
回答已采纳
我想在微服务结构中开发一个项目。我必须使用php/laravel和nodejs/nestjs，这是我的微服务之间最好的连接方法。我读到了RabbitMQ和NATS消息传递，还有GRPC，哪个选项更适合微服务？为什么？提前感谢
浏览 3提问于2021-10-02得票数 0
1回答
我有一个rabbitmq服务，它有一个队列，消息中没有模式json。
如下所示：
{"customFieldOne": "foo", "another": "bar", "numbers": [3, 5, 8]}
但是，使用rabbitmq的nestjs需要一个json模式，如下所示：
{"pattern": "my-pattern", "data": {"fieldOne": 1 ...}}
它必须具有模式和数据字段。
在没有定义模式或模式的情况下，
浏览 0提问于2021-07-03得票数 1
我有一些微服务，它们是通过API-Gateway公开的。网关负责处理身份验证和路由到系统中。网关背后的服务大多是简单的CRUD-Services。每个服务都公开自己的API，它们通过HTTP进行同步通信。所有这些服务，包括API-Gateway，都是“默认的”NestJS应用程序。 让我们继续使用Cats示例。每当Cat-Service更新或创建新的Cat时，我都希望发出一个CatCreatedEvent或CatUpdatedEvent。应该将事件推送到像RabbitMQ这样的消息代理中，并且另一个服务应该侦听该事件并异步处理该事件。 我不确定如何实现这一点，就如何以正确的方式“注入”Rab
浏览 65提问于2019-01-01得票数 7
回答已采纳
我创建了一个具有rabbitmq连接的微服务(通知-微服务)。我有一个产品的微服务，从那里，我将推动一个事件的狂犬病an通知客户有关新产品。在通知-微服务微服务中，我有一个websocket。我如何从rabbitmq读取事件通知客户。现在，我只能从微服务控制器中读取兔子of上的事件。如何从websocket文件中读取。
微服务main.ts文件：
import { Logger } from '@nestjs/common';
import { NestFactory } from '@nestjs/core';
import { Transport } fro
浏览 0提问于2021-04-25得票数 0
1回答
我正在为一个简单的CRUD API寻找一个PHP框架，它需要一些身份验证。这个应用程序的唯一目的是具有高度的可伸缩性。
php将是非常简单的CRUD，主要用于写操作。这个API只会在iphone应用程序中使用，该应用程序将每隔几毫秒发送一次用户数据。
在我看来
Load Balancer -> PHP Framework (Horizontally Scalable) -> RabbitMQ Cluster -> Some Java Servers talking tp Hadoop/Cassandra -> Hadoop/Cassandra Cluster
因此，负
浏览 4提问于2014-06-30得票数 0
回答已采纳
日安！
我正在尝试实现2 microservices that communicate with each other through a message broker。But one of them should accept Http requests via REST-Api。不幸的是，我不明白如何让微服务同时侦听消息队列和传入的HTTP请求。也许我不了解通过message进行通信的范例中的一些内容，但是如何接收来自客户端的请求并将它们转发到微服务体系结构呢？
Main.ts
import { NestFactory } from '@nestjs/core';
impo
浏览 4提问于2022-01-21得票数 2
回答已采纳
2回答
我开始学习rabbitmq，我怎么会不明白微服务是如何通过网关进行通信的。在学习nestJS、微服务架构、网关时，您能理解它们是如何通信的吗？
浏览 2提问于2021-05-18得票数 0
我正在构建一个nestjs应用程序，我想在其中创建一个rabbitmq @Module({
imports: [
ClientsModule.register([
{
name: 'rabbitmq',
transport: Transport.RMQ,
options: {
urls: [
'amqp://guest:guest@rabbitmq',
],
浏览 33提问于2021-01-16得票数 0
2回答
我有一个由3个NestJS和1个dotnet5.0应用程序组成的多容器项目。除了应用程序之外，该项目还依赖于RabbitMQ和InfluxDB服务(以纯坞映像的形式运行)。
docker-compose文件如下所示：
version: '3.8'
services:
influxdb:
image: influxdb:2.0
container_name: influxdb
ports:
- '8086:8086'
expose:
- '8086'
volumes:
浏览 0提问于2021-05-31得票数 10
回答已采纳
在RabbitMQ服务器的情况下，可以获得线程转储和堆转储吗？
具体来说:我所指的RabbitMQ服务器在码头上运行，我希望在这种情况下获得线程转储和堆转储，这将在灾难分析或其他预防性警报中非常有用。
浏览 2提问于2018-02-22得票数 0
回答已采纳
我对从客户端调用在线API有异议。我使用httponly凭据创建了nestjs，并在
在本地托管的nestjs应用程序和来自本地的客户端它工作了，当nestjs应用程序托管在在线服务器中，客户端托管在在线服务器中时，它使用了，但是当nestjs托管在在线服务器中时，客户端从本地调用API得到了禁止的错误。
nestjs main.ts：
import { NestFactory } from '@nestjs/core';
import { AppModule } from './app.module';
import { ValidationPipe } fr
浏览 9提问于2022-08-01得票数 0
在nestjs中向服务抛出Http Exeption是一种好方法吗？在nestjs中处理服务错误的最佳方法是什么？
浏览 5提问于2022-01-11得票数 5
回答已采纳
我使用一个NestJS应用程序来使用一个RabbitMQ队列。无论订单如何，都可以处理每条消息，所以我想知道为同一队列声明新消费者的最佳做法是什么。
预期行为：队列由该服务处理，该服务使用多个使用者
队列: 1,2,3,4,5,6，...N；
在nestJS中，您可以使用@RabbitSubscribe装饰器分配一个函数来处理数据。我想要做的事情可以通过简单地用装饰器复制(并重命名)函数来实现，所以这个函数也会被调用来处理队列中的数据。
@RabbitSubscribe({
...
queue: 'my-queue',
})
async first
浏览 22提问于2021-07-05得票数 0
如何设置rabbitMQ连接名，以便使用NestJS在管理控制台上显示？在RmqOptions接口中，我看不到任何选项。
我想为这个连接设置友好的名称，如本文中所示：
我在网上做过一些研究。转到NestJS文档并查看代码。
浏览 11提问于2022-11-12得票数 0
我使用Unity作为我WCF项目的服务层的IOC容器。使用Unity.WCF库将其插入到每个WCF服务中是非常有效的。
最近，我在服务层中引入了RabbitMQ，目前我正在使用“使用”块来连接和添加队列。我不喜欢这个，我想使用HierachicalLifetimeManager来创建和破坏我与RabbitMQ的连接，因为我需要它们？这听起来对吗？
我正在寻找这个示例，或者至少是一些关于最佳方法的指导？(例如，我应该封装连接并根据需要注入到每个服务中吗？如何封装RabbitMQ使用者等？)
浏览 4提问于2015-05-01得票数 11
回答已采纳
所以我使用NestJS (v8)和RabbitMQ传输(Transport.RMQ)来侦听消息
我的NestJS代码如下所示：
// main.ts
const app = await NestFactory.createMicroservice<MicroserviceOptions>(AppModule, {
transport: Transport.RMQ,
options: {
urls: ['amqp://localhost:5672'],
queue: 'my-queue',
replyQueue: &#
浏览 5提问于2021-10-04得票数 0
回答已采纳
1回答
我有一个NestJs和一些应用程序(微服务)和Libs。我在我的所有应用程序中都使用了一个Service类，所以我想在lib中提取它。
我认为这是个好主意，但后来我意识到，我在这个类的方法上有一个修饰器，每个应用程序都需要一个不同的const字符串。看来我做不到.有办法吗？基本上，我需要将加载应用程序中的const字符串“注入”到库中，以便由装饰器使用。
更确切地说，装饰器是一个@RabbitSubscribe() (来自golevelup/nestjs-rabbitmq)，每个模块的队列名称(用于装饰器的const参数)需要不同。
但是更一般地说，如果我在lib中有这个类：
@Injecta
浏览 4提问于2020-09-14得票数 0
回答已采纳
1回答
我正在尝试为我的NestJS服务实现gRPC服务的身份验证和授权，这些服务是在NestJS中实现的。
@GrpcMethod(USER_SERVICE_NAME, 'GetUser')
private getUser(req: GetUserRequest): Promise<GetUserResponse> {
return this.userService.getUser(req);
}
到目前为止，我已经了解了如何在之后为常规HTTP请求实现它。但据我所见，这将从常规的http请求中获取JWT。
现在，我如何将它应用于gRPC请求。我也找到了，但是这里
浏览 11提问于2022-04-20得票数 0
回答已采纳
2回答
我在windows中设置了rabbitMQ和它的管理单元，
路径中键入“示例文件”类型的rabbitmq.config文件。
“...AppData\Roaming\RabbitMQ”和“C:\Program (x86)\RabbitMQ \rabbitmq_server-3.3.1\等等”
我将行{loopback_users，[]}添加到此rabbitmq.config文件中，并重新启动windows服务，但仍然无法从另一台带有来宾/来宾的计算机登录
我是否编辑了错误的配置文件？
下面是一些相关的讨论：
浏览 10提问于2014-05-21得票数 1
1回答
我需要一个网络服务器，它路由传入的请求到后端工作人员通过批处理他们每0.5秒或当它有50个http请求时，以较早发生。用python/tornado或任何其他语言实现它的好方法是什么？
我的想法是将传入的请求发布到rabbitMQ队列，然后以某种方式将它们批处理在一起，然后发送到后端服务器。我搞不懂的是如何从rabbitMq队列中挑选多个请求。有没有人能告诉我正确的方向，或者给我提个替代方案？
浏览 1提问于2015-08-19得票数 10
我试图使用RabbitMq从NestJs微服务调用特定的函数，但是我无法使用nodejs访问特定的消息模式。
我试图从控制器文件访问的消息模式。
@MessagePattern('signin')
async signin(
@Payload(ValidationPipe) signInCredentialsDto: SignInCredentialsDto,
@Ctx() context: RmqContext,
): Promise<{ accessToken: string }> {
this.logger.verbose(&#
浏览 1提问于2021-04-02得票数 3
1回答
我有一个使用NestJs和无服务器框架编写的系统，每个端点都是aws上的一个lambda函数。其中一个功能不是端点，而是来自AWS eventbridge的触发器。由于此函数不是端点，因此不能将其包含在NestJs模块中，因为它必须单独导出。我的问题是，当事件到达Eventbridge并触发lambda时，我必须调用NestJs服务，但我无法这样做，因为lambda函数在NestJs环境之外。这是我从模块外部调用NestJs服务的一种方式吗？
下面是无服务器框架的配置
functions:
function 1(NestJs controller):
handler: src/la
浏览 46提问于2021-06-17得票数 0
我想要的
我正在使用NestJS实现一个删除路由。
由于该路由仅在成功删除时才返回HTTP 204 No Content，因此我使用@nestjs/swagger装饰器对其进行了如下注释：
@ApiParam({
name: 'id',
required: true,
type: 'string',
example: 'abc123',
})
@ApiNoContentResponse({
description: 'All items for the given id have been deleted',
浏览 12提问于2022-11-10得票数 1
回答已采纳
我在Play应用程序中有一个WebSocket服务器，我想将其移动到akka-http服务。我目前使用的是ActorFlow.actorRef，它是在Akka中不存在的Play的一部分。
当WebSocket被接受时，我订阅一个RabbitMQ队列，并将每条消息转发给WebSocket。当我收到来自WebSocket的消息时，我会在本地处理一些消息，并将其他消息转发到RabbitMQ交换。
我如何使用akka-http来做同样的事情呢？我可以使用Sink.actorRef创建一个接收器并在那里处理入站消息，但是源呢？
我可以用Source.actorRef创建源，但是如何在实现时访问要向其发送
浏览 1提问于2016-09-20得票数 0
我用二进制.tar.gz安装了rabbmitmq服务器，然后创建了rabbitmq-env.conf和rabbitmq.config。
在rabbitmq-env.conf中
LOG_BASE=/var/log/rabbitmq
但是当我启动rabbitmq-server时
vagrant@jinming:/usr/local/rabbitmq_server-3.5.4$ sudo rabbitmq-server
RabbitMQ 3.5.4. Copyright (C) 2007-2015 Pivotal Software, Inc.
## ##
浏览 6提问于2015-09-09得票数 0
回答已采纳
我正在将一个NestJS应用程序与RabbitMQ集成，并遵循教程中的此tutorial。我可以看到，消息使用者可以使用队列名连接到rabbitMQ代理，但实际上我想创建一个连接到exchange的临时队列。我在教程中指定的队列选项中找不到指定交换名称的选项。谁能指出用来指定交换而不是队列的正确配置？是否可以在'queueOptions‘结构中指定交换名称？
浏览 25提问于2021-08-26得票数 1
我有一个简单的NestJs微服务应用程序，它正在侦听来自Rabbitmq服务的消息。
async function bootstrap() {
dotenv.config();
// TODO: Check for ENV valid
const rabbitOptions = {
urls: [`amqp://${process.env.MQ_HOSTNAME}:${process.env.MQ_PORT}`],
queue: process.env.TASK_QUEUE_NAME,
queueOptions: { durable: false },
浏览 3提问于2020-01-17得票数 1
对于nestJS兔子MQ，我从一台服务器到另一台服务器使用RPC。我基本上想要的是，当消费者抛出错误时，await this.amqpConnection.request拒绝承诺。正如我从、和文档中了解到的，当您使用NACK (负面ack)消息时，它应该将RPC响应放到相应的队列中，其中包含将传递给客户端的错误信息。下面是一些代码示例：
生产者
import { AmqpConnection } from '@golevelup/nestjs-rabbitmq';
let amqpConnection: AmqpConnection;
sendMessage(payload
浏览 1提问于2021-01-09得票数 4
5回答
微服务异步响应
、、
我遇到很多博客说，使用rabbitmq可以提高微服务的性能，这是由于rabbitmq的异步特性。
在这种情况下，我不明白http响应是如何发送给最终用户的，我在下面更清楚地阐述了我的问题。
用户向microservice1发送http请求(这是面向用户的服务)
microservice1将其发送到rabbitmq，因为它需要来自microservice2的一些服务。
microservice2接收请求，处理请求并将响应发送给rabbitmq
microservice1从rabbitmq接收响应
现在如何将此响应发送到浏览器？microservice1是否等待直到收到来自
浏览 5提问于2019-10-09得票数 10
2回答
我正在寻找一种解决方案来使用RabbitMQ来安排消息，这样不仅可以像几个来源中描述的那样延迟消息，而且可以计划它有一条消息，例如每天。
如果不是RabbitMQ，那么对于使用消息总线的微服务环境，您还能想到什么其他的解决方案吗？因此，它实际上是关于将任务调度器和消息总线的概念结合起来……
或者，使用作业调度程序只是为了将消息推送到消息队列，例如结合使用rundeck和RabbitMQ，会更好吗？
浏览 2提问于2016-11-25得票数 8
回答已采纳
我使用RabbitMQ作为消息队列/消息总线进行评估，并一直在查看RabbitMQ页面上的示例。
我正在寻找一个没有包含在教程中的特定场景，我不确定是否以及如何通过RabbitMQ来实现。
安装程序
让我们假设我得到了一项服务，我们把它称为“采购订单”，而我不得不将其他服务称为“物流”和“会计”。
当订单被发送时，我想通过RabbitMQ作为消息发送它。
有2个“帐户”和3个“后勤”服务
怎样才能确保“帐户”和“后勤”只处理一次信息？如果我正确理解，使用pub/sub将导致消息被处理两次(帐户)或trice (物流)。
使用工作队列和prefetch=1，可以确保只有一个得
浏览 2提问于2015-11-29得票数 4
回答已采纳
1回答
包: apt-cacher-ng版本: 3.1-1 我们已经使用apt-cacher-ng配置了一个apt代理服务器，虽然它适用于大多数软件包，但在尝试安装rabbitmq-server时提到了一个特定的版本，它会失败，并出现403错误。在V/PfilePatternEx中使用regex的任何尝试都会得到相同的结果。 我们在服务器和客户端都使用ubuntu 18.04.2 在客户端，它看起来像这样： Err:1 http://dl.bintray.com/rabbitmq/debian xenial/main amd64 rabbitmq-server all 3.6.15-1
403
浏览 21提问于2019-04-08得票数 3
回答已采纳
2回答
我必须在NestJ中为我的一个项目使用SOAP服务。我正在尝试使用来自web的虚拟SOAP服务。详情如下-
URL -
http://webservices.oorsprong.org/websamples.countryinfo/CountryInfoService.wso?WSDL
方法- POST
报头-
Content-Type: text/xml
请求机构-
<Envelope xmlns="http://schemas.xmlsoap.org/soap/envelope/">
<Body>
<CapitalCit
浏览 5提问于2021-10-28得票数 7
我有一个利用MassTransit和RabbitMQ作为消息总线的ASP.NET项目，我正在尝试实现MassTransit Saga，我想使用Saga的ScheduleTimeout功能，这需要MassTransit.RuntimeServices (TimeoutService)。
然而，随着我逐渐了解到，MassTransit的NuGet安装并不包含RuntimeServices，这在我看来似乎很愚蠢，但是哦，好吧。
因此，我尝试将MassTransit.RuntimeServices和MassTransit.RuntimeServices.Database直接包含在我的项目中，这导致了许
浏览 2提问于2013-08-09得票数 0
从角客户端到NestJS服务器的Http请求将Number转换为String：
我通过从我的角度客户端到我的NestJS服务器的GET http请求的参数传递NestJS。无论什么地方我都把它定义为数字。在我的服务函数firstIndex: number的参数中。当从服务器端@Query('firstIndex') firstIndex: number抓取它时，但是当我尝试使用它时，我会遇到问题。当我记录typeof firstIndex时，它会以字符串的形式出现。我必须用const firstInd = Number(firstIndex)把它转换成一个数字。
我假设这只是与
浏览 1提问于2021-08-13得票数 1
回答已采纳
我已经用Spring开发了一段时间的微服务，使用虚拟客户端、rest模板和AMPQ代理来建立每个微服务之间的通信。
现在，我正在学习NestJ和它的微服务方法。我注意到，nestjs使用TCP作为默认传输层，这与使用Spring的方式不同。
为什么nestjs更喜欢那些传输层(TCP，AMPQ)而不是HTTP？HTTP不是rest微服务的传输协议吗？
来自NestJ的文档：
“一个微服务从根本上说是一个应用程序，它使用与HTTP"不同的传输层。
浏览 2提问于2020-09-29得票数 5
构建一个NestJS应用程序，我希望通过https路由所有传入的流量，而不会给用户带来不便。
到目前为止，我知道有两种方法不符合我的要求。
为http和https设置两个服务器，而不是为每个路由/api端点重定向流量，这确实不是干的，也不是最佳实践。
通过只创建https服务器，用户将被迫手动键入我不想要的https地址。
理想情况下，我会假设一种解决方案，在这种解决方案中，https在第一分钟就被检查和强制执行，有些人只需输入example.com即可命中服务器。我认为最好在我的NestJS应用程序的NestJS应用程序中完成。
浏览 6提问于2020-02-25得票数 4
回答已采纳
1回答
我正在尝试使用NestJS中主脚手架应用程序控制器中的服务模块中的服务。
这是有效的- helloWorldsService.message在@Get方法中显示预期的问候语-但是在app.module和app.controller中导入HelloWorldsService似乎是多余的，并且似乎违反了服务模块对服务的封装。
我说的对吗?这是你如何从不同的模块使用谨慎的服务，还是我遗漏了什么？我问的原因是:如果这是正确的，并且您必须直接引用其他类(例如，直接在控制器中引用HelloWorldService )，那么我很难理解为什么要为@Module声明的providers/imports属性而烦恼
浏览 0提问于2020-12-23得票数 0
1回答
根据NestJS文档，我实现了websockets网关，并在AppModule中提供它。服务器正在正常启动，我可以通过http成功地提供静态资产。但是，我根本无法运行websockets，在ws://localhost:3333中，ws服务器不可用，afterInit函数也根本没有执行。即使在定义@SubscribeMessage时也是如此。
网关实现为
@WebSocketGateway()
export class SocketGateway implements OnGatewayInit {
afterInit() {
console.log('Gateway in
浏览 0提问于2019-04-13得票数 3
回答已采纳
第一次在这里使用狂犬病。我使用下面的命令来使用docker启动rabbitmq。
docker run --rm -it -p 15672:15672 -p 5672:5672 rabbitmq:3-management
我可以看到，狂犬病已经开始了，我也可以打开管理宇宙。当启动nestjs应用程序中的各个服务时，我看到在rabbitmq上正在创建队列。但是，每当服务试图通信时，便会出现以下错误。
2022-10-13 08:50:46.763870+00:00 [info] <0.1222.0> connection <0.1222.0> (172.17.0.1:62
浏览 7提问于2022-10-13得票数 0
3回答
我在用nestjs创建微型服务，传输rabbitmq。如何使微服务从队列中接收消息，然后等待上一个队列的完成。
main.ts
import { NestFactory } from '@nestjs/core';
import { AppModule } from './app.module';
import { Transport } from '@nestjs/microservices';
async function bootstrap() {
const app = await NestFactory.createM
浏览 0提问于2019-05-14得票数 4
回答已采纳
有任何方法可以使用nestjs作为独立的udp服务器吗？我创建了自定义udp服务器适配器，在文档中解释了这一点，但是当我尝试使用star应用程序时，我给出了这个错误。
没有选择驱动程序(HTTP)。为了利用默认的驱动程序，请确保安装"@nestjs/platform-express“包($ npm install @nestjs/platform-express)。
async function bootstrap() {
const app = await NestFactory.create(AppModule);
app.useWebSocketAdapter(new
浏览 4提问于2020-05-18得票数 0
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
腾讯云开发者
