|
此版本仍在开发中，尚不被认为是稳定的。对于最新的稳定版本，请使用 Spring Integration 6.5.1！ |
java.util.function接口支持
从版本 5.1 开始，Spring Integration 为java.util.function包。
所有消息传递端点（Service Activator、Transformer、Filter 等）现在都可以引用Function（或Consumer）豆子。
消息传递注释可以直接应用于这些 bean，类似于常规MessageHandler定义。
例如，如果你有这个Function豆子定义：
@Configuration
public class FunctionConfiguration {
@Bean
public Function<String, String> functionAsService() {
return String::toUpperCase;
}
}您可以将其用作 XML 配置文件中的简单引用：
<service-activator input-channel="processorViaFunctionChannel" ref="functionAsService"/>当我们使用消息传递注释配置流时，代码很简单：
@Bean
@Transformer(inputChannel = "functionServiceChannel")
public Function<String, String> functionAsService() {
return String::toUpperCase;
}当函数返回数组时，Collection（本质上，任何Iterable),Stream或反应堆Flux,@Splitter可以在这样的 bean 上用于对结果内容执行迭代。
这java.util.function.Consumer接口可用于<int:outbound-channel-adapter>或者，与@ServiceActivator注释，以执行流的最后一步：
@Bean
@ServiceActivator(inputChannel = "messageConsumerServiceChannel")
public Consumer<Message<?>> messageConsumerAsService() {
// Has to be an anonymous class for proper type inference
return new Consumer<Message<?>>() {
@Override
public void accept(Message<?> e) {
collector().add(e);
}
};
}另外，请注意上面代码片段中的注释：如果您想处理整个消息Function/Consumer不能使用 lambda 定义。
由于 Java 类型擦除，我们无法确定apply()/accept()方法调用。
这java.util.function.Supplier接口可以简单地与@InboundChannelAdapter注释，或作为ref在<int:inbound-channel-adapter>:
@Bean
@InboundChannelAdapter(value = "inputChannel", poller = @Poller(fixedDelay = "1000"))
public Supplier<String> pojoSupplier() {
return () -> "foo";
}对于 Java DSL，我们只需要在端点定义中使用对函数 bean 的引用。
同时，实现Supplier接口可以作为常规使用MessageSource定义：
@Bean
public Function<String, String> toUpperCaseFunction() {
return String::toUpperCase;
}
@Bean
public Supplier<String> stringSupplier() {
return () -> "foo";
}
@Bean
public IntegrationFlow supplierFlow() {
return IntegrationFlow.from(stringSupplier())
.transform(toUpperCaseFunction())
.channel("suppliedChannel")
.get();
}当与 Spring Cloud Function 框架一起使用时，此函数支持非常有用，其中我们有一个函数目录，可以从集成流定义中引用其成员函数。
此外，许多 Spring Integration 通道适配器和模式在 Spring Functions Catalog 项目中作为函数自动配置实现。