分配器
要创建拆分器,请使用split()
弹性公网 IP 方法。
默认情况下,如果有效负载是Iterable
一Iterator
一Array
一个Stream
或反应式Publisher
这split()
方法将每个项目输出为单独的消息。
它接受 lambda、spEL 表达式或任何AbstractMessageSplitter
实现。
或者,您也可以在不带参数的情况下使用它来提供DefaultMessageSplitter
.
以下示例演示如何使用splitWith()
方法:
@Bean
public IntegrationFlow splitFlow() {
return IntegrationFlow.from("splitInput")
.splitWith(s -> s.applySequence(false).delimiters(","))
.channel(MessageChannels.executor(taskExecutor()))
.get();
}
前面的示例创建一个拆分器,该拆分器将包含逗号分隔的消息String
.
另请参阅lambda 和Message<?>
参数.