分隔器

要创建分割器，请使用split() EIP 方法。默认情况下，如果负载是Iterable、Iterator、Array、Stream或反应式Publisher，则split()方法会将每个项目作为单个消息输出。它接受 lambda、SpEL 表达式或任何AbstractMessageSplitter实现。或者，您也可以在不带参数的情况下使用它来提供DefaultMessageSplitter。以下示例演示了如何通过提供 lambda 来使用splitWith()方法

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

前面的示例创建了一个分割器，该分割器分割包含逗号分隔的String的消息。

另请参见 Lambda 和Message<?> 参数。