对于最新的稳定版本，请使用 Spring Integration 6.4.0！spring-doc.cn

Kotlin DSL

Kotlin DSL 是 Java DSL 的包装器和扩展，旨在通过与现有 Java API 和 Kotlin 语言特定结构的互操作性，使 Kotlin 上的 Spring 集成开发尽可能流畅和直接。spring-doc.cn

您只需导入 - Kotlin DSL 的重载全局函数即可开始使用。org.springframework.integration.dsl.integrationFlowspring-doc.cn

对于作为 lambda 的定义，我们通常不需要 Kotlin 中提供任何其他内容，只需声明一个 bean，如下所示：IntegrationFlowspring-doc.cn

@Bean
fun oddFlow() =
IntegrationFlow { flow ->
    flow.handle<Any> { _, _ -> "odd" }
}

在这种情况下，Kotlin 知道 lambda 应该转换为匿名实例，并且目标 Java DSL 处理器会将此结构正确解析为 Java 对象。IntegrationFlowspring-doc.cn

作为上述结构的替代方案，并且为了与下面解释的用例保持一致，应使用特定于 Kotlin 的 DSL 来声明构建器模式样式中的集成流：spring-doc.cn

@Bean
fun flowLambda() =
    integrationFlow {
        filter<String> { it === "test" }
        wireTap {
                    handle { println(it.payload) }
                }
        transform<String> { it.toUpperCase() }
    }

此类全局函数需要 a 的生成器样式的 lambda（用于的 Kotlin 包装器），并生成常规 lambda 实现。请参阅下面的更多重载变体。integrationFlow()KotlinIntegrationFlowDefinitionIntegrationFlowDefinitionIntegrationFlowintegrationFlow()spring-doc.cn

许多其他场景需要从数据源开始（例如，或只是现有的）。为此，Spring 集成 Java DSL 提供了一个 Fluent API 及其大量重载方法。此 API 也可以在 Kotlin 中使用：IntegrationFlowJdbcPollingChannelAdapterJmsInboundGatewayMessageChannelIntegrationFlowfrom()spring-doc.cn

@Bean
fun flowFromSupplier() =
         IntegrationFlow.fromSupplier({ "bar" }) { e -> e.poller { p -> p.fixedDelay(10).maxMessagesPerPoll(1) } }
                 .channel { c -> c.queue("fromSupplierQueue") }
                 .get()

但遗憾的是，并非所有方法都与 Kotlin 结构兼容。为了弥补这一差距，该项目围绕 Fluent API 提供了一个 Kotlin DSL。它作为一组重载函数实现。使用使用者论坛将流的其余部分声明为 lambda，以重用上述体验，并避免最后调用例如：from()IntegrationFlowintegrationFlow()KotlinIntegrationFlowDefinitionIntegrationFlowget()spring-doc.cn

@Bean
fun functionFlow() =
        integrationFlow<Function<String, String>>({ beanName("functionGateway") }) {
            transform<String> { it.toUpperCase() }
        }

@Bean
fun messageSourceFlow() =
        integrationFlow(MessageProcessorMessageSource { "testSource" },
                { poller { it.fixedDelay(10).maxMessagesPerPoll(1) } }) {
            channel { queue("fromSupplierQueue") }
        }

此外，还为 Java DSL API 提供了 Kotlin 扩展，该 API 需要对 Kotlin 结构进行一些改进。例如，需要对许多方法进行 reifying with argument：IntegrationFlowDefinition<*>Class<P>spring-doc.cn

@Bean
fun convertFlow() =
    integrationFlow("convertFlowInput") {
        convert<TestPojo>()
    }

如果需要访问 Headers 以及运算符的 lambda 中，则 reified 类型可以是一个整体。Message<*>