gtsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects 1 Releases Wiki Activity

feat: 1.5.0-hotfix

Browse Source 
1. 优化代码
This commit is contained in:
www.byteblogs.com 2023-06-12 23:53:07 +08:00
parent 8051a033ca
commit 6d04e3311e
2 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
easy-retry-client-core/src/main/java/com/aizuda/easy/retry/client/core/plugin/RequestHeaderPlugins.java
View File

@ -40,9 +40,11 @@ public class RequestHeaderPlugins {
LogUtils.warn(log, "entry method time is null. easyRetryId:[{}]", retryHeader.getEasyRetryId()); LogUtils.warn(log, "entry method time is null. easyRetryId:[{}]", retryHeader.getEasyRetryId());
} else { } else {
long transmitTime = retryHeader.getDdl() - (callRemoteTime - entryMethodTime); 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) { if (transmitTime > 0) {
retryHeader.setDdl(transmitTime); retryHeader.setDdl(transmitTime);
// 重新刷新进入时间
RetrySiteSnapshot.setEntryMethodTime(System.currentTimeMillis());
} else { } else {
throw new EasyRetryClientException("调用链超时, 不在继续调用后面请求"); throw new EasyRetryClientException("调用链超时, 不在继续调用后面请求");
} }

4
example/src/main/java/com/example/demo/TestRetryMethodService.java
View File

@ -22,8 +22,10 @@ public class TestRetryMethodService {
return "测试自定义重试方法"; return "测试自定义重试方法";
} }
@Retryable(scene = "testRetryHeaderTransfer", retryStrategy = RetryType.ONLY_LOCAL) @Retryable(scene = "testRetryHeaderTransfer", retryStrategy = RetryType.ONLY_LOCAL, localTimes = 1)
public String testRetryHeaderTransfer(String p) { public String testRetryHeaderTransfer(String p) {
demoClient.get();
demoClient.get();
demoClient.get(); demoClient.get();
double i = 1 / 0; double i = 1 / 0;
return "测试重试流量标识服务间传递"; return "测试重试流量标识服务间传递";