SpringCloud_Sleuth分布式链路请求跟踪的示例代码

目录
  • 一、概述
    • 1.为什么会出现这个技术?需要解决哪些问题?
    • 2.是什么
    • 3.解决
  • 二、搭建链路监控步骤
    • 1.zipkin
    • 2.服务提供者
    • 3.服务消费者(调用方)
    • 4.依次启动eureka7001/8001/80

Spring Cloud Sleuth是一款针对Spring Cloud的分布式跟踪工具。它借鉴了Dapper、Zipkin和HTrace。

特点

  • 将trace Id和 span Id 添加到Slf4J MDC,这样就可以在日志聚合器中从给定的trace或span提取所有日志。
  • 提供通用分布式跟踪数据模型的抽象。
  • spring-cloud-sleuth-zipkin可收集到zipkin server。

代码链接https://github.com/lidonglin-bit/cloud

一、概述

1.为什么会出现这个技术?需要解决哪些问题?

问题
在微服务框架中,一个由客户端发起的请求在后端系统中会经过多个不同的服务节点调用来协同产生最后的请求结果,每一个前端请求都会形成一个复杂的分布式服务调用链路,链路中的任何一环出现高延时或错误都会引起整个请求最后的失败。

2.是什么

Spring Cloud Sleuth提供了一套完整的服务跟踪的解决方案
在分布式系统中提供追踪解决方案并且兼容支持了zipkin(负责展现)
https://github.com/spring-cloud/spring-cloud-sleuth

https://cloud.spring.io/spring-cloud-sleuth/reference/html/

3.解决

二、搭建链路监控步骤

1.zipkin

下载
SpringCloud从F版起已不需要自己构建Zipkin server了,只需要调用jar包即可
zipkin-server-2.12.9.exec.jar
运行jar
java -jar zipkin-server-2.12.9-exec.jar
运行控制台
http://localhost:9411/zipkin/
术语
完整的调用链路
表示一请求链路,一条链路通过Trace Id唯一标识,Span标识发起的请求信息,各span通过parent id 关联起来。

上图what
一条链路通过Trace Id唯一标识,Span标识发起的请求信息,各span通过parent id 关联起来。

整个链路的依赖关系如下:

名词解释
Trace:类似于树结构的Span集合,表示一条调用链路,存在唯一标识
span:表示调用链路来源,通俗的理解span就是一次请求信息

2.服务提供者

1.修改:cloud-provider-payment8001
2.POM

<!--包含了sleuth+zipkin-->
<dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-zipkin</artifactId>
</dependency>

3.YML

server:
  port: 8001

spring:
  application:
    name: cloud-payment-service
  zipkin:
    base-url: http://localhost:9411
  sleuth:
    sampler:
      #采样率值介于0~1之间,1表示全部采样
      probability: 1
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    driver-class-name: com.mysql.jdbc.Driver
    url: jdbc:mysql://localhost:3306/cloud2020?useUnicode=true&characterEncoding=utf-8&useSSL=false
    username: root
    password: root

