经过身份验证的套接字 io.adapter.ts

main.ts

授权成功时： 授权成功

授权失败时： 授权失败

我正在使用nestjs创建一些微服务。

例如，我有x、y和z服务都通过grpc互连，但我希望服务 x 在特定实体更改时向 webapp 发送更新，所以我考虑了 server-sent-events [对任何其他更好的解决方案开放]。

根据nestjs 文档，他们有一个以n 间隔运行的函数，用于sse 路由，似乎资源枯竭。有没有办法在有更新时实际发送事件。

假设我在同一个服务中有另一个 api 调用，由单击另一个 web 应用程序的按钮触发，我如何触发事件仅在单击按钮时触发，而不是持续发送事件。此外，如果您知道任何惯用的方法来实现这一点，将不胜感激，希望它是最后的手段。

[奖金问题]

我还考虑使用MQTT发送事件。但是我感觉单个服务不可能拥有MQTT 和 gRPC。我对使用 MQTT 持怀疑态度，因为它的延迟以及它将如何影响内部消息传递。如果我可以限制外部客户端，那就太好了（即，x 服务使用 gRPC 进行内部连接，使用 MQTT 进行 webapp 只需要一个由 mqtt 公开的路由）。（PS我是微服务新手，所以请全面了解您的解决方案：p）

提前感谢您阅读到最后！

我对nestjs 完全陌生，并试图将服务注入网关。无法让它工作。以下是代码，

#notification.gateway.ts

#notification.service.ts

#notifications.module.ts

我收到以下错误，

在服务构造函数中删除 InjectModel 使服务可用，但我希望模型保留通知。

任何有关如何解决此问题的帮助都非常感谢。谢谢。

我正在尝试与nestjs创建聊天，它的问题，@SubscribeMessage()连接实现正在工作，但是当我尝试监听来自前端的发射和consolenestjs中的数据时，它不起作用

从前端我发送这个请求

当我将nodejs（expressjs）与socket.io一起使用时它可以工作，但是当我尝试用nestjs执行此操作时，它不起作用

我有三个模式（用户、帐户、联系人）这三个模式用于创建模型并生成迁移文件接下来，这个迁移文件迁移 PostgreSQL 数据库，这部分使用 Nest JS 成功完成。

接下来，我手动创建了一个表并在表中添加了几列。在这个表（模型）中，我需要自动集成到我们的 Nest JS 代码中，这可能吗？

因此，我在谷歌上搜索了如何在给定一个解决方案架构优先方法的情况下实现此场景。

在 Nest JS 中使用了一个库，即GraphQL ，该库用于实现模式优先的方法。我尝试了这种方法，但我无法在我们的代码中获取数据库模型。

任何人都告诉我如何实现这种情况

身份验证失败后，在断开连接之前，我想向客户端发出一个事件，通知请求提供的令牌无效。在我的 WebSocketGateway 这是我的代码：

我的客户：

未发送/接收事件。任何想法？

干杯

问题改写：如何通过 NestJs 路由套接字服务器 URL

我在 AWS 网关上有一个 WebSocket 服务器实现，我想使用 NestJS 作为所有实现服务的包装器。这样，我将提供 OpenAPI 文档并为所有不必要的逻辑抽象前端开发。

我该如何存档？

我想使用 Kafka 消息，因此我emit()首先调用了该消息，该消息成功地将消息存储在 Kafka 中。

我可以通过运行批处理文件看到：bin/windows/kafka-console-consumer.bat --topic signals --from-beginning --bootstrap-server localhost:9092

并记录新消息。{"botId":"TKS","emailToken":"38fhsf29h","pair":"xy","size":100}

这是我的 nodejs/nestjs 服务文件。我的脚本中缺少什么 - 因为同一个脚本成功写入 Kafka？我已经尝试过@MessagePattern并@EventPattern使用该消息。有任何想法吗？

我正在使用 nestjs 并想设置一个工作流程：

我已经使用示例repo中的代码设置了nestjs 网关，并准备了一个发送给所有客户端的方法。WsAdapterbroadcast

我有一个广播控制器供外部服务调用POST http://myserver/api/broadcast。

我有一个队列来BroadcastService排队广播事件。

如何让网关从broadcast队列和调用broadcast方法中获取项目？

到目前为止，我只看到了这样的示例，即在@SubscribeMessage('xxx')从任何客户端（通过）接收到消息后，服务器将消息广播给所有客户端。但现在触发器是队列消息。

我正在尝试过滤 RcpException （如果重要，来自 RabbitMQ）

网关.ts：

RPC-异常-filter.ts：

测试RMQ.ts：

预期输出：

给定输出：

为什么过滤器不起作用？