在 Spring Boot 上运行

一个服务就是类路径上带有它的领域模块和 Wow 宿主的一个 Spring Boot 应用。宿主找到编译器生成的模型，打开存储，提供路由，运行订阅；应用不写任何装配代码。本页说明宿主装配了什么，以及应用在哪里接入。

应用

eShop 的 catalog 服务是它最小的服务：一个空的应用类。

kotlin

package me.ahoo.wow.example.eshop.catalog.server

import org.springframework.boot.autoconfigure.SpringBootApplication
import org.springframework.boot.runApplication

/**
 * The eShop's catalog service on the Wow host: the host finds the product model through `eshop-catalog-domain`'s binding
 * index and serves its routes on the public port and the cluster on the internal one. It runs on the memory backend.
 */
@SpringBootApplication(proxyBeanMethods = false)
class CatalogServer

fun main(args: Array<String>) {
    runApplication<CatalogServer>(*args)
}

它的构建依赖 catalog 的领域模块和宿主：

kotlin

dependencies {
    implementation(project(":eshop-catalog-domain"))
    implementation("me.ahoo.wow:wow-spring-boot")
    // Swagger UI over the service's routes (/swagger-ui.html): the host merges Wow's document into springdoc's.
    implementation("org.springdoc:springdoc-openapi-starter-webflux-ui")
    // A Bean Validation provider: the host checks each command's constraints with it.
    implementation("org.springframework.boot:spring-boot-starter-validation")
    // Actuator's health endpoint, which the host gives the node's readiness and liveness: the
    // deployment's probes read /actuator/health/readiness and /actuator/health/liveness.
    implementation("org.springframework.boot:spring-boot-health")
    implementation("org.springframework.boot:spring-boot-actuator-autoconfigure")
    // Traces and metrics on the node's seams, through the OpenTelemetry Java agent when the
    // deployment attaches one (deploy/eshop-*: the OpenTelemetry Operator's annotation), a no-op otherwise.
    implementation("me.ahoo.wow:wow-observability")
    // The `postgres` profile: the host runs on PostgreSQL when the application gives it a DataSource, and serves the
    // snapshot queries there, with the indexes the product's state declares.
    implementation("me.ahoo.wow:wow-postgres")
    // The pool the host makes of `spring.datasource.*` in the postgres profile.
    runtimeOnly("com.zaxxer:HikariCP")
    // The `mongo` profile: the host runs on MongoDB when the Mongo URI is set.
    implementation("me.ahoo.wow:wow-mongo")
    // The `search` profile, MongoDB with the products' search on Elasticsearch, over the client Spring Boot's
    // Elasticsearch support makes of `spring.elasticsearch.uris`.
    implementation("me.ahoo.wow:wow-elasticsearch")
    implementation("org.springframework.boot:spring-boot-elasticsearch")
    // The `cosec` profile, behind the CoSec gateway: CoSec's gateway mode reads the principal the gateway verified
    // from its CoSec-Identity header, and wow-cosec's resolver makes it the caller.
    implementation("me.ahoo.wow:wow-cosec")
    implementation(libs.cosec.spring.boot)
    implementation(libs.cosec.webflux)
    testImplementation("me.ahoo.wow:wow-test-spring-boot")
    // The springdoc bridge's acceptance: the document checked against the OpenAPI 3.1 schema.
    testImplementation(libs.json.schema.validator)
}

宿主是制品 me.ahoo.wow:wow-spring-boot，一个 WebFlux 应用。它和其他所有 Wow 模块的版本都来自 BOM me.ahoo.wow:wow-bom。

类路径决定什么

类路径上有某个模块时，宿主就装配对应的部分；这部分需要设置时，再看它自己的设置：

模块	增加
`wow-postgres`	PostgreSQL 后端，基于应用的 `DataSource`
`wow-mongo`	MongoDB 后端，基于应用的 `MongoClient`
`wow-kafka`	设置了 `wow.kafka.bootstrap-servers` 时的 Kafka 传输：上下文之间发布的事件流、命令和回执（Kafka）
`wow-clickhouse`	数仓 Sink 和数据集的查询
`wow-elasticsearch`	存储类型 `elasticsearch`，用于快照及其查询，以及为检索索引事件流的 Sink
`wow-observability`	节点工作的追踪和指标
`wow-cosec`	公开路由的 CoSec 认证与授权（保护部署）；在 10.0 中是实验性的，跟随 CoSec 8 的预发布版本
`wow-cosid`	CosId 的 ID 生成器
`wow-reactor`	返回 Reactor 的 `Mono` 和 `Flux` 的处理函数

类路径上有 Spring Boot Actuator 时，节点的健康状况会加入就绪和存活分组（部署模型）。

宿主装配什么

模型。 类路径上的每个领域模块都带有一个绑定索引。宿主加载每个模块的模型，用应用的 Bean 作为领域服务构建它们，并把各模块的 Manifest 片段合并成服务的 Manifest。wow.contexts.include 和 wow.contexts.exclude 选择节点提供哪些上下文；默认提供全部。
存储。 每个上下文的日志、快照和定时器，放在宿主选择的后端上（见下文）。
端口。 应用的 WebFlux 服务器上的公开路由，以及在它自己的服务器上的内部端口 wow.internal.port：集群通道、等待信号、服务之间的同步调用和读（部署模型）。
订阅。 绑定索引列出的每个处理器处理函数，以及类路径上各模块的 Sink。
生命周期。 节点在存储就绪、内部端口已绑定并加入了同伴之后启动，并按相反的顺序停止。

选择后端

配置中没有指明存储实例时，wow.backend 选择数据放在哪里：

`wow.backend`	节点
`auto`（默认）	应用有 `DataSource` 时用 PostgreSQL，有 `MongoClient` 时用 MongoDB：它自己的 Bean，或宿主用 `spring.datasource.url`、`spring.mongodb.uri` 建的那个。两者都有时拒绝启动，直到 `wow.backend` 指明其一
`postgres`、`mongo` 或社区存储提供者的类型	使用该后端；应用缺少它所需的东西时拒绝启动
`memory`	有意把一切放在内存里：一个节点，数据不会比它活得更久

在 auto 下两个 Bean 都没有时，节点拒绝启动，除非处于开发 profile（wow.dev-profiles），或者它的内部端口只绑定在回环网卡上；这时它在内存中运行并发出警告。生产节点绝不会意外地退回到内存。

聚合把数据放在不同存储里的服务，在 wow.stores.<name> 下命名存储实例（每个带它的 type，例如 postgres、mongo、elasticsearch 或 memory，以及它运行所基于的 Bean），并把每个聚合类型的日志和快照放到这些实例上：wow.log.store、wow.snapshot.stores，以及按类型的 wow.aggregates.[<context>.<aggregate>].log.store。布局示例见 PostgreSQL。query.events.store 指向 Elasticsearch 存储的类型，它的事件由宿主自行启动的 Sink 在那里建立索引（Elasticsearch）。选择存储说明了什么时候用哪种存储：默认用 MongoDB，在它旁边用 Elasticsearch 做检索副本。

wow.ddl 决定存储是创建它们的表、集合和索引（auto，默认），只检查它们（validate），还是两者都不做（none）。

应用提供的 Bean

应用定义了这些 Bean 时，宿主就从应用获取，否则退回到它自己的：

Bean	作用
领域服务	命令函数和处理器的参数，按类型获取，或用 `@Name` 按名字获取
`CallerResolver`	把已认证的主体变成调用方。没有它时，开发 profile 下宿主读取开发请求头，内部端口只在回环地址上时使用匿名调用方，其他情况下不启动
`CommandAuthorizer`	说明它是否反对调用方向某个聚合发送命令
`ReadAuthorizer`	说明它是否反对调用方读取某个模型：查询、状态读取或 trace，在读取任何东西之前询问（授权读取）
`CommandTransformer`、`CommandValidator`	在命令被决定之前改写或检查它
`GlobalIdGenerator`、`AggregateIdGenerator`	生成请求 ID 和聚合 ID；按类型由 `wow.aggregates.[<context>.<aggregate>].id-generator` 指定
`FailureClassifier`	为订阅处理函数的失败分类（失败与重试）
Bean Validation 实现（`spring-boot-starter-validation`）	在准入时检查每个命令体的 Jakarta 约束，回答 `wow.command.invalid`（400）（编写聚合）
`Observer`	观察节点的工作：各个阶段，以及它注意到的事，比如一次拒绝

这些钩子大多是列表：宿主取该类型的每个 Bean，按 Bean 的顺序（@Order、Ordered 或 @Priority，这是唯一的排序方式）。授权器、变换器、校验器、观察者、失败分类器，以及读取授权器、查询过滤器和查询观察者，都是这样的列表：

授权器全部询问。 只有每个 CommandAuthorizer 都允许，命令才被允许；按顺序第一个拒绝的就是答案，其余的不再询问。允许的意思是没有异议，而不是推翻其他授权器，也没有弃权：只管一类事的授权器（比如服务身份可以调用哪些命令，caller.service）对它管辖之外的命令一律允许。开启 wow.cosec.authorizer.enabled 后，CoSec 的授权器也是其中之一。一个授权器都没有时，命令被允许，但 Wow 内置聚合的系统命令（定时任务的命令和快照重建）除外，公开端口这时拒绝它们（授权命令）。
读取授权器全部询问，与命令授权器一样：只有每个 ReadAuthorizer 都允许，读取才被允许，按顺序第一个拒绝的作答。每个入口的每个调用方都会被询问：公开端口、对端的读取，以及以调用方身份读取的进程内代码；不带调用方读取的受信任进程内代码不被询问。
观察者全部通知。 每个 Observer 都按顺序看到每个阶段和事件。某个观察者失败时会被记录日志并在这次调用中跳过；它绝不会让命令失败，也不会妨碍其他观察者收到通知。

少数几个是单值接缝，节点只取一个 Bean：CallerResolver、GlobalIdGenerator、MaskStrategyResolver、DatasetVisibility、CommandCaller 和 QueryCountCache。同一个接缝有两个 Bean 时启动失败，并指出接缝和这两个 Bean。把节点应取的那个标为 @Primary：这是在多个之中选定一个的唯一方式。

配置会被检查

Spring 绑定它认识的键、忽略其余的键，所以拼错的键会悄悄什么都不做。宿主在启动时把环境中的每个 wow.* 键与类路径上的配置元数据比较：

未知的键会阻止启动，并指明它：写错的设置会保留默认值，而有些默认值允许一切。更早版本的键与其他未知键一样被拒绝，消息指向迁移指南的配置页，那里列出它今天的键；不在类路径上的模块的键（没有 wow-cosid 时的 wow.cosid.*）会给出那个模块。
在设置的映射之下，例如 wow.aggregates、wow.stores、wow.callers 和 wow.peers，每一项自己的键会一直检查到叶子。

Wow 分组下的环境变量（如 WOW_KAFKA_…）也按同样方式检查。所有的键见配置项。

运行

./gradlew bootRun 或应用的 main 函数会启动一个节点。没有 DataSource 或 MongoClient 时，数据保存在内存中，这只在开发 profile 或内部端口只绑定在回环网卡上时允许。没有 Kafka 时，只要它做的事都不需要主题，它在任何地方都能启动，并在启动时说明它不发布任何流；在开发中，它改为把主题保存在 JVM 里（服务什么时候需要 Kafka）。生产服务需要什么，见部署模型。

在 Spring Boot 上运行 ​

应用 ​

类路径决定什么 ​

宿主装配什么 ​

选择后端 ​

应用提供的 Bean ​

配置会被检查 ​

运行 ​