Wow : 基于 DDD & EventSourcing 的现代响应式 CQRS 架构微服务开发框架

领域驱动 | 事件驱动 | 测试驱动 | 声明式设计 | 响应式编程 | 命令查询职责分离 | 事件溯源

中文文档 | English Document

Wow v6.13.5 发布：为高性能而生 🚀

亲爱的 Wow 开发者们，

我们很高兴地宣布 Wow v6.13.5 版本正式发布！🎊 本次更新是一次着眼于内核性能与开发体验的重大飞跃。我们不仅在关键路径上实现了显著的性能提升，还带来了 Kotlin 协程的原生支持，并进行了大规模的内部架构清理与优化，旨在为你提供一个更快速、更现代、更强大的领域驱动设计（DDD）与事件溯源（Event Sourcing）框架。

✨ 核心功能增强

🚀 拥抱 Kotlin 协程

我们正式将 Kotlin 协程支持融入框架核心，让你能够以更现代、更简洁的方式编写响应式业务逻辑。

• 协程函数访问器：新增了针对响应式函数的协程风格访问器，让你的聚合根和领域服务代码可以无缝使用 suspend 函数。
• 实战示例：我们更新了示例项目，提供了基于协程的订单聚合实现，为你展示最佳实践。

⚡ 性能狂飙

本版本的核心主题是性能。我们进行了全方位的基准测试与优化，特别是在高并发场景下的表现令人瞩目。

• 消息总线革命：彻底重构了 InMemoryMessageBus，引入了线程安全的 ConcurrentManySink、可配置的重试机制和忙等待策略，大幅提升了消息吞吐量与处理效率。
• 命令处理优化：新增了 notifyAndForget 通知机制，优化了命令分发器的并行处理能力，并提供了详尽的 JMH 基准测试数据供你参考。
• 内存事件存储：对 InMemoryEventStore 进行了专门优化，使其在处理高频事件流时速度更快。
• 序列化加速：优化了深拷贝（Deep Copy）和对象转换的性能，减少了数据传输与持久化时的开销。
• 全面的基准测试套件：新增了 wow-benchmarks 模块，包含了 MongoDB、Redis 事件存储以及多种命令分发器的基准测试，为你的技术选型提供可靠数据支持。

🏗 架构清理与 API 优化

为了让框架更清晰、更易维护，我们进行了一系列重要的架构调整。

• 弃用旧函数：为了引导更佳实践，我们标记了 GivenStage 和 WhenStage 中的旧版 inject 函数以及部分 when 函数为弃用状态，请参考文档迁移至新 API。
• 移除模板引擎：在 wow-bi 模块中移除了 jte 模板引擎，改用内联 SQL 生成，简化了依赖并提升了编译时安全性。
• 领域建模增强：引入了 VersionAware 和 StatusCapable 接口，为聚合根的状态和版本管理提供了更强大的类型支持。

🛠 基础设施与工具改进

• 调度器支持：为聚合分发器增加了调度器（Scheduler）支持，配合并行度控制接口，让你能更精细地控制任务执行。
• 事件存储功能增强：增加了按单个流和加载最新事件流的能力，丰富了事件回溯与查询的灵活性。
• 监控与追踪：为消息总线的等待策略添加了 OpenTelemetry 追踪支持，便于在生产环境进行性能诊断。
• 构建与依赖：项目已升级至 Kotlin 2.3.0，并使用 BOM 管理 Kotlinx Coroutines 依赖，确保构建的一致性与现代化。

🎯 总结

Wow v6.13.5 是一个为构建高性能、高响应性应用而精心打磨的版本。它不仅通过深度的性能优化和协程支持带来了实实在在的速度提升，还通过架构清理为未来的发展奠定了更坚实的基础。

立即升级，体验更迅捷、更流畅的领域驱动开发之旅！我们期待看到你用 Wow 构建出更卓越的系统。

前往 GitHub 查看完整更新日志与升级指南

Happy Coding with Wow! ❤️

简介

Wow 是一个基于领域驱动设计和事件溯源的现代响应式 CQRS 微服务开发框架，历经多年生产环境验证。

旨在帮助开发者构建现代化的、高性能且易于维护的微服务应用程序，充分发挥领域驱动设计和事件溯源等模式优势的同时降低应用的复杂性以及实践成本。

值得一提的是，领域驱动设计和事件溯源并非微服务架构的专属，Wow 框架不仅适用于微服务开发，同样也可用于构建基于领域驱动设计的单体应用程序。

快速开始

使用 Wow 项目模板快速创建基于 Wow 框架的 DDD 项目

特性概览

架构图

