我正在尝试为<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 的最佳方法是什么?