在微服务框架中,一个由客户端发起的请求,在后端系统中会调用多个不同的的服务节点,来协同产生最后的响应结果,因此每一个前端请求都会形成一条复杂的分布式服务调用链路,链路中的任何一环出现高延时或错误时都会引起整个请求最后的失败。
因此就需要一个能够跟踪我们发出的请求调用了哪些服务,哪些服务出现了问题的组件,这时Sleuth就应运而生
SpringCloud从F版起已不需要自己构建Zipkin Server了,只需调用jar包即可
zipkin下载地址: https://zipkin.io/pages/quickstart.html
运行jar: java -jar
运行控制台: http://localhost:9411/zipkin/
下图展示了一条完整的调用链路,其中有一些比较重要的概念:
Trace: span形成的调用树的集合。traceID是整个请求调用链路的唯一标识,相同的TraceID表示调用动作在同一个调用链路上。
Span: 链路上的最小工作单位。每一次的RPC(远程服务调用)都是一个span,这个span上会携带各种信息,例如描述、时间戳事件、键值注释(标记)、spanId和进程ID(通常是IP地址,也就是来源服务器的标识)。根据携带的数据我们就可以知道这个span的来源和去向。
下面是一个调用链路的简略图示:
使用“订单服务(服务消费者)”调用“支付服务(服务提供者)”,模拟集群服务间的链路调用,需要在消费端和提供端配置sleuth的服务支持
cloud-provider-payment8001
引入pom依赖:
org.springframework.cloud spring-cloud-starter-zipkin
配置yaml:
spring:application:name: cloud-payment-servicezipkin: #<-------------------------------------关键 base-url: http://localhost:9411sleuth: #<-------------------------------------关键sampler:#采样率值介于 0 到 1 之间,1 则表示全部采集probability: 1datasource:type: com.alibaba.druid.pool.DruidDataSource # 当前数据源操作类型driver-class-name: org.gjt.mm.mysql.Driver # mysql驱动包url: jdbc:mysql://localhost:3306/db2020?useUnicode=true&characterEncoding=utf-8&useSSL=falseusername: rootpassword: 123456
编写测试方法:
@RestController
@Slf4j
public class PaymentController {@GetMapping("/payment/zipkin")public String paymentZipkin() {return "hi ,i'am paymentzipkin server fall back,welcome to here";}
}
cloue-consumer-order80
引入pom依赖:
org.springframework.cloud spring-cloud-starter-zipkin
配置yaml文件:
spring:application:name: cloud-order-servicezipkin:base-url: http://localhost:9411sleuth:sampler:probability: 1
编写业务类测试方法:
// ====================> zipkin+sleuth@GetMapping("/consumer/payment/zipkin")public String paymentZipkin(){String result = restTemplate.getForObject("http://localhost:8001"+"/payment/zipkin/", String.class);return result;}
1. 依次启动eureka7001/8001/80 - 80调用8001几次测试下
5.打开浏览器访问: http://localhost:9411