2

我正在尝试为<int-http:outbound-gateway>. 我有以下配置:

<int-http:outbound-gateway 
            request-channel="REQUEST_CHANNEL"
            reply-channel="RESPONSE_CHANNEL"
            url="HTTP_URL"
            http-method="POST"
            charset="UTF-8" 
            header-mapper="headerMapper"
            extract-request-payload="true">
            <int-http:request-handler-advice-chain>
                <ref bean="retryHttpAdvice" />
            </int-http:request-handler-advice-chain>
</int-http:outbound-gateway>

<bean id="headerMapper" class="org.springframework.integration.http.support.DefaultHttpHeaderMapper">
        <property name="outboundHeaderNames" value="HTTP_REQUEST_HEADERS, UserRole" />
        <property name="userDefinedHeaderPrefix" value="" />
</bean>

<int:handler-retry-advice id="retryHttpAdvice" recovery-channel="RECOVERY_CHANNEL" 
        max-attempts="5">
        <int:exponential-back-off 
            initial="1000" 
            multiplier="2" />
</int:handler-retry-advice>

在Logback 中DEBUG启用级别org.springframework.integration后,我可以看到 RetryAdvice 正在执行但没有任何重试尝试。

这是预期的行为吗?例如,我收到 404 错误,我预计至少会看到 3 次尝试(重试计数类似于 service-activator),但此时只有一次没有重试计数。

exception is java.net.ConnectException: Connection refused
    at org.springframework.integration.http.outbound.HttpRequestExecutingMessageHandler.handleRequestMessage(HttpRequestExecutingMessageHandler.java:409)
    at org.springframework.integration.handler.AbstractReplyProducingMessageHandler$AdvisedRequestHandler.handleRequestMessage(AbstractReplyProducingMessageHandler.java:144)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:302)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.invokeJoinpoint(ReflectiveMethodInvocation.java:190)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157)
    at org.springframework.integration.handler.advice.AbstractRequestHandlerAdvice$1.cloneAndExecute(AbstractRequestHandlerAdvice.java:92)
    at org.springframework.integration.handler.advice.RequestHandlerRetryAdvice$2.doWithRetry(RequestHandlerRetryAdvice.java:92)
    at org.springframework.retry.support.RetryTemplate.doExecute(RetryTemplate.java:263)
    at org.springframework.retry.support.RetryTemplate.execute(RetryTemplate.java:193)
    at org.springframework.integration.handler.advice.RequestHandlerRetryAdvice.doInvoke(RequestHandlerRetryAdvice.java:88)
    at org.springframework.integration.handler.advice.AbstractRequestHandlerAdvice.invoke(AbstractRequestHandlerAdvice.java:69)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
    at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:208)
    at com.sun.proxy.$Proxy176.handleRequestMessage(Unknown Source)

使用 http-outbound-gateway 调用 retryAdvice 的最佳方法是什么?

4

0 回答 0