Dapr+NestJs编写Pub及Sub装饰器实战示例【Js基础】

目录

• 系列
• Dapr Javascript SDK
• 安装
• 结构
• 实战
• Demo 源码
• 准备环境和项目结构
• 注入 Dapr 赖项
• 配置 Dapr 组件(rabbitMQ)
• API/Gateway 服务
• 内部监听微服务
• @DaprPubSubscribe 装饰器
• 运行应用程序

npm install --save @dapr/dapr

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

providers: [
...
  {
    provide: DaprClient,
    useValue: new DaprClient()
  }
]

providers: [
...
  {
    provide: DaprServer,
    useValue: new DaprServer()
  }
]

version: "3.9"
services:
  pubsub:
    image: rabbitmq:3-management-alpine
    container_name: "pubsub"
    ports:
      - 5674:5672
      - 15674:15672 #web port

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"

apiVersion: dapr.io/v1alpha1
kind: Configuration
metadata:
  name: api
  namespace: default

apiVersion: dapr.io/v1alpha1
kind: Configuration
metadata:
  name: page-view
  namespace: default

 @Post("/add-page-view")
 async prderAdd(@Body() pageViewDto: PageViewDto): Promise {
   try {
      console.log(pageViewDto);
      await this.daprClient.pubsub.publish("pubsub", "page-view-add", pageViewDto);
    } catch (e) {
      console.log(e);
    }
  }

@DaprPubSubSubscribe("pubsub", "add")
addPageView(data: PageViewDto) {
    console.log(`addPageView executed with data: ${JSON.stringify(data)}`);
    this.data.push(data);
}

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"
}"