命令处理传播链

背景

随着业务的发展和复杂性的增加，传统的架构和开发方式逐渐显露出瓶颈。领域驱动设计和事件溯源等理念在提高系统设计的灵活性和可维护性方面表现出色，但在实践中常常需要面对复杂性和学习曲线的挑战。

Wow 框架的目标是以简单易用的方式将领域驱动设计和事件溯源等理念融入到微服务应用开发中，降低开发者的学习成本，提高开发效率。 通过提供现代响应式的 CQRS 架构和相关组件，Wow 框架旨在让开发者更专注于业务逻辑的实现，而不必过多关心底层技术细节。

经过多年的实践和不断的演进，Wow 框架在生产环境中得到了验证，积累了丰富的经验。这些经验和反馈不仅丰富了框架的功能和性能，也为持续的改进和优化提供了宝贵的指导。

对于开发者而言，Wow 框架意味着什么？

我曾告诫我的团队：如果我们过于依赖数据驱动设计而忽视领域驱动设计，我们最终将沦为CRUD工程师。

CRUD工程师的竞争力和可替代性可想而知，这或许是为何会有 35 岁效应，企业显然更倾向于招募没有太多生活羁绊、更加廉价的 25 岁CRUD工程师。

业务价值

软件系统的核心价值体现在业务价值上，研发人员不应只关注技术实现上，而是应该更多地关注业务价值的实现。 这其中的好处显而易见，当你开发完一个业务系统之后，你将变成一个业务专家，甚至比跟你合作的领域专家还要专业，因为你需要洞察业务细节。

使用 Wow 框架，意味着你将关注点放在围绕领域模型设计上，与业务专家一起探索业务领域，而不是关注于技术实现上。 你仅需编写领域模型，即可完成服务开发，Wow 框架自动为你准备好 OpenAPI 接口。

在《实现领域驱动设计》一书中，作者 Vaughn Vernon 提到：核心域才值得投入精力进行领域驱动设计， 但如果你使用 Wow 框架，你将发现，因为低廉开发成本、快速的开发效率，即使是次要的支撑子域也值得 DDD。

性能与伸缩性

随着业务的发展，你需要开始思考系统的性能和伸缩性问题。 在传统架构中，这牵扯到数据库关系模式、分片规则等复杂问题，同时你还需要处理因数据库分片导致的跨分片事务问题。 这时，你不得不修改你的业务代码，以适应水平拆分后的数据库架构。

然而，如果你选择使用 Wow 框架，你将不再需要过多关注数据库关系模式、分片规则等问题。你的业务代码无需变更，系统能够轻松实现水平伸缩。

你可以在这里了解更多关于 Wow 框架的性能。

读写分离与同步延迟

读写分离是一种极为普遍的性能优化架构模式。 然而，同步延迟问题常伴随而来，事务执行成功后写库落库成功，但读库同步延迟，用户刷新页面后无法获取最新数据，从而对用户的体验产生影响。例如：

• 用户发起下单事务，写库执行成功，但由于某种原因，读库同步延迟，用户刷新页面后发现订单未成功创建。
• 商家编辑完商品后，同步到 Elasticsearch 索引库，但由于某种原因，同步延迟，导致商家刷新页面后搜索不到该商品。

通常，大家采用最简便的方法，等待1秒后刷新页面。 虽然这种方式能解决大多数数据同步延迟的问题，但效率不够高。 因为大多数情况下，同步在100毫秒内就已完成，剩余的900毫秒成了浪费。 然而，有时1秒无法完成同步，这就导致用户获取的数据变得无效。

使用 Wow 框架，你可以通过等待 PROJECTED 信号完成，然后再将结果返回给用户，以更为优雅和高效的方式处理数据同步延迟的问题。

工程质量

单元测试是确保代码质量且符合预期业务需求的重要手段，但在传统架构中，单元测试往往是一项相当困难的任务，因为你需要考虑数据库连接、事务管理、数据清理等问题。

使用 Wow 框架，你将会发现基于 Given->When->Expect 模式的测试套件，使得单元测试变得异常简单。 你只需关注领域模型是否符合预期，而无需为数据库连接等问题烦恼。

在实际应用中，我们将领域模型的单元测试覆盖率下限阈值设置为 85%，也是可以轻松实现的。

在没有刻意要求的情况下，开发人员甚至自觉地将覆盖率提升至 95%。

因此，每次提交代码都变得轻松自在，因为你确信你的代码经过了充分的测试，并且真正意义上从单元测试中获得了收益。

在研发同级别的项目中，我们的测试团队在系统 API 测试中发现，基于 Wow 框架的项目，其 BUG 数仅为传统架构项目的 1/3。

