高版本springcloud sleuth+zipkin+rabbitmq+ES 微服务链路追踪,还是有几个坑哎-程序员宅基地

技术标签: springcloud  

一、用来干嘛的

微服务运用较多,相互调用可能错综复杂,链路追踪可以帮助定位问题,分析各个服务性能瓶颈,快速了解整个服务调用过程。功能比较简单,UI简单,没有CAT的报表及报警/系统指标,但集成较简单,侵入较小;CAT有一定侵入,需要埋点(aop环绕通知),依赖mysql,skywalking是个比较新的链路追踪开源软件,界面比较炫,无侵入集成,没cat丰富的报表。但是它们的思路是差不多了,还是值得一学。

二、了解原理

虚线外部分一般springcloud sleuth,是zipkin的client端,用于收集链路数据,这些链路数据通过http或mq收集并存储到zipkin的存储—ES或MySQL,并可以在zipkin server的web ui上简单查询

一个链路一个traceId多个跨度spanId(第一个spanId=traceId),可以自定义跨度,前一个spanId是后一个的parent,维系调用顺序。如图上一行的server received(SR)事件对应下一行的则是server sent (SS)事件(或相反),client sent (CS)对应client recieved(CR)事件(或相反),且上下行spanId对应,整个过程traveId不变。spanId=A的server receive时间与spanId=A的server sent时间差为调用耗时。springcloud-sleuth大致原理是这样的:也是扫描spring.factories里一些配置类实例化一些特殊bean实现链路追踪,有十余个配置类,这里简单看几个

TraceAutoConfiguration->主要配置了一个Tracing对象到spring
TraceWebServletAutoConfiguration->设置自定义请求头traceID,spanID,这是为什么traceID,spanID能跨服务器传递的原因,而同一进程内能够自由获取到traceID,spanID就是threadlocal的作用了
TraceSchedulingAutoConfiguration ->通过aop切入@Scheduled注解的方法来记录spanid等,
TraceFeignClientAutoConfiguration同上
TraceZuulAutoConfiguration以拦截器方式获取请求中获取请求头中的span等

 

 

三、集成步骤

先整合log4j2,@link https://mp.csdn.net/postedit/88916349log4j2    异步日志总结

,关键是日志pattern配置pattern="%d{yyyy-MM-dd HH:mm:ss.SSS} [%t] %-5level [%logger{50}:%L] [%X{X-B3-TraceId},%X{X-B3-SpanId}] - %msg%n" ,然后每个服务添加依赖,重启即可看到traceID与spanID.,需要配置类zipkin URL等相关配置

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-sleuth</artifactId>
        </dependency>
        <dependency>
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-starter-zipkin</artifactId>
         </dependency>
每个服务的主配置都要配置,通过http上传链路数据
spring.zipkin.base-url=http://localhost:9411
spring.zipkin.enabled=true
spring.sleuth.sampler.probability=1

四、直接下载安装zipkin-server

springcloud F版本开始不需要自己搭建zipkin server工程,直接下载最新版:https://search.maven.org/remote_content?g=io.zipkin.java&a=zipkin-server&v=LATEST&c=exechttps://dl.bintray.com/openzipkin/maven/io/zipkin/java/zipkin-server/。 java -jar直接启动jar包,默认端口9411。浏览器访问:http://localhost:9411/zipkin/

五、使用rabbitmq/kafak收集数据,ES储存数据(自己搭建的zipkinserver)

1、自己搭建zipkin-server,实现从rabbitMQ收集数据,ES储存数据

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.1.RELEASE</version>
        <relativePath/>
    </parent>
    <groupId>com.jwolf</groupId>
    <artifactId>zipkin-server</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>zipkin-server</name>
    <description>zipkin-server</description>

    <properties>
        <project-name>zipkin-server-stream</project-name>
        <spring-cloud.version>Finchley.SR2</spring-cloud.version>
        <zipkin.version>2.11.9</zipkin.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>io.zipkin.java</groupId>
            <artifactId>zipkin-server</artifactId>
            <version>${zipkin.version}</version>
        </dependency>

        <!-- 使用消息的方式收集数据(使用rabbitmq) -->
        <dependency>
            <groupId>io.zipkin.java</groupId>
            <artifactId>zipkin-autoconfigure-collector-rabbitmq</artifactId>
            <version>${zipkin.version}</version>
        </dependency>

        <!-- 支持Elasticsearch 2.x - 6.x -->
        <dependency>
            <groupId>io.zipkin.java</groupId>
            <artifactId>zipkin-autoconfigure-storage-elasticsearch-http</artifactId>
            <version>2.8.4</version>
        </dependency>

        <dependency>
            <groupId>io.zipkin.java</groupId>
            <artifactId>zipkin-autoconfigure-ui</artifactId>
            <version>2.11.12</version>
        </dependency>
        
    </dependencies>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

2.配置文件,入口类开启@EnableZipkinServer

