春季集成 - 如何使用kotlin DSL根据标头值路由

Question

假设我有一个标题，上面有一个名为“计数”的属性，我该如何根据该值路由？

在Kotlin DSL中有路由函数，但是我不确定如何将其配置为HeaderValuerouter

文档对Java DSL说了以下内容，但是我不清楚我如何如何可以握住路由器块中的标题。

有人有例子（Kotlin和Java DSL）吗？

春季集成本地提供专业路由器类型， 包括：

headervaluerouter

PayloadTyperouter

异常

coverentlistrouter

xpathrouter

与许多其他DSL IntegrationFlowBuilder EIP方法一样，路由（） 方法可以应用任何AbstractMessagerouter实现或用于 便利性，作为Spel表达式的弦或Ref方法对。在 此外，您可以使用lambda配置Route（），然后使用lambda 消费者＆lt; Routerspec＆gt;。

Answer 1

这是一个单元测试，演示了Kotlin DSL的可能性：

@SpringJUnitConfig
@DirtiesContext
class RouterDslTests {

    @Autowired
    @Qualifier("routeByHeader.input")
    private lateinit var routeByHeaderInputChannel: MessageChannel

    @Autowired
    private lateinit var fooChannel: PollableChannel

    @Autowired
    private lateinit var barChannel: PollableChannel

    @Test
    fun `route by header`() {
        var message = MessageBuilder.withPayload("test1")
            .setHeader("my_route", "foo")
            .build()

        this.routeByHeaderInputChannel.send(message)

        var receive = this.fooChannel.receive(10_000)
        var payload = receive?.payload
        assertThat(payload)
            .isNotNull()
            .isEqualTo("test1")

        message = MessageBuilder.withPayload("test2")
            .setHeader("my_route", "bar")
            .build()

        this.routeByHeaderInputChannel.send(message)

        receive = this.barChannel.receive(10_000)
        payload = receive?.payload
        assertThat(payload)
            .isNotNull()
            .isEqualTo("test2")
    }

    @Configuration
    @EnableIntegration
    class Config {

        @Bean
        fun routeByHeader() =
            integrationFlow {
                route<Message<*>, String>({ it.headers["my_route"].toString() }) {
                    suffix("Channel")
                }
            }

        @Bean
        fun fooChannel() = QueueChannel()

        @Bean
        fun barChannel() = QueueChannel()
    }

}

您只需要执行route（）函数来处理整个message> Message作为输入。然后，您可以在Lambda中访问其标题。

这可能无法在Kotlin DSL文档中解释，但这是Java DSL中的内容： https://docs.spring.io/spring-integration/docs/current/current/reference/reference/html/html.html.html#java-dsl-w.jjava-dsl-class-class-class-class-cast-cast-cast-cast-cast