From 15f3331ae7625e61e553d0a9a9224f05089f4566 Mon Sep 17 00:00:00 2001
From: zengxiaoyan <>
Date: Mon, 7 Nov 2022 19:42:24 +0800
Subject: [PATCH] =?UTF-8?q?=E6=94=AF=E6=8C=81=E9=85=8D=E7=BD=AE=E6=96=87?=
 =?UTF-8?q?=E4=BB=B6=E6=8C=87=E5=AE=9A=E8=BF=9E=E6=8E=A5=E4=B8=AD=E6=96=AD?=
 =?UTF-8?q?=E5=90=8E=E9=87=8D=E8=AF=95=E6=97=B6=E9=97=B4=E9=97=B4=E9=9A=94?=
 =?UTF-8?q?=EF=BC=88=E5=8E=9F=E6=9D=A5=E7=9A=84=E7=A8=8B=E5=BA=8F=E5=86=99?=
 =?UTF-8?q?=E6=AD=BB10=E5=88=86=E9=92=9F=E4=B8=94=E4=B8=8D=E5=8F=AF?=
 =?UTF-8?q?=E4=BF=AE=E6=94=B9=EF=BC=89?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../domain/conn/TrackerConnectionManager.java  | 18 ++++++++++++++++++
 1 file changed, 18 insertions(+)

diff --git a/src/main/java/com/github/tobato/fastdfs/domain/conn/TrackerConnectionManager.java b/src/main/java/com/github/tobato/fastdfs/domain/conn/TrackerConnectionManager.java
index 301211a..d129682 100644
--- a/src/main/java/com/github/tobato/fastdfs/domain/conn/TrackerConnectionManager.java
+++ b/src/main/java/com/github/tobato/fastdfs/domain/conn/TrackerConnectionManager.java
@@ -33,6 +33,11 @@ public class TrackerConnectionManager extends FdfsConnectionManager {
     @NotNull
     private List<String> trackerList = new ArrayList<String>();
 
+    /**
+     * 连接中断以后经过N秒重试，不配置时默认为10分钟
+     */
+    private int retryAfterSecond;
+
     /**
      * 构造函数
      */
@@ -54,6 +59,11 @@ public TrackerConnectionManager(FdfsConnectionPool pool) {
     public void initTracker() {
         LOGGER.debug("init trackerLocator {}", trackerList);
         trackerLocator = new TrackerLocator(trackerList);
+        if (0 != retryAfterSecond) {
+            // 如果 retryAfterSecond ！= 0则，表示开发者自己配置了；set相关对象的属性值
+            trackerLocator.setRetryAfterSecond(retryAfterSecond);
+            LOGGER.debug("update trackerLocator retryAfterSecond to [{}]s", retryAfterSecond);
+        }
     }
 
     /**
@@ -89,4 +99,12 @@ public List<String> getTrackerList() {
     public void setTrackerList(List<String> trackerList) {
         this.trackerList = trackerList;
     }
+
+    public int getRetryAfterSecond() {
+        return retryAfterSecond;
+    }
+
+    public void setRetryAfterSecond(int retryAfterSecond) {
+        this.retryAfterSecond = retryAfterSecond;
+    }
 }