Merge pull request #113 from lepdou/2020/optimize_metadata

refactor transfer metadata

CHANGELOG.md

@@ -1,9 +1,10 @@
 # Change Log
 ---
 
-- [Bugfix: fix router bug and add router example](https://github.com/Tencent/spring-cloud-tencent/pull/109)
-- [feat:add custom label resolver spi for rate limit](https://github.com/Tencent/spring-cloud-tencent/pull/107)
-- [feat:fix discovery weight param not set to register request bug](https://github.com/Tencent/spring-cloud-tencent/pull/104)
-- [Bugfix: fix causing cpu 100% when set ScheduledThreadPoolExecutor corePoolSize=0](https://github.com/Tencent/spring-cloud-tencent/pull/101)
+- [Bugfix: fix router bug and add router example](https://github.com/Tencent/spring-cloud-tencent/pull/89)
+- [feat:add custom label resolver spi for rate limit](https://github.com/Tencent/spring-cloud-tencent/pull/105)
+- [feat:fix discovery weight param not set to register request bug](https://github.com/Tencent/spring-cloud-tencent/pull/102)
+- [Bugfix: fix causing cpu 100% when set ScheduledThreadPoolExecutor corePoolSize=0](https://github.com/Tencent/spring-cloud-tencent/pull/98)
+- [Refactor: refactor transfer metadata](https://github.com/Tencent/spring-cloud-tencent/pull/113)
 - [Bugfix: fix circuitbreaker http code greater than 400 as fail response bug](https://github.com/Tencent/spring-cloud-tencent/pull/118)
 - [Feat: optimize router dependency](https://github.com/Tencent/spring-cloud-tencent/pull/115)

spring-cloud-starter-tencent-metadata-transfer/pom.xml

@@ -33,6 +33,12 @@
 			<optional>true</optional>
 		</dependency>
 
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-web</artifactId>
+			<optional>true</optional>
+		</dependency>
+		
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter-test</artifactId>

spring-cloud-starter-tencent-metadata-transfer/src/main/java/com/tencent/cloud/metadata/config/MetadataTransferAutoConfiguration.java

@@ -13,6 +13,7 @@
  * 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.config;
@@ -20,13 +21,18 @@ package com.tencent.cloud.metadata.config;
 import java.util.List;
 import java.util.Map;
 
-import com.tencent.cloud.metadata.core.filter.gateway.Metadata2HeaderScgFilter;
-import com.tencent.cloud.metadata.core.interceptor.Metadata2HeaderFeignInterceptor;
-import com.tencent.cloud.metadata.core.interceptor.Metadata2HeaderRestTemplateInterceptor;
+import com.tencent.cloud.common.constant.MetadataConstant;
+import com.tencent.cloud.metadata.core.DecodeTransferMetadataReactiveFilter;
+import com.tencent.cloud.metadata.core.DecodeTransferMetadataServletFilter;
+import com.tencent.cloud.metadata.core.EncodeTransferMedataFeignInterceptor;
+import com.tencent.cloud.metadata.core.EncodeTransferMedataRestTemplateInterceptor;
+import com.tencent.cloud.metadata.core.EncodeTransferMedataScgFilter;
 
 import org.springframework.beans.BeansException;
 import org.springframework.beans.factory.config.BeanPostProcessor;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnWebApplication;
+import org.springframework.boot.web.servlet.FilterRegistrationBean;
 import org.springframework.cloud.gateway.filter.GlobalFilter;
 import org.springframework.context.ApplicationContext;
 import org.springframework.context.ApplicationContextAware;
@@ -36,6 +42,11 @@ import org.springframework.http.client.ClientHttpRequestInterceptor;
 import org.springframework.util.CollectionUtils;
 import org.springframework.web.client.RestTemplate;
 
+import static javax.servlet.DispatcherType.ASYNC;
+import static javax.servlet.DispatcherType.ERROR;
+import static javax.servlet.DispatcherType.FORWARD;
+import static javax.servlet.DispatcherType.INCLUDE;
+import static javax.servlet.DispatcherType.REQUEST;
 /**
  * Metadata transfer auto configuration.
  *
@@ -44,6 +55,46 @@ import org.springframework.web.client.RestTemplate;
 @Configuration
 public class MetadataTransferAutoConfiguration {
 
+	/**
+	 * Create when web application type is SERVLET.
+	 */
+	@Configuration
+	@ConditionalOnWebApplication(type = ConditionalOnWebApplication.Type.SERVLET)
+	static class MetadataServletFilterConfig {
+
+		@Bean
+		public FilterRegistrationBean<DecodeTransferMetadataServletFilter> metadataServletFilterRegistrationBean(
+				DecodeTransferMetadataServletFilter decodeTransferMetadataServletFilter) {
+			FilterRegistrationBean<DecodeTransferMetadataServletFilter> filterRegistrationBean = new FilterRegistrationBean<>(
+					decodeTransferMetadataServletFilter);
+			filterRegistrationBean.setDispatcherTypes(ASYNC, ERROR, FORWARD, INCLUDE,
+					REQUEST);
+			filterRegistrationBean
+					.setOrder(MetadataConstant.OrderConstant.WEB_FILTER_ORDER);
+			return filterRegistrationBean;
+		}
+
+		@Bean
+		public DecodeTransferMetadataServletFilter metadataServletFilter() {
+			return new DecodeTransferMetadataServletFilter();
+		}
+
+	}
+
+	/**
+	 * Create when web application type is REACTIVE.
+	 */
+	@Configuration
+	@ConditionalOnWebApplication(type = ConditionalOnWebApplication.Type.REACTIVE)
+	static class MetadataReactiveFilterConfig {
+
+		@Bean
+		public DecodeTransferMetadataReactiveFilter metadataReactiveFilter() {
+			return new DecodeTransferMetadataReactiveFilter();
+		}
+
+	}
+
 	/**
 	 * Create when gateway application is SCG.
 	 */
@@ -52,8 +103,8 @@ public class MetadataTransferAutoConfiguration {
 	static class MetadataTransferScgFilterConfig {
 
 		@Bean
-		public GlobalFilter metadata2HeaderScgFilter() {
-			return new Metadata2HeaderScgFilter();
+		public GlobalFilter encodeTransferMedataScgFilter() {
+			return new EncodeTransferMedataScgFilter();
 		}
 
 	}
@@ -66,8 +117,8 @@ public class MetadataTransferAutoConfiguration {
 	static class MetadataTransferFeignInterceptorConfig {
 
 		@Bean
-		public Metadata2HeaderFeignInterceptor metadata2HeaderFeignInterceptor() {
-			return new Metadata2HeaderFeignInterceptor();
+		public EncodeTransferMedataFeignInterceptor encodeTransferMedataFeignInterceptor() {
+			return new EncodeTransferMedataFeignInterceptor();
 		}
 
 	}
@@ -82,13 +133,13 @@ public class MetadataTransferAutoConfiguration {
 		private ApplicationContext context;
 
 		@Bean
-		public Metadata2HeaderRestTemplateInterceptor metadata2HeaderRestTemplateInterceptor() {
-			return new Metadata2HeaderRestTemplateInterceptor();
+		public EncodeTransferMedataRestTemplateInterceptor encodeTransferMedataRestTemplateInterceptor() {
+			return new EncodeTransferMedataRestTemplateInterceptor();
 		}
 
 		@Bean
-		BeanPostProcessor metadata2HeaderRestTemplatePostProcessor(
-				Metadata2HeaderRestTemplateInterceptor metadata2HeaderRestTemplateInterceptor) {
+		BeanPostProcessor encodeTransferMetadataRestTemplatePostProcessor(
+				EncodeTransferMedataRestTemplateInterceptor encodeTransferMedataRestTemplateInterceptor) {
 			// Coping with multiple bean injection scenarios
 			Map<String, RestTemplate> beans = this.context.getBeansOfType(RestTemplate.class);
 			// If the restTemplate has been created when the
@@ -98,13 +149,15 @@ public class MetadataTransferAutoConfiguration {
 				for (RestTemplate restTemplate : beans.values()) {
 					List<ClientHttpRequestInterceptor> interceptors = restTemplate.getInterceptors();
 					// Avoid setting interceptor repeatedly.
-					if (null != interceptors && !interceptors.contains(metadata2HeaderRestTemplateInterceptor)) {
-						interceptors.add(metadata2HeaderRestTemplateInterceptor);
+					if (null != interceptors && !interceptors
+							.contains(encodeTransferMedataRestTemplateInterceptor)) {
+						interceptors.add(encodeTransferMedataRestTemplateInterceptor);
 						restTemplate.setInterceptors(interceptors);
 					}
 				}
 			}
-			return new Metadata2HeaderRestTemplatePostProcessor(metadata2HeaderRestTemplateInterceptor);
+			return new EncodeTransferMetadataRestTemplatePostProcessor(
+					encodeTransferMedataRestTemplateInterceptor);
 		}
 
 		@Override
@@ -112,13 +165,14 @@ public class MetadataTransferAutoConfiguration {
 			this.context = applicationContext;
 		}
 
-		public static class Metadata2HeaderRestTemplatePostProcessor implements BeanPostProcessor {
+		public static class EncodeTransferMetadataRestTemplatePostProcessor
+				implements BeanPostProcessor {
 
-			private Metadata2HeaderRestTemplateInterceptor metadata2HeaderRestTemplateInterceptor;
+			private EncodeTransferMedataRestTemplateInterceptor encodeTransferMedataRestTemplateInterceptor;
 
-			Metadata2HeaderRestTemplatePostProcessor(
-					Metadata2HeaderRestTemplateInterceptor metadata2HeaderRestTemplateInterceptor) {
-				this.metadata2HeaderRestTemplateInterceptor = metadata2HeaderRestTemplateInterceptor;
+			EncodeTransferMetadataRestTemplatePostProcessor(
+					EncodeTransferMedataRestTemplateInterceptor encodeTransferMedataRestTemplateInterceptor) {
+				this.encodeTransferMedataRestTemplateInterceptor = encodeTransferMedataRestTemplateInterceptor;
 			}
 
 			@Override
@@ -132,8 +186,9 @@ public class MetadataTransferAutoConfiguration {
 					RestTemplate restTemplate = (RestTemplate) bean;
 					List<ClientHttpRequestInterceptor> interceptors = restTemplate.getInterceptors();
 					// Avoid setting interceptor repeatedly.
-					if (null != interceptors && !interceptors.contains(metadata2HeaderRestTemplateInterceptor)) {
-						interceptors.add(this.metadata2HeaderRestTemplateInterceptor);
+					if (null != interceptors && !interceptors
+							.contains(encodeTransferMedataRestTemplateInterceptor)) {
+						interceptors.add(this.encodeTransferMedataRestTemplateInterceptor);
 						restTemplate.setInterceptors(interceptors);
 					}
 				}

spring-cloud-starter-tencent-metadata-transfer/src/main/java/com/tencent/cloud/metadata/core/DecodeTransferMetadataReactiveFilter.java

@@ -13,9 +13,10 @@
  * 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.common.metadata.filter.web;
+package com.tencent.cloud.metadata.core;
 
 import java.io.UnsupportedEncodingException;
 import java.net.URLDecoder;
@@ -42,9 +43,10 @@ import org.springframework.web.server.WebFilterChain;
  *
  * @author Haotian Zhang
  */
-public class MetadataReactiveFilter implements WebFilter, Ordered {
+public class DecodeTransferMetadataReactiveFilter implements WebFilter, Ordered {
 
-	private static final Logger LOG = LoggerFactory.getLogger(MetadataReactiveFilter.class);
+	private static final Logger LOG = LoggerFactory
+			.getLogger(DecodeTransferMetadataReactiveFilter.class);
 
 	@Override
 	public int getOrder() {

spring-cloud-starter-tencent-metadata-transfer/src/main/java/com/tencent/cloud/metadata/core/DecodeTransferMetadataServletFilter.java

@@ -13,9 +13,10 @@
  * 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.common.metadata.filter.web;
+package com.tencent.cloud.metadata.core;
 
 import java.io.IOException;
 import java.io.UnsupportedEncodingException;
@@ -44,9 +45,10 @@ import org.springframework.web.filter.OncePerRequestFilter;
  * @author Haotian Zhang
  */
 @Order(MetadataConstant.OrderConstant.WEB_FILTER_ORDER)
-public class MetadataServletFilter extends OncePerRequestFilter {
+public class DecodeTransferMetadataServletFilter extends OncePerRequestFilter {
 
-	private static final Logger LOG = LoggerFactory.getLogger(MetadataServletFilter.class);
+	private static final Logger LOG = LoggerFactory
+			.getLogger(DecodeTransferMetadataServletFilter.class);
 
 	@Override
 	protected void doFilterInternal(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse,

spring-cloud-starter-tencent-metadata-transfer/src/main/java/com/tencent/cloud/metadata/core/EncodeTransferMedataFeignInterceptor.java

@@ -13,9 +13,10 @@
  * 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.interceptor;
+package com.tencent.cloud.metadata.core;
 
 import java.io.UnsupportedEncodingException;
 import java.net.URLEncoder;
@@ -41,9 +42,10 @@ import static com.tencent.cloud.common.constant.MetadataConstant.HeaderName.CUST
  *
  * @author Haotian Zhang
  */
-public class Metadata2HeaderFeignInterceptor implements RequestInterceptor, Ordered {
+public class EncodeTransferMedataFeignInterceptor implements RequestInterceptor, Ordered {
 
-	private static final Logger LOG = LoggerFactory.getLogger(Metadata2HeaderFeignInterceptor.class);
+	private static final Logger LOG = LoggerFactory
+			.getLogger(EncodeTransferMedataFeignInterceptor.class);
 
 	@Override
 	public int getOrder() {

spring-cloud-starter-tencent-metadata-transfer/src/main/java/com/tencent/cloud/metadata/core/EncodeTransferMedataRestTemplateInterceptor.java

@@ -13,9 +13,10 @@
  * 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.interceptor;
+package com.tencent.cloud.metadata.core;
 
 import java.io.IOException;
 import java.io.UnsupportedEncodingException;
@@ -41,7 +42,8 @@ import org.springframework.util.CollectionUtils;
  *
  * @author Haotian Zhang
  */
-public class Metadata2HeaderRestTemplateInterceptor implements ClientHttpRequestInterceptor, Ordered {
+public class EncodeTransferMedataRestTemplateInterceptor
+		implements ClientHttpRequestInterceptor, Ordered {
 
 	@Override
 	public int getOrder() {

spring-cloud-starter-tencent-metadata-transfer/src/main/java/com/tencent/cloud/metadata/core/EncodeTransferMedataScgFilter.java

@@ -13,9 +13,10 @@
  * 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.filter.gateway;
+package com.tencent.cloud.metadata.core;
 
 import java.io.UnsupportedEncodingException;
 import java.net.URLEncoder;
@@ -41,7 +42,7 @@ import static org.springframework.cloud.gateway.filter.ReactiveLoadBalancerClien
  *
  * @author Haotian Zhang
  */
-public class Metadata2HeaderScgFilter implements GlobalFilter, Ordered {
+public class EncodeTransferMedataScgFilter implements GlobalFilter, Ordered {
 
 	private static final int METADATA_SCG_FILTER_ORDER = LOAD_BALANCER_CLIENT_FILTER_ORDER + 1;
 

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

@@ -13,12 +13,14 @@
  * 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.common.metadata.filter.web;
+package com.tencent.cloud.metadata;
 
 import com.tencent.cloud.common.constant.MetadataConstant;
 import com.tencent.cloud.common.metadata.config.MetadataLocalProperties;
+import com.tencent.cloud.metadata.core.DecodeTransferMetadataReactiveFilter;
 import org.assertj.core.api.Assertions;
 import org.junit.Before;
 import org.junit.Test;
@@ -36,23 +38,23 @@ import org.springframework.web.server.WebFilterChain;
 import static org.springframework.boot.test.context.SpringBootTest.WebEnvironment.MOCK;
 
 /**
- * Test for {@link MetadataReactiveFilter}
  *
  * @author Haotian Zhang
  */
 @RunWith(SpringRunner.class)
-@SpringBootTest(webEnvironment = MOCK, classes = MetadataServletFilterTest.TestApplication.class,
+@SpringBootTest(webEnvironment = MOCK,
+		classes = DecodeTransferMetadataServletFilterTest.TestApplication.class,
 		properties = {"spring.config.location = classpath:application-test.yml"})
-public class MetadataReactiveFilterTest {
+public class DecodeTransferMetadataReactiveFilterTest {
 
 	@Autowired
 	private MetadataLocalProperties metadataLocalProperties;
 
-	private MetadataReactiveFilter metadataReactiveFilter;
+	private DecodeTransferMetadataReactiveFilter metadataReactiveFilter;
 
 	@Before
 	public void setUp() {
-		this.metadataReactiveFilter = new MetadataReactiveFilter();
+		this.metadataReactiveFilter = new DecodeTransferMetadataReactiveFilter();
 	}
 
 	@Test

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

@@ -13,9 +13,10 @@
  * 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.common.metadata.filter.web;
+package com.tencent.cloud.metadata;
 
 import java.io.IOException;
 
@@ -24,6 +25,7 @@ import javax.servlet.ServletException;
 
 import com.tencent.cloud.common.constant.MetadataConstant;
 import com.tencent.cloud.common.metadata.config.MetadataLocalProperties;
+import com.tencent.cloud.metadata.core.DecodeTransferMetadataServletFilter;
 import org.assertj.core.api.Assertions;
 import org.junit.Test;
 import org.junit.runner.RunWith;
@@ -38,20 +40,20 @@ import org.springframework.test.context.junit4.SpringRunner;
 import static org.springframework.boot.test.context.SpringBootTest.WebEnvironment.RANDOM_PORT;
 
 /**
- * Test for {@link MetadataServletFilter}
  *
  * @author Haotian Zhang
  */
 @RunWith(SpringRunner.class)
-@SpringBootTest(webEnvironment = RANDOM_PORT, classes = MetadataServletFilterTest.TestApplication.class,
+@SpringBootTest(webEnvironment = RANDOM_PORT,
+		classes = DecodeTransferMetadataServletFilterTest.TestApplication.class,
 		properties = {"spring.config.location = classpath:application-test.yml"})
-public class MetadataServletFilterTest {
+public class DecodeTransferMetadataServletFilterTest {
 
 	@Autowired
 	private MetadataLocalProperties metadataLocalProperties;
 
 	@Autowired
-	private MetadataServletFilter metadataServletFilter;
+	private DecodeTransferMetadataServletFilter metadataServletFilter;
 
 	@Test
 	public void test1() throws ServletException, IOException {

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

@@ -13,12 +13,13 @@
  * 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.config;
 
-import com.tencent.cloud.metadata.core.interceptor.Metadata2HeaderFeignInterceptor;
-import com.tencent.cloud.metadata.core.interceptor.Metadata2HeaderRestTemplateInterceptor;
+import com.tencent.cloud.metadata.core.EncodeTransferMedataFeignInterceptor;
+import com.tencent.cloud.metadata.core.EncodeTransferMedataRestTemplateInterceptor;
 import org.assertj.core.api.Assertions;
 import org.junit.Test;
 
@@ -44,14 +45,16 @@ public class MetadataTransferAutoConfigurationTest {
 				.run(context -> {
 					Assertions.assertThat(context).hasSingleBean(
 							MetadataTransferAutoConfiguration.MetadataTransferFeignInterceptorConfig.class);
-					Assertions.assertThat(context).hasSingleBean(Metadata2HeaderFeignInterceptor.class);
 					Assertions.assertThat(context)
-							.hasSingleBean(MetadataTransferAutoConfiguration.MetadataTransferRestTemplateConfig.class);
-					Assertions.assertThat(context).hasSingleBean(Metadata2HeaderRestTemplateInterceptor.class);
+							.hasSingleBean(EncodeTransferMedataFeignInterceptor.class);
 					Assertions.assertThat(context).hasSingleBean(
-							MetadataTransferAutoConfiguration.MetadataTransferRestTemplateConfig.Metadata2HeaderRestTemplatePostProcessor.class);
+							MetadataTransferAutoConfiguration.MetadataTransferRestTemplateConfig.class);
 					Assertions.assertThat(context)
-							.hasSingleBean(MetadataTransferAutoConfiguration.MetadataTransferScgFilterConfig.class);
+							.hasSingleBean(EncodeTransferMedataRestTemplateInterceptor.class);
+					Assertions.assertThat(context).hasSingleBean(
+							MetadataTransferAutoConfiguration.MetadataTransferRestTemplateConfig.EncodeTransferMetadataRestTemplatePostProcessor.class);
+					Assertions.assertThat(context).hasSingleBean(
+							MetadataTransferAutoConfiguration.MetadataTransferScgFilterConfig.class);
 					Assertions.assertThat(context).hasSingleBean(GlobalFilter.class);
 				});
 	}

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

@@ -13,6 +13,7 @@
  * 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.intercepter;
@@ -25,7 +26,7 @@ import com.tencent.cloud.common.constant.MetadataConstant;
 import com.tencent.cloud.common.metadata.MetadataContextHolder;
 import com.tencent.cloud.common.metadata.config.MetadataLocalProperties;
 import com.tencent.cloud.common.util.JacksonUtils;
-import com.tencent.cloud.metadata.core.interceptor.Metadata2HeaderFeignInterceptor;
+import com.tencent.cloud.metadata.core.EncodeTransferMedataFeignInterceptor;
 import feign.RequestInterceptor;
 import feign.RequestTemplate;
 import org.assertj.core.api.Assertions;
@@ -51,14 +52,16 @@ import org.springframework.web.bind.annotation.RestController;
 import static org.springframework.boot.test.context.SpringBootTest.WebEnvironment.DEFINED_PORT;
 
 /**
- * Test for {@link Metadata2HeaderFeignInterceptor}
+ * Test for {@link EncodeTransferMedataFeignInterceptor}
  *
  * @author Haotian Zhang
  */
 @RunWith(SpringRunner.class)
-@SpringBootTest(webEnvironment = DEFINED_PORT, classes = Metadata2HeaderFeignInterceptorTest.TestApplication.class,
-		properties = { "server.port=8081", "spring.config.location = classpath:application-test.yml" })
-public class Metadata2HeaderFeignInterceptorTest {
+@SpringBootTest(webEnvironment = DEFINED_PORT,
+		classes = EncodeTransferMedataFeignInterceptorTest.TestApplication.class,
+		properties = { "server.port=8081",
+				"spring.config.location = classpath:application-test.yml" })
+public class EncodeTransferMedataFeignInterceptorTest {
 
 	@Autowired
 	private MetadataLocalProperties metadataLocalProperties;

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

@@ -13,6 +13,7 @@
  * 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.intercepter;
@@ -24,7 +25,7 @@ import com.tencent.cloud.common.constant.MetadataConstant;
 import com.tencent.cloud.common.metadata.MetadataContextHolder;
 import com.tencent.cloud.common.metadata.config.MetadataLocalProperties;
 import com.tencent.cloud.common.util.JacksonUtils;
-import com.tencent.cloud.metadata.core.interceptor.Metadata2HeaderRestTemplateInterceptor;
+import com.tencent.cloud.metadata.core.EncodeTransferMedataRestTemplateInterceptor;
 import org.assertj.core.api.Assertions;
 import org.junit.Test;
 import org.junit.runner.RunWith;
@@ -46,15 +47,15 @@ import org.springframework.web.client.RestTemplate;
 import static org.springframework.boot.test.context.SpringBootTest.WebEnvironment.RANDOM_PORT;
 
 /**
- * Test for {@link Metadata2HeaderRestTemplateInterceptor}
+ * Test for {@link EncodeTransferMedataRestTemplateInterceptor}
  *
  * @author Haotian Zhang
  */
 @RunWith(SpringRunner.class)
 @SpringBootTest(webEnvironment = RANDOM_PORT,
-		classes = Metadata2HeaderRestTemplateInterceptorTest.TestApplication.class,
+		classes = EncodeTransferMedataRestTemplateInterceptorTest.TestApplication.class,
 		properties = { "spring.config.location = classpath:application-test.yml" })
-public class Metadata2HeaderRestTemplateInterceptorTest {
+public class EncodeTransferMedataRestTemplateInterceptorTest {
 
 	@Autowired
 	private MetadataLocalProperties metadataLocalProperties;

spring-cloud-starter-tencent-polaris-discovery/src/main/java/com/tencent/cloud/polaris/PolarisDiscoveryProperties.java

@@ -49,7 +49,7 @@ public class PolarisDiscoveryProperties {
 	/**
 	 * Service name to registry.
 	 */
-	@Value("${spring.cloud.polaris.discovery.service:${spring.application.name:}}")
+	@Value("${spring.cloud.polaris.discovery.service:${spring.cloud.polaris.service:${spring.application.name:}}}")
 	private String service;
 
 	/**

spring-cloud-tencent-commons/src/main/java/com/tencent/cloud/common/metadata/MetadataContext.java

@@ -13,6 +13,7 @@
  * 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.common.metadata;
@@ -24,6 +25,8 @@ import java.util.concurrent.ConcurrentHashMap;
 import com.tencent.cloud.common.util.ApplicationContextAwareUtils;
 import com.tencent.cloud.common.util.JacksonUtils;
 
+import org.springframework.util.StringUtils;
+
 /**
  * Metadata Context.
  *
@@ -34,15 +37,12 @@ public class MetadataContext {
 	/**
 	 * Namespace of local instance.
 	 */
-	public static final String LOCAL_NAMESPACE = ApplicationContextAwareUtils
-			.getProperties("spring.cloud.polaris.discovery.namespace", "default");
+	public static String LOCAL_NAMESPACE;
 
 	/**
 	 * Service name of local instance.
 	 */
-	public static final String LOCAL_SERVICE = ApplicationContextAwareUtils.getProperties(
-			"spring.cloud.polaris.discovery.service",
-			ApplicationContextAwareUtils.getProperties("spring.application.name", null));
+	public static String LOCAL_SERVICE;
 
 	/**
 	 * Transitive custom metadata content.
@@ -54,6 +54,22 @@ public class MetadataContext {
 	 */
 	private final Map<String, String> systemMetadata;
 
+	static {
+		String namespace = ApplicationContextAwareUtils.getProperties("spring.cloud.polaris.namespace");
+		if (StringUtils.isEmpty(namespace)) {
+			namespace = ApplicationContextAwareUtils.getProperties("spring.cloud.polaris.discovery.namespace", "default");
+		}
+		LOCAL_NAMESPACE = namespace;
+
+		String serviceName = ApplicationContextAwareUtils.getProperties("spring.cloud.polaris.service");
+		if (StringUtils.isEmpty(serviceName)) {
+			serviceName = ApplicationContextAwareUtils.getProperties(
+					"spring.cloud.polaris.discovery.service",
+					ApplicationContextAwareUtils.getProperties("spring.application.name", null));
+		}
+		LOCAL_SERVICE = serviceName;
+	}
+
 	public MetadataContext() {
 		this.transitiveCustomMetadata = new ConcurrentHashMap<>();
 		this.systemMetadata = new ConcurrentHashMap<>();

spring-cloud-tencent-commons/src/main/java/com/tencent/cloud/common/metadata/config/MetadataAutoConfiguration.java

@@ -13,29 +13,19 @@
  * 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.common.metadata.config;
 
-import com.tencent.cloud.common.constant.MetadataConstant;
 import com.tencent.cloud.common.metadata.filter.gateway.MetadataFirstScgFilter;
-import com.tencent.cloud.common.metadata.filter.web.MetadataReactiveFilter;
-import com.tencent.cloud.common.metadata.filter.web.MetadataServletFilter;
 import com.tencent.cloud.common.metadata.interceptor.feign.MetadataFirstFeignInterceptor;
 
 import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
-import org.springframework.boot.autoconfigure.condition.ConditionalOnWebApplication;
-import org.springframework.boot.web.servlet.FilterRegistrationBean;
 import org.springframework.cloud.gateway.filter.GlobalFilter;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
-import static javax.servlet.DispatcherType.ASYNC;
-import static javax.servlet.DispatcherType.ERROR;
-import static javax.servlet.DispatcherType.FORWARD;
-import static javax.servlet.DispatcherType.INCLUDE;
-import static javax.servlet.DispatcherType.REQUEST;
-
 /**
  * Metadata auto configuration.
  *
@@ -53,44 +43,6 @@ public class MetadataAutoConfiguration {
 		return new MetadataLocalProperties();
 	}
 
-	/**
-	 * Create when web application type is SERVLET.
-	 */
-	@Configuration
-	@ConditionalOnWebApplication(type = ConditionalOnWebApplication.Type.SERVLET)
-	static class MetadataServletFilterConfig {
-
-		@Bean
-		public FilterRegistrationBean<MetadataServletFilter> metadataServletFilterRegistrationBean(
-				MetadataServletFilter metadataServletFilter) {
-			FilterRegistrationBean<MetadataServletFilter> filterRegistrationBean = new FilterRegistrationBean<>(
-					metadataServletFilter);
-			filterRegistrationBean.setDispatcherTypes(ASYNC, ERROR, FORWARD, INCLUDE, REQUEST);
-			filterRegistrationBean.setOrder(MetadataConstant.OrderConstant.WEB_FILTER_ORDER);
-			return filterRegistrationBean;
-		}
-
-		@Bean
-		public MetadataServletFilter metadataServletFilter() {
-			return new MetadataServletFilter();
-		}
-
-	}
-
-	/**
-	 * Create when web application type is REACTIVE.
-	 */
-	@Configuration
-	@ConditionalOnWebApplication(type = ConditionalOnWebApplication.Type.REACTIVE)
-	static class MetadataReactiveFilterConfig {
-
-		@Bean
-		public MetadataReactiveFilter metadataReactiveFilter() {
-			return new MetadataReactiveFilter();
-		}
-
-	}
-
 	/**
 	 * Create when Feign exists.
 	 */

spring-cloud-tencent-commons/src/test/java/com/tencent/cloud/common/metadata/config/MetadataAutoConfigurationTest.java

@@ -13,13 +13,12 @@
  * 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.common.metadata.config;
 
 import com.tencent.cloud.common.metadata.filter.gateway.MetadataFirstScgFilter;
-import com.tencent.cloud.common.metadata.filter.web.MetadataReactiveFilter;
-import com.tencent.cloud.common.metadata.filter.web.MetadataServletFilter;
 import com.tencent.cloud.common.metadata.interceptor.feign.MetadataFirstFeignInterceptor;
 import org.assertj.core.api.Assertions;
 import org.junit.Test;
@@ -49,13 +48,10 @@ public class MetadataAutoConfigurationTest {
 	public void test1() {
 		this.applicationContextRunner.withConfiguration(AutoConfigurations.of(MetadataAutoConfiguration.class))
 				.run(context -> {
-					Assertions.assertThat(context).hasSingleBean(MetadataLocalProperties.class);
-					Assertions.assertThat(context)
-							.doesNotHaveBean(MetadataAutoConfiguration.MetadataServletFilterConfig.class);
-					Assertions.assertThat(context).doesNotHaveBean(MetadataServletFilter.class);
 					Assertions.assertThat(context)
-							.doesNotHaveBean(MetadataAutoConfiguration.MetadataReactiveFilterConfig.class);
-					Assertions.assertThat(context).doesNotHaveBean(MetadataReactiveFilter.class);
+							.hasSingleBean(MetadataLocalProperties.class);
+					Assertions.assertThat(context).hasSingleBean(
+							MetadataAutoConfiguration.MetadataFeignInterceptorConfig.class);
 					Assertions.assertThat(context)
 							.hasSingleBean(MetadataAutoConfiguration.MetadataFeignInterceptorConfig.class);
 					Assertions.assertThat(context).hasSingleBean(MetadataFirstFeignInterceptor.class);
@@ -72,13 +68,10 @@ public class MetadataAutoConfigurationTest {
 	public void test2() {
 		this.webApplicationContextRunner.withConfiguration(AutoConfigurations.of(MetadataAutoConfiguration.class))
 				.run(context -> {
-					Assertions.assertThat(context).hasSingleBean(MetadataLocalProperties.class);
-					Assertions.assertThat(context)
-							.hasSingleBean(MetadataAutoConfiguration.MetadataServletFilterConfig.class);
-					Assertions.assertThat(context).hasSingleBean(MetadataServletFilter.class);
 					Assertions.assertThat(context)
-							.doesNotHaveBean(MetadataAutoConfiguration.MetadataReactiveFilterConfig.class);
-					Assertions.assertThat(context).doesNotHaveBean(MetadataReactiveFilter.class);
+							.hasSingleBean(MetadataLocalProperties.class);
+					Assertions.assertThat(context).hasSingleBean(
+							MetadataAutoConfiguration.MetadataFeignInterceptorConfig.class);
 					Assertions.assertThat(context)
 							.hasSingleBean(MetadataAutoConfiguration.MetadataFeignInterceptorConfig.class);
 					Assertions.assertThat(context).hasSingleBean(MetadataFirstFeignInterceptor.class);
@@ -97,14 +90,9 @@ public class MetadataAutoConfigurationTest {
 				.withConfiguration(AutoConfigurations.of(MetadataAutoConfiguration.class)).run(context -> {
 					Assertions.assertThat(context).hasSingleBean(MetadataLocalProperties.class);
 					Assertions.assertThat(context)
-							.doesNotHaveBean(MetadataAutoConfiguration.MetadataServletFilterConfig.class);
-					Assertions.assertThat(context).doesNotHaveBean(MetadataServletFilter.class);
-					Assertions.assertThat(context)
-							.hasSingleBean(MetadataAutoConfiguration.MetadataReactiveFilterConfig.class);
-					Assertions.assertThat(context).hasSingleBean(MetadataReactiveFilter.class);
-					Assertions.assertThat(context)
-							.hasSingleBean(MetadataAutoConfiguration.MetadataFeignInterceptorConfig.class);
-					Assertions.assertThat(context).hasSingleBean(MetadataFirstFeignInterceptor.class);
+							.hasSingleBean(MetadataLocalProperties.class);
+					Assertions.assertThat(context).hasSingleBean(
+							MetadataAutoConfiguration.MetadataFeignInterceptorConfig.class);
 					Assertions.assertThat(context)
 							.hasSingleBean(MetadataAutoConfiguration.MetadataScgFilterConfig.class);
 					Assertions.assertThat(context).hasSingleBean(MetadataFirstScgFilter.class);

spring-cloud-tencent-polaris-context/src/main/java/com/tencent/cloud/polaris/context/PolarisContextProperties.java

@@ -57,6 +57,11 @@ public class PolarisContextProperties {
 	 */
 	private String namespace = "default";
 
+	/**
+	 * polaris service name.
+	 */
+	private String service;
+
 	@Autowired
 	private Environment environment;
 
@@ -111,4 +116,11 @@ public class PolarisContextProperties {
 		this.namespace = namespace;
 	}
 
+	String getService() {
+		return service;
+	}
+
+	void setService(String service) {
+		this.service = service;
+	}
 }

spring-cloud-tencent-polaris-context/src/main/resources/META-INF/spring-configuration-metadata.json

@@ -20,6 +20,13 @@
       "default": "default",
       "sourceType": "com.tencent.cloud.polaris.context.PolarisContextProperties"
     },
+    {
+      "name": "spring.cloud.polaris.service",
+      "type": "java.lang.String",
+      "description": "polaris service name",
+      "default": "${spring.application.name}",
+      "sourceType": "com.tencent.cloud.polaris.context.PolarisContextProperties"
+    },
     {
       "name": "spring.cloud.polaris.local-ip-address",
       "type": "java.lang.String",