事件补偿配置

补偿配置分为两层：

• Starter 级（wow-spring-boot-starter）—— 单个 wow.compensation.enabled 开关。
• 服务端级（wow-compensation-server）—— 重试策略、调度器和 Webhook 投递。

Starter 级

属性	类型	默认值	说明
wow.compensation.enabled	Boolean	true	启用事件补偿功能

wow:
  compensation:
    enabled: true

启用后，EventCompensationFilter 会自动注册到每个事件分发器 （DomainEventDispatcher、StatelessSagaDispatcher、ProjectionDispatcher、SnapshotDispatcher）。 任何抛出异常的处理器都会被捕获，并发送 CreateExecutionFailed 命令记录失败。每个处理器上的 @Retry 注解控制逐函数的重试行为：

@ProjectionProcessor
class OrderProjection {
    // 此处理器使用默认重试规格（maxRetries=10, minBackoff=180s, executionTimeout=120s）
    @OnEvent
    fun onOrderCreated(event: OrderCreated): Mono<Void> { ... }

    // 为调用不稳定外部 API 的处理器自定义重试
    @Retry(maxRetries = 3, minBackoff = 60, executionTimeout = 10)
    @OnEvent
    fun onOrderPaid(event: OrderPaid): Mono<Void> { ... }

    // 完全退出此处理器的补偿
    @Retry(enabled = false)
    @OnEvent
    fun onOrderShipped(event: OrderShipped): Mono<Void> { ... }
}

设置 wow.compensation.enabled=false 可全局禁用本服务所有处理器的补偿过滤器。 即使全局启用了补偿，个别处理器仍可通过 @Retry(enabled = false) 退出。

服务端级

以下属性用于配置独立的补偿服务端（wow-compensation-server）。

重试策略

属性	类型	默认值	说明
wow.compensation.host	String	（空）	补偿服务端的宿主地址
wow.compensation.max-retries	Integer	10	失败执行的最大重试次数
wow.compensation.min-backoff	Integer	180	重试之间的最小退避时间（秒）
wow.compensation.execution-timeout	Integer	120	单次执行超时时间（秒）

wow:
  compensation:
    host: http://compensation-service
    max-retries: 10
    min-backoff: 180
    execution-timeout: 120

调度器

属性	类型	默认值	说明
wow.compensation.scheduler.enabled	Boolean	true	启用定时重试执行循环
wow.compensation.scheduler.mutex	String	compensation_mutex	守护单实例调度的分布式锁 Key
wow.compensation.scheduler.batch-size	Integer	100	每个调度周期处理的失败执行数量
wow.compensation.scheduler.initial-delay	Duration	PT60S（60 秒）	首次调度前的延迟
wow.compensation.scheduler.period	Duration	PT60S（60 秒）	调度周期之间的间隔

wow:
  compensation:
    scheduler:
      enabled: true
      mutex: compensation_mutex
      batch-size: 100
      initial-delay: PT60S
      period: PT60S

企业微信 Webhook（可选）

将补偿事件投递到企业微信群机器人。

属性	类型	默认值	说明
wow.compensation.webhook.weixin.url	String	（必填）	企业微信群机器人 Webhook URL
wow.compensation.webhook.weixin.events	Set<HookEvent>	execution_failed_created、execution_failed_applied、execution_success_applied、recoverable_marked	触发通知的 Hook 事件。可选值：execution_failed_created、execution_failed_applied、execution_success_applied、compensation_prepared、recoverable_marked

wow:
  compensation:
    webhook:
      weixin:
        url: https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=YOUR_KEY
        events:
          - execution_failed_created
          - execution_failed_applied
          - execution_success_applied
          - recoverable_marked