[JavaScript知识库] 【深入浅出 Node + React 的微服务项目】18. Event Flow

开发: C++知识库 Java知识库 JavaScript Python PHP知识库人工智能区块链大数据移动开发嵌入式开发工具数据结构与算法开发测试游戏开发网络协议系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑笔记本显卡显示器固态硬盘硬盘耳机手机 iphone vivo oppo 小米华为单反装机图拉丁

-> JavaScript知识库 -> 【深入浅出 Node + React 的微服务项目】18. Event Flow -> 正文阅读

[JavaScript知识库]【深入浅出 Node + React 的微服务项目】18. Event Flow

文章目录

Orders Service Events

在这里插入图片描述

? back to top

创建 Events

// common/src/events/order-created-event.ts
import { Subjects } from './subjects';
import { OrderStatus } from './types/order-status';

export interface OrderCreatedEvent {
  subject: Subjects.OrderCreated;
  data: {
    id: string;
    status: OrderStatus;
    userId: string;
    expiresAt: string;
    ticket: {
      id: string;
      price: number;
    };
  };
}

// section-18/ticketing/common/src/events/order-cancelled-event.ts
import { Subjects } from './subjects';

export interface OrderCancelledEvent {
  subject: Subjects.OrderCancelled;
  data: {
    id: string;
    ticket: {
      id: string;
    };
  };
}

? back to top

实现 Publishers

// orders/src/events/publishers/order-created-publisher.ts
import { Publisher, OrderCreatedEvent, Subjects } from '@heysirius-common/common';

export class OrderCreatedPublisher extends Publisher<OrderCreatedEvent> {
  subject: Subjects.OrderCreated = Subjects.OrderCreated;
}

// orders/src/events/publishers/order-cancelled-publisher.ts
import { Subjects, Publisher, OrderCancelledEvent } from '@heysirius-common/common';

export class OrderCancelledPublisher extends Publisher<OrderCancelledEvent> {
  subject: Subjects.OrderCancelled = Subjects.OrderCancelled;
}

? back to top

Publishing Order Creation Event

// orders/src/routes/new.ts
  // Publish an event saying that an order was created
  new OrderCreatedPublisher(natsWrapper.client).publish({
    id: order.id,
    status: order.status,
    userId: order.userId,
    expiresAt: order.expiresAt.toISOString(),
    ticket: {
      id: ticket.id,
      price: ticket.price,
    },
  });

? back to top

Publishing Order Cancellation Event

// orders/src/routes/delete.ts
  // publishing an event saying this was cancelled!
  new OrderCancelledPublisher(natsWrapper.client).publish({
    id: order.id,
    ticket: {
      id: order.ticket.id,
    },
  });