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 trackerList = new ArrayList(); + /** + * 连接中断以后经过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 getTrackerList() { public void setTrackerList(List trackerList) { this.trackerList = trackerList; } + + public int getRetryAfterSecond() { + return retryAfterSecond; + } + + public void setRetryAfterSecond(int retryAfterSecond) { + this.retryAfterSecond = retryAfterSecond; + } }