|
此版本仍在开发中，尚不被认为是稳定的。对于最新的稳定版本，请使用 Spring Integration 6.5.1！ |
分配器
要创建拆分器，请使用split()EIP 方法。
默认情况下，如果有效负载是Iterable一Iterator一Array一个Stream，或响应式Publisher这split()方法将每个项目输出为单独的消息。
它接受 lambda、SpEL 表达式或任何AbstractMessageSplitter实现。
或者，您可以在不带参数的情况下使用它来提供DefaultMessageSplitter.
以下示例演示如何使用splitWith()方法，提供 lambda：
@Bean
public IntegrationFlow splitFlow() {
return IntegrationFlow.from("splitInput")
.splitWith(s -> s.applySequence(false).delimiters(","))
.channel(MessageChannels.executor(taskExecutor()))
.get();
}前面的示例创建了一个拆分器，用于拆分包含逗号分隔的消息String.
另请参阅lambda 和Message<?>参数.