*fix an issue where inputstream is sometimes lost.

Signed-off-by: provenceee <[email protected]>
sermant-io · Nov 20, 2024 · eeb568c · eeb568c
1 parent bc976bf
commit eeb568c
Show file tree

Hide file tree

Showing 31 changed files with 255 additions and 624 deletions.
diff --git a/...est/dubbo-integration-api/src/main/java/io/sermant/integration/entity/LaneTestEntity.java b/...est/dubbo-integration-api/src/main/java/io/sermant/integration/entity/LaneTestEntity.java
@@ -1,5 +1,5 @@
 /*
- * Copyright (C) 2023-2023 Huawei Technologies Co., Ltd. All rights reserved.
+ * Copyright (C) 2023-2024 Huawei Technologies Co., Ltd. All rights reserved.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -32,7 +32,7 @@ public class LaneTestEntity implements Serializable {
     private final boolean enabled;
 
     /**
-     * 构造方法
+     * constructor
      *
      * @param id id
      * @param enabled enabled

diff --git a/...dubbo-test/dubbo-integration-test/src/test/java/io/sermant/integration/lane/LaneTest.java b/...dubbo-test/dubbo-integration-test/src/test/java/io/sermant/integration/lane/LaneTest.java
@@ -1,5 +1,5 @@
 /*
- * Copyright (C) 2023-2023 Huawei Technologies Co., Ltd. All rights reserved.
+ * Copyright (C) 2023-2024 Huawei Technologies Co., Ltd. All rights reserved.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -53,7 +53,7 @@ public class LaneTest {
     private final boolean isExecuteSpringTest;
 
     /**
-     * 构造方法
+     * constructor
      */
     public LaneTest() {
         baseUrl = "http://127.0.0.1:" + System.getProperty("controller.port", "28019") + "/controller/getLaneBy";

diff --git a/...st/dubbo-integration-test/src/test/java/io/sermant/integration/registry/ConsumerTest.java b/...st/dubbo-integration-test/src/test/java/io/sermant/integration/registry/ConsumerTest.java
@@ -1,5 +1,5 @@
 /*
- * Copyright (C) 2022-2022 Huawei Technologies Co., Ltd. All rights reserved.
+ * Copyright (C) 2022-2024 Huawei Technologies Co., Ltd. All rights reserved.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -41,7 +41,7 @@ public class ConsumerTest {
     private final String dubboVersion;
 
     /**
-     * 构造方法
+     * constructor
      */
     public ConsumerTest() {
         dubboVersion = System.getProperty("dubbo.running.version");

diff --git a/...bo-integration-test/src/test/java/io/sermant/integration/registry/SpringAndDubboTest.java b/...bo-integration-test/src/test/java/io/sermant/integration/registry/SpringAndDubboTest.java
@@ -1,5 +1,5 @@
 /*
- * Copyright (C) 2022-2022 Huawei Technologies Co., Ltd. All rights reserved.
+ * Copyright (C) 2022-2024 Huawei Technologies Co., Ltd. All rights reserved.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -38,7 +38,7 @@ public class SpringAndDubboTest {
     private final String baseUrl;
 
     /**
-     * 构造方法
+     * constructor
      */
     public SpringAndDubboTest() {
         baseUrl = "http://127.0.0.1:" + System.getProperty("controller.port", "28020") + "/consumer/";

diff --git a/...o-test/dubbo-integration-test/src/test/java/io/sermant/integration/router/RouterTest.java b/...o-test/dubbo-integration-test/src/test/java/io/sermant/integration/router/RouterTest.java
@@ -1,5 +1,5 @@
 /*
- * Copyright (C) 2022-2023 Huawei Technologies Co., Ltd. All rights reserved.
+ * Copyright (C) 2022-2024 Huawei Technologies Co., Ltd. All rights reserved.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -60,7 +60,7 @@ public class RouterTest {
     private final boolean isExecuteSpringTest;
 
     /**
-     * 构造方法
+     * constructor
      */
     public RouterTest() throws InterruptedException {
         testTagRouterBaseUrl =

diff --git a/...ring-test/spring-integration-test/src/test/java/io/sermant/integration/lane/LaneTest.java b/...ring-test/spring-integration-test/src/test/java/io/sermant/integration/lane/LaneTest.java
@@ -1,5 +1,5 @@
 /*
- * Copyright (C) 2023-2023 Huawei Technologies Co., Ltd. All rights reserved.
+ * Copyright (C) 2023-2024 Huawei Technologies Co., Ltd. All rights reserved.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -90,7 +90,7 @@ public class LaneTest {
     private final boolean shouldTestWebclient;
 
     /**
-     * 构造方法
+     * constructor
      */
     public LaneTest() {
         springCloudVersion = Optional.ofNullable(System.getenv("SPRING_CLOUD_VERSION")).orElse("Hoxton.RELEASE");

diff --git a/...st/spring-integration-test/src/test/java/io/sermant/integration/router/TagRouterTest.java b/...st/spring-integration-test/src/test/java/io/sermant/integration/router/TagRouterTest.java
@@ -1,5 +1,5 @@
 /*
- * Copyright (C) 2022-2023 Huawei Technologies Co., Ltd. All rights reserved.
+ * Copyright (C) 2022-2024 Huawei Technologies Co., Ltd. All rights reserved.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -92,7 +92,7 @@ public class TagRouterTest {
     private final String springCloudVersion;
 
     /**
-     * 构造方法
+     * constructor
      */
     public TagRouterTest() throws InterruptedException {
         springCloudVersion = Optional.ofNullable(System.getenv("SPRING_CLOUD_VERSION")).orElse("Hoxton.RELEASE");

diff --git a/...loadbalancer-plugin/src/main/java/io/sermant/loadbalancer/interceptor/UrlInterceptor.java b/...loadbalancer-plugin/src/main/java/io/sermant/loadbalancer/interceptor/UrlInterceptor.java
@@ -1,5 +1,5 @@
 /*
- * Copyright (C) 2022-2022 Huawei Technologies Co., Ltd. All rights reserved.
+ * Copyright (C) 2022-2024 Huawei Technologies Co., Ltd. All rights reserved.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -66,7 +66,7 @@ public class UrlInterceptor extends AbstractInterceptor {
     private Set<String> supportRules;
 
     /**
-     * 构造方法
+     * constructor
      */
     public UrlInterceptor() {
         config = PluginConfigManager.getPluginConfig(LoadbalancerConfig.class);

diff --git a/...balancer-plugin/src/main/java/io/sermant/loadbalancer/declarer/ClientFactoryDeclarer.java b/...balancer-plugin/src/main/java/io/sermant/loadbalancer/declarer/ClientFactoryDeclarer.java
@@ -1,5 +1,5 @@
 /*
- * Copyright (C) 2022-2022 Huawei Technologies Co., Ltd. All rights reserved.
+ * Copyright (C) 2022-2024 Huawei Technologies Co., Ltd. All rights reserved.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -32,7 +32,7 @@ public class ClientFactoryDeclarer extends AbstractDeclarer {
     private static final String METHOD_NAME = "getInstance";
 
     /**
-     * 构造方法
+     * constructor
      */
     public ClientFactoryDeclarer() {
         super(ENHANCE_CLASS, INTERCEPT_CLASS, METHOD_NAME);

diff --git a/...tor-plugin/src/main/java/io/sermant/monitor/interceptor/DispatcherServletInterceptor.java b/...tor-plugin/src/main/java/io/sermant/monitor/interceptor/DispatcherServletInterceptor.java
@@ -40,7 +40,7 @@ public class DispatcherServletInterceptor extends AbstractInterceptor {
     private Function<Object, String> getRequestUri;
 
     /**
-     * 构造方法
+     * constructor
      */
     public DispatcherServletInterceptor() {
         initFunction();

diff --git a/...ava/io/sermant/router/dubbo/interceptor/ServiceDiscoveryRegistryDirectoryInterceptor.java b/...ava/io/sermant/router/dubbo/interceptor/ServiceDiscoveryRegistryDirectoryInterceptor.java
@@ -39,7 +39,7 @@ public class ServiceDiscoveryRegistryDirectoryInterceptor extends AbstractInterc
     private final AtomicBoolean isInitialized = new AtomicBoolean();
 
     /**
-     * 构造方法
+     * constructor
      */
     public ServiceDiscoveryRegistryDirectoryInterceptor() {
         invokerRuleStrategyService = PluginServiceManager.getPluginService(InvokerRuleStrategyService.class);

diff --git a/.../spring-router-plugin/src/main/java/io/sermant/router/spring/handler/AbstractHandler.java b/.../spring-router-plugin/src/main/java/io/sermant/router/spring/handler/AbstractHandler.java
@@ -1,5 +1,5 @@
 /*
- * Copyright (C) 2023-2023 Huawei Technologies Co., Ltd. All rights reserved.
+ * Copyright (C) 2023-2024 Huawei Technologies Co., Ltd. All rights reserved.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -60,6 +60,19 @@ protected Map<String, List<String>> getRequestTag(Map<String, List<String>> head
         return map;
     }
 
+    /**
+     * Obtain transparent tags
+     *
+     * @param path The path of the request
+     * @param methodName http method
+     * @param headers HTTP request headers
+     * @param parameters URL parameter
+     * @param keys The key of the tag to be obtained
+     * @return Marks for transparent transmission
+     */
+    public abstract Map<String, List<String>> getRequestTag(String path, String methodName,
+            Map<String, List<String>> headers, Map<String, List<String>> parameters, Keys keys);
+
     /**
      * Collect Lane Count Metric.
      *
@@ -87,4 +100,35 @@ protected void collectLaneCountMetric(Map<String, List<String>> laneTag) {
             });
         });
     }
+
+    /**
+     * Transparent transmission marks the key entity
+     *
+     * @author provenceee
+     * @since 2023-02-21
+     */
+    public static class Keys {
+        private final Set<String> matchKeys;
+
+        private final Set<String> injectTags;
+
+        /**
+         * Constructor
+         *
+         * @param matchKeys Label routing transparent transmission markers
+         * @param injectTags Swim lane transparent markers
+         */
+        public Keys(Set<String> matchKeys, Set<String> injectTags) {
+            this.matchKeys = matchKeys;
+            this.injectTags = injectTags;
+        }
+
+        public Set<String> getMatchKeys() {
+            return matchKeys;
+        }
+
+        public Set<String> getInjectTags() {
+            return injectTags;
+        }
+    }
 }
diff --git a/...-router-plugin/src/main/java/io/sermant/router/spring/handler/AbstractMappingHandler.java b/...-router-plugin/src/main/java/io/sermant/router/spring/handler/AbstractMappingHandler.java
diff --git a/...uter-plugin/src/main/java/io/sermant/router/spring/handler/AbstractRequestTagHandler.java b/...uter-plugin/src/main/java/io/sermant/router/spring/handler/AbstractRequestTagHandler.java