演示案例:由 cloud-comsumer-order80 消费端调用 cloud-provider-payment8001 服务端,然后由 Sleuth + Zipkin 监控其调用的情况。
<br/>
步骤如下:
[TOC]
# 1. 启动Zipkin
:-: ![](https://img.kancloud.cn/fa/d6/fad63b3dd038377e7b50ff7cf3ef3af1_1053x508.jpg)
官网原图:Zipkin完整的调用链路
![](https://img.kancloud.cn/48/a2/48a28ce6268c685f39977ff5ac777b90_1166x290.jpg)
简化官网图:Zipkin完整的调用链路
![](https://img.kancloud.cn/d5/a1/d5a120633a2ebf2f1bd9eeee0f78670b_1263x194.jpg)
整个链路的依赖关系
如上面的图所示:表示一请求链路,一条链路通过Trace ld唯一标识,Span标识发起的请求信息,各 span 通过 parent id 关联起来。
```
Trace:类似于树结构的Span集合,表示一条调用链路,存在唯一标识
span:表示调用链路来源,通俗的理解span就是一次请求信息
```
<br/>
SpringCloud从F版起已不需要自己构建Zipkin Server了,只需调用jar包即可,当前使用 SpringCloud版本为H版本(F -> H)。
****
zipkin下载地址 github:https://github.com/openzipkin/zipkin
<br/>
**1. 运行 zipin server jar 包**
如果没有现成的 zipkin-server-2.23.3-*exec.jar 包,则需要自己编译,按照如下命令编译。
```shell
$ git clone https://github.com/openzipkin/zipkin
$ cd zipkin
$ mvn -DskipTests --also-make -pl zipkin-server clean install
# 运行 zipkin-server jar包
$ java -jar ./zipkin-server/target/zipkin-server-*exec.jar
```
**2. 访问Zipkin Server http://localhost:9411/zipkin/**
![](https://img.kancloud.cn/0e/ca/0eca1ca201d185afc143314b4f6f99ab_1763x379.jpg)
<br/>
# 2. cloud-provider-payment8001 服务端配置
**1. 在 payment8001 模块的`pom.xml`添加 zipkin 依赖**
```xml
<dependencies>
<!--包含了Sleuth-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-zipkin</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
...
</dependencies>
```
**2. 在 payment8001 模块的`application.yml`中添加 Zipkin 相关配置**
```yml
spring:
application:
name: cloud-payment-service
zipkin:
base-url: http://localhost:9411 #Zipkin的访问地址
sleuth:
sampler:
#采样率值介于0到1之间,1则表示全部采集,一般取0.5即可
probability: 1
```
**3. 在 controller 添加一个用于测试的方法**
```java
@RestController
@RequestMapping("/payment")
public class PaymentController {
@GetMapping("/zipkin")
public String paymentZipkin() {
return "hi,i`am paymentzipkin server fall back.welcome to atguigu";
}
}
```
<br/>
# 3. cloud-comsumer-order80 消费端配置
**1. 在 order80 消费端的`pom.xml`中添加 zipkin 依赖**
```xml
<dependencies>
<!--包含了Sleuth-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-zipkin</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
...
</dependencies>
```
**2. 在 order80 消费端的`application.yml`中添加 zipkin 相关配置**
```yml
spring:
application:
name: cloud-comsumer-order
zipkin:
base-url: http://localhost:9411 #Zipkin的访问地址
sleuth:
sampler:
#采样率值介于0到1之间,1则表示全部采集,一般取0.5即可
probability: 1
```
**3. 在 order80 消费端的controller层添加一个测试方法**
```java
@RestController
@RequestMapping("/order")
public class OrderController {
@Resource
private RestTemplate restTemplate;
@GetMapping("/zipkin")
public String paymentZipkin() {
String result = restTemplate.getForObject("http://localhost:8001/payment/zipkin", String.class);
return result;
}
}
```
<br/>
# 4. 测试
(1)已经运行了 zipkin server jar 包。
(2)启动 payment8001 服务端,再启动 order80 消费端。
访问 order80 消费端 http://localhost/consumer/zipkin 并多刷新几次页面。
(3)访问Zipkin http://localhost:9411/zipkin/ ,查看Zipkin上监控的信息。
:-: ![](https://img.kancloud.cn/a2/9a/a29a6d5df016ec09d38c30970250b6ec_780x343.jpg)
图1:可以看到两个服务之间的依赖关系
![](https://img.kancloud.cn/5e/cc/5ecc970bb099ff0b6afc4a9d2806062d_780x429.jpg)
图2:可以查看两个服务就的请求情况
- 微服务
- 微服务是什么?
- 微服务架构
- 微服务优缺点
- 微服务技术栈
- 微服务框架对比
- SpringCloud
- SpringCloud是什么
- SpringCloud与SpringBoot对比
- SpringCloud与Dubbo对比
- Rest微服务案例
- 总体介绍
- 父工程构建步骤
- 公共模块构建步骤
- 服务端模块构建步骤
- 消费端模块构建步骤
- Eureka服务注册与发现
- Eureka是什么
- Eureka原理
- Eureka注册服务中心构建
- 向Eureka注册已有微服务
- Eureka的自我保护机制
- Eureka服务发现
- Eureka集群配置
- Eureka与Zookeeper对比
- Ribbon负载均衡
- Ribbon是什么
- Ribbon负载均衡演示
- 构建服务端模块
- 构建消费端模块
- Ribbon核心组件IRule
- 自定义负载均衡策略
- Ribbon均衡策略优先级
- 轮询策略算法
- OpenFeign负载均衡
- OpenFeign是什么
- 负载均衡演示
- 日志打印功能
- 导出功能
- Hystrix断路器
- Hystrix是什么
- 服务熔断
- Hystrix服务端构建
- 服务熔断演示
- 服务熔断类型
- HystrixProperty配置汇总
- 服务降级
- Hystrix客户端构建
- 服务降级演示
- fallbackFactory
- 熔断与降级
- 服务监控
- 网关服务Zuul
- Zuul是什么
- Zuul路由服务构建
- 设置访问映射规则
- Config分布式配置中心
- Config分布式配置中心是什么
- Config服务端与Git通信
- Config客户端获取配置
- Config客户端动态刷新
- Bus消息总线
- Bus消息总线是什么
- Bus消息总线原理
- 广播通知设计思想
- 广播通知演示
- 定点通知演示
- Stream消息驱动
- 为什么要引入Stream
- Stream消息驱动是什么
- Stream设计思想
- Stream流程和注解
- Stream案例演示
- 重复消费问题
- 消息持久化
- Sleuth分布式链路跟踪
- Sleuth是什么
- 搭建链路监控
- SpringCloud Alibaba
- Nacos注册与配置中心
- Nacos是什么
- 安装并运行Nacos
- Nacos注册中心
- 服务端入住Nacos
- 消费端入住Nacos
- Nacos负载均衡演示
- 服务注册中心对比
- Nacos的AP和CP转化
- Nacos配置中心
- 基础配置演示
- Nacos分类配置
- Nacos集群搭建
- Sentinel实现熔断与限流
- Sentinel是什么
- Sentinel环境搭建
- Sentinel监控微服务演示
- Sentinel流控规则
- 流量监控的作用
- 设置流控规则
- Sentinel降级规则
- 熔断降级作用
- 设置降级规则
- Sentinel热点限流
- 什么是热点
- 设置热点限流
- Sentinel系统限流
- @SentinelResource
- @SentinelResource属性
- @SentinelResource限流演示
- @SentinelResource熔断演示
- 规则持久化
- 熔断框架比较
- Seata分布式事务
- 分布式事务问题
- Seata是什么
- Seata分布式事务过程
- Seata环境搭建
- 演示示例
- 业务说明
- 数据库环境准备
- 微服务环境准备
- 测试
- Consul服务注册与发现
- Consul是什么
- Consul能做什么
- 环境搭建
- Windows平台
- 服务端入住Consul
- 消费端入住Consul
- 注册中心对比
- Zookeeper服务注册与发现
- Zookeeper是什么
- 环境搭建
- 服务端入住Zookeeper
- 消费端入住Zookeeper
- 网关服务Gateway
- Gateway是什么
- Gateway能做什么
- Gateway对比Zuul
- 三大核心概念
- Gateway工作流
- 环境搭建
- 网关路由配置方式
- 配置文件配置
- 代码中配置
- 动态路由
- Predicate断言
- 断言是什么
- 常用断言
- Filter过滤器
- 过滤器是什么
- 过滤器种类
- 自定义过滤器