解析Spring Cloud Sleuth的跟踪数据

2023-04-28 01:56| 来源: 网络整理| 查看: 265

假设我们有一个微服务架构，其中包括两个服务：用户服务和订单服务。当用户下单时，订单服务会向用户服务发送一个请求，获取用户的信息。此时，我们可以使用Spring Cloud Sleuth来跟踪这个请求的整个调用链路，包括每个服务的处理情况和耗时。具体代码如下：

在用户服务中：

import org.springframework.cloud.sleuth.Tracer; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RestController; import java.util.concurrent.TimeUnit; ... @RestController public class UserController { @Autowired private Tracer tracer; @GetMapping("/users/{id}") public User getUser(@PathVariable Long id) throws InterruptedException { Span span = tracer.nextSpan().name("getUser").start(); try (Tracer.SpanInScope ws = tracer.withSpan(span)) { TimeUnit.SECONDS.sleep(1); User user = new User(); user.setId(id); user.setName("Alice"); user.setAge(18); return user; } finally { span.finish(); } } }

在订单服务中：

import org.springframework.cloud.sleuth.Tracer; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RestController; import org.springframework.web.client.RestTemplate; import java.util.concurrent.TimeUnit; ... @RestController public class OrderController { @Autowired private Tracer tracer; @Autowired private RestTemplate restTemplate; @GetMapping("/orders/{id}") public Order getOrder(@PathVariable Long id) throws InterruptedException { Span span = tracer.nextSpan().name("getOrder").start(); try (Tracer.SpanInScope ws = tracer.withSpan(span)) { TimeUnit.SECONDS.sleep(1); User user = restTemplate.getForObject("http://localhost:8080/users/" + id, User.class); Order order = new Order(); order.setId(id); order.setUser(user); return order; } finally { span.finish(); } } }

在上面的代码中，我们分别在用户服务和订单服务中使用了Tracer接口来记录每个请求的Trace ID和Span ID，并通过注解和标签记录了请求的开始、结束时间和耗时。当我们访问订单服务时，Spring Cloud Sleuth会自动将Trace ID和Span ID传递给用户服务，并

在订单服务中，我们使用RestTemplate调用用户服务的getUser接口，并将返回的User对象作为Order对象的一个字段。在getUser接口中，我们使用了TimeUnit.SECONDS.sleep(1)来模拟请求的处理时间，以便更好地观察调用链路的情况。

当我们在浏览器中访问http://localhost:8081/orders/1时，我们可以在控制台中看到类似以下的输出：

Span name: getOrder Span begin: 1649145286467 Span end: 1649145287478 Span annotations: [cs=1649145286467, cr=1649145287478] Span tags: {http.host=localhost, http.method=GET, http.path=/users/1, http.status_code=200, span.kind=client, http.url=http://localhost:8080/users/1} Span name: getUser Span begin: 1649145286467 Span end: 1649145287478 Span annotations: [sr=1649145286467, ss=1649145287477, ss=1649145287477, cr=1649145287477] Span tags: {http.host=localhost, http.method=GET, http.path=/users/1, http.status_code=200, span.kind=server}

在上面的输出中，我们可以看到getOrder和getUser两个Span的开始时间、结束时间和注解信息。我们还可以看到getUser Span的标签信息，其中包括了用户服务的请求路径、请求方法、响应状态码和Span的类型。通过这些信息，我们可以更好地了解整个请求的调用链路和性能情况，方便我们进行性能优化和故障排查。

除了在控制台中输出调用链路信息，我们还可以将这些信息记录到日志文件中，以便更好地跟踪和分析。在Spring Boot应用中，我们可以使用logback等日志框架来记录日志信息。以下是一个logback.xml文件的示例配置：

%d [%thread] %-5level %logger{36} - %msg%n /var/log/myapp.log /var/log/myapp.%d{yyyy-MM-dd}.log 7 %d [%thread] %-5level %logger{36} - %msg%n

在上面的配置中，我们将org.springframework.cloud.sleuth包下的日志级别设置为DEBUG，以便记录Sleuth的调用链路信息。我们还将日志输出到控制台和/var/log/myapp.log文件中，并使用TimeBasedRollingPolicy来进行日志滚动，保留最近7天的日志文件。

【本文地址】

公司简介

联系我们