服务激活器(Service Activators)与 .handle()
方法
.handle()
EIP 方法的目标是调用任何 MessageHandler
实现或 POJO 上的任何方法。另一个选项是使用 lambda 表达式定义一个“活动”。因此,我们引入了一个泛型函数式接口 GenericHandler<P>
。它的 handle
方法需要两个参数:P payload
和 MessageHeaders headers
(从版本 5.1 开始)。有了它,我们可以按如下方式定义一个流:
@Bean
public IntegrationFlow myFlow() {
return IntegrationFlow.from("flow3Input")
.<Integer>handle((p, h) -> p * 2)
.get();
}
上面的例子会将接收到的任何整数加倍。
然而,Spring Integration 的一个主要目标是实现松耦合
,通过运行时类型转换将消息 payload 转换为消息处理器的目标参数。由于 Java 不支持 lambda 类的泛型类型解析,我们引入了一个变通方法,为大多数 EIP 方法和 LambdaMessageProcessor
添加了一个额外的 payloadType
参数。这样做将繁重的转换工作委托给了 Spring 的 ConversionService
,后者使用提供的 type
和请求的消息来处理目标方法参数。下面的示例展示了结果 IntegrationFlow
可能的样子:
@Bean
public IntegrationFlow integerFlow() {
return IntegrationFlow.from("input")
.<byte[], String>transform(p - > new String(p, "UTF-8"))
.handle(Integer.class, (p, h) -> p * 2)
.get();
}
我们也可以在 ConversionService
中注册一个 BytesToIntegerConverter
来去掉额外的 .transform()
调用。
@Bean
@IntegrationConverter
public BytesToIntegerConverter bytesToIntegerConverter() {
return new BytesToIntegerConverter();
}
@Bean
public IntegrationFlow integerFlow() {
return IntegrationFlow.from("input")
.handle(Integer.class, (p, h) -> p * 2)
.get();
}
另请参阅 Lambdas 与 Message<?>
参数。