如何使用 spring webflux 实现对服务的跟踪服务？

如何解决如何使用 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"

Preference service trace in Jaeger Customer service trace in Jaeger

解决方法

基于此：

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

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

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

如何使用 spring webflux 实现对服务的跟踪服务？

如何解决如何使用 spring webflux 实现对服务的跟踪服务？

解决方法

相关推荐