perf: job-gateway从ESB获取JWT公钥增加重试 TencentBlueKing#786

jsonwan · Nov 14, 2022 · bf5c2e7 · bf5c2e7
1 parent a35b8e7
commit bf5c2e7
Showing 1 changed file with 20 additions and 19 deletions.
diff --git a/.../job-gateway/src/main/java/com/tencent/bk/job/gateway/service/impl/EsbJwtServiceImpl.java b/.../job-gateway/src/main/java/com/tencent/bk/job/gateway/service/impl/EsbJwtServiceImpl.java
@@ -67,26 +67,27 @@ public EsbJwtServiceImpl(EsbJwtPublicKeyService esbJwtPublicKeyService) {
 
     private void getPublicKeyOrRetryInBackground() {
         boolean publicKeyGotten = tryToGetAndCachePublicKeyOnce();
-        if (!publicKeyGotten) {
-            Thread esbPublicKeyGetter = new Thread(() -> {
-                boolean keyGotten;
-                int retryCount = 0;
-                int sleepMillsOnce = 5000;
-                // 最多重试一整天
-                int maxRetryCount = 24 * 3600 / 5;
-                do {
-                    log.warn("esbJwtPublicKey not gotten, retry {} after 5s", ++retryCount);
-                    ThreadUtils.sleep(sleepMillsOnce);
-                    keyGotten = tryToGetAndCachePublicKeyOnce();
-                } while (!keyGotten && retryCount <= maxRetryCount);
-                if (!keyGotten) {
-                    log.error("esbJwtPublicKey not gotten after {} retry, plz check esb", maxRetryCount);
-                }
-            });
-            esbPublicKeyGetter.setDaemon(true);
-            esbPublicKeyGetter.setName("esbPublicKeyGetter");
-            esbPublicKeyGetter.start();
+        if (publicKeyGotten) {
+            return;
         }
+        Thread esbPublicKeyGetter = new Thread(() -> {
+            boolean keyGotten;
+            int retryCount = 0;
+            int sleepMillsOnce = 5000;
+            // 最多重试3天
+            int maxRetryCount = 3 * 24 * 3600 / 5;
+            do {
+                log.warn("esbJwtPublicKey not gotten, retry {} after 5s", ++retryCount);
+                ThreadUtils.sleep(sleepMillsOnce);
+                keyGotten = tryToGetAndCachePublicKeyOnce();
+            } while (!keyGotten && retryCount <= maxRetryCount);
+            if (!keyGotten) {
+                log.error("esbJwtPublicKey not gotten after {} retry (3 days), plz check esb", maxRetryCount);
+            }
+        });
+        esbPublicKeyGetter.setDaemon(true);
+        esbPublicKeyGetter.setName("esbPublicKeyGetter");
+        esbPublicKeyGetter.start();
     }
 
     private boolean tryToGetAndCachePublicKeyOnce() {