feat:support recover router zero protect switch. (#611)

Author: SkyeBeFreeman

polaris-common/polaris-config-default/src/main/resources/conf/default-config.yml

@@ -212,6 +212,8 @@ consumer:
       recoverRouter:
         # 是否剔除被熔断的实例
         excludeCircuitBreakInstances: true
+        # 是否启用全死全活
+        allRecoverEnable: true
       metadataRouter:
         #描述: 元数据路由降级策略。none(不降级), all(降级返回所有的节点), others(降级返回其他KEY的节点)
         metadataFailOverType: all

polaris-common/polaris-config/src/main/java/com/tencent/polaris/factory/config/global/APIConfigImpl.java

@@ -160,8 +160,8 @@ public void setDefault(Object defaultObject) {
             if (null == reportInterval) {
                 setReportInterval(apiConfig.getReportInterval());
             }
-            if (null == reportInterval) {
-                setReportInterval(apiConfig.getReportInterval());
+            if (null == reportEnable) {
+                setReportEnable(apiConfig.isReportEnable());
             }
             if (null == retryInterval) {
                 setRetryInterval(apiConfig.getRetryInterval());

polaris-plugins/polaris-plugins-router/router-healthy/src/main/java/com/tencent/polaris/plugins/router/healthy/RecoverRouter.java

@@ -28,16 +28,12 @@
 import com.tencent.polaris.api.plugin.common.PluginTypes;
 import com.tencent.polaris.api.plugin.route.RouteInfo;
 import com.tencent.polaris.api.plugin.route.RouteResult;
-import com.tencent.polaris.api.pojo.CircuitBreakerStatus;
-import com.tencent.polaris.api.pojo.Instance;
-import com.tencent.polaris.api.pojo.ServiceInstances;
-import com.tencent.polaris.api.pojo.ServiceKey;
-import com.tencent.polaris.api.pojo.ServiceMetadata;
+import com.tencent.polaris.api.pojo.*;
 import com.tencent.polaris.circuitbreak.api.flow.CircuitBreakerFlow;
 import com.tencent.polaris.circuitbreak.api.pojo.CheckResult;
-import com.tencent.polaris.circuitbreak.client.api.DefaultCircuitBreakAPI;
 import com.tencent.polaris.client.util.Utils;
 import com.tencent.polaris.plugins.router.common.AbstractServiceRouter;
+
 import java.util.List;
 import java.util.function.Predicate;
 import java.util.stream.Collectors;
@@ -76,7 +72,7 @@ public boolean test(Instance instance) {
 
         int healthyInstanceCount = healthyInstance.size();
         //如果过滤之后，没有实例，则返回全量的实例。推空保护
-        if (healthyInstanceCount == 0) {
+        if (recoverRouterConfig.isAllRecoverEnable() && healthyInstanceCount == 0) {
             return new RouteResult(instances.getInstances(), RouteResult.State.Next);
         }
 

polaris-plugins/polaris-plugins-router/router-healthy/src/main/java/com/tencent/polaris/plugins/router/healthy/RecoverRouterConfig.java

@@ -30,6 +30,9 @@ public class RecoverRouterConfig implements Verifier {
     @JsonProperty
     private Boolean excludeCircuitBreakInstances;
 
+    @JsonProperty
+    private Boolean allRecoverEnable;
+
     @Override
     public void verify() {
 
@@ -42,6 +45,9 @@ public void setDefault(Object defaultConfig) {
             if (excludeCircuitBreakInstances == null) {
                 setExcludeCircuitBreakInstances(recoverRouterConfig.isExcludeCircuitBreakInstances());
             }
+            if (allRecoverEnable == null) {
+                setAllRecoverEnable(recoverRouterConfig.isAllRecoverEnable());
+            }
         }
     }
 
@@ -52,4 +58,12 @@ public Boolean isExcludeCircuitBreakInstances() {
     public void setExcludeCircuitBreakInstances(Boolean excludeCircuitBreakInstances) {
         this.excludeCircuitBreakInstances = excludeCircuitBreakInstances;
     }
+
+    public Boolean isAllRecoverEnable() {
+        return allRecoverEnable;
+    }
+
+    public void setAllRecoverEnable(Boolean allRecoverEnable) {
+        this.allRecoverEnable = allRecoverEnable;
+    }
 }