Nestjs 上的 Azure 服务总线侦听器

Posted 2023-02-19

【中文标题】Nestjs 上的 Azure 服务总线侦听器

【英文标题】：Azure servicebus listener on nestjs

【发布时间】：2021-12-26 14:07:06

【问题描述】：

我有一项服务可以处理我的产品的业务逻辑。

当我通过 azure 上的服务总线收到消息时，我需要调用该服务。

我可以使用 azure npm 包从 azure 服务总线队列中挑选消息。参考：https://docs.microsoft.com/en-us/azure/service-bus-messaging/service-bus-nodejs-how-to-use-queues

但是当消息到达我的应用程序时，我无法将业务逻辑类注入上述侦听器。我们正在使用 NestJS 框架。

技术细节：NestJS、NodeJs、Typescript、Azure 服务总线

【问题讨论】：

你有没有查看npmjs.com/package/@pebula/nesbus

能否请您详细说明您的目标是什么以及您尝试过的一些代码遇到了什么问题，而不是提供链接，以便我可以通过重现您的问题来提供帮助。

您可以参考NesBus (Nest / Service Bus) is a microservice extension for NestJS并在GitHub上打开一个问题：azure-sdk-for-js

【参考方案1】：

Jesse-Carter 提供的发布建议作为答案，以便对面临类似问题的其他社区成员有所帮助。

NesBus（Nest / Service Bus）是 NestJS 的微服务扩展，它在 NestJS 中以简单且直观的方式。

消息处理

处理传入的服务总线消息现在就像处理传入的 REST 请求一样简单。

@Controller()

export  class  ServiceBusController  

 @Queue<MethodDecorator>((

 name:  'nesbus-queue.demo'

 )

 async  myQueueEntity(@Ctx()  context: SbContext)  

 

更多信息请查看NesBus。

【讨论】：

如果我的答案对您有帮助，您可以接受它作为答案（点击答案旁边的复选标记，将其从灰色切换为已填充。）。这对其他社区成员可能是有益的。谢谢