添加traceId代码

pom.xml

@@ -99,6 +99,12 @@
             <version>9.0.0</version>
         </dependency>
 
+        <dependency>
+            <groupId>org.apache.skywalking</groupId>
+            <artifactId>apm-toolkit-webflux</artifactId>
+            <version>9.0.0</version>
+        </dependency>
+
     </dependencies>
 
     <!-- 构建环境变量 -->

src/main/java/com/tuoheng/gateway/filter/SkywalkingFilter.java

@@ -0,0 +1,20 @@
+package com.tuoheng.gateway.filter;
+
+import org.apache.skywalking.apm.toolkit.trace.TraceContext;
+import org.apache.skywalking.apm.toolkit.webflux.WebFluxSkyWalkingOperators;
+import org.springframework.cloud.gateway.filter.GatewayFilterChain;
+import org.springframework.cloud.gateway.filter.GlobalFilter;
+import org.springframework.stereotype.Component;
+import org.springframework.web.server.ServerWebExchange;
+import reactor.core.publisher.Mono;
+
+@Component
+public class SkywalkingFilter implements GlobalFilter {
+
+    @Override
+    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
+        String traceId = WebFluxSkyWalkingOperators.continueTracing(exchange, TraceContext::traceId);
+        exchange.getResponse().getHeaders().set("x-trace-id", traceId);
+        return chain.filter(exchange);
+    }
+}