我们必须在Zipkins中传递来自WebClient的标头值吗

Question

我在客户端和服务器端使用Spring boot和下面的库，

dependencyManagement {
    imports {
        mavenBom "org.springframework.cloud:spring-cloud-dependencies:Finchley.SR2"
    }
}
 // Spring Cloud Sleuth
    compile group: 'org.springframework.cloud', name: 'spring-cloud-starter-sleuth', version: '2.0.1.RELEASE'
    compile group: 'org.springframework.cloud', name: 'spring-cloud-starter-zipkin', version: '2.0.1.RELEASE'

基于spring文档，"https://cloud.spring.io/spring-cloud-sleuth/“

运行此应用程序，然后访问主页。您将在日志中看到填充的traceId和spanId。如果此应用程序调用另一个应用程序(例如，使用RestTemplate)，它将在报头中发送跟踪数据，如果接收方是另一个侦听应用程序，您将看到跟踪在那里继续。

这将如何与Spring5 web client一起工作？

Answer 1

它将以同样的方式工作。它足以注入一个WebClient或WebClientBuilder类型的bean。查看此示例https://github.com/spring-cloud-samples/sleuth-documentation-apps/blob/master/service1/src/main/java/io/spring/cloud/sleuth/docs/service1/Service2Client.java

/**
 * @author Marcin Grzejszczak
 */
@Component
class Service2Client {

    private static final Logger log = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());

    private final WebClient webClient;
    private final String serviceAddress;
    private final Tracer tracer;

    Service2Client(WebClient webClient,
            @Value("${service2.address:localhost:8082}") String serviceAddress,
            Tracer tracer) {
        this.webClient = webClient;
        this.serviceAddress = serviceAddress;
        this.tracer = tracer;
    }

    public String start() throws InterruptedException {
        log.info("Hello from service1. Setting baggage foo=>bar");
        Span span = tracer.currentSpan();
        String secretBaggage = ExtraFieldPropagation.get("baggage");
        log.info("Super secret baggage item for key [baggage] is [{}]", secretBaggage);
        if (StringUtils.hasText(secretBaggage)) {
            span.annotate("secret_baggage_received");
            span.tag("baggage", secretBaggage);
        }
        String baggageKey = "key";
        String baggageValue = "foo";
        ExtraFieldPropagation.set(baggageKey, baggageValue);
        span.annotate("baggage_set");
        span.tag(baggageKey, baggageValue);
        log.info("Hello from service1. Calling service2");
        String response = webClient.get()
                .uri("http://" + serviceAddress + "/foo")
                .exchange()
                .block()
                .bodyToMono(String.class).block();
        Thread.sleep(100);
        log.info("Got response from service2 [{}]", response);
        log.info("Service1: Baggage for [key] is [" + ExtraFieldPropagation.get("key") + "]");
        return response;
    }

    @NewSpan("first_span")
    String timeout(@SpanTag("someTag") String tag) {
        try {
            Thread.sleep(300);
            log.info("Hello from service1. Calling service2 - should end up with read timeout");
            String response = webClient.get()
                    .uri("http://" + serviceAddress + "/readtimeout")
                    .retrieve()
                    .onStatus(httpStatus -> httpStatus.isError(), clientResponse -> {
                        throw new IllegalStateException("Exception!");
                    })
                    .bodyToMono(String.class)
                    .block();
            log.info("Got response from service2 [{}]", response);
            return response;
        } catch (Exception e) {
            log.error("Exception occurred while trying to send a request to service 2", e);
            throw new RuntimeException(e);
        }
    }
}