译见 | 用 Docker，Spring Boot/Cloud 和 Axon CQRS/ES（事件溯源）来构建微服务

Posted 2021-04-24 道客船长

译见系列  道客船长「译见」系列，关注国外云计算领域的技术和前沿趋势，每周为开发者提供精选译文。 

软件架构变化的步伐在过去几年快速演进。新的实践，如 DevOps，微服务和容器化已经成为热点话题也被逐渐广泛采用。在这篇文章中，作者 Ben Wilcock 会介绍一个自己实践的微服务项目，包含了两个在架构层面上比较突出的点：命令和查询职责分离（CQRS）与容器化。

在第一部分，作者会演示如何轻松用容器分发和运行一个多服务的微服务应用。

为了做到这一点，我使用 Docker 创建了一套包含所有运行演示所需的微服务容器集群。在写本文的时候，Demo 包含了七个微服务：

这个 Demo 的源代码放在了 ，该项目同时演示了如何实施和集成多个 “云原生（Java）应用” 需要的特性，包括：

• Microservices with Java and Spring Boot

• Build, Ship and Run anywhere using Docker containers

• Command and Query Responsibility Separation (CQRS) and Event Sourcing (ES) using the Axon Framework v2, MongoDB and RabbitMQ

• Centralised configuration（统一配置管理）, service registration（服务注册） and API Gateway（API 网关） using Spring Cloud

▼

工作原理

这里介绍的微服务示例项目围绕一个虚构的 “产品” 主数据应用，它会和大多数零售或制造企业得的产品应用相关。使用简单的 RESTful 服务 API，产品可以被添加，存储，搜索和获取。当变化发生时，通知会通过消息的方式发送给相关服务。

产品数据应用使用 CQRS 构建。在 CQRS 命令中如 ADD 在物理上与查询命令例如VIEW（其中id = 1）分离。事实上，在这个特殊的例子中，产品领域的代码库被分成两个独立的部分 - 命令侧微服务和查询侧微服务。

就像通常的 12-Factor 应用一样，每个微服务都有自己独立的职责，独立的数据存储，并且可以独立地进行部署和扩展，这是 CQRS 和微服务最直观的字面解释。CQRS 或者微服务并非一定要如此实现，在这里我选择将读写逻辑关注点分离只是为了更好的示范。

整体的逻辑结构如下图：

命令侧和查询侧的微服务都是采用 Spring Boot 框架搭建的。命令和查询部分之间的所有通信都是单纯通过event-driven（事件驱动）。事件在微服务组件之间的传递采用 RabbitMQ 消息。消息传递提供了以松散耦合的方式在进程，微服务，传统系统和其他部分之间传递事件的可扩展手段。

请注意：任何服务都不会与其他服务共享数据库。这是非常重要的，因为它使得每个服务具有高度的自主性，这反过来保证了个体服务能够独立于系统中的其他服务进行扩展。

CQRS 架构模式中存在的高度自主和隔离给我们带来了一个有趣的问题————我们应该如何分配和运行如此松散耦合的组件？在我看来，对于这个问题容器化提供了最好的机制，并且随着 Docker 被越来越广泛的应用，它的格式已经成为容器镜像的标准，并且那些最流行的云平台也提供了直接的支持，再加上它确实非常方便使用，因此必定有所帮助。

▼

命令侧微服务

所谓命令就是 “改变状态的动作”。命令侧微服务包含所有逻辑部分和业务规则。命令用于添加新内容或更改其状态。在特定内容上执行这些命令将导致生成“事件”，这些事件由 Axon 框架持久保存到 MongoDB 中，并通过 RabbitMQ 消息传播到其他进程（由业务决定可能更多的进程）。

在事件溯源中，事件是系统唯一的状态记录，系统使用它们来描述和重建任何实体的当前状态（依次重放它过去的每个事件，直到所有事件被重新应用一遍）。这听起来很慢，但实际上因为事件很简单因此执行的很快，并且可以使用snapshots（快照）进一步实现回滚。

在域驱动设计（DDD）中，实体通常被称为Aggregate（聚合）或AggregateRoot（聚合根）。

▼

查询侧微服务

查询侧的微服务充当着一个事件监听者的角色。监听着被命令方提交的事件并将其通过最直观的方式表达出来（比如一个表格视图）。

在本例中，查询侧只是简单的构建并且维护一个产品状态的可视化或投影（依据它们的 ID 和描述与是否在售的状态）。查询侧可以横向拓展多实例，RabbitMQ 的消息队列也可被设置为持久化的，因此如果查询侧服务不可用的时候，RabbitMQ 可以保存临时存储消息。

命令侧和查询侧都提供了通过 REST API 查询的能力。

更多信息，可以查看 Axon 的文档，其中描述了 Axon 如何使用 CQRS，事件采集等一系列的细节与如何配置和用法。

▼

运行演示

运行示例代码非常简单，但是首先需要在你的机器上安装以下软件。作为参考，我使用 Ubuntu 16.04 作为操作系统，但同时我也在新的 Docker for Windows Beta 版本上成功测试了该应用程序。

• Docker (版本：v1.8.2)

