核心配置

WowProperties

• 配置类：WowProperties
• 前缀：wow

名称	数据类型	描述	默认值
enabled	Boolean	启用/禁用 Wow 框架	true
context-name	String	服务的限界上下文名称	${spring.application.name}
shutdown-timeout	Duration	优雅停机超时时间	60s

wow:
  enabled: true
  context-name: order-service
  shutdown-timeout: 120s

BusProperties

BusProperties 是 CommandBus、EventBus 和 StateEventBus 的公共配置。

• 配置类：BusProperties

名称	数据类型	描述	默认值
type	BusType	消息总线实现类型	kafka
local-first	LocalFirstProperties	LocalFirst 模式配置

BusType

enum class BusType {
    KAFKA,      // Apache Kafka（生产环境推荐）
    REDIS,      // Redis Streams
    IN_MEMORY,  // 内存模式（用于测试）
    NO_OP;      // 无操作模式（用于特殊场景）
}

LocalFirst 模式

LocalFirst 模式通过优先在本地消费消息而非通过分布式消息总线来优化命令和事件处理：

优势

1. 降低延迟：本地消息处理避免了网络往返
2. 更好的资源利用率：在分发到分布式总线之前最大化本地处理
3. 容错能力：失败的本地消息通过分布式总线重试

名称	数据类型	描述	默认值
local-first.enabled	Boolean	启用 LocalFirst 模式	true

命令总线

• 配置类：CommandProperties
• 前缀：wow.command.

名称	数据类型	描述	默认值
bus	BusProperties	命令总线配置
idempotency	IdempotencyProperties	命令幂等性

wow:
  command:
    bus:
      type: kafka
      local-first:
        enabled: true
    idempotency:
      enabled: true
      bloom-filter:
        expected-insertions: 1000000
        ttl: PT60S
        fpp: 0.00001

IdempotencyProperties

• 配置类：IdempotencyProperties

名称	数据类型	描述	默认值
enabled	boolean	是否启用	true
bloom-filter	BloomFilter	布隆过滤器

BloomFilter

名称	数据类型	描述	默认值
ttl	Duration	存活时间	Duration.ofMinutes(1)
expected-insertions	Long	预期插入数量	1000_000
fpp	Double	误判率	0.00001

事件总线

• 配置类：EventProperties
• 前缀：wow.event.

名称	数据类型	描述	默认值
bus	BusProperties	事件总线配置

wow:
  event:
    bus:
      type: kafka
      local-first:
        enabled: true

事件溯源

EventStoreProperties

• 配置类：EventStoreProperties
• 前缀：wow.eventsourcing.store

名称	数据类型	描述	默认值
storage	EventStoreStorage	事件存储后端	mongo

wow:
  eventsourcing:
    store:
      storage: mongo

EventStoreStorage

enum class EventStoreStorage {
    MONGO,
    REDIS,
    R2DBC,
    IN_MEMORY,
    DELAY
    ;
}

SnapshotProperties

• 配置类：SnapshotProperties
• 前缀：wow.eventsourcing.snapshot

名称	数据类型	描述	默认值
enabled	Boolean	是否启用快照	true
strategy	Strategy	快照策略	all
version-offset	Int	版本偏移阈值	5
storage	SnapshotStorage	快照存储后端	mongo

wow:
  eventsourcing:
    snapshot:
      enabled: true
      strategy: version_offset
      version-offset: 10
      storage: mongo

Strategy

enum class Strategy {
    ALL,
    VERSION_OFFSET,
    ;
}

SnapshotStorage

enum class SnapshotStorage {
    MONGO,
    REDIS,
    R2DBC,
    ELASTICSEARCH,
    IN_MEMORY,
    DELAY
    ;
}

状态事件总线

• 配置类：StateProperties
• 前缀：wow.eventsourcing.state

名称	数据类型	描述	默认值
bus	BusProperties	状态事件总线配置

wow:
  eventsourcing:
    state:
      bus:
        type: kafka
        local-first:
          enabled: true

Prepare Key

• 前缀：wow.prepare

名称	数据类型	描述	默认值
enabled	Boolean	启用 PrepareKey 功能	true
storage	PrepareStorage	PrepareKey 存储后端	MONGO
base-packages	List<String>	扫描 PrepareKey 定义的基础包路径	[]

PrepareStorage 值

值	描述
MONGO	MongoDB（推荐）
REDIS	Redis

wow:
  prepare:
    enabled: true
    storage: mongo
    base-packages:
      - com.example.domain

环境特定配置

开发环境

wow:
  command:
    bus:
      type: in_memory
  event:
    bus:
      type: in_memory
  eventsourcing:
    store:
      storage: in_memory
    snapshot:
      storage: in_memory

生产环境

wow:
  command:
    bus:
      type: kafka
      local-first:
        enabled: true
  event:
    bus:
      type: kafka
      local-first:
        enabled: true
  eventsourcing:
    store:
      storage: mongo
    snapshot:
      enabled: true
      strategy: version_offset
      version-offset: 10
      storage: mongo

完整配置示例

spring:
  application:
    name: order-service

wow:
  enabled: true
  context-name: order-service
  shutdown-timeout: 120s

  command:
    bus:
      type: kafka
      local-first:
        enabled: true

  event:
    bus:
      type: kafka
      local-first:
        enabled: true

  eventsourcing:
    store:
      storage: mongo
    snapshot:
      enabled: true
      strategy: version_offset
      version-offset: 10
      storage: mongo
    state:
      bus:
        type: kafka
        local-first:
          enabled: true

  kafka:
    bootstrap-servers:
      - kafka-0:9092
      - kafka-1:9092
      - kafka-2:9092
    topic-prefix: 'wow.'

  mongo:
    enabled: true
    auto-init-schema: true

  openapi:
    enabled: true

  webflux:
    enabled: true
    global-error:
      enabled: true