分發器

要建立分發器，請使用 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<?> 引數。