Spring集成DSL：如何添加HTTP。outboundGateway标头？

Question

添加HTTP最简单的方法是什么。我的程序中的outboundGateway头？

我想做的是：

我首先对URL执行HTTP GET

http://localhost:8050/session

然后我得到JSON

{
   "session": "session8050"
}

我提取session变量的值，并将其添加到下一个HTTP GET作为session头变量。

目前我有工作代码，但我想我可以做得更容易吗？我的实现

>

然后，该实现使用enrichHeaders方法将session变量添加到集成流消息头中

然后，该实现使用HeaderMapper类将session变量添加到HTTP调用头中

我的实现是

integrationFlowBuilder
.transform(p -> authenticationJson)
.enrichHeaders(h -> h.header("Content-Type", "application/json"))
.handle(Http.outboundGateway("http://localhost:8050/session").httpMethod(HttpMethod.POST)
        .expectedResponseType(String.class))
.enrichHeaders(
        h -> h.headerExpression("session", "#jsonPath(payload, '$.session')", true)
.handle(Http
        .outboundGateway(completeFromUrl)
        .httpMethod(HttpMethod.GET).mappedRequestHeaders("session").headerMapper(headerMapper())
        .expectedResponseType(String.class))

我的headerMapper是

@Bean
HeaderMapper headerMapper() {
    final DefaultHttpHeaderMapper headerMapper = new DefaultHttpHeaderMapper();
    final String[] headerNames = { "session" };
    headerMapper.setOutboundHeaderNames(headerNames);

    headerMapper.setUserDefinedHeaderPrefix("");
    return headerMapper;
}

是否可以从JSON中提取会话变量并将其直接添加到HTTP标头？？

为什么必须使用HeaderMapper？为什么集成流消息头不能直接进入HTTP。outboundGateway在有效负载移动时调用？

Answer 1

首先，您需要了解Spring集成与任何其他EIP解决方案一样的主要目标是使流中的组件尽可能隔离，因此在未来，您可以添加一些中间步骤或删除这些步骤，而不会对整个解决方案和集成流中的其他组件产生重大影响。这应该是关于为什么必须使用HeaderMapper的问题的答案。

正如您看到的HeaderMapper的合约将MessageHeaders重新映射到目标协议标头表示。没有关于payload的内容，因此您需要首先将payload中的值映射到标头中。然后说Http.outboundGateway（）应该从MessageHeaders重新映射到HttpHeaders中的内容。

默认情况下，DefaultHttpHeaderMapper（它位于Http.outboundGateway（）中）只映射适合Http请求的标准Http头。

如果您需要包含一些自定义标头，例如在您的会话中，您确实可以为DefaultHttpHeaderMapper使用自定义配置，或者只需在Http.outboundGateway（）上配置一个方便的选项：

.mappedRequestHeaders("session")

从版本5.0中不需要setUserDefedHeaderPrefix（"）。它现在默认为空字符串，因为HTTP协议中的前缀中没有自定义标头的要求。