server.port=9411
spring.application.name=zipkin
management.metrics.web.server.auto-time-requests=false
#rabbitmq采集数据
zipkin.collector.rabbitmq.addresses=127.0.0.1:5672
zipkin.collector.rabbitmq.password=guest
zipkin.collector.rabbitmq.username=guest
zipkin.collector.rabbitmq.queue=zipkin  #不可自定义

#ES存储数据
zipkin.storage.type=elasticsearch
zipkin.storage.elasticsearch.cluster=elasticsearch
zipkin.storage.elasticsearch.hosts=192.168.199.128:9200
zipkin.storage.elasticsearch.index=zipkin #可自定义
zipkin.storage.elasticsearch.index-shards=3
zipkin.storage.elasticsearch.index-replicas=0

3.client端(各个微服务)依赖

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.1.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.jwolf</groupId>
    <artifactId>jwolf-ordercenter</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>jwolf-ordercenter</name>
    <description>order center</description>

    <properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>Greenwich.RC2</spring-cloud.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>com.jwolf</groupId>
            <artifactId>jwolf-usercenter</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-sleuth</artifactId>
        </dependency>
        <dependency>
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-starter-zipkin</artifactId>
         </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-stream-binder-rabbit</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
            <exclusions>
                <!-- 排除自带的logback依赖 -->
                <exclusion>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-starter-logging</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
            <exclusions>
                <exclusion>   <!-- 排除自带的logback依赖 -->
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-starter-logging</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-log4j2</artifactId>
        </dependency>
        <dependency><!--log4j2异步支持-->
            <groupId>com.lmax</groupId>
            <artifactId>disruptor</artifactId>
            <version>3.3.6</version>
        </dependency>
        
    </dependencies>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

    <repositories>
        <repository>
            <id>spring-milestones</id>
            <name>Spring Milestones</name>
            <url>https://repo.spring.io/milestone</url>
        </repository>
    </repositories>

</project>

4.client端配置

spring.sleuth.sampler.probability=1
spring.sleuth.web.client.enabled=true
spring.zipkin.enabled=true
#spring.zipkin.base-url=http://localhost:9411   默认web http方式上传,改用mq异步方式
spring.zipkin.sender.type=rabbit
spring.rabbitmq.addresses=localhost:5672
spring.rabbitmq.password=guest
spring.rabbitmq.username=guest
spring.rabbitmq.port=5672
spring.zipkin.service.name=${spring.application.name}

5.ES效果预览

 

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/qq_39506978/article/details/88912365

智能推荐

JSP的7大动作_jsp7大-程序员宅基地

文章浏览阅读391次。jsp7大动作指令jsp:include用于动态引入一个 JSP 页面jsp:forward执行页面转向,将请求的处理转发到下一个页面jsp:param用于传递参数,必须与其他支持参数曲标签一起使用jsp:plugin用于下载 JavaBean 或 Applet 到客户端执行jsp:useBean使用 JavaBeanjsp:setProperty设置 JavaBean 实例的属性值jsp:get..._jsp7大

数组表示的二叉树_用数组表示二叉树-程序员宅基地

