基于回复内容的Spring集成HTTP出站网关重试

Question

我使用的API分为两个步骤：

1. 它以异步方式开始处理文档，向您提供用于步骤2的id

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

我已经尝试了以下操作，但首先HandleMessage建议中提供的消息的有效负载为空，其次重试未触发：

.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年前的阿特姆找到了这个答案，但首先我没有在出站网关上找到回复通道方法，其次不确定这种情况是否已经在较新版本的Spring整数中得到改进：超文本传输协议出站重试条件（对于检查器条件）。

更新

根据阿特姆的建议，我有以下几点：

.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"]>

Answer 1

根据Arem的建议，我想出了以下方法（额外的技巧是将预期的响应类型设置为字符串，否则使用响应实体主体是空的）：

.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");
        }
    };
}

Answer 2

Java DSL中确实没有请求和回复通道选项，因为您只需将该句柄（）封装到配置中，或者仅以流自然的方式链接endpoint，它们将使用中间的隐式直接通道交换消息。您可以将Java DSL集成流作为

您的建议配置有点错误：您需要将您的自定义建议声明为链中的第一个建议，所以当从那里引发异常时，将由重试处理。

您还应该考虑实现一个AbstractRequest estHandlerAdvie以使其与Request estHandlerRetryAdvie逻辑对齐。

您在那里实现了一个调用ExecutionCallback的doInvoke（）。execute（）并分析结果以按原样返回或引发所需的异常。调用HttpRequestExecutingMessageHandler的结果将是一个抽象集成消息生成器（AbstractIntegrationMessageBuilder），很可能是一个响应属性（ResponseEntity），作为一个有效负载（payload）来检查进一步的逻辑。