我继承了一个包含Spring Retry的Spring Integration项目。我不确定它是否已经过测试，并且没有单独的测试。因此，我尝试在一个简单的场景中进行练习。
通过模拟RestTemplate exchange方法，我希望能够测试重试逻辑。我可以得到我想引发的异常，但是它只会发生一次-不会重试。
重试建议的XML在这里（retry-advice-context.xml）：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:int="http://www.springframework.org/schema/integration"
xmlns:util="http://www.springframework.org/schema/util"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/spring-integration.xsd
http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util.xsd">
<bean id="retryAdvice" class="org.springframework.integration.handler.advice.RequestHandlerRetryAdvice" >
<property name="retryTemplate">
<bean class="org.springframework.retry.support.RetryTemplate">
<property name="backOffPolicy">
<bean class="org.springframework.retry.backoff.ExponentialBackOffPolicy">
<property name="initialInterval" value="${retry.initialInterval}"/>
<property name="maxInterval" value="${retry.maxInterval}"/>
<property name="multiplier" value="${retry.multiplier}"/>
</bean>
</property>
<property name="retryPolicy">
<bean class="com.reachlocal.mediapublishing.shim.integration.retry.CustomRetryPolicy">
<constructor-arg name="maxAttempts" value="${retry.maxAttempts}" />
<constructor-arg name="retryableExceptions" ref="retryableExceptions" />
</bean>
</property>
</bean>
</property>
<property name="recoveryCallback">
<bean class="org.springframework.integration.handler.advice.ErrorMessageSendingRecoverer">
<constructor-arg ref="errorChannel" />
</bean>
</property>
</bean>
<util:map id="retryableExceptions" map-class="java.util.HashMap" >
<entry key="java.net.SocketException" value="true" />
<entry key="com.examplel.ConnectionException" value="true" />
<entry key="com.example.CustomException" value="true" />
</util:map>
</beans>
这是SI处理文件的一部分：
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:int="http://www.springframework.org/schema/integration"
xmlns="http://www.springframework.org/schema/beans"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/spring-integration.xsd">
<import resource="retry-advice-context.xml"/>
<int:channel id="channel1">
</int:channel>
<int:header-value-router id="commandTypeRouter" input-channel="commandChannel" <---DEFINED IN MASTER FILE
header-name="commandType" resolution-required="true">
<int:mapping value="COMMAND_1" channel="channel1"/>
</int:header-value-router>
<int:chain id="command1Chain" input-channel="channel1" output-channel="commandProcessed">
<int:header-enricher>
<int:error-channel ref="errorChannel" />
</int:header-enricher>
<int:service-activator ref="eventDataWriter" method = "addEventStart"/>
<int:service-activator ref="accountProcessor" method="processAccount">
<int:request-handler-advice-chain><ref bean="retryAdvice" /></int:request-handler-advice-chain>
</int:service-activator>
</int:chain>
</beans>
因此，重试bean
retryAdvice是不同链中的一部分。链上还有很多其他内容，因此我只希望能够从服务层检查重试逻辑。在代码的任何地方都没有Retry注释（不知道是否需要它们）。几个问题：
我可以从服务层测试重试功能还是需要执行整个链？
重试机制是否需要缺少任何内容（注释，其他XML）？
顺便说一句，这是使用SI 4.1.3。
谢谢。
更新1：
设法使Gary的项目在我的环境中运行。之后，我将
retry-advice-context.xml文件添加到主SI xml中。我将地图更改为仅包含RuntimeException。日志语句显示ExponentialBackoffPolicy语句。我也得到了RetryTemplate调试日志语句。通过更多的了解，我将那里的内容翻译成了我正在使用的真实代码，并获得了更大的成功。我收到了发生异常的日志语句，并将重试3次。
不幸的是，我得到的是：
17:29:26.154 DEBUG [task-scheduler-2][org.springframework.retry.support.RetryTemplate] Checking for rethrow: count=1
17:29:26.155 DEBUG [task-scheduler-2][org.springframework.retry.support.RetryTemplate] Retry failed last attempt: count=1
因此，它最初知道应该重试3次。但随后它指出，它是在1次重试后进行的最后一次尝试。
在Gary的工作代码中，调试语句将显示
Retry: count=2等...，以便进行下一个连续的尝试。在重试期间，Spock测试代码中有一个
sleep语句。我既延长又缩短了时间，没有任何改变。继续尝试并调试重试代码，以了解为什么它在第一次重试时停止。
最佳答案
您不需要任何其他注释或XML。
如果提供chain和service id属性，则可以独立测试处理程序...
<int:chain id="myChain" input-channel="foo">
<int:transformer expression="payload" />
<int:service-activator id="myService" ref="bar">
<int:request-handler-advice-chain>
<int:ref bean="retry" />
</int:request-handler-advice-chain>
</int:service-activator>
</int:chain>
<bean id="retry" class="org.springframework.integration.handler.advice.RequestHandlerRetryAdvice" />
<bean id="bar" class="com.example.Bar" />
随着
Bar被...public class Bar {
private int count;
public void bar(String in) {
System.out.println(in);
if (count++ < 2) {
throw new RuntimeException("foo");
}
}
}
测试：
public class So39604931ApplicationTests {
@Autowired
@Qualifier("myChain$child.myService.handler")
public MessageHandler handler;
@Test
public void test() {
handler.handleMessage(new GenericMessage<>("foo"));
}
}
结果：
foo
foo
foo
您还应该打开
org.springframework.retry的调试日志记录以查看重试行为。08:51:16.897 [main] DEBUG o.s.retry.support.RetryTemplate - Retry: count=0
foo
08:51:16.902 [main] DEBUG o.s.retry.support.RetryTemplate - Checking for rethrow: count=1
08:51:16.902 [main] DEBUG o.s.retry.support.RetryTemplate - Retry: count=1
foo
08:51:16.903 [main] DEBUG o.s.retry.support.RetryTemplate - Checking for rethrow: count=2
08:51:16.903 [main] DEBUG o.s.retry.support.RetryTemplate - Retry: count=2
foo
关于java - 在Spring Integration应用程序中，是否可以在链外测试Spring Retry机制？，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/39604931/