Spring Integration HTTP出站网关标头不是连续请求上的转发器

Question

我正在与以下流程作斗争：

.enrichHeaders(h -> h.headerFunction("ocp-apim-subscription-key", m ->
        "xxx"))
.handle(Http.outboundGateway("https://northeurope.api.cognitive.microsoft.com/vision/v3" +
        ".0/read/analyzeResults/abc")
        .mappedRequestHeaders("ocp-apim-subscription-key")
        .httpMethod(HttpMethod.GET))
.enrichHeaders(h -> h.headerFunction("ocp-apim-subscription-key", m ->
        "xxx"))
.handle(Http.outboundGateway("https://northeurope.api.cognitive.microsoft.com/vision/v3" +
        ".0/read/analyzeResults/def")
        .mappedRequestHeaders("ocp-apim-subscription-key")
        .httpMethod(HttpMethod.GET))

第一个请求被正确地提交，我得到了结果，对于第二个请求，我得到了401未经授权的结果，这意味着ocp-apim-subscription-key不包括在内。我尝试过没有第二个浓缩步骤，因为我认为头不会被清除，但这也没有改变任何东西。

你知道我可能做错了什么吗？我需要以不同的方式配置头映射器吗？

17:45:31.468 [main] DEBUG org.springframework.integration.http.outbound.HttpRequestExecutingMessageHandler - bean 'ocrDocument.http:outbound-gateway#2' for component 'ocrDocument.org.springframework.integration.config.ConsumerEndpointFactoryBean#3'; defined in: 'processing.OCRIntegrationFlow'; from source: 'bean method ocrDocument' received message: GenericMessage [payload=<200,[Transfer-Encoding:"chunked", Content-Type:"application/json; charset=utf-8", x-envoy-upstream-service-time:"25", CSP-Billing-Usage:"CognitiveServices.ComputerVision.Transaction=1", Strict-Transport-Security:"max-age=31536000; includeSubDomains; preload", x-content-type-options:"nosniff", Date:"Mon, 31 Aug 2020 15:45:31 GMT"]>, headers={Transfer-Encoding=chunked, ocp-apim-subscription-key=xxx, id=11fa4a77-d97a-772b-69b6-059de29ef808, contentType=application/json;charset=utf-8, http_statusCode=200 OK, Date=1598888731000, timestamp=1598888731467}]

Answer 1

好的。我知道问题出在哪里了：

private HttpEntity<?> createHttpEntityFromPayload(Message<?> message, HttpMethod httpMethod) {
Object payload = message.getPayload();
if (payload instanceof HttpEntity<?>) {
    // payload is already an HttpEntity, just return it as-is
    return (HttpEntity<?>) payload;
}
HttpHeaders httpHeaders = mapHeaders(message);

由于将ResponseEntity从第一个调用传播到第二个调用，因此实际上没有任何头映射，因为我们只是在AbstracthtPrequestExecutingMessageHandler中不执行该逻辑，而是按原样使用提供的HttpEntity。

我们不能假设您想用它做什么，但既然您已经提供了整个实体，我们只是不改变它并按原样对它执行请求。

我们可能需要改进docs中关于这个问题的内容，并解释请求消息在这个组件中是如何处理的。请随意提出生长激素问题！