对于最新稳定版本,请使用 Spring Integration 7.0.0spring-doc.cadn.net.cn

分配器

要创建分线器,可以使用分裂()EIP方法。 默认情况下,如果有效载荷是可迭代迭 代数组一个或者说是响应式发行人分裂()方法将每个项目输出为单独的消息。 它接受 lambda、SpEL 表达式或任意摘要消息分流器实现。 或者,你也可以用它来不带参数,提供默认消息分裂器. 以下示例展示了如何使用splitWith()通过提供一个λ来实现方法:spring-doc.cadn.net.cn

@Bean
public IntegrationFlow splitFlow() {
    return IntegrationFlow.from("splitInput")
              .splitWith(s -> s.applySequence(false).delimiters(","))
              .channel(MessageChannels.executor(taskExecutor()))
              .get();
}

前面的例子创建了一个分线器,用于拆分包含逗号分隔的消息字符串.spring-doc.cadn.net.cn