Spring Integration JAVA DSL 在后续调用中使用原始有效负载

Question

我正在使用 spring 集成来定义一个流程，它将做两件事 - 首先使用给定的有效负载执行 http 调用，然后使用提供的响应和原始有效负载进行另一个 http 调用。

如何做到这一点？在下面的代码中，我可以使用和修改第一个有效负载并在 firstHttpRequest 中使用它，但是如何将原始有效负载与来自 firstHttpRequest 的响应一起使用？

有什么好的做法吗？

@Bean
public IntegrationFlow makeHttpCalls(){

    return message -> message               
             .transform(new GenericTransformer<Message<String>, String>() {
                    @Override
                    public String transform(Message<String> message){
                            return message.getPayload() + " first call";    
                    }    
             })
             .handle(makeFirstHttpRequest())
             .transform(new GenericTransformer<Message<String>, String>() {
                @Override
                public String transform(Message<String> message) {
                    logger.debug("Response from transform: " + message);
                    return message.getPayload();
                }
             }) 
            .handle(makeSecondHttpRequest())
            .channel("entrypoint");
}

Answer 1

一种方法是.enrichHeaders() 并将原始payload 放入一个自定义标题中。因此下游，响应后，处理该标头以恢复原始payload。

另一种方法是.enrich()，当您拨打外部电话并使用回复信息丰富原始消息时。

还有其他工具，例如 .routeToRecipients() 和 .publishSubscribeChannel()，您可以将相同的消息发送到不同逻辑的不同子流。

但这就是你必须选择的。