增加拦截点

sermant-io · Feb 27, 2025 · 5444db5 · 5444db5
1 parent cc83193
commit 5444db5
Show file tree

Hide file tree

Showing 7 changed files with 113 additions and 317 deletions.
diff --git a/...ration-provider/src/main/java/io/sermant/integration/Dubbo3ProviderApplication.java.banck b/...ration-provider/src/main/java/io/sermant/integration/Dubbo3ProviderApplication.java.banck
diff --git a/...vider/src/main/java/io/sermant/integration/configuration/FlowControlExceptionHandler.java b/...vider/src/main/java/io/sermant/integration/configuration/FlowControlExceptionHandler.java
diff --git a/...-integration-tests/dubbo-test/dubbo-2-7-integration-provider/src/main/resources/rule.yaml b/...-integration-tests/dubbo-test/dubbo-2-7-integration-provider/src/main/resources/rule.yaml
diff --git a/...egration-test/src/test/java/io/sermant/integration/flow/dubbo3/Dubbo3FlowControlTest.java b/...egration-test/src/test/java/io/sermant/integration/flow/dubbo3/Dubbo3FlowControlTest.java
@@ -111,6 +111,34 @@ public void instanceEx() {
         test("instanceEx", BREAKER_MSG, BREAKER_REQUEST_COUNT);
     }
 
+    /**
+     * 错误注入-返回空
+     */
+    @Test
+    public void faultNull() {
+        final String result = RequestUtils.get(BASE_URL + "faultNull", Collections.emptyMap(), String.class);
+        Assertions.assertNull(result);
+    }
+
+    /**
+     * 错误注入-抛异常
+     */
+    @Test
+    public void faultThrowEx() {
+        test("faultThrowEx", "Request has been aborted by fault-ThrowException", 1);
+    }
+
+    /**
+     * 错误注入-返回空
+     */
+    @Test
+    public void faultDelay() {
+        final long start = System.currentTimeMillis();
+        long delay = 2000L;
+        RequestUtils.get(BASE_URL + "faultDelay", Collections.emptyMap(), String.class);
+        Assertions.assertTrue((System.currentTimeMillis() - start) >= delay);
+    }
+
     /**
      * 隔离仓测试
      */
@@ -136,6 +164,15 @@ public void bulkHead() throws InterruptedException {
         threadPoolExecutor.shutdown();
     }
 
+    /**
+     * 重试
+     */
+    @Test
+    public void retry() {
+        final String result = RequestUtils.get(BASE_URL + "retry", Collections.emptyMap(), String.class);
+        Assertions.assertEquals(result, "3");
+    }
+
     /**
      * 测试熔断-异常
      */