🎉 领域建模即微服务开发 | Wow 2.10.3 发布
基于 DDD、EventSourcing 的现代响应式 CQRS 架构微服务开发框架
领域驱动 | 事件驱动 | 测试驱动 | 声明式设计 | 响应式编程 | 命令查询职责分离 | 事件溯源
🎉 更新内容 🎉
事件补偿服务 支持 分布式定时调度
- 重构: 默认启用客户端事件补偿过滤器(
CompensationFilter
) - 特性: 支持客户端主动配置分布式重试(补偿)策略
- 特性: 新增修改重试策略命令(
ApplyRetrySpec
)API - 部署: 新增事件补偿服务端 Kubernetes 部署清单
- 文档: 新增事件补偿处理时序图
快速开始
使用 Wow 项目模板快速创建基于 Wow 框架的 DDD 项目。
特性概览
架构图
性能测试 (Example)
- 测试代码:Example
- 测试场景:加入购物车、下单
- 命令发送等待模式(
WaitStrategy
):SENT
、PROCESSED
部署
测试报告
加入购物车
命令等待策略(
WaitStrategy
)为SENT
模式,加入购物车命令(AddCartItem
)写请求 API 经过 2 分钟的压测,平均 TPS 为 59625,峰值为 82312,平均响应时间为 29 毫秒。
命令等待策略(
WaitStrategy
)为PROCESSED
模式,加入购物车命令(AddCartItem
)写请求 API 经过 2 分钟的压测,平均 TPS 为 18696,峰值为 24141,平均响应时间为 239 毫秒。
下单
命令等待策略(
WaitStrategy
)为SENT
模式,下单命令(CreateOrder
)写请求 API 经过 2 分钟的压测,平均 TPS 为 47838,峰值为 86200,平均响应时间为 217 毫秒。
命令等待策略(
WaitStrategy
)为PROCESSED
模式,下单命令(CreateOrder
)写请求 API 经过 2 分钟的压测,平均 TPS 为 180230,峰值为 25506,平均响应时间为 268 毫秒。
事件源
可观测性
OpenAPI (Spring WebFlux 集成)
自动注册 命令 路由处理函数 (
HandlerFunction
) ,开发人员仅需编写领域模型,即可完成服务开发。
测试套件:80%+ 的测试覆盖率轻而易举
Given -> When -> Expect .
前置条件
- 理解 领域驱动设计:《实现领域驱动设计》、《领域驱动设计:软件核心复杂性应对之道》
- 理解 命令查询职责分离(CQRS)
- 理解 事件源架构
- 理解 响应式编程
Example
订单服务(Kotlin)
银行转账(JAVA)
单元测试套件
80%+ 的测试覆盖率轻而易举。
Given -> When -> Expect .
Aggregate Unit Test (AggregateVerifier
)
internal class OrderTest { @Test private fun createOrder() { val tenantId = GlobalIdGenerator.generateAsString() val customerId = GlobalIdGenerator.generateAsString() val orderItem = OrderItem( GlobalIdGenerator.generateAsString(), GlobalIdGenerator.generateAsString(), BigDecimal.valueOf(10), 10, ) val orderItems = listOf(orderItem) val inventoryService = object : InventoryService { override fun getInventory(productId: String): Mono<Int> { return orderItems.filter { it.productId == productId }.map { it.quantity }.first().toMono() } } val pricingService = object : PricingService { override fun getProductPrice(productId: String): Mono<BigDecimal> { return orderItems.filter { it.productId == productId }.map { it.price }.first().toMono() } } aggregateVerifier<Order, OrderState>(tenantId = tenantId) .inject(DefaultCreateOrderSpec(inventoryService, pricingService)) .given() .`when`(CreateOrder(customerId, orderItems, SHIPPING_ADDRESS, false)) .expectEventCount(1) .expectEventType(OrderCreated::class.java) .expectStateAggregate { assertThat(it.aggregateId.tenantId, equalTo(tenantId)) } .expectState { assertThat(it.id, notNullValue()) assertThat(it.customerId, equalTo(customerId)) assertThat(it.address, equalTo(SHIPPING_ADDRESS)) assertThat(it.items, equalTo(orderItems)) assertThat(it.status, equalTo(OrderStatus.CREATED)) } .verify() } @Test fun createOrderGivenEmptyItems() { val customerId = GlobalIdGenerator.generateAsString() aggregateVerifier<Order, OrderState>() .inject(mockk<CreateOrderSpec>(), "createOrderSpec") .given() .`when`(CreateOrder(customerId, listOf(), SHIPPING_ADDRESS, false)) .expectErrorType(IllegalArgumentException::class.java) .expectStateAggregate { /* * 该聚合对象处于未初始化状态,即该聚合未创建成功. */ assertThat(it.initialized, equalTo(false)) }.verify() } /** * 创建订单-库存不足 */ @Test fun createOrderWhenInventoryShortage() { val customerId = GlobalIdGenerator.generateAsString() val orderItem = OrderItem( GlobalIdGenerator.generateAsString(), GlobalIdGenerator.generateAsString(), BigDecimal.valueOf(10), 10, ) val orderItems = listOf(orderItem) val inventoryService = object : InventoryService { override fun getInventory(productId: String): Mono<Int> { return orderItems.filter { it.productId == productId } /* * 模拟库存不足 */ .map { it.quantity - 1 }.first().toMono() } } val pricingService = object : PricingService { override fun getProductPrice(productId: String): Mono<BigDecimal> { return orderItems.filter { it.productId == productId }.map { it.price }.first().toMono() } } aggregateVerifier<Order, OrderState>() .inject(DefaultCreateOrderSpec(inventoryService, pricingService)) .given() .`when`(CreateOrder(customerId, orderItems, SHIPPING_ADDRESS, false)) /* * 期望:库存不足异常. */ .expectErrorType(InventoryShortageException::class.java) .expectStateAggregate { /* * 该聚合对象处于未初始化状态,即该聚合未创建成功. */ assertThat(it.initialized, equalTo(false)) }.verify() } }
Saga Unit Test (SagaVerifier
)
class CartSagaTest { @Test fun onOrderCreated() { val orderItem = OrderItem( GlobalIdGenerator.generateAsString(), GlobalIdGenerator.generateAsString(), BigDecimal.valueOf(10), 10, ) sagaVerifier<CartSaga>() .`when`( mockk<OrderCreated> { every { customerId } returns "customerId" every { items } returns listOf(orderItem) every { fromCart } returns true }, ) .expectCommandBody<RemoveCartItem> { assertThat(it.id, equalTo("customerId")) assertThat(it.productIds, hasSize(1)) assertThat(it.productIds.first(), equalTo(orderItem.productId)) } .verify() } }
设计
聚合建模
Single Class | Inheritance Pattern | Aggregation Pattern |
---|---|---|
加载聚合
聚合状态流
发送命令
命令与事件流
Saga - OrderProcessManager (Demo)

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
【店滴云】继无人茶室代码开源后,快速开发后台也开源
【店滴云】继无人茶室代码开源后,快速开发后台也开源 快速开发后台可以做到的能力: 1、一句话后台表单,满足各种输入场景,数据联动,数据渲染 2、后台检索组件一句话配置 3、后台列表渲染,兼容手机与电脑,分别采用不同渲染,支持无限极分类渲染 4、支持多商户,多层级代理 5、支持不同客户端配置,包含小程序,app,公众号等 6、模块化结构,方便快速开发 7、页面路由,按钮,菜单级别的权限控制 8、后台代码可生成,接口标准化
- 下一篇
AiEditor rc.1 发布,一个面向 AI 的下一代富文本编辑器
AiEditor 关于 AiEditor(官网https://aieditor.dev) AiEditor 是一个面向 AI 的下一代富文本编辑器,她基于 Web Component,因此支持 Layui、Vue、React、Angular 等几乎任何前端框架。她适配了 PC Web 端和手机端,并提供了 亮色 和 暗色 两个主题。除此之外,她还提供了灵活的配置,开发者可以方便的使用其开发任何文字编辑的应用。 在这个的版本中,我们添加了选择文字,弹出 AI 菜单并可以自定义 AI 指令的功能,如下图所示: 在之前的版本中,我们已经完善了:AI 翻译、AI 续写、AI 校正(发现错别字)、AI 菜单、AI 命令等功能,欢迎体验:http://aieditor1.jpress.cn。 v1.0.0-rc.1 更新细节: 新增:AI 功能添加选择文字时,对文字进行在定义 Prompt 操作的功能 新增:添加选中文字内容时,弹出操作菜单的功能 新增:AiEditor 添加 onCreateBefore 的钩子函数,方便初始化插件 修复:同一个页面下,初始化多个 editor 实例时出错的问题...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- CentOS8安装MyCat,轻松搞定数据库的读写分离、垂直分库、水平分库
- Red5直播服务器,属于Java语言的直播服务器
- Eclipse初始化配置,告别卡顿、闪退、编译时间过长
- SpringBoot2全家桶,快速入门学习开发网站教程
- CentOS7设置SWAP分区,小内存服务器的救世主
- CentOS7安装Docker,走上虚拟化容器引擎之路
- CentOS7编译安装Cmake3.16.3,解决mysql等软件编译问题
- Docker快速安装Oracle11G,搭建oracle11g学习环境
- CentOS8安装Docker,最新的服务器搭配容器使用
- SpringBoot2初体验,简单认识spring boot2并且搭建基础工程