修改统计错误率的时间窗口

src/main/java/com/nanyan/securitylink/config/AppConfig.java

@@ -15,6 +15,13 @@ public class AppConfig {
     @Value("${gateway.request.timeout:30000}")
     private Integer requestTimeout;
 
+    @Value("${gateway.window.time:600000}")
+    private Integer windowsTime;
+
+    public Integer getWindowsTime() {
+        return windowsTime;
+    }
+
     public Integer getRequestTimeout() {
         return requestTimeout;
     }

src/main/java/com/nanyan/securitylink/filter/FailoverGatewayFilterFactory.java

@@ -61,16 +61,18 @@ public class FailoverGatewayFilterFactory extends AbstractGatewayFilterFactory<F
 
     // 内部类：环形队列，用于记录请求结果
     private static class CircularQueue {
+        AppConfig appConfig;
         private final long[] timestamps;
         private final boolean[] results; // true表示成功，false表示失败
         private int currentIndex = 0;
         private final int capacity;
         private final Object lock = new Object();
 
-        public CircularQueue(int capacity) {
+        public CircularQueue(int capacity, AppConfig appConfig) {
             this.capacity = capacity;
             this.timestamps = new long[capacity];
             this.results = new boolean[capacity];
+            this.appConfig = appConfig;
         }
 
         public void add(boolean success) {
@@ -84,7 +86,7 @@ public class FailoverGatewayFilterFactory extends AbstractGatewayFilterFactory<F
         public double getErrorRate() {
             synchronized (lock) {
                 long currentTime = System.currentTimeMillis();
-                long oneMinuteAgo = currentTime - WINDOW_SIZE_SECONDS * 1000;
+                long oneMinuteAgo = currentTime - appConfig.getWindowsTime();
                 int totalRequests = 0;
                 int failedRequests = 0;
 
@@ -104,7 +106,7 @@ public class FailoverGatewayFilterFactory extends AbstractGatewayFilterFactory<F
 
     private CircularQueue getOrCreateErrorStats(String primaryUrl) {
         return errorStatsMap.computeIfAbsent(primaryUrl,
-                k -> new CircularQueue(WINDOW_SIZE_SECONDS * 10)); // 存储10次/秒的采样
+                k -> new CircularQueue(WINDOW_SIZE_SECONDS * 10, appConfig)); // 存储10次/秒的采样
     }
 
     private boolean shouldSkipPrimary(String primaryUrl) {