feat: support trace report feature

spring-cloud-starter-tencent-all/pom.xml

@@ -49,6 +49,11 @@
 			<groupId>com.tencent.cloud</groupId>
 			<artifactId>spring-cloud-starter-tencent-polaris-contract</artifactId>
 		</dependency>
+
+		<dependency>
+			<groupId>com.tencent.cloud</groupId>
+			<artifactId>spring-cloud-tencent-trace-plugin</artifactId>
+		</dependency>
 	</dependencies>
 
 	<build>

spring-cloud-tencent-commons/src/main/java/com/tencent/cloud/common/constant/OrderConstant.java

@@ -181,5 +181,10 @@ public class OrderConstant {
 		 * Order of service contract configuration modifier.
 		 */
 		public static Integer SERVICE_CONTRACT_ORDER = Integer.MAX_VALUE - 9;
+
+		/**
+		 * Order of trace configuration modifier.
+		 */
+		public static Integer TRACE_ORDER = 2;
 	}
 }

spring-cloud-tencent-commons/src/main/java/org/springframework/tsf/core/context/TsfContext.java

@@ -29,11 +29,13 @@ import com.tencent.polaris.metadata.core.TransitiveType;
 
 import org.springframework.tsf.core.entity.Tag;
 
-public class TsfContext {
+public final class TsfContext {
+
+	static final int MAX_KEY_LENGTH = 32;
+	static final int MAX_VALUE_LENGTH = 128;
+
+	private TsfContext() {
 
-	private static class Limit {
-		static final int MAX_KEY_LENGTH = 32;
-		static final int MAX_VALUE_LENGTH = 128;
 	}
 
 	public static void putTags(Map<String, String> tagMap, Tag.ControlFlag... flags) {
@@ -61,17 +63,16 @@ public class TsfContext {
 	}
 
 	private static void validateTag(String key, String value) {
-		int keyLength, valueLength;
-		keyLength = key.getBytes(StandardCharsets.UTF_8).length;
-		valueLength = value.getBytes(StandardCharsets.UTF_8).length;
+		int keyLength = key.getBytes(StandardCharsets.UTF_8).length;
+		int valueLength = value.getBytes(StandardCharsets.UTF_8).length;
 
-		if (keyLength > Limit.MAX_KEY_LENGTH) {
+		if (keyLength > MAX_KEY_LENGTH) {
 			throw new RuntimeException(String.format("Key \"%s\" length (after UTF-8 encoding) exceeding limit (%d)", key,
-					Limit.MAX_KEY_LENGTH));
+					MAX_KEY_LENGTH));
 		}
-		if (valueLength > Limit.MAX_VALUE_LENGTH) {
+		if (valueLength > MAX_VALUE_LENGTH) {
 			throw new RuntimeException(String.format("Value \"%s\" length (after UTF-8 encoding) exceeding limit (%d)", value,
-					Limit.MAX_VALUE_LENGTH));
+					MAX_VALUE_LENGTH));
 		}
 	}
 }

spring-cloud-tencent-commons/src/main/java/org/springframework/tsf/core/entity/Tag.java

@@ -27,122 +27,118 @@ import com.google.gson.annotations.Expose;
 import com.google.gson.annotations.SerializedName;
 
 public class Tag implements Serializable {
-    // 每次对这个结构的 JSON 序列化结果有改动时，必须修改 VERSION 并写兼容性代码
-    public static final int VERSION = 1;
-
-    public enum ControlFlag {
-        /**
-         * 表示标签要在调用中传递下去，默认不启用
-         */
-        @SerializedName("0")
-        TRANSITIVE,
-
-        /**
-         * 表示标签不被使用在服务鉴权，默认是被使用的
-         */
-        @SerializedName("1")
-        NOT_IN_AUTH,
-
-        /**
-         * 表示标签不被使用在服务路由，默认是被使用的
-         */
-        @SerializedName("2")
-        NOT_IN_ROUTE,
-
-        /**
-         * 表示标签不被使用在调用链，默认是被使用的
-         */
-        @SerializedName("3")
-        NOT_IN_SLEUTH,
-
-        /**
-         * 表示标签不被使用在调用链，默认是被使用的
-         */
-        @SerializedName("4")
-        NOT_IN_LANE,
-        
-        /**
-         * 表示标签被使用在单元化场景，默认是不被使用的
-         */
-        @SerializedName("5")
-        IN_UNIT
-    }
-
-    public enum Scene {
-        /**
-         * 不限场景
-         */
-        NO_SPECIFIC,
-        AUTH, ROUTE, SLEUTH, LANE, UNIT
-    }
-
-    @SerializedName("k")
-    @Expose
-    private String key;
-
-    @SerializedName("v")
-    @Expose
-    private String value;
-
-    @SerializedName("f")
-    @Expose
-    private Set<ControlFlag> flags = new HashSet<>();
-
-    public Tag(String key, String value, ControlFlag... flags) {
-        this.key = key;
-        this.value = value;
-        this.flags = new HashSet<>(Arrays.asList(flags));
-    }
-
-    public Tag() {
-    }
-
-    public String getKey() {
-        return key;
-    }
-
-    public void setKey(String key) {
-        this.key = key;
-    }
-
-    public String getValue() {
-        return value;
-    }
-
-    public void setValue(String value) {
-        this.value = value;
-    }
-
-    public Set<ControlFlag> getFlags() {
-        return flags;
-    }
-
-    public void setFlags(Set<ControlFlag> flags) {
-        this.flags = flags;
-    }
-
-    @Override
-    public boolean equals(Object object) {
-        if (object instanceof Tag) {
-            Tag tag = (Tag) object;
-            return (key == null ? tag.key == null : key.equals(tag.key))
-                    && (flags == null ? tag.flags == null : flags.equals(tag.flags));
-        }
-        return false;
-    }
-
-    @Override
-    public int hashCode() {
-        return (key == null ? 0 : key.hashCode()) + (flags == null ? 0 : flags.hashCode());
-    }
-
-
-    @Override
-    public String toString() {
-        return "Tag{" +
-                "key='" + key + '\'' +
-                ", value='" + value + '\'' +
-                ", flags=" + flags +
-                '}';
-    }
+
+	/**
+	 * update version whenever change the content in tag.
+	 */
+	public static final int VERSION = 1;
+
+	public enum ControlFlag {
+
+		/**
+		 * tag transitive by all services.
+		 */
+		@SerializedName("0")
+		TRANSITIVE,
+
+		/**
+		 * tag not used in auth.
+		 */
+		@SerializedName("1")
+		NOT_IN_AUTH,
+
+		/**
+		 * tag not used in route.
+		 */
+		@SerializedName("2")
+		NOT_IN_ROUTE,
+
+		/**
+		 * tag not used in trace.
+		 */
+		@SerializedName("3")
+		NOT_IN_SLEUTH,
+
+		/**
+		 * tag not used in lane.
+		 */
+		@SerializedName("4")
+		NOT_IN_LANE,
+
+		/**
+		 * tag not used in unit.
+		 */
+		@SerializedName("5")
+		IN_UNIT
+	}
+
+	@SerializedName("k")
+	@Expose
+	private String key;
+
+	@SerializedName("v")
+	@Expose
+	private String value;
+
+	@SerializedName("f")
+	@Expose
+	private Set<ControlFlag> flags = new HashSet<>();
+
+	public Tag(String key, String value, ControlFlag... flags) {
+		this.key = key;
+		this.value = value;
+		this.flags = new HashSet<>(Arrays.asList(flags));
+	}
+
+	public Tag() {
+	}
+
+	public String getKey() {
+		return key;
+	}
+
+	public void setKey(String key) {
+		this.key = key;
+	}
+
+	public String getValue() {
+		return value;
+	}
+
+	public void setValue(String value) {
+		this.value = value;
+	}
+
+	public Set<ControlFlag> getFlags() {
+		return flags;
+	}
+
+	public void setFlags(Set<ControlFlag> flags) {
+		this.flags = flags;
+	}
+
+	@Override
+	public boolean equals(Object object) {
+		if (object instanceof Tag) {
+			Tag tag = (Tag) object;
+			return (key == null ? tag.key == null : key.equals(tag.key))
+					&& (flags == null ? tag.flags == null : flags.equals(tag.flags));
+		}
+		return false;
+	}
+
+	@Override
+	public int hashCode() {
+		return (key == null ? 0 : key.hashCode()) + (flags == null ? 0 : flags.hashCode());
+	}
+
+
+	@Override
+	public String toString() {
+		return "Tag{" +
+				"key='" + key + '\'' +
+				", value='" + value + '\'' +
+				", flags=" + flags +
+				'}';
+	}
 }

spring-cloud-tencent-dependencies/pom.xml

@@ -74,7 +74,7 @@
 		<revision>1.14.0-2022.0.5-SNAPSHOT</revision>
 
 		<!-- Polaris SDK version -->
-		<polaris.version>1.16.0-SNAPSHOT</polaris.version>
+		<polaris.version>1.15.7-SNAPSHOT</polaris.version>
 
 		<!-- Dependencies -->
 		<guava.version>32.0.1-jre</guava.version>
@@ -199,6 +199,12 @@
 				<version>${revision}</version>
 			</dependency>
 
+			<dependency>
+				<groupId>com.tencent.cloud</groupId>
+				<artifactId>spring-cloud-tencent-trace-plugin</artifactId>
+				<version>${revision}</version>
+			</dependency>
+
 			<!-- third part framework dependencies -->
 			<dependency>
 				<groupId>com.google.guava</groupId>

spring-cloud-tencent-examples/quickstart-example/quickstart-caller-service/src/main/java/com/tencent/cloud/quickstart/caller/QuickstartCallerController.java

@@ -17,9 +17,12 @@
 
 package com.tencent.cloud.quickstart.caller;
 
+import java.util.Collections;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.atomic.AtomicInteger;
 
+import com.tencent.cloud.common.metadata.MetadataContext;
+import com.tencent.cloud.common.metadata.MetadataContextHolder;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import reactor.core.publisher.Mono;
@@ -63,6 +66,8 @@ public class QuickstartCallerController {
 	 */
 	@GetMapping("/feign")
 	public String feign(@RequestParam int value1, @RequestParam int value2) {
+		MetadataContext metadataContext = MetadataContextHolder.get();
+		metadataContext.setTransitiveMetadata(Collections.singletonMap("feign-trace", String.format("%d+%d", value1, value2)));
 		return quickstartCalleeService.sum(value1, value2);
 	}
 

spring-cloud-tencent-examples/tsf-example/consumer-demo/src/main/java/com/tencent/cloud/tsf/demo/consumer/controller/ConsumerController.java

@@ -17,10 +17,15 @@
 
 package com.tencent.cloud.tsf.demo.consumer.controller;
 
+import java.util.HashMap;
+import java.util.Map;
+
 import com.tencent.cloud.tsf.demo.consumer.proxy.ProviderDemoService;
 import com.tencent.cloud.tsf.demo.consumer.proxy.ProviderService;
 
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.tsf.core.context.TsfContext;
+import org.springframework.tsf.core.entity.Tag;
 import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestMethod;
@@ -38,16 +43,31 @@ public class ConsumerController {
 
 	@RequestMapping(value = "/echo-rest/{str}", method = RequestMethod.GET)
 	public String restProvider(@PathVariable String str) {
+		TsfContext.putTag("operation", "rest");
+		Map<String, String> mTags = new HashMap<>();
+		mTags.put("rest-trace-key1", "value1");
+		mTags.put("rest-trace-key2", "value2");
+		TsfContext.putTags(mTags, Tag.ControlFlag.TRANSITIVE);
 		return restTemplate.getForObject("http://provider-demo/echo/" + str, String.class);
 	}
 
 	@RequestMapping(value = "/echo-feign/{str}", method = RequestMethod.GET)
 	public String feignProvider(@PathVariable String str) {
+		TsfContext.putTag("operation", "feign");
+		Map<String, String> mTags = new HashMap<>();
+		mTags.put("feign-trace-key1", "value1");
+		mTags.put("feign-trace-key2", "value2");
+		TsfContext.putTags(mTags, Tag.ControlFlag.TRANSITIVE);
 		return providerDemoService.echo(str);
 	}
 
 	@RequestMapping(value = "/echo-feign-url/{str}", method = RequestMethod.GET)
 	public String feignUrlProvider(@PathVariable String str) {
+		TsfContext.putTag("operation", "feignUrl");
+		Map<String, String> mTags = new HashMap<>();
+		mTags.put("feignUrl-trace-key1", "value1");
+		mTags.put("feignUrl-trace-key2", "value2");
+		TsfContext.putTags(mTags, Tag.ControlFlag.TRANSITIVE);
 		return providerService.echo(str);
 	}
 }

spring-cloud-tencent-plugin-starters/spring-cloud-tencent-trace-plugin/src/main/java/com/tencent/cloud/plugin/trace/TraceClientMetadataEnhancedPlugin.java

@@ -18,7 +18,6 @@
 
 package com.tencent.cloud.plugin.trace;
 
-import java.util.Collections;
 import java.util.HashMap;
 import java.util.Map;
 
@@ -33,17 +32,14 @@ import com.tencent.polaris.api.utils.CollectionUtils;
 import com.tencent.polaris.assembly.api.AssemblyAPI;
 import com.tencent.polaris.assembly.api.pojo.TraceAttributes;
 
-public class TraceMetadataEnhancedPlugin implements EnhancedPlugin {
+public class TraceClientMetadataEnhancedPlugin implements EnhancedPlugin {
 
 	private final PolarisSDKContextManager polarisSDKContextManager;
 
-	private SpanAttributesProvider spanAttributesProvider;
+	private final SpanAttributesProvider spanAttributesProvider;
 
-	public TraceMetadataEnhancedPlugin(PolarisSDKContextManager polarisSDKContextManager) {
+	public TraceClientMetadataEnhancedPlugin(PolarisSDKContextManager polarisSDKContextManager, SpanAttributesProvider spanAttributesProvider) {
 		this.polarisSDKContextManager = polarisSDKContextManager;
-	}
-
-	public void setSpanAttributesProvider(SpanAttributesProvider spanAttributesProvider) {
 		this.spanAttributesProvider = spanAttributesProvider;
 	}
 
@@ -65,7 +61,15 @@ public class TraceMetadataEnhancedPlugin implements EnhancedPlugin {
 		MetadataContext metadataContext = MetadataContextHolder.get();
 		Map<String, String> transitiveCustomAttributes = metadataContext.getFragmentContext(MetadataContext.FRAGMENT_TRANSITIVE);
 		if (CollectionUtils.isNotEmpty(transitiveCustomAttributes)) {
-			attributes.putAll(transitiveCustomAttributes);
+			for (Map.Entry<String, String> entry : transitiveCustomAttributes.entrySet()) {
+				attributes.put("custom." + entry.getKey(), entry.getValue());
+			}
+		}
+		Map<String, String> disposableCustomAttributes = metadataContext.getFragmentContext(MetadataContext.FRAGMENT_DISPOSABLE);
+		if (CollectionUtils.isNotEmpty(disposableCustomAttributes)) {
+			for (Map.Entry<String, String> entry : disposableCustomAttributes.entrySet()) {
+				attributes.put("custom." + entry.getKey(), entry.getValue());
+			}
 		}
 		TraceAttributes traceAttributes = new TraceAttributes();
 		traceAttributes.setAttributes(attributes);

spring-cloud-tencent-plugin-starters/spring-cloud-tencent-trace-plugin/src/main/java/com/tencent/cloud/plugin/trace/TraceServerMetadataEnhancedPlugin.java

@@ -0,0 +1,84 @@
+/*
+ * 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.plugin.trace;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import com.tencent.cloud.common.metadata.MetadataContext;
+import com.tencent.cloud.common.metadata.MetadataContextHolder;
+import com.tencent.cloud.polaris.context.PolarisSDKContextManager;
+import com.tencent.cloud.rpc.enhancement.plugin.EnhancedPlugin;
+import com.tencent.cloud.rpc.enhancement.plugin.EnhancedPluginContext;
+import com.tencent.cloud.rpc.enhancement.plugin.EnhancedPluginType;
+import com.tencent.cloud.rpc.enhancement.plugin.PluginOrderConstant;
+import com.tencent.polaris.api.utils.CollectionUtils;
+import com.tencent.polaris.assembly.api.AssemblyAPI;
+import com.tencent.polaris.assembly.api.pojo.TraceAttributes;
+
+public class TraceServerMetadataEnhancedPlugin implements EnhancedPlugin {
+
+	private final PolarisSDKContextManager polarisSDKContextManager;
+
+	private final SpanAttributesProvider spanAttributesProvider;
+
+	public TraceServerMetadataEnhancedPlugin(PolarisSDKContextManager polarisSDKContextManager, SpanAttributesProvider spanAttributesProvider) {
+		this.polarisSDKContextManager = polarisSDKContextManager;
+		this.spanAttributesProvider = spanAttributesProvider;
+	}
+
+	@Override
+	public EnhancedPluginType getType() {
+		return EnhancedPluginType.Server.PRE;
+	}
+
+	@Override
+	public void run(EnhancedPluginContext context) throws Throwable {
+		AssemblyAPI assemblyAPI = polarisSDKContextManager.getAssemblyAPI();
+		Map<String, String> attributes = new HashMap<>();
+		if (null != spanAttributesProvider) {
+			Map<String, String> additionalAttributes = spanAttributesProvider.getConsumerSpanAttributes(context);
+			if (CollectionUtils.isNotEmpty(additionalAttributes)) {
+				attributes.putAll(additionalAttributes);
+			}
+		}
+		MetadataContext metadataContext = MetadataContextHolder.get();
+		Map<String, String> transitiveCustomAttributes = metadataContext.getFragmentContext(MetadataContext.FRAGMENT_TRANSITIVE);
+		if (CollectionUtils.isNotEmpty(transitiveCustomAttributes)) {
+			for (Map.Entry<String, String> entry : transitiveCustomAttributes.entrySet()) {
+				attributes.put("custom." + entry.getKey(), entry.getValue());
+			}
+		}
+		Map<String, String> disposableCustomAttributes = metadataContext.getFragmentContext(MetadataContext.FRAGMENT_DISPOSABLE);
+		if (CollectionUtils.isNotEmpty(disposableCustomAttributes)) {
+			for (Map.Entry<String, String> entry : disposableCustomAttributes.entrySet()) {
+				attributes.put("custom." + entry.getKey(), entry.getValue());
+			}
+		}
+		TraceAttributes traceAttributes = new TraceAttributes();
+		traceAttributes.setAttributes(attributes);
+		traceAttributes.setAttributeLocation(TraceAttributes.AttributeLocation.SPAN);
+		assemblyAPI.updateTraceAttributes(traceAttributes);
+	}
+
+	@Override
+	public int getOrder() {
+		return PluginOrderConstant.ServerPluginOrder.PROVIDER_TRACE_METADATA_PLUGIN_ORDER;
+	}
+}

spring-cloud-tencent-plugin-starters/spring-cloud-tencent-trace-plugin/src/main/java/com/tencent/cloud/plugin/trace/config/TraceConfigModifier.java

@@ -0,0 +1,41 @@
+/*
+ * 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.plugin.trace.config;
+
+import com.tencent.cloud.common.constant.OrderConstant;
+import com.tencent.cloud.polaris.context.PolarisConfigModifier;
+import com.tencent.polaris.factory.config.ConfigurationImpl;
+
+/**
+ * Spring Cloud Tencent config Override polaris trace config.
+ *
+ * @author andrew 2024-06-18
+ */
+public class TraceConfigModifier implements PolarisConfigModifier {
+
+	@Override
+	public void modify(ConfigurationImpl configuration) {
+		configuration.getGlobal().getTraceReporter().setEnable(true);
+	}
+
+	@Override
+	public int getOrder() {
+		return OrderConstant.Modifier.TRACE_ORDER;
+	}
+}

spring-cloud-tencent-plugin-starters/spring-cloud-tencent-trace-plugin/src/main/java/com/tencent/cloud/plugin/trace/config/TraceConfigModifierAutoConfiguration.java

@@ -0,0 +1,37 @@
+/*
+ * 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.plugin.trace.config;
+
+import com.tencent.cloud.polaris.context.ConditionalOnPolarisEnabled;
+
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration(proxyBeanMethods = false)
+@ConditionalOnPolarisEnabled
+@ConditionalOnProperty(value = "spring.cloud.polaris.trace.enabled", matchIfMissing = true)
+public class TraceConfigModifierAutoConfiguration {
+
+	@Bean
+	public TraceConfigModifier traceConfigModifier() {
+		return new TraceConfigModifier();
+	}
+
+}

spring-cloud-tencent-plugin-starters/spring-cloud-tencent-trace-plugin/src/main/java/com/tencent/cloud/plugin/trace/config/TracePropertiesAutoConfiguration.java

@@ -0,0 +1,50 @@
+/*
+ * 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.plugin.trace.config;
+
+import com.tencent.cloud.plugin.trace.SpanAttributesProvider;
+import com.tencent.cloud.plugin.trace.TraceClientMetadataEnhancedPlugin;
+import com.tencent.cloud.plugin.trace.TraceServerMetadataEnhancedPlugin;
+import com.tencent.cloud.polaris.context.ConditionalOnPolarisEnabled;
+import com.tencent.cloud.polaris.context.PolarisSDKContextManager;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+
+@Configuration(proxyBeanMethods = false)
+@ConditionalOnPolarisEnabled
+@ConditionalOnProperty(value = "spring.cloud.polaris.trace.enabled", matchIfMissing = true)
+public class TracePropertiesAutoConfiguration {
+
+	@Bean
+	public TraceClientMetadataEnhancedPlugin traceClientMetadataEnhancedPlugin(
+			PolarisSDKContextManager polarisSDKContextManager, @Autowired(required = false) SpanAttributesProvider spanAttributesProvider) {
+		return new TraceClientMetadataEnhancedPlugin(polarisSDKContextManager, spanAttributesProvider);
+	}
+
+	@Bean
+	public TraceServerMetadataEnhancedPlugin traceServerMetadataEnhancedPlugin(
+			PolarisSDKContextManager polarisSDKContextManager, @Autowired(required = false) SpanAttributesProvider spanAttributesProvider) {
+		return new TraceServerMetadataEnhancedPlugin(polarisSDKContextManager, spanAttributesProvider);
+	}
+
+}

spring-cloud-tencent-plugin-starters/spring-cloud-tencent-trace-plugin/src/main/java/com/tencent/cloud/plugin/trace/config/TracePropertiesBootstrapAutoConfiguration.java

@@ -0,0 +1,30 @@
+/*
+ * 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.plugin.trace.config;
+
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Import;
+
+@Configuration(proxyBeanMethods = false)
+@ConditionalOnProperty("spring.cloud.polaris.enabled")
+@Import(TraceConfigModifierAutoConfiguration.class)
+public class TracePropertiesBootstrapAutoConfiguration {
+
+}

spring-cloud-tencent-plugin-starters/spring-cloud-tencent-trace-plugin/src/main/java/com/tencent/cloud/plugin/trace/tsf/TsfSpanAttributesProvider.java

@@ -0,0 +1,52 @@
+/*
+ * 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.plugin.trace.tsf;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import com.tencent.cloud.common.tsf.TsfConstant;
+import com.tencent.cloud.plugin.trace.SpanAttributesProvider;
+import com.tencent.cloud.rpc.enhancement.plugin.EnhancedPluginContext;
+import com.tencent.polaris.api.utils.CollectionUtils;
+import com.tencent.polaris.api.utils.StringUtils;
+
+import org.springframework.cloud.client.ServiceInstance;
+
+public class TsfSpanAttributesProvider implements SpanAttributesProvider {
+
+	@Override
+	public Map<String, String> getConsumerSpanAttributes(EnhancedPluginContext context) {
+		Map<String, String> attributes = new HashMap<>();
+		if (null != context.getRequest().getUrl()) {
+			attributes.put("remoteInterface", context.getRequest().getUrl().getPath());
+		}
+		ServiceInstance targetServiceInstance = context.getTargetServiceInstance();
+		if (null != targetServiceInstance && CollectionUtils.isNotEmpty(targetServiceInstance.getMetadata())) {
+			String nsId = targetServiceInstance.getMetadata().get(TsfConstant.TSF_NAMESPACE_ID);
+			attributes.put("remote.namespace-id", StringUtils.defaultString(nsId));
+			String groupId = targetServiceInstance.getMetadata().get(TsfConstant.TSF_GROUP_ID);
+			attributes.put("remote.group-id", StringUtils.defaultString(groupId));
+			String applicationId = targetServiceInstance.getMetadata().get(TsfConstant.TSF_APPLICATION_ID);
+			attributes.put("remote.application-id", StringUtils.defaultString(applicationId));
+		}
+		return attributes;
+	}
+
+}

spring-cloud-tencent-plugin-starters/spring-cloud-tencent-trace-plugin/src/main/java/com/tencent/cloud/plugin/trace/tsf/TsfTracePropertiesAutoConfiguration.java

@@ -0,0 +1,39 @@
+/*
+ * 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.plugin.trace.tsf;
+
+import com.tencent.cloud.polaris.context.tsf.ConditionalOnTsfEnabled;
+
+import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration(proxyBeanMethods = false)
+@ConditionalOnTsfEnabled
+@ConditionalOnProperty(value = "spring.cloud.polaris.trace.enabled", matchIfMissing = true)
+public class TsfTracePropertiesAutoConfiguration {
+
+	@Bean
+	@ConditionalOnMissingBean
+	public TsfSpanAttributesProvider tsfClientSpanAttributesProvider() {
+		return new TsfSpanAttributesProvider();
+	}
+
+}

spring-cloud-tencent-plugin-starters/spring-cloud-tencent-trace-plugin/src/main/resources/META-INF/spring.factories

@@ -0,0 +1,2 @@
+org.springframework.cloud.bootstrap.BootstrapConfiguration=\
+  com.tencent.cloud.plugin.trace.config.TracePropertiesBootstrapAutoConfiguration

spring-cloud-tencent-plugin-starters/spring-cloud-tencent-trace-plugin/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports

@@ -0,0 +1,3 @@
+com.tencent.cloud.plugin.trace.config.TraceConfigModifierAutoConfiguration
+com.tencent.cloud.plugin.trace.config.TracePropertiesAutoConfiguration
+com.tencent.cloud.plugin.trace.tsf.TsfTracePropertiesAutoConfiguration

spring-cloud-tencent-polaris-context/pom.xml

@@ -49,6 +49,84 @@
 			</exclusions>
 		</dependency>
 
+		<dependency>
+			<groupId>com.tencent.polaris</groupId>
+			<artifactId>polaris-circuitbreaker-factory</artifactId>
+			<exclusions>
+				<exclusion>
+					<groupId>com.tencent.polaris</groupId>
+					<artifactId>router-rule</artifactId>
+				</exclusion>
+				<exclusion>
+					<groupId>com.tencent.polaris</groupId>
+					<artifactId>router-nearby</artifactId>
+				</exclusion>
+				<exclusion>
+					<groupId>com.tencent.polaris</groupId>
+					<artifactId>router-metadata</artifactId>
+				</exclusion>
+				<exclusion>
+					<groupId>com.tencent.polaris</groupId>
+					<artifactId>circuitbreaker-errrate</artifactId>
+				</exclusion>
+				<exclusion>
+					<groupId>com.tencent.polaris</groupId>
+					<artifactId>circuitbreaker-errcount</artifactId>
+				</exclusion>
+				<exclusion>
+					<groupId>com.tencent.polaris</groupId>
+					<artifactId>circuitbreaker-composite</artifactId>
+				</exclusion>
+				<exclusion>
+					<groupId>com.tencent.polaris</groupId>
+					<artifactId>stat-prometheus</artifactId>
+				</exclusion>
+				<exclusion>
+					<groupId>com.tencent.polaris</groupId>
+					<artifactId>healthchecker-http</artifactId>
+				</exclusion>
+				<exclusion>
+					<groupId>com.tencent.polaris</groupId>
+					<artifactId>healthchecker-tcp</artifactId>
+				</exclusion>
+				<exclusion>
+					<groupId>com.tencent.polaris</groupId>
+					<artifactId>healthchecker-udp</artifactId>
+				</exclusion>
+			</exclusions>
+		</dependency>
+
+		<dependency>
+			<groupId>com.tencent.polaris</groupId>
+			<artifactId>polaris-ratelimit-factory</artifactId>
+			<exclusions>
+				<exclusion>
+					<groupId>com.tencent.polaris</groupId>
+					<artifactId>router-rule</artifactId>
+				</exclusion>
+				<exclusion>
+					<groupId>com.tencent.polaris</groupId>
+					<artifactId>router-nearby</artifactId>
+				</exclusion>
+				<exclusion>
+					<groupId>com.tencent.polaris</groupId>
+					<artifactId>router-metadata</artifactId>
+				</exclusion>
+				<exclusion>
+					<groupId>com.tencent.polaris</groupId>
+					<artifactId>ratelimiter-reject</artifactId>
+				</exclusion>
+				<exclusion>
+					<groupId>com.tencent.polaris</groupId>
+					<artifactId>ratelimiter-unirate</artifactId>
+				</exclusion>
+				<exclusion>
+					<groupId>com.tencent.polaris</groupId>
+					<artifactId>stat-prometheus</artifactId>
+				</exclusion>
+			</exclusions>
+		</dependency>
+
 		<dependency>
 			<groupId>com.tencent.polaris</groupId>
 			<artifactId>polaris-client</artifactId>

spring-cloud-tencent-rpc-enhancement/src/main/java/com/tencent/cloud/rpc/enhancement/plugin/PluginOrderConstant.java

@@ -61,8 +61,18 @@ public class PluginOrderConstant {
 
 		/**
 		 * order for
-		 * {@link com.tencent.cloud.plugin.trace.TraceMetadataEnhancedPlugin}
+		 * {@link com.tencent.cloud.plugin.trace.TraceMetadataEnhancedPlugin}.
 		 */
 		public static final int CONSUMER_TRACE_METADATA_PLUGIN_ORDER = CONSUMER_TRANSFER_METADATA_PLUGIN_ORDER - 1;
 	}
+
+	public static class ServerPluginOrder {
+
+		/**
+		 * order for
+		 * {@link com.tencent.cloud.plugin.trace.TraceServerMetadataEnhancedPlugin}.
+		 */
+		public static final int PROVIDER_TRACE_METADATA_PLUGIN_ORDER = Ordered.HIGHEST_PRECEDENCE + 1;
+	}
+
 }