分配器

要创建拆分器,请使用split()弹性公网 IP 方法。 默认情况下,如果有效负载是IterableIteratorArray一个Stream或反应式Publishersplit()方法将每个项目输出为单独的消息。 它接受 lambda、spEL 表达式或任何AbstractMessageSplitter实现。 或者,您也可以在不带参数的情况下使用它来提供DefaultMessageSplitter. 以下示例演示如何使用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();
}

前面的示例创建一个拆分器,该拆分器将包含逗号分隔的消息String.spring-doc.cadn.net.cn