Spring IntegrationFlow 实现中的 ClassCastException

Question

我目前有一个 IntegrationFlow 实现，它利用 Service 类来实现要由流执行的所有所需功能。像这样的...

@Service
public class FlowService {

    public Message<String> removeLineFeeds(Message<String> message) {
        return MessageBuilder
                .withPayload(StringUtils.remove(message.getPayload(), StringUtils.LF))
                .copyHeadersIfAbsent(message.getHeaders())
                .build();
    }

}

@Configuration
@EnableIntegration
public class FlowConfiguration {

    @Autowired
    private FlowService flowService;

    @Bean
    public IntegrationFlow flow() {
        return IntegrationFlows
                .from("inputChannel")
                .transform(flowService, "removeLineFeeds")
                .get();
    }
}

上述实现完全按照预期工作，但我希望改进/修改实现以利用 Java 8/Lambdas 的强大功能，使其看起来像这样......

@Bean
public IntegrationFlow flow() {
    return IntegrationFlows
            .from("inputChannel")
            .transform(flowService::removeLineFeeds)
            .get();
}

不幸的是，当以这种方式实现时，流程将在处理消息时抛出ClassCastException。我已经尝试了一些目前在线存在的不同提议的解决方案，但它们似乎都没有奏效。无论使用何种 IntegrationFlow 方法（转换、过滤器等），我都会遇到类似的问题。

需要对当前实现进行哪些更改以允许在 IntegrationFlow 方法中使用flowService::removeLineFeeds？

编辑：PER ARTEM 的回应

似乎 IntegrationFlow 中的一个简单转换器可以解决问题。我当前的实现似乎将消息作为Message<byte[]> 传递，而不是我期待的Message<String>。有关详细信息，请参阅下面 Artem 的完整回复。

@Bean
public IntegrationFlow flow() {
    return IntegrationFlows
            .from("inputChannel")
            .convert(String.class)
            .transform(flowService::removeLineFeeds)
            .get();
}

Answer 1

重点是 lambda 必须对应一些函数式接口。 对于transform()，它是GenericTransformer<S, T>。事实上，您的Message<String> removeLineFeeds(Message<String> message) 满足这样的合同。如果你只处理有效载荷，它会很好用：

public String removeLineFeeds(String message) {
    return StringUtils.remove(message.getPayload(), StringUtils.LF);
}

仅仅因为当目标实现中的所有通用信息在运行时被删除时，我们无法猜测您想要处理整个Message<?>，因此框架仅将有效负载传播到您的 lambda。你的String 不能转换为Message，因此是ClassCastException。

为了解决问题并模拟 Java 泛型系统，我们建议使用具有显式预期类型的​​重载方法：

/**
 * Populate the {@link MessageTransformingHandler} instance for the provided
 * {@link GenericTransformer} for the specific {@code payloadType} to convert at
 * runtime.
 * @param payloadType the {@link Class} for expected payload type. It can also be
 * {@code Message.class} if you wish to access the entire message in the transformer.
 * Conversion to this type will be attempted, if necessary.
 * @param genericTransformer the {@link GenericTransformer} to populate.
 * @param <P> the payload type - 'transform from' or {@code Message.class}.
 * @param <T> the target type - 'transform to'.
 * @return the current {@link BaseIntegrationFlowDefinition}.
 * @see MethodInvokingTransformer
 * @see LambdaMessageProcessor
 */
public <P, T> B transform(Class<P> payloadType, GenericTransformer<P, T> genericTransformer) {

所以，你的配置应该是这样的：

.transform(Message.class, flowService::removeLineFeeds)

这样我们就可以说我们想要获得完整消息以供我们的函数处理的框架。

无论如何，我更喜欢仅带有payload 的第一个变体：框架会照顾您将请求标头处理为回复消息。

在文档中查看更多信息：https://docs.spring.io/spring-integration/reference/html/dsl.html#java-dsl-class-cast