diff --git a/easy-retry-client-core/src/main/java/com/aizuda/easy/retry/client/core/plugin/RequestHeaderPlugins.java b/easy-retry-client-core/src/main/java/com/aizuda/easy/retry/client/core/plugin/RequestHeaderPlugins.java
index 5d09d025..0acea2c5 100644
--- a/easy-retry-client-core/src/main/java/com/aizuda/easy/retry/client/core/plugin/RequestHeaderPlugins.java
+++ b/easy-retry-client-core/src/main/java/com/aizuda/easy/retry/client/core/plugin/RequestHeaderPlugins.java
@@ -40,9 +40,11 @@ public class RequestHeaderPlugins {
LogUtils.warn(log, "entry method time is null. easyRetryId:[{}]", retryHeader.getEasyRetryId());
} else {
long transmitTime = retryHeader.getDdl() - (callRemoteTime - entryMethodTime);
- LogUtils.info(log, "RPC传递header头 callRemoteTime:[{}] - entryMethodTime:[{}] = transmitTime:[{}]", entryMethodTime, callRemoteTime, transmitTime);
+ LogUtils.info(log, "RPC传递header头 callRemoteTime:[{}] - entryMethodTime:[{}] = transmitTime:[{}]", callRemoteTime, entryMethodTime, transmitTime);
if (transmitTime > 0) {
retryHeader.setDdl(transmitTime);
+ // 重新刷新进入时间
+ RetrySiteSnapshot.setEntryMethodTime(System.currentTimeMillis());
} else {
throw new EasyRetryClientException("调用链超时, 不在继续调用后面请求");
}
diff --git a/example/src/main/java/com/example/demo/TestRetryMethodService.java b/example/src/main/java/com/example/demo/TestRetryMethodService.java
index c53f4a5f..8917c94f 100644
--- a/example/src/main/java/com/example/demo/TestRetryMethodService.java
+++ b/example/src/main/java/com/example/demo/TestRetryMethodService.java
@@ -22,8 +22,10 @@ public class TestRetryMethodService {
return "测试自定义重试方法";
}
- @Retryable(scene = "testRetryHeaderTransfer", retryStrategy = RetryType.ONLY_LOCAL)
+ @Retryable(scene = "testRetryHeaderTransfer", retryStrategy = RetryType.ONLY_LOCAL, localTimes = 1)
public String testRetryHeaderTransfer(String p) {
+ demoClient.get();
+ demoClient.get();
demoClient.get();
double i = 1 / 0;
return "测试重试流量标识服务间传递";