spring - 如何使用spring webflux实现跟踪服务到服务？

问题描述

我正在使用 spring webflux 实现服务到服务集成。每个微服务都是隔离的并运行不同的端口。我希望看到使用 jaeger 的端到端跟踪。问题是每个服务都在毫无问题地捕获跟踪，但我看不到服务到服务的通信和架构设计。

Preference-service正在接收请求并转发customer-service。

使用 sleuth 和 zipkin 收集痕迹

implementation 'org.springframework.boot:spring-boot-starter-webflux'
implementation 'org.springframework.cloud:spring-cloud-sleuth-zipkin'
implementation 'org.springframework.cloud:spring-cloud-starter-sleuth'

偏好服务代码部分

   @RequestMapping("/preference")
@ContinueSpan
public Flux<?> preference(@RequestHeader Map<String, String> headers) {
   
    return callByPriceReactive( headers);
}

@NewSpan("chainingPriceReactive")
private Flux<?> callByPriceReactive(Map<String, String> headers ){
    logger.debug("starting statement");
    logger.info("active span: " + tracer.activeSpan());

    return webClient.get().uri("/customerByPrice?maxPrice=1")
           // .header("X-B3-TRACEID", headers.get("X-B3-TRACEID"))
            .retrieve()
            .bodyToFlux(String.class)
            .checkpoint();


}

首选项服务道具文件

logging.level.com.trace.customer=debug
server.port=7072
logging.level.org.springframework.web=info
spring.sleuth.traceId128=true
spring.sleuth.sampler.probability=1.0
spring.application.name=preference-application 
customer.api.url= http://localhost:7071
spring.sleuth.opentracing.enabled=true
##spring.zipkin.base-url=http://<your-Jaeger-server>:<port>

客户服务代码部分

  @RequestMapping("/customerByPrice")
@ContinueSpan
public ResponseEntity<Flux<?>> getCustomer(@RequestParam int maxPrice,@RequestHeader Map<String, String> headers) {
    
    logger.debug("tracer: " + tracer);
    logger.info("active span: " + tracer.activeSpan());
    // just a log statement to show the current context
    logger.debug("starting statement");

    return ResponseEntity.ok(customerService.
            generateRandomCustomer(maxPrice)
          //  .delayElements(Duration.ofSeconds(1))
            .doOnNext(customer -> logger.info("Found customer  {} for ${}", customer.getCustomerId(), 
             customer.getAmount()))
            .doOnComplete(() -> logger.debug("done!"))
            .doOnError(e -> logger.error("failure", e)));
}

客户服务道具文件

logging.level.com.trace.customer=debug
server.port=7071
logging.level.org.springframework.web=info 
spring.sleuth.traceId128=true
spring.sleuth.sampler.probability=1.0
spring.application.name=customer-application 
spring.sleuth.opentracing.enabled=true
##spring.zipkin.base-url=http://<your-Jaeger-server>:<port>

Jaeger 在 docker-compose 文件中运行

version: "3"

services:
 jaeger:
  image: "jaegertracing/all-in-one:latest"
  environment:
   - COLLECTOR_ZIPKIN_HTTP_PORT=9411
  ports:
  - "5775:5775/udp"
  - "6831:6831/udp"
  - "6832:6832/udp"
  - "5778:5778"
  - "16686:16686"
  - "14268:14268"
  - "9411:9411"

Jaeger 中的首选项服务跟踪 Jaeger 中的客户服务跟踪

标签： springspring-webfluxspring-cloud-sleuthzipkinjaeger

基于此：

问题是每个服务都在毫无问题地捕获跟踪，但我看不到服务到服务的通信和架构设计。

似乎跟踪信息没有跨服务传播。您可以通过查看 HTTP 标头并检查traceId. 为了使这项工作traceId在请求中应该是相同的。traceId您也应该在日志中看到相同的内容。

该文档为您提供了一些如何解决此问题的指示：

spring - 如何使用spring webflux实现跟踪服务到服务？

问题描述

解决方案

推荐阅读