1

我正在使用一个分两步工作的 API：

  1. 它以异步方式开始处理文档，并为您提供用于步骤 2 的 id
  2. 它提供了一个端点，您可以在其中获得结果，但前提是它们准备就绪。所以基本上它总是会给你一个 200 响应，其中包含一些细节，比如处理的状态。

所以问题是如何为 HTTP 出站网关实现自定义“成功”标准。我还想将它与我已经实现的 RetryAdvice 结合起来。

我尝试了以下方法，但首先在 HandleMessageAdvice 中提供的消息有效负载是空的，其次没有触发重试：

.handle(Http.outboundGateway("https://northeurope.api.cognitive.microsoft.com/vision/v3" +
        ".0/read/analyzeResults/abc")
        .mappedRequestHeaders("Ocp-Apim-Subscription-Key")
        .httpMethod(HttpMethod.GET), c -> c.advice(this.advices.retryAdvice())
              .handleMessageAdvice(new AbstractHandleMessageAdvice() {
    @Override
    protected Object doInvoke(MethodInvocation invocation, Message<?> message) throws Throwable {
        String body = (String) message.getPayload();
        if (StringUtils.isEmpty(body))
            throw new RuntimeException("Still analyzing");
        JSONObject document = new JSONObject(body);
        if (document.has("analyzeResult"))
            return message;
        else
            throw new RuntimeException("Still analyzing");
    }
}))

我从 4 年前就从 Artem 那里找到了这个答案，但首先我没有在出站网关上找到回复通道方法，其次不确定这个场景是否已经在新版本的 Spring 集成中得到了改进：http outbound带条件重试（用于检查条件）。

更新

按照 Artem 的建议，我有以下几点：

.handle(Http.outboundGateway("https://northeurope.api.cognitive.microsoft.com/vision/v3" +
        ".0/read/analyzeResults/abc")
        .mappedRequestHeaders("Ocp-Apim-Subscription-Key")
        .httpMethod(HttpMethod.GET), c -> c.advice(advices.verifyReplySuccess())
        .advice(advices.retryUntilRequestCompleteAdvice()))

和建议：

@Bean
public Advice verifyReplySuccess() {
    return new AbstractRequestHandlerAdvice() {
        @Override
        protected Object doInvoke(ExecutionCallback callback, Object target, Message<?> message) {
            try {
                Object payload = ((MessageBuilder) callback.execute()).build().getPayload();
                String body = (String) ((ResponseEntity) payload).getBody();
                JSONObject document = new JSONObject(body);
                if (document.has("analyzeResult"))
                    return message;
            } catch (JSONException e) {
                throw new RuntimeException(e);
            }
            throw new RuntimeException("Still analyzing");
        }
    };
}

但是现在当我调试doInvoke方法时，有效负载的主体是null。奇怪的是，当我使用 Postman 执行相同的 GET 请求时，正文被正确返回。任何想法？

使用 Postman 响应的正文如下所示：

{
    "status": "succeeded",
    "createdDateTime": "2020-09-01T10:55:52Z",
    "lastUpdatedDateTime": "2020-09-01T10:55:57Z",
    "analyzeResult": {
        "version": "3.0.0",
        "readResults": [
            {
                "page": 1,........

这是我使用回调从出站网关获得的有效负载：

在此处输入图像描述

<200,[Transfer-Encoding:"chunked", Content-Type:"application/json; charset=utf-8", x-envoy-upstream-service-time:"27", CSP-Billing-Usage:"CognitiveServices.ComputerVision.Transaction=1", apim-request-id:"a503c72f-deae-4299-9e32-625d831cfd91", Strict-Transport-Security:"max-age=31536000; includeSubDomains; preload", x-content-type-options:"nosniff", Date:"Tue, 01 Sep 2020 19:48:36 GMT"]>
4

2 回答 2

1

Java DSL中确实没有request和reply通道选项，因为您只需将其包装handle()到channel()配置中，或者只是以流自然的方式链接端点，它们将使用其间的隐式直接通道交换消息。您可以在 XML 配置中IntegrationFlow查看Java DSL 。<chain>

您的建议配置有点错误：您需要将自定义建议声明为链中的第一个，因此当从那里抛出异常时，重试将处理它。

您还应该考虑实现一个AbstractRequestHandlerAdvice以使其与RequestHandlerRetryAdvice逻辑保持一致。

您在那里实现doInvoke()，调用ExecutionCallback.execute()并分析结果以按原样返回或抛出所需的异常。该要求的结果HttpRequestExecutingMessageHandler将是AbstractIntegrationMessageBuilder并且可能是ResponseEntity作为payload检查您的进一步逻辑的结果。

于 2020-09-01T15:34:29.413 回答
0

按照 Artem 的建议，我提出了以下建议（附加技巧是将expectedResponseType设置为 String，否则使用ResponseEntity主体为空）：

.handle(Http.outboundGateway("https://northeurope.api.cognitive.microsoft.com/vision/v3" +
        ".0/read/analyzeResults/abc")
        .mappedRequestHeaders("Ocp-Apim-Subscription-Key")
        .httpMethod(HttpMethod.GET).expectedResponseType(String.class),
        c -> c.advice(advices.retryUntilRequestCompleteAdvice())
              .advice(advices.verifyReplySuccess()))

和建议：

@Bean
public Advice verifyReplySuccess() {
    return new AbstractRequestHandlerAdvice() {
        @Override
        protected Object doInvoke(ExecutionCallback callback, Object target, Message<?> message) {
            Object payload = ((MessageBuilder) callback.execute()).build().getPayload();
            if (((String) payload).contains("analyzeResult"))
                return payload;
            else
                throw new RuntimeException("Still analyzing");
        }
    };
}
于 2020-09-07T15:36:04.517 回答