Does anyone know how to add tracing to spring webflux

[haboy52581]

Hi there,

I want to add the Jaeger client tracing code to the following but failed:
before adding:

@Bean
    public RouteLocator vpcRouteLocator(RouteLocatorBuilder builder){
        return builder.routes()
                .route(r -> r
                        .path("/*/networks", "/*/vpcs", "/project/*/vpcs")
                        .and().method(HttpMethod.GET)
                        .filters(f -> f.modifyResponseBody(VpcsWebJson.class, NetworksWebJson.class,
                                (exchange, vpcsWebJson) -> {
                                    NetworksWebJson networksWebJson = new NetworksWebJson(vpcsWebJson.getVpcs());
                                    return Mono.just(networksWebJson);
                                }))
                        .uri(vpcUrl))
                .route(r -> r
                        .path("/*/networks", "/*/networks/*",
                                "/project/*/vpcs",  "/project/*/vpcs/*")
                        .uri(vpcUrl))
                .build();
    }

after adding:

       String serviceName="ApiGW";
        Map<String,String> headers=new HashMap();
        Tracer tracer = new JaegerTracerHelper().initTracer(serviceName);
        Tracer.SpanBuilder spanBuilder = null;
        SpanContext parentSpanContext = tracer.extract(Format.Builtin.HTTP_HEADERS, new TextMapAdapter(headers));
        if (null == parentSpanContext) {
            spanBuilder = tracer.buildSpan(serviceName);
        } else {
            spanBuilder = tracer.buildSpan("apiGW").asChildOf(parentSpanContext);
        }
        Span span = spanBuilder.start();
        Request.Builder request2 = new 
        Request.Builder().url(vpcUrl).post(RequestBody.create(MediaType.parse("application/json;charset=utf-8"), ""));
        Tags.SPAN_KIND.set(span, Tags.SPAN_KIND_CLIENT);
        Tags.HTTP_URL.set(span, vpcUrl);
        tracer.activateSpan(span);
        tracer.inject(span.context(), Format.Builtin.HTTP_HEADERS, new RequestBuilderCarrier(request2));
        try (Scope op= tracer.scopeManager().activate(span)) {
        return builder.routes()
                .route(r -> r
                        .path("/*/networks", "/*/vpcs", "/project/*/vpcs")
                        .and().method(HttpMethod.GET)
                        .filters(f -> f.modifyResponseBody(VpcsWebJson.class, NetworksWebJson.class,
                                (exchange, vpcsWebJson) -> {
                                    NetworksWebJson networksWebJson = new NetworksWebJson(vpcsWebJson.getVpcs());
                                    return Mono.just(networksWebJson);
                                }))
                        .uri(vpcUrl))
                .route(r -> r
                        .path("/*/networks", "/*/networks/*",
                                "/project/*/vpcs",  "/project/*/vpcs/*")
                        .uri(vpcUrl))
                .build();
        } catch (Exception e)
        {
            e.printStackTrace();
        }
        finally
        {
            span.finish();
        }
        return null;
    }

Got error during run:

{
    "timestamp": "2020-12-28T17:43:33.465+0000",
    "path": "/project/3dda2801-d675-4688-a63f-dcda8d327f50/vpcs",
    "status": 500,
    "error": "Internal Server Error",
    "message": "class org.springframework.core.io.buffer.DefaultDataBuffer 
    cannot be cast to class org.springframework.core.io.buffer.NettyDataBuffer 
    (org.springframework.core.io.buffer.DefaultDataBuffer 
    and org.springframework.core.io.buffer.NettyDataBuffer are in unnamed module of 
    loader java.net.URLClassLoader @7d5176d6)"
}

Anything wrong?
Thanks!

Best regards
xd