文章浏览阅读3.3k次。面试某厂的时候面试官问了二叉树最长路径的算法题,给定一个数组找出最长路径的值,第一反应就是动态规划,结果手写代码的时候懵逼想不起怎么通过子节点推算父节点的下标,特此记录警世自己。 fun main(args: Array&lt;String&gt;) { val t = Tree() t.printParentNode(1) t.printParentNode(2..._用数组表示二叉树

Osmocombb项目编译GnuArmToolchain中的GCC4.5.2时遇到recipe for target 'doc/cpp.info' failed(texinfo)错误的解决方法_gcc/doc/cppopts.texi:763: @itemx must follow @item-程序员宅基地

文章浏览阅读3.6k次。Osmocombb项目编译GnuArmToolchain中的GCC4.5.2时遇到recipe for target 'doc/cpp.info' failed(texinfo)错误的解决方法_gcc/doc/cppopts.texi:763: @itemx must follow @item

matlab的矩阵转置问题_reshape会打乱顺序吗-程序员宅基地

文章浏览阅读1k次。matlab中一个矩阵为1000行、2列数据的数据A,需要变为2行,1000列的数据B,这是一个矩阵的转置问题解决办法:B = A'注意:不要使用reshape,reshape时会出现重排数组的情况,这样会打乱数据的顺序。..._reshape会打乱顺序吗

typec扩展坞hdmi没反应_手机通过扩展坞连笔记本HDMI接口,笔记本屏幕为啥没反应?...-程序员宅基地

文章浏览阅读6.7k次。飚王出品,必属精品!最近安卓阵营新机发布不断,前有三星S20,后有华为Mate Xs,Vivo的iQOO 3等,各种酷炫卖点狂轰滥炸,狠狠地激起了网友们的选择困难症。不过他们都有一个共同特点,就是带Type-C接口(里边的协议各不相同)。如果Type-C接口是USB3.0以上且带DP功能,那就可以视频输出,接上扩展坞小屏手机秒变大屏。手机通过扩展坞小屏变大屏因此就有网友将手机接Type-C扩展坞后..._笔记本自带hdmi,扩展坞的hdmi不能用?

java流量录制测试框架_录制线上流量做回归测试的正确打开方式-程序员宅基地

文章浏览阅读446次。目录线上流量什么是录制线上流量回放为什么需要录制线上流量回放项目大迭代更新,容易漏测,或者有很多没用评估到的地方。如果用线上流量做一次回归测试,可以进一步减少 bug 的风险。大大节省构造测试数据,或者构造测试数据脚本的时间,提高效率。线上流量回放的限制是什么只回放 GET 请求因为其他请求的回放,会对用户数据进行操作,有风险,需要排除。除非构建多套备份数据库,但成本太高,不是很有必要。需要对比回..._java线上流量录制线下回放原理

随便推点

程序员的那些反模式-程序员宅基地

文章浏览阅读2.2k次,点赞4次,收藏7次。有鸡汤就有反鸡汤,有模式就有反模式。今天,我们来谈一谈程序员的行为中的那些反模式,涉及程序员的日常工作和学习的各个方面。这些反行为模式,并不针对某些特定的个人。如果你不幸中招,千万不要懊恼,因为这实在太正常不过了,很多反模式的坑我也是亲身踩过的^-^稍微修改几行代码就调试对所有程序员来说,这个行为有一点心理上的原因:工程师都喜欢在做完一点修改之后,立即看到它的效..._反模式开发

人工智能、机器学习和模式识别以及神经网络_智能控制,智能检测,模式识别,神经网络,模糊逻辑,机器学习,人工智能,深度学习,优化-程序员宅基地

文章浏览阅读2.8k次。梯度下降的定义梯度下降问题就是沿着导数下降的地方移动,直到某点梯度最小,这个时候就达到了最优解多变量的梯度下降问题神经网络中遇到的问题是多变量的最优解,即多变量的梯度为零的解局部最优和全局最优问题通常,我们求得的最优解不一定是全局最优解,其可能只是局部最优解。..._智能控制,智能检测,模式识别,神经网络,模糊逻辑,机器学习,人工智能,深度学习,优化

每个人在职场上都不是一帆风顺的,总是会在工作中遇到各种各样的困难_工作没有一帆风顺总有坎坷不平-程序员宅基地

文章浏览阅读2.4k次。每个人在职场上都不是一帆风顺的,总是会在工作中遇到各种各样的困难,这时候有些职场人就会坚持不住,产生消极的情绪,这对我们在职场上的发展是很不利的。为了我们能在职场上更好的发展,一定要学会控制好自己的情绪,要有一定的心理承受能力。有一些人,因为自身性格的原因,喜欢比较与别人在习惯或者生活中的不同,通常会表现出一种自卑的心理。那你一定不要有这样的想法,每个人从小的生活经历不同,做事习惯肯定也不相同,因此我们要在职场上中养成这四个好习惯,让我们在职场上更加自信。要勇于认识自己的缺点在工作中,我们通常会对自己_工作没有一帆风顺总有坎坷不平

Eigen notes_eigen::matrix4f转eigen::affine3f-程序员宅基地

文章浏览阅读193次。Eigen::Affine3与Eigen::Matrix4的转换// Matrix4f to Affine3fEigen::Matrix4f matrixTrans;Eigen::Transform<float, 3, Eigen::Affine> affineTrans (matrixTrans);// Affine3f to Matrix4fEigen::Transf..._eigen::matrix4f转eigen::affine3f

ubuntu顶部栏的图标隐藏办法_ubuntu20.04隐藏顶部状态栏-程序员宅基地

文章浏览阅读1.4k次。前言我使用的是ubuntu20.04版本,最近安装的应用多了以后顶部图标栏的图标太多了,就找了些方法,终于让我找到了一个插件解决这个问题。教程1、打开网址https://extensions.gnome.org/2、搜索Icon Hider3、下载安装即可..._ubuntu20.04隐藏顶部状态栏

反向代理与 Real-IP 和 X-Forwarded-For_alb 配置proxy_set_header x-forwarded-for-程序员宅基地

文章浏览阅读1k次。http://blog.csdn.net/broadview2006/article/details/54570943当我们访问互联网上的服务时,大多数时,客户端并不是直接访问到服务端的,而是客户端首先请求到反向代理,反向代理再转发到服务端实现服务访问,通过反向代理实现路由/负载均衡等策略。这样一来在服务端拿到的客户端IP将是反向代理IP,而不是真实客户端IP,因此需要一种办法_alb 配置proxy_set_header x-forwarded-for

推荐文章

热门文章

相关标签