|
对于最新稳定版本,请使用 Spring Integration 7.0.0! |
分配器
要创建分线器,可以使用分裂()EIP方法。
默认情况下,如果有效载荷是可迭代一迭 代一数组一个流或者说是响应式发行人这分裂()方法将每个项目输出为单独的消息。
它接受 lambda、SpEL 表达式或任意摘要消息分流器实现。
或者,你也可以用它来不带参数,提供默认消息分裂器.
以下示例展示了如何使用splitWith()通过提供一个λ来实现方法:
@Bean
public IntegrationFlow splitFlow() {
return IntegrationFlow.from("splitInput")
.splitWith(s -> s.applySequence(false).delimiters(","))
.channel(MessageChannels.executor(taskExecutor()))
.get();
}
前面的例子创建了一个分线器,用于拆分包含逗号分隔的消息字符串.