你可以在这里了解更多关于 Wow 单元测试套件。

对于企业而言，Wow 框架意味着什么？

商业智能

商业智能是企业决策的关键支持，而数据则是商业智能的分析原料。业务数据越为丰富有价值，商业智能的分析结果越准确，决策也就更加可靠。

与传统架构有着显著差异，Wow 提供了实时聚合根状态事件（StateEvent）和聚合命令（Command）作为数据分析的数据源，同时极大降低了实时 ETL（Extract, Transform, Load）的难度。

在传统架构中，实现实时 ETL 通常需要经过繁琐的流程，包括 DB->CDC->Process->DB，而在 Wow 框架中，仅需一段简单的 SQL 脚本即可完成这一过程。

另外，在传统架构中，使用 CDC（MySql Binlog）数据仅记录数据的变化，缺乏明确的业务语义。进行业务分析时，需要基于数据状态的变化推断出业务语义，这往往需要进行大量的数据处理。 相较之下，Wow 框架直接提供了聚合根状态事件和聚合命令作为数据分析的数据源，极大降低了数据处理的难度。

Wow 提供的实时同步机制将数据实时同步至数据仓库（ClickHouse），为实时数据分析提供了极大的便利。这种方法为商业智能提供了强有力的支持，构建了一个实时数据分析系统，使决策制定能够基于及时而准确的信息。

你可以在这里了解更多关于 Wow 商业智能。

操作审计

操作审计是企业中保障安全性和合规性的重要组成部分，同时也是对系统操作进行监控和追踪的关键手段。Wow 框架在这方面为企业带来了显著的优势。

通过记录聚合命令（Command）作为操作审计的数据源，Wow 框架能够详细追踪系统中的各种操作。 这些记录不仅包含了操作本身的内容，还涵盖了操作触发的副作用（领域事件），为审计提供了更为全面和准确的数据基础。

相较于传统审计方法，Wow 框架的操作审计的数据源具备更加明确的业务语义，以及操作后产生的明确领域事件。

此外，Wow 框架提供的实时数据同步机制也为操作审计带来了便利，确保了审计数据的及时性和一致性。

了解更多关于 Wow 操作审计。

事件补偿

事件补偿在事件驱动架构中的作用是处理和恢复因为事件处理失败而导致的数据不一致性或错误状态。 当系统中的某个事件处理失败时，event compensation 机制会介入并执行相应的补偿操作，以确保系统状态得以修复并保持一致性。 这个机制有助于保障系统的可靠性和稳定性，尤其是在复杂的分布式系统中，其中事件可能在多个组件或服务之间传递。 通过 event compensation，系统可以更好地处理故障和异常情况，防止错误状态的传播，并最终确保系统能够从失败中恢复并继续正常运行。

事件补偿模块提供了可视化的事件补偿控制台和自动补偿机制，确保系统数据的最终一致性。

执行时序图

• 订阅者服务：
  • 订阅领域事件，执行业务逻辑。
  • 在执行失败时，发送执行失败记录。
  • 在执行成功时，发送执行成功记录。
• 控制台：
  • 分布式补偿调度器： 定时检查待补偿事件并执行准备补偿操作。
  • 通知： 在发生执行失败异常时，发送通知消息。
• 开发者：
  • 监控： 监控补偿事件，执行重试操作以重新触发补偿逻辑，或标记不再需要的补偿事件。
  • 接收通知： 接收执行失败通知，快速定位到异常，修复 BUG。
  • 修复 BUG： 当发生无法自动修复的异常时，开发者可以通过控制台快速定位到异常，修复 BUG，并重新发起重试。

控制台

事件补偿控制台的强大功能不仅包括分布式定时调度自动补偿，还搭载直观可视化的补偿事件管理功能、事件补偿通知（企业微信）以及 OpenAPI 接口。

通过分布式定时自动补偿，Wow 框架智能地解决了系统数据最终一致性的难题，摆脱了手动补偿的繁琐过程。 而可视化的补偿事件管理功能为开发者提供了巨大便利，轻松监控和处理补偿事件。

在控制台上，开发者能轻松进行特定状态的补偿事件查询，执行重试操作以重新触发补偿逻辑，或删除不再需要的补偿事件，提供了灵活而直观的操作手段。

这一设计不仅增强了系统的稳健性和可维护性，同时也让开发者更容易处理复杂的分布式事务流程，确保系统在异常情况下能够正确而可控地进行补偿操作。

事件补偿控制台 也是基于 Wow 框架设计开发的。可以作为 Wow 框架的参考实现来学习。

UI