分割器
若要建立分割器,請使用 split()
EIP 方法。預設情況下,如果 payload 是 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<?>
引數。