Spring集成-管理http出站适配器调用中的401错误

Question

我是Spring整合的新手。

我有一个流，根据某些条件，我需要在其上执行超文本传输协议或tcp调用。我关注的问题与超文本传输协议调用有关。调用的其余endpoint需要一个访问令牌作为身份验证的标头参数，该参数由具有2个方法getMONtAccessToken（）和刷新AccessToken（）的Spring服务提供。我想仅在电流AccessToken过期时调用方法刷新访问令牌。

我想做的是在执行对rest api的调用时添加以下逻辑：

如果令牌过期，restendpoint返回401，我希望在流中拦截此错误，并通过添加刷新的访问令牌重试请求。

  @Bean
  public IntegrationFlow clientIn(AbstractServerConnectionFactory server,
      AbstractClientConnectionFactory client, LogService logService) {

    return IntegrationFlows.from(Tcp.inboundAdapter(client)
        .enrichHeaders(t -> t.headerFunction(IpHeaders.CONNECTION_ID, message -> this.client, true))
        .log(msg -> "client: " + logService.log(msg))
        .<byte[], Boolean>route(this::shouldForwardToHttp,
            mapping -> mapping.subFlowMapping(true, sf -> sf
                .enrichHeaders(t -> t.header("Content-Type", MimeTypeUtils.APPLICATION_JSON_VALUE))
                .<byte[], RequestMessage>transform(this::buildRequestFromMessage)
                .<RequestMessage, HttpEntity>transform(this::getHttpEntity)
                .handle(Http.outboundGateway(restUrl).httpMethod(HttpMethod.POST)
                    .expectedResponseType(ResponseMessage.class))
                .<ResponseMessage, byte[]>transform(p -> this.transformResponse(p))
                .handle(Tcp.outboundAdapter(client))).subFlowMapping(false,
                    t -> t.handle(Tcp.outboundAdapter(server).retryInterval(1000))))
        .get();
  }
 HttpEntity getHttpEntity(RequestMessage request) {

    MultiValueMap<String, String> mv = new HttpHeaders();
    mv.add("accessToken", tokenProvider.getCurrentAccessToken());
    HttpEntity entity = new HttpEntity(request, mv);
    return entity;
  }

我尝试添加Request estHandlerRetry建议并将其重定向到恢复通道，但我无法将某些内容返回给调用者流以获取状态代码的响应并使用新的访问令牌重试调用。

你知道我该怎么做吗？

Answer 1

我认为您不需要重试建议，因为您肯定是通过捕捉401异常并使用刷新的令牌调用服务来模拟它的。听起来更像递归。为了正确实现这一点，我建议研究一下ExpressionEvaluationRequestHandlerAdvice：https://docs.spring.io/spring-integration/docs/current/reference/html/messaging-endpoints.html#message-处理程序建议链。是的，它类似于重试，也有故障通道，但没有内置的重试，因为我们将在必要时模拟它反复调用同一endpoint。

为了简化递归逻辑，我将把.handle（Http.outboundGateway（restUrl）.httpMethod（httpMethod.POST）.expectedResponseType（ResponseMessage.class））提取到一个单独的流中，并使用一个带有输入通道的网关（）代替主流中的该流。

故障通道子流应将其消息重新路由回网关流的输入。

这个逻辑中最重要的部分是进行所有原始请求消息头，其中包括网关逻辑复制通道所需的。

查看有关网关的更多文档：https://docs.spring.io/spring-integration/docs/current/reference/html/messaging-endpoints.html#gateway.

当表达式EvaluagingRequestHandlerAdvice向故障通道发送消息时，它将作为一条错误消息，并将消息HandlingExpressionEvaluagingAdviceException作为有效负载。导致故障并具有所有必需标头的消息位于getFailedMessage（）属性中。所以，您获取该消息，请求新令牌，将其添加到基于原始令牌的新消息的头中。最后，您将这个新消息发送到HTTP请求的集成流的输入通道。当一切正常时，HTTP调用的结果将从标头转发到前面提到的replyChannel，并因此转发到下一步的主流。