Dapr+NestJs编写Pub及Sub装饰器实战示例
Dapr 是一个可移植的、事件驱动的运行时，它使任何开发人员能够轻松构建出弹性的、无状态和有状态的应用程序，并可运行在云平台或边缘计算中，它同时也支持多种编程语言和开发框架。Dapr 确保开发人员专注于编写业务逻辑，不必分神解决分布式系统难题，从而显著提高了生产力。Dapr 降低了构建微服务架构类现代云原生应用的门槛。
系列
本地使用 Docker Compose 与 Nestjs 快速构建基于 Dapr 的 Redis 发布/订阅分布式应用
NodeJS 基于 Dapr 构建云原生微服务应用，从 0 到 1 快速上手指南
Dapr JavaScript SDK
用于在 JavaScript 和 TypeScript 中构建 Dapr 应用程序的客户端库。 该客户端抽象了公共 Dapr API，例如服务到服务调用、状态管理、发布/订阅、Secret 等，并为构建应用程序提供了一个简单、直观的 API。
安装
要开始使用 Javascript SDK，请从 NPM 安装 Dapr JavaScript SDK 包：
npm install --save @dapr/dapr
⚠️ dapr-client 现在已弃用。 请参阅#259 了解更多信息。
结构
Dapr Javascript SDK 包含两个主要组件：
- DaprServer: 管理所有 Dapr sidecar 到应用程序的通信。
- DaprClient: 管理所有应用程序到 Dapr sidecar 的通信。
上述通信可以配置为使用 gRPC 或 HTTP 协议。
实战
创建一个小应用程序来生成有关网站中用户行为的统计信息。
Demo 源码
准备环境和项目结构
npm install -g @nestjs/cli nest new api mv api nest-dapr cd nest-dapr nest generate app page-view npm install dapr-client wget -q https://raw.githubusercontent.com/dapr/cli/master/install/install.sh -O - | /bin/bash
创建一个 decorators.ts 文件（apps/shared/decorators.ts），这样所有微服务都可以从我们即将编写的基础架构中受益。
注入 Dapr 赖项
注入 DaprClient 和 DaprServer，我们需要提供它们到 nest.js。
在 app.module.ts 中让我们注册 DaprClient：
providers: [
...
{
provide: DaprClient,
useValue: new DaprClient()
}
]
在 page-view.module.ts 中以同样的方式添加 DaprServer：
providers: [
...
{
provide: DaprServer,
useValue: new DaprServer()
}
]
配置 Dapr 组件(rabbitMQ)
用 docker compose 启动 rabbitmq：
version: '3.9'
services:
pubsub:
image: rabbitmq:3-management-alpine
container_name: 'pubsub'
ports:
- 5674:5672
- 15674:15672 #web port
我们还需要配置 Dapr 组件。在根文件夹中创建一个 component/pubsub.yml：
apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
name: pubsub
namespace: default
spec:
type: pubsub.rabbitmq
version: v1
metadata:
- name: host
value: 'amqp://guest:guest@localhost:5674'
每个 Dapr 微服务都需要自己的 config。
api/dapr/config.yml：
apiVersion: dapr.io/v1alpha1 kind: Configuration metadata: name: api namespace: default
page-view/dapr/config.yml：
apiVersion: dapr.io/v1alpha1 kind: Configuration metadata: name: page-view namespace: default
API/Gateway 服务
在 app.controller.ts 中，我们将公开一个简单的 API — /add-page-view。
@Post('/add-page-view')
async prderAdd(@Body() pageViewDto: PageViewDto): Promise<void> {
try {
console.log(pageViewDto);
await this.daprClient.pubsub.publish('pubsub', 'page-view-add', pageViewDto);
} catch (e) {
console.log(e);
}
}
内部监听微服务
在我们将数据发布到队列之后，我们需要监听它并调用它：
在 page-view.controller.ts 添加：
@DaprPubSubSubscribe('pubsub', 'add')
addPageView(data: PageViewDto) {
console.log(`addPageView executed with data: ${JSON.stringify(data)}`);
this.data.push(data);
}
注意我们现在需要创建的新装饰器：@DaprPubSubscribe。
@DaprPubSubscribe 装饰器
在 shared/decorators.ts 中：
import { INestApplication } from '@nestjs/common';
import { DaprServer } from 'dapr-client';
export type PubsubMap = {
[pubSubName: string]: {
topic: string;
target: any;
descriptor: PropertyDescriptor;
};
};
export const DAPR_PUB_SUB_MAP: PubsubMap = {};
export const DaprPubSubSubscribe = (
pubSubName: string,
topic: string,
): MethodDecorator => {
return (target: any, propertyKey: string, descriptor: PropertyDescriptor) => {
DAPR_PUB_SUB_MAP[pubSubName] = {
topic,
target,
descriptor,
};
return descriptor;
};
};
export const useDaprPubSubListener = async (app: INestApplication) => {
const daprServer = app.get(DaprServer);
for (const pubSubName in DAPR_PUB_SUB_MAP) {
const item = DAPR_PUB_SUB_MAP[pubSubName];
console.log(
`Listening to the pubsub name - "${pubSubName}" on topic "${item.topic}"`,
);
await daprServer.pubsub.subscribe(
pubSubName,
item.topic,
async (data: any) => {
const targetClassImpl = app.get(item.target.constructor);
await targetClassImpl[item.descriptor.value.name](data);
},
);
}
};
运行应用程序
运行：
docker-compose up -d # 启动 rabbitmq npm run dapr:api:dev # 启动 api/gateway npm run page-view:dev # 启动内部微服务监听 dapr rabbitmq 队列
执行请求：
curl --location --request POST 'http://localhost:7001/v1.0/invoke/api/method/statistics/add-page-view' \
--header 'Content-Type: application/json' \
--data-raw '{
"pageUrl" : "https://test.com/some-page",
"userAgent": "Mozilla/5.0 (Windows NT 6.1; Win64; x64; rv:47.0) Gecko/20100101 Firefox/47.0"
}'以上就是Dapr+NestJs编写Pub及Sub装饰器实战示例的详细内容，更多关于Dapr NestJs编写Pub及Sub的资料请关注脚本之家其它相关文章！
相关文章
Nodejs Socket连接池及TCP HTTP网络模型详解
这篇文章主要为大家介绍了Nodejs Socket连接池及TCP HTTP网络模型,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪2023-08-08
这篇文章主要为大家详细介绍了基于nodejs实现微信支付功能，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2017-12-12
这篇文章主要为大家介绍了Public Npm Registry的使用方式示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2023-11-11
这篇文章主要介绍了pm2与Verdaccio搭建私有npm库过程详解,有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2022-08-08
npm报错：request to httpsregistry.npm.taobao.org
这篇文章主要介绍了npm报错：request to httpsregistry.npm.taobao.org failed, reason certificate has expired的解决方案,文中有详细的解决方案,需要的朋友可以参考下2024-03-03
这篇文章主要给大家介绍了关于Nodejs使用Mongodb存储与提供后端CRD服务的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2018-09-09
这篇文章主要介绍了node(koa2) web应用模块介绍详解，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2019-03-03
这篇文章主要介绍了node ftp上传文件夹到服务器的视线方法,结合具体实例分析了node.js调用ftp模块进行文件上传的相关配置、连接、path路径操作与文件传输实现方法,需要的朋友可以参考下2023-04-04
这篇文章主要介绍了node.js中的fs.write方法使用说明,本文介绍了fs.write的方法说明、语法、接收参数、使用实例和实现源码,需要的朋友可以参考下2014-12-12
本篇文章主要介绍了nodejs异步I/O和事件循环，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2017-06-06
最新评论