add ut

spring-cloud-starter-tencent-metadata-transfer/src/test/java/com/tencent/cloud/metadata/config/MetadataTransferAutoConfigurationTest.java

@@ -26,6 +26,7 @@ import java.util.stream.Collectors;
 
 import com.tencent.cloud.metadata.core.EncodeTransferMedataFeignInterceptor;
 import com.tencent.cloud.metadata.core.EncodeTransferMedataRestTemplateInterceptor;
+import com.tencent.cloud.metadata.core.EncodeTransferMedataWebClientFilter;
 import org.junit.jupiter.api.Test;
 
 import org.springframework.boot.autoconfigure.AutoConfigurations;
@@ -61,6 +62,7 @@ public class MetadataTransferAutoConfigurationTest {
 					assertThat(context).hasSingleBean(EncodeTransferMedataRestTemplateInterceptor.class);
 					assertThat(context).hasSingleBean(MetadataTransferAutoConfiguration.MetadataTransferScgFilterConfig.class);
 					assertThat(context).hasSingleBean(GlobalFilter.class);
+					assertThat(context).hasSingleBean(EncodeTransferMedataWebClientFilter.class);
 				});
 	}
 

spring-cloud-starter-tencent-metadata-transfer/src/test/java/com/tencent/cloud/metadata/core/EncodeTransferMedataWebClientFilterTest.java

@@ -0,0 +1,82 @@
+/*
+ * Tencent is pleased to support the open source community by making Spring Cloud Tencent available.
+ *
+ * Copyright (C) 2019 THL A29 Limited, a Tencent company. All rights reserved.
+ *
+ * Licensed under the BSD 3-Clause License (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://opensource.org/licenses/BSD-3-Clause
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed
+ * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
+ * CONDITIONS OF ANY KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations under the License.
+ *
+ */
+
+package com.tencent.cloud.metadata.core;
+
+import com.tencent.cloud.common.metadata.MetadataContext;
+import com.tencent.cloud.common.metadata.MetadataContextHolder;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.boot.web.server.LocalServerPort;
+import org.springframework.context.annotation.Bean;
+import org.springframework.test.context.junit.jupiter.SpringExtension;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.reactive.function.client.WebClient;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.springframework.boot.test.context.SpringBootTest.WebEnvironment.RANDOM_PORT;
+
+/**
+ * Test for {@link EncodeTransferMedataWebClientFilter}.
+ *
+ * @author sean yu
+ */
+@ExtendWith(SpringExtension.class)
+@SpringBootTest(webEnvironment = RANDOM_PORT,
+		classes = EncodeTransferMedataWebClientFilterTest.TestApplication.class,
+		properties = {"spring.config.location = classpath:application-test.yml"})
+public class EncodeTransferMedataWebClientFilterTest {
+
+	@Autowired
+	private WebClient.Builder webClientBuilder;
+
+	@Test
+	public void testTransitiveMetadataFromApplicationConfig() {
+		String metadata = webClientBuilder.baseUrl("http://localhost:" + localServerPort).build()
+				.get()
+				.uri("/test")
+				.retrieve()
+				.bodyToMono(String.class)
+				.block();
+		assertThat(metadata).isEqualTo("2");
+	}
+
+	@LocalServerPort
+	private int localServerPort;
+
+
+	@SpringBootApplication
+	@RestController
+	protected static class TestApplication {
+
+		@Bean
+		public WebClient.Builder webClientBuilder() {
+			return WebClient.builder();
+		}
+
+		@RequestMapping("/test")
+		public String test() {
+			return MetadataContextHolder.get().getContext(MetadataContext.FRAGMENT_TRANSITIVE, "b");
+		}
+	}
+}

spring-cloud-tencent-examples/polaris-ratelimit-example/ratelimit-callee-service/src/main/java/com/tencent/cloud/ratelimit/example/service/callee/BusinessController.java

@@ -59,7 +59,7 @@ public class BusinessController {
 	@Autowired
 	private RestTemplate restTemplate;
 	@Autowired
-	private WebClient.Builder WebClientBuilder;
+	private WebClient.Builder webClientBuilder;
 	@Value("${spring.application.name}")
 	private String appName;
 
@@ -81,7 +81,7 @@ public class BusinessController {
 	@GetMapping("/invoke/webclient")
 	public String invokeInfoWebClient() throws InterruptedException, ExecutionException {
 		StringBuffer builder = new StringBuffer();
-		WebClient webClient = WebClientBuilder.baseUrl("http://" + appName).build();
+		WebClient webClient = webClientBuilder.baseUrl("http://" + appName).build();
 		List<Mono<String>> monoList = new ArrayList<>();
 		for (int i = 0; i < 30; i++) {
 			Mono<String> response = webClient.get()