提升部分稳定性

Author: 胡贵

job-core/src/main/java/com/lts/job/core/registry/FailbackRegistry.java

@@ -195,6 +195,7 @@ protected void retry() {
                 try {
                     for (Node node : failed) {
                         doRegister(node);
+                        failedRegistered.remove(node);
                     }
                 } catch (Throwable t) {     // 忽略所有异常，等待下次重试
                     LOGGER.warn("Failed to retry register " + failed + ", waiting for again, cause: " + t.getMessage(), t);
@@ -210,6 +211,7 @@ protected void retry() {
                 try {
                     for (Node node : failed) {
                         doUnRegister(node);
+                        failedUnRegistered.remove(node);
                     }
                 } catch (Throwable t) {     // 忽略所有异常，等待下次重试
                     LOGGER.warn("Failed to retry unregister " + failed + ", waiting for again, cause: " + t.getMessage(), t);
@@ -235,6 +237,7 @@ protected void retry() {
                             try {
                                 doSubscribe(node, listener);
                                 listeners.remove(listener);
+                                failedSubscribed.remove(entry.getKey());
                             } catch (Throwable t) { // 忽略所有异常，等待下次重试
                                 LOGGER.warn("Failed to retry subscribe " + failed + ", waiting for again, cause: " + t.getMessage(), t);
                             }