Serverless CQRS 体系结构：在 Serverless 中的工作

本文将介绍 Serverless CQRS（命令查询职责分离）体系结构，并探讨如何在 Serverless 环境中实现它。Serverless CQRS 是一种以分离职责为基础的软件架构模式，可用于开发分布式系统，其优势在于它可以在不增加部署和管理复杂性的情况下，使应用程序更加可维护和可扩展。

CQRS 基础

在 CQRS 中，应用程序被划分为两个独立的部分。第一部分处理写操作（命令），第二部分负责读操作（查询）。这种分离使应用程序更加灵活，因为可以使用不同的技术和存储选项来处理不同的职责。

例如，对于写操作，我们可能使用一个带有事务支持的关系型数据库。同时，对于查询操作，我们可能使用一个简单的 NoSQL 数据库或者缓存。

此外，CQRS 还提供了一个事件驱动模型，使得我们可以轻松地将其与 Event Sourcing、消息传递和事件总线系统相结合，以便支持可扩展的系统和领域驱动设计模式。

Serverless CQRS

传统的 CQRS 实现需要运行自己的服务器，管理其托管的服务、数据存储和云基础设施等。Serverless 技术可以使 CQRS 更简单，因为它可以减少管理和维护基础设施的成本。同时，Serverless 架构可以根据实际使用量自动缩放，因此可以支持大量的并发操作。

下面我们将探讨如何在 Serverless 环境中实现 CQRS 模式。我们将采用以下技术：

  • AWS Lambda：用于处理命令和查询，以及事件驱动模型的事件处理程序。
  • AWS API Gateway：用于公开 RESTful API。
  • AWS S3：用于持久化事件和命令。
  • AWS DynamoDB： 用于存储和检索读模型。

下图演示了 Serverless CQRS 架构。

                       ----------------
------------------     -     ---      -     -------------------
-                -  -- -   -------    - --  -                 -
-     ------     -     -  ---------   -     -   --- ------    -
-                -     ----------------     -    ---------    -
------------------                          -------------------
          -                                           -
          -                                           -
          -         --------------------              -
          --------  - --- ----- ------ - --------------
                    --------------------
                               -
          -------------------------------------     -------------------
          -                                   -     -                 -
          -                                   -  -  -    --- ------   -
          -                                   -     -     -------     -
          -          ------------------       -     -------------------
          -          -   --- --       -       -
          -  ------  -  ------ ------ -  --------------
          -  -       ------------------       -     -       -
          -  -                                  -     -       -
          -  -               --------------     -     -       -
          -  ----------------- --- ------ -  -  - -  - --- -------- -
          -                  -  -------------     -     -   ----- -------
          -                  --------------     -     -       -
          -                                   -     -       -
          -                                   -     -       -
          -------------------------------------     -------------------

Serverless CQRS 体系结构包括以下组件：

  • API Gateway：负责公开 RESTful API，客户端可以使用它发送命令。
  • Command Lambda：负责处理命令并将其写入事件存储中。
  • Event Store：负责存储事件，它是代码逻辑和设计思想的唯一来源。
  • Projection Lambda：负责使用查询模型将事件转换为查询，并将其存储在 DynamoDB 中。
  • Query Lambda：负责读取查询模型并返回响应。

实现 Serverless CQRS

准备工作

在开始实现之前，我们需要创建一个 AWS 账户和一个 IAM 管理用户，这将为我们提供 AWS CLI 访问和管理资源的权限。我们还需要安装 AWS CLI。

创建 AWS S3 存储桶

我们需要为事件存储创建 S3 存储桶。请运行以下 AWS CLI 命令：

--- ----- ------------- -------- --------- -------- ---------

其中，my-bucket 是存储桶名称，us-east-1 是存储桶所在的 AWS 区域。

部署 Command Lambda

Command Lambda 用于处理客户端发送的命令并将其写入事件存储中。我们可以使用 Node.js 编写 Lambda 函数。请使用以下代码创建一个 Node.js 项目：

----- --------------
-- ---------------
--- ---- --

接下来，安装 AWS SDK 和 AWS Lambda SDK：

--- ------- -------
--- ------- ----------

创建 index.js 文件并添加以下代码：

----- --- - -------------------
----- -- - --- ---------

--------------- - ----- ------- -- -
  ----- ------ - -----------------
  ----- ---- - ------------------------

  -- ------- ----- -- --
  ----- ------ - -
    ------- -------------------------
    ---- ----------------------------------------
    ----- ------------
  --

  ----- -------------------------------

  -- ------- ----- -- -----------
  ----- ----------- - --- ------------------
  ----- ----- - -
    ------- -------------------------
    ----------- ----------
    ------- ------------
  --

  ----- ----------------------- -------- ------- -------------

  ------ - ----------- --- --
--

此代码使用 AWS SDK 和 AWS Lambda SDK 访问 S3 和 EventBridge。

该代码是将客户端发送的命令写入事件存储，并将其发布到 EventBridge 的完整实现。

使用 AWS CLI 部署 Lambda 函数，运行以下命令：

--- ------ --------------- --------------- -------------- --------- ---------- ---------- ------------------ --------- ------------- ------ --------------- ------------- -------------------------------------------------------- ------------- --- --------- -

其中：

  • --function-name：Lambda 函数名称。
  • --runtime：Lambda 函数运行时。
  • --zip-file：将要部署的代码包。
  • --handler：Lambda 函数要处理的事件，例如 index.handler。
  • --role：IAM 角色 ARN，用于授权 Lambda 函数访问其他 AWS 资源。
  • --environment：指定 Lambda 函数的环境变量。
  • --memory-size：Lambda 函数的内存大小。
  • --timeout：Lambda 函数的超时时间。

以上命令将构建和部署到 Lambda，作为一个函数，它的名称是 command-lambda。

部署 Query Lambda

Query Lambda 用于读取查询模型并返回响应。我们可以使用 Node.js 和 AWS SDK 编写 Lambda 函数。请使用以下代码创建一个 Node.js 项目：

----- ------------
-- -------------
--- ---- --

安装 AWS SDK 和 AWS Lambda SDK：

--- ------- -------
--- ------- ----------

创建 index.js 文件并添加以下代码：

----- --- - -------------------
----- --------- - --- ------------------------------

--------------- - ----- ------- -- -
  -- ---- ----- ----- ---- --------
  ----- ------ - -
    ---------- -----------------------
    ---- -
      --- ------------------------
    --
  --

  ----- ------ - ----- --------------------------------

  -- -------------- -
    ------ - ----------- --- --
  -

  ----- -------- - -
    ----------- ----
    -------- -
      --------------- -------------------
    --
    ----- ----------------------------
  --

  ------ ---------
--

使用 AWS CLI 部署 Lambda 函数，运行以下命令：

--- ------ --------------- --------------- ------------ --------- ---------- ---------- ------------------ --------- ------------- ------ --------------- ------------- --------------------------------- ------------- --- --------- -

部署 Projection Lambda

Projection Lambda 会将事件转换为查询，并将其存储在 DynamoDB 中。我们可以使用 Node.js 和 AWS SDK 编写 Lambda 函数来实现它。请使用以下代码创建一个 Node.js 项目：

----- -----------------
-- ------------------
--- ---- --

安装 AWS SDK 和 AWS Lambda SDK：

--- ------- -------
--- ------- ----------

创建 index.js 文件并添加以下代码：

----- --- - -------------------
----- --------- - --- ------------------------------

--------------- - ----- ------- -- -
  ----- ------ - -----------------
  ----- ---- - ------------------------

  -- ------- --- ----- -- ---- -----
  --- --------- - ---
  -- ---------- --- --------------- -
    --------- - -
      ---------- -------------
      ----------- --------------
      ------------ ---------------
    --
  - ---- -- ---------- --- --------------- -
    ----- ------ - -
      ---------- -----------------------
      ---- -
        --- -------------
      --
    --

    ----- ------ - ----- --------------------------------

    -- -------------- -
      ----- --- ------------ --- ----- ---- -- ------------------
    -

    --------- - -
      ---------- --------------------
      ----------- ---------------------
      ------------ ---------------
    --
  - ---- -- ---------- --- --------------- -
    ----- ------ - -
      ---------- -----------------------
      ---- -
        --- -------------
      --
    --

    ----- -----------------------------------

    -------
  - ---- -
    ----- --- ------------------ ----- ---- ---------------
  -

  -- ----- -- --------
  ----- ------ - -
    ---------- -----------------------
    ----- ----------
  --

  ----- --------------------------------
--

使用 AWS CLI 部署 Lambda 函数，运行以下命令：

--- ------ --------------- --------------- ----------------- --------- ---------- ---------- ------------------ --------- ------------- ------ --------------- ------------- --------------------------------- ------------- --- --------- -

部署事件桥

我们需要配置事件桥以将事件从 Command Lambda 传递到 Projection Lambda 和 S3 存储。

请运行以下 AWS CLI 命令：

--- ------ -------- ------ ---------------- --------------- ------------------------------------------------------------------------------------------------

--- ------ -------------- --------------- ----------------- -------------- ---------- -------- --------------------- ----------- -------------------- ------------ -------------------------
--- ------ -------------- --------------- -------------- -------------- ---------- -------- --------------------- ----------- -------------------- ------------ -------------------------

--- ------ ----------- ------ ---------------- --------- -------------------------------------------
--- ------ ----------- ------ ---------------- --------- --------------------------------------- ------- --------------------------------------------------------------------------------

其中，my-event-pattern 是事件桥所使用的规则名称，my-app 是事件源名称。

以上步骤将为我们创建事件规则、Lambda 函数授权和 S3 存储。

部署 API Gateway

请运行以下 AWS CLI 命令：

--- ---------- --------------- ------ ------
--- ---------- --------------- ------------- ------------- ----------- -------------------- ----------- ------

--- ---------- ---------- ------------- ------------- ------------- ------------------ ------------- ---- -------------------- ----

--- ---------- --------------- ------------- ------------- ------------- ------------------ ------------- ---- ------ --------- ------------------------- ---- ----- --------------------------------------------------------------------------------------------------------

--- ---------- ------------------- ------------- ------------- ------------- ------------------ ------------- ---- ------------- --- ----------------- ----------------------- -----------

--- ---------- ----------------- ------------- ------------- ------------ ---

此代码将创建一个 RESTful API 和一个 orders 资源。此外，它将创建一个 POST 方法，该方法可将请求发送到 Command Lambda。最后，我们将创建一个部署，以便我们可以测试 API。

测试 API

现在可以测试 API。我们将向 API 发送命令。

请运行以下 AWS CLI 命令：

---- -- ---- -- -------------- ----------------- -- --------------------------------------------------------------------------------------------- ----------------------------------

此命令将创建一个新的订单并将其发布到 S3 和 EventBridge。

查询

我们可以使用 Query Lambda 从 DynamoDB 中读取查询模型。

请运行以下 AWS CLI 命令：

---- -- --- ------------------------------------

该命令将返回查询模型的 JSON 表示形式。

总结

在本文中，我们学习了在 Serverless 环境中实现 CQRS 模式的基本原理和实现方法。我们使用 AWS Lambda、API Gateway、S3 和 DynamoDB 等工具来构建 Serverless CQRS 体系结构。

Serverless CQRS 体系结构使得系统具有更高的可维护性和可扩展性，并节省了管理基础设施的时间和资源。

来源：JavaScript中文网 ，转载请联系管理员！ 本文地址：https://www.javascriptcn.com/post/65913d9ceb4cecbf2d674891

阅读全文

猜你喜欢

  • GraphQL：用 Connection 优化节点查询

    前言 GraphQL 是一种由 Facebook 开发的数据查询和操作语言，它提供了一种更高效、更灵活的方式来获取和操作数据。GraphQL 的一个重要特性就是可以精确地指定需要查询的数据，避免了传统...

    1 个月前
  • Server-sent Events 的浏览器支持情况及解决方法

    什么是 Server-sent Events？ Server-sent Events（简称 SSE）是一种基于 HTTP 的服务器推送技术，它可以让服务器向客户端发送事件流，客户端通过监听这个事件流来...

    1 个月前
  • ECMAScript 2020（ES11）中的新特性：BigInt 转换

    在 ECMAScript 2020（ES11）中，新增了一种数据类型：BigInt。它是一种可以表示任意大整数的数据类型，可以用来解决 JavaScript 中整数运算的精度问题。

    1 个月前
  • CSS Reset 在 IE6、IE7 等老浏览器中的应用

    什么是 CSS Reset CSS Reset 是一种通过重置浏览器默认样式的方式，消除不同浏览器之间的差异，从而实现更加一致的样式效果的技术手段。在前端开发中，使用 CSS Reset 可以让我们更...

    1 个月前
  • ES6 中的类继承和原型链之间的关系解析

    在 ES6 中，引入了 class 关键字，使得 JavaScript 也具备了面向对象编程的能力。在类继承和原型链之间，有着密切的关系。本文将详细解析 ES6 中的类继承和原型链之间的关系，并提供一...

    1 个月前
  • 如何使用 Redux 处理 React 应用中的表单数据

    前言 在开发 React 应用时，表单数据的处理是非常常见的需求。然而，由于 React 的单向数据流和组件化特性，传统的表单处理方式可能会变得非常繁琐。而 Redux 作为一种状态管理工具，可以帮助...

    1 个月前
  • Redis 处理高并发的策略

    前言 随着互联网的发展，高并发已经成为了一个不可避免的问题。而 Redis 作为一款高性能的 NoSQL 数据库，也成为了处理高并发的重要工具之一。本文将会介绍 Redis 处理高并发的策略，并且会提...

    1 个月前
  • 响应式设计中的图片适配问题解决方案

    在响应式设计中，图片适配是一个比较棘手的问题。如果不加以处理，可能会导致图片在不同设备上显示不佳，影响用户体验。本文将介绍响应式设计中的图片适配问题，并提供解决方案。

    1 个月前
  • 解析 TypeScript 中 encapsulation（封装）的实现方式

    解析 TypeScript 中 encapsulation（封装）的实现方式 在 TypeScript 中，封装（encapsulation）是一种重要的面向对象编程的特性。

    1 个月前
  • PM2 崩溃处理：如何避免由于 PM2 进程奔溃导致应用崩溃？

    在前端开发中，我们经常使用 PM2 进行进程管理和部署。但是，当 PM2 进程崩溃时，应用也会跟着崩溃。如何避免这种情况的发生？本文将介绍 PM2 崩溃处理的方法和技巧，帮助您更好地管理和部署应用。

    1 个月前
  • 在 Node.js 中运行 HTTPS 服务器的方法

    Node.js 是一个非常流行的 JavaScript 运行时环境，它可以让我们通过 JavaScript 编写服务器端应用程序。在开发 Web 应用程序时，安全性是非常重要的。

    1 个月前
  • 详解 ECMAScript 2018 中的三个新操作符及其用法

    ECMAScript 2018 (简称 ES2018) 是 JavaScript 语言的最新标准，其中包含了许多新特性和语法糖。本文将详细介绍其中的三个新操作符及其用法，分别是：扩展运算符、剩余运算符...

    1 个月前
  • 解决 Enzyme 测试 React Native 组件时动画无法渲染的问题

    在开发 React Native 应用时，我们经常需要使用 Enzyme 来测试组件。然而，当我们测试涉及到动画的组件时，我们可能会遇到一些问题：动画无法渲染，导致测试失败。

    1 个月前
  • 使用 React Router 打造复杂而强大的 SPA 应用

    随着 Web 技术的不断发展，单页应用（Single Page Application，SPA）已经成为了现代 Web 应用的主流。SPA 通过异步加载数据和动态更新页面，提供了更快速、更流畅的用户体...

    1 个月前
  • AngularJS 中如何使用 ng-repeat 中的 filter 来过滤数据

    在 AngularJS 中，ng-repeat 指令是用于循环遍历数组或对象并生成 HTML 元素的常用指令。而 ng-repeat 指令中的 filter 属性则是用于过滤数据的功能。

    1 个月前
  • 如何在 Chai 中验证 Promise.all

    如何在 Chai 中验证 Promise.all 在前端开发中，Promise.all 是一个非常常用的功能，它可以让我们在多个异步操作完成后再执行一些操作，这个功能在实际开发中非常实用。

    1 个月前
  • Mongoose 实现数据批量更新的方式详解

    前言 在前端开发中，经常会涉及到对数据库中的数据进行批量更新的操作。而 Mongoose 是一款 Node.js 平台下的 MongoDB 对象模型工具，它提供了一种方便的方式来操作 MongoDB ...

    1 个月前
  • 在使用 lit-element 的时候，如何解决麻烦的 Shadow DOM 的变量传递问题

    前言 在使用 Web Components 的时候，我们通常会使用 Shadow DOM 来实现封装和样式隔离。然而，Shadow DOM 的封闭性也带来了一些挑战，其中之一就是变量传递问题。

    1 个月前
  • Tailwind CSS 如何实现动态换肤？

    随着互联网的发展，越来越多的网站和应用开始支持动态换肤功能。动态换肤不仅可以提升用户体验，还可以让用户在不同的环境下选择适合自己的主题，增加用户黏性和满意度。本文将介绍如何使用 Tailwind CS...

    1 个月前
  • 如何在 Less 中使用字符串操作函数？

    在前端开发中，样式表是不可或缺的一部分。而 Less 是一种动态样式语言，它是 CSS 的一种扩展。在 Less 中，我们可以使用字符串操作函数来处理字符串，这些函数可以帮助我们更加方便地操作字符串，...

    1 个月前

相关推荐