分流器

要建立拆分器，請使用 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 的訊息。

另請參見 Lambdas 和 Message<?> 引數。