分割器

若要建立分割器,請使用 split() EIP 方法。預設情況下,如果 payload 是 IterableIteratorArrayStream 或反應式 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 的訊息。