• Docker-compose (版本： v1.7.1)

如果以上两个软件都已存在，那么你可以通过下面列出的步骤运行示例。

如果您已经安装有 MongoDB 或 RabbitMQ，请先关闭这些服务，然后再按照以下步骤继续，以避免端口冲突。

Step 1：获取 Docker-compose 配置文件

新建一个空文件夹，在终端执行下列命令以下载此示例的最新 docker-compose 配置文件。

$ wget https://raw.githubusercontent.com/benwilcock/microservice-sampler/master/docker-compose.yml

请不要尝试更改文件的名称———Docker 在默认情况下，会去寻找名为 “docker-compose.yml” 的文件。 如果你确实需要更改文件名称，请在以下步骤中使用-f转换。

Step 2：启动微服务

因为我们使用 docker-compose 文件，所以启动微服务只需要简单的执行下面的命令。

$ docker-compose up

随着 Docker 镜像的下载和运行，你将在终端窗口中看到大量的下载和日志输出。

总共需要下载七个 docker 镜像，它们是 mongodb，rabbitmq，config-service，discovery-service，gateway-service，product-cmd-side和product-qry-side。

$ docker ps

一旦容器启动并运行（一开始可能需要一点时间），你立即可以通过浏览器进行查看。你应该能够访问：

1. The Rabbit Management Console on port 15672

2. The Eureka Discovery Server Console on port 8761

3. The Configuration Server mappings on port 8888

4. The API Gateway Routes on port ‘8080’

Step 3：使用产品

到目前为止都很顺利，现在我们要测试新增的产品。

在本次手动的系统测试中，我们将向命令侧 REST API 发出一个add命令。

当命令侧处理该指令时，产生了一个 'ProductAddedEvent'，存储在 MongoDB 中，并通过 RabbitMQ 转发给查询端。然后查询侧处理此事件，并为产品的物化视图（本简单示例中实际上是一个 H2 内存数据库）添加一条记录。一旦事件被处理，我们就可以使用查询侧微服务来查找关于已经添加的新产品的信息。执行这些任务时，您可以在 docker-compose 终端窗口中观察到一些日志的输出。

Step 3.1：添加新产品

要执行这项测试，我们首先需要打开第二个终端窗口，我们可以继续输入一些 CURL 命令，同时不停止在第一个窗口中运行着的 docker 组合实例。

为了达到测试目的，我们将在产品目录中添加一个名为 “Everything is Awesome” 的 MP3 产品。为此，我们可以使用命令侧的 REST API，并发出 POST 请求，如下所示：

$ curl -X POST -v --header "Content-Type: application/json" --header "Accept: */*" "http://localhost:8080/commands/products/add/01?name=Everything%20Is%20Awesome"

如果没有可用的 “CURL”，可以使用任何你喜欢的 REST API 测试工具（例如Postman，SoapUI，RESTeasy 等）。

你应该会看到类似于以下的响应内容：

* Trying 127.0.0.1...
* Connected to localhost (127.0.0.1) port 8080(#0)
> POST /commands/products/add/01?name=Everything%20Is%20Awesome     HTTP/1.1
> Host: localhost:9000
> User-Agent: curl/7.47.0
> Content-Type: application/json
> Accept: */*$ http://localhost:8080/commands/products/01
< HTTP/1.1 201 Created
< Date: Thu, 02 Jun 2016 13:37:07 GMTThis
< X-Application-Context: product-command-side:9000
< Content-Length: 0
< Server: Jetty(9.2.16.v20160414)

响应码为 HTTP / 1.1 201 Created。这意味着 MP3 产品 “Everything is Awesome” 已成功添加到命令端事件源存储库。

Step 3.2：查询新产品

现在我们可以查看刚添加的产品。为此，首先发出一个简单的 “GET” 请求。

$ curl http://localhost:8080/queries/products/1

你应该可以看到以下输出，这表明查询侧微服务具有我们新添加的 MP3 产品的记录：

{
    name: "Everything Is Awesome",
    saleable: false,
    _links: {
        self: {
        href: "http://localhost:8080/queries/products/1"
        },
    product: {
        href: "http://localhost:8080/queries/products/1"
        }
    }   
}

搞定！如果你愿意，可以重复测试，添加更多的产品，不过小心不要尝试使用相同的 ID，否则当你发出 POST 请求时将会反馈一个错误。

如果你熟悉 MongoDB，你可以检查数据库以查看创建的所有事件。同样，如果你知道 RabbitMQ 管理控制台的方式，也可以看到消息在命令端和查询端微服务之间传输的过程。

作者介绍 | Ben Wilcock

Ben Wilcock 是一位自由软件架构师和技术主管，对微服务，云和移动应用充满热情。Ben 曾经帮助过多家 FTSE 100 的公司变得更加可靠，创新和敏捷。 同时 Ben 也是一位受人尊敬的技术博客，其文章被收录于 Java Code Geeks，InfoQ，android Weekly 等等。如果你存在任何问题，可以通过 LinkedIn，Twitter 或者 Github 联系他。

推 荐 阅 读

点击标题即可阅读