Groovy DSL
Groovy DSL 是对 Java DSL 的封装和扩展。我们的主要目标是使 Groovy 上的 Spring Integration 开发尽可能平滑和直接,并能与现有 Java DSL 以及一些 Groovy 扩展或语言特定结构进行互操作。此实现是 Groovy 支持 模块的一部分。
要开始使用,您只需要导入 import static org.springframework.integration.groovy.dsl.IntegrationGroovyDsl.integrationFlow
- 这是一个包含 Groovy DSL 的重载工厂方法的类。
对于将 IntegrationFlow
定义为 lambda 表达式,我们通常不需要 Groovy 的其他任何东西,只需像这样声明一个 bean:
@Bean
IntegrationFlow oddFlow() {
{ IntegrationFlowDefinition flow ->
flow.handle(Object, { p, h -> 'odd' })
}
}
在这种情况下,Groovy 会理解闭包应转换为一个 IntegrationFlow
匿名实例,并且目标 Java DSL 处理器会正确地将此结构解析为 Java 对象。
作为上述结构的替代方案,并为了与下文解释的用例保持一致,spring-integration-groovy
模块提供了一个 Groovy 特定的 DSL,用于以 构建器 模式风格声明集成流
@Bean
flowLambda() {
integrationFlow {
filter String, { it == 'test' }, { id 'filterEndpoint' }
wireTap integrationFlow {
channel { queue 'wireTapChannel' }
}
delay {
messageGroupId 'delayGroup'
defaultDelay 100
}
transform {
transformer { it.toUpperCase() }
expectedType String
}
}
}
这种全局 integrationFlow()
函数期望一个 GroovyIntegrationFlowDefinition
(是 IntegrationFlowDefinition
的 Groovy 封装器) 的构建器风格的闭包,并生成一个常规的 IntegrationFlow
lambda 实现。请参阅下面的更多重载 integrationFlow()
变体。
许多其他场景需要从数据源(例如 JdbcPollingChannelAdapter
、JmsInboundGateway
或只是一个现有的 MessageChannel
)启动一个 IntegrationFlow
。为此,Spring Integration Java DSL 提供了一个 IntegrationFlow
工厂,其中包含多个重载的 from()
方法。这个工厂也可以在 groovy 中使用
@Bean
flowFromSupplier() {
IntegrationFlow.fromSupplier({ 'bar' }) { e -> e.poller { p -> p.fixedDelay(10).maxMessagesPerPoll(1) } }
.channel({ c -> c.queue('fromSupplierQueue') } as Function)
.get()
}
但遗憾的是,并非所有 from()
方法都与 Groovy 结构兼容。为了解决这个问题,Spring Integration 在 IntegrationFlow
工厂的基础上提供了一个 Groovy DSL 工厂。它实现为一组重载的 integrationFlow()
函数。通过一个 GroovyIntegrationFlowDefinition
的消费者来声明流的其余部分作为 IntegrationFlow
闭包,以重用上述经验,并避免最终需要调用 get()
。例如
@Bean
functionFlow() {
integrationFlow Function<byte[], String>,
{ beanName 'functionGateway' },
{
transform {
transformer Transformers.objectToString()
id 'objectToStringTransformer'
}
transform {
transformer { it.toUpperCase() }
expectedType String
}
splitWith {
expectedType Message<?>
function { it.payload }
}
splitWith {
expectedType Object
id 'splitterEndpoint'
function { it }
}
resequence()
aggregate {
id 'aggregator'
outputProcessor { it.one }
}
}
}
@Bean
someFlow() {
integrationFlow ({ 'test' },
{
poller { it.trigger new OnlyOnceTrigger() }
id 'pollingSource'
})
{
log LoggingHandler.Level.WARN, 'test.category'
channel { queue 'pollerResultChannel' }
}
}