mybatis:
  mapperLocations: classpath:/mapper/*.xml
  type-aliases-package: com.donglin.springcloud.entities

eureka:
  client:
    register-with-eureka: true
    fetchRegistry: true
    service-url:
      defaultZone: http://localhost:7001/eureka

4.业务类PaymentController

@GetMapping("/payment/zipkin")
public String paymentZipkin(){
        return "hi ,i'am paymentzipkin server,welcome to donglin,O(∩_∩)O哈哈~";
}

3.服务消费者(调用方)

1.修改:cloud-consumer-order80
2.POM

 <!--包含了sleuth+zipkin-->
<dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-zipkin</artifactId>
</dependency>

3.YML

server:
  port: 80

spring:
    application:
        name: cloud-order-service
    zipkin:
      base-url: http://localhost:9411
    sleuth:
      sampler:
        probability: 1

eureka:
  client:
    #表示是否将自己注册进EurekaServer默认为true。
    register-with-eureka: false
    #是否从EurekaServer抓取已有的注册信息,默认为true。单节点无所谓,集群必须设置为true才能配合ribbon使用负载均衡
    fetchRegistry: true
    service-url:
      #单机
      defaultZone: http://localhost:7001/eureka
      #集群
      #defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka  # 集群版

4.业务类PaymentController

 //==> zipkin+sleuth
@GetMapping("/consumer/payment/zipkin")
public String paymentZipkin(){
        String result = restTemplate.getForObject("http://localhost:8001"+"/payment/zipkin/", String.class);
        return result;
}

4.依次启动eureka7001/8001/80

80调用8001几次测试下

5.打开浏览器访问: http://localhost:9411

会出现以下界面
查看

查看依赖关系

到此这篇关于SpringCloud_Sleuth分布式链路请求跟踪的文章就介绍到这了,更多相关SpringCloud_Sleuth分布式链路跟踪内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们!

(0)

相关推荐

  • SpringCloud Sleuth实现分布式请求链路跟踪流程详解

    目录 1.概念 2.搭建链路监控步骤 2.1.zipkin 2.2.服务提供者 2.3.服务消费者(调用方) 1.概念 Git官网地址:https://github.com/spring-cloud/spring-cloud-sleuth 官网地址:https://spring.io/projects/spring-cloud-sleuth 在微服务框架中,一个由客户端发起的请求在后端系统中会经过多个不同的的服务节点调用来协同产生最后的请求结果,每一个前段请求都会形成一条复杂的分布式服务调用链路

  • SpringCloud链路追踪组件Sleuth配置方法解析

    1.官方文档 https://spring.io/projects/spring-cloud-sleuth 什么是Sleuth? 一个组件,专门用于追踪每个请求的完整调用链路 最主要功能? 做日志埋点 2.添加依赖 <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-sleuth</artifactId> </d

  • SpringCloud_Sleuth分布式链路请求跟踪的示例代码

    目录 一.概述 1.为什么会出现这个技术?需要解决哪些问题? 2.是什么 3.解决 二.搭建链路监控步骤 1.zipkin 2.服务提供者 3.服务消费者(调用方) 4.依次启动eureka7001/8001/80 Spring Cloud Sleuth是一款针对Spring Cloud的分布式跟踪工具.它借鉴了Dapper.Zipkin和HTrace. 特点 将trace Id和 span Id 添加到Slf4J MDC,这样就可以在日志聚合器中从给定的trace或span提取所有日志. 提供

  • webpack+vuex+axios 跨域请求数据的示例代码

    本文介绍了webpack+vuex+axios 跨域请求数据的示例代码,分享给大家,具体如下: 使用vue-li 构建 webpack项目,修改bulid/config/index.js文件 dev: { env: require('./dev.env'), port: process.env.PORT || 8080, autoOpenBrowser: true, assetsSubDirectory: 'static', assetsPublicPath: '/', proxyTable:

  • JavaScript/TypeScript 实现并发请求控制的示例代码

    场景 假设有 10 个请求,但是最大的并发数目是 5 个,并且要求拿到请求结果,这样就是一个简单的并发请求控制 模拟 利用 setTimeout 实行简单模仿一个请求 let startTime = Date.now(); const timeout = (timeout: number, ret: number) => { return (idx?: any) => new Promise((resolve) => { setTimeout(() => { const compa

  • C#调用HTTP POST请求上传图片的示例代码

    现在很多B/S系统的开发都是通过API方式来进行的,一般服务端会开放一个API接口,客户端调用API接口来实现图片或文件上传的功能. GET和POST是什么?HTTP协议中的两种发送请求的方法. HTTP是什么?HTTP是基于TCP/IP的关于数据如何在万维网中如何通信的协议. HTTP的底层是TCP/IP.所以GET和POST的底层也是TCP/IP,也就是说,GET/POST都是TCP链接.GET和POST能做的事情是一样一样的.你要给GET加上request body,给POST带上url参

  • 利用js实现Ajax并发请求限制请求数量的示例代码

    出现问题描述:当不确定异步请求个数时,为防止当一瞬间发生上百个http请求时,导致堆积了无数调用栈进而导致内存溢出问题. 要求:将同一时刻并发请求数量控制在3个以内,同时还要尽可能快速的拿到响应的结果. 同面试问题: 实现一个批量请求函数 multiRequest(urls, maxNum),要求如下: 要求最大并发数 maxNum 每当有一个请求返回,就留下一个空位,可以增加新的请求 所有请求完成后,结果按照 urls 里面的顺序依次打出 1.基于Promise.all实现Ajax的串行和并行

  • 利用OpenCV进行对象跟踪的示例代码

    目录 OpenCV 对象跟踪 OpenCV 对象跟踪器 物体跟踪 总结 OpenCV 对象跟踪 这篇文章使用 OpenCV 中内置的八种不同的对象跟踪算法,实现对物体的跟踪. 首先,介绍一下8种跟踪算法. 然后,演示如何使用OpenCV实现这些跟踪算法. 最后,对本文做总结. OpenCV 对象跟踪器 OpenCV 八种对象跟踪器: BOOSTING Tracker:基于用于驱动 Haar 级联 (AdaBoost) 背后的机器学习的相同算法,但与 Haar 级联一样,已有十多年的历史.这个跟踪

  • vue的全局变量和全局拦截请求器的示例代码

    做的产品证书管理系统使用的是VueJs和ElementUI,现将遇到的一些知识点记录一下. VUe全局变量的实现 全局变量专用模块Global.vue是以一个特定模块来组织管理全局变量,需要引用的地方导入该模块即可.使用方法如下: 将全局变量模块挂载到Vue.prototype里,在程序入口的main.js里加下面代码: import Global from '../components/Global.vue' Vue.prototype.global = Global 挂载后,在需要引用全局变

  • 利用Promise自定义一个GET请求的函数示例代码

    写在最前面 近期 review 自己以前的代码的时候,看到 promise 的使用方法,用的比较模糊.含义不清,用法凌乱,这里重新温习一下基础知识. 前言 JavaScript 是单线程工作,但是浏览器是多线程的.为了更好的完成我们程序的任务.Promise 异步的操作就由此诞生了. 一个 Promise 就是一个代表了异步操作最终完成或者失败的结果对象. 怎么使用? 语法 基本 new Promise( function(resolve, reject) {...} /* executor *

  • SpringBoot使用Aspect切面拦截打印请求参数的示例代码

    AspectJ作为语言级别的AOP框架,功能相比于SpringAOP更加强大.SpringAOP旨在提供给用户一个轻量级的AOP实现方案,它只能应用在SpringIOC容器中管理的bean.而AspectJ旨在提供给用户一个完整的AOP解决方案,它可以应用在所有的域对象中,下面给大家介绍SpringBoot使用Aspect切面拦截打印请求参数的代码. 引入依赖 <dependency> <groupId>org.springframework.boot</groupId>

  • jsp判断请求来自手机示例代码

    复制代码 代码如下: <% String wap = "http://3g.ssss.com.cn"; String agent = request.getHeader("user-agent"); //String agent = "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_7_2) AppleWebKit/534.51.22 (KHTML, like Gecko) Version/5.1.1 Safari

随机推荐