架构设计(13)–分布式链路跟踪:skywalking原理和实践

一、Skywalking是什么

Skywalking 是一个APM系统,即应用性能监控系统,为微服务架构和原生架构系统设计。它通过探针自动收集所需的指标,并进行分布式追踪。通过这些调用链路以及指标,Skywalking APM会感知应用间关系和服务间关系,并进行相应的指标统计

1、skywalking中文文档

skywalking完全由国人主导开发,在国内社区相当活跃。创建于2015年,目前skywalking已成为 Apache 基金会顶级项目。

https://github.com/apache/skywalking/blob/v5.0.0-alpha/docs/README_ZH.md

大家可以前往如下地址下载我们的发布包:

l  Apache官网: http://skywalking.apache.org/downloads/

GitHub发布页面: https://github.com/apache/incubator-skywalking/releases/tag/v5.0.0-alpha

5.0.0-alpha的发布文档:

l  英文: https://github.com/apache/incubator-skywalking/blob/v5.0.0-alpha/docs/README.md

l 中文: https://github.com/apache/incubator-skywalking/blob/v5.0.0-alpha/docs/README_ZH.md

2、主要功能

  • 分布式追踪和上下文传输
  • 应用、实例、服务性能指标分析
  • 根源分析
  • 应用拓扑分析
  • 应用和服务依赖分析
  • 慢服务检测
  • 性能优化

3、功能特性

  • 多种监控手段,语言探针和服务网格(Service Mesh)
  • 多语言自动探针,Java,.NETCore ,PHP, Python和 NodeJS
  • 轻量高效,不需要大数据
  • 模块化,UI、存储、集群管理多种机制可选
  • 支持告警:应用、实例和服务的告警
  • 优秀的可视化Web UI

目前支持链路追踪和监控应用组件如下,基本涵盖主流框架和容器,如国产PRC Dubbo和motan等,国际化的spring boot,spring cloud都支持。

架构设计(13)--分布式链路跟踪:skywalking原理和实践

二、Skywalking架构和原理

1、skywalaking架构

skywalaking总体架构分为4部分

skywalking-agent:

探针,用来收集和发送数据到归集器,主要采集tracing(调用链数据)和metric(指标),使用 JavaAgent字节码植入,无侵入式的收集,并通过 HTTP 或者 gRPC 方式发送数据到 SkyWalking Collector。

skywalking-collector:

链路数据归集器,对agent传过来的tracing和metric数据进行整合分析, 通过Analysis Core模块处理并落入相关的数据存储中,同时会通过Query Core模块进行二次统计和监控告警.  数据可以落地ElasticSearch,单机也可以落地H2,不推荐,H2仅作为临时演示用.

UI:

web可视化平台,用来展示落地的数据.  目前官方采纳了RocketBot作为SkyWalking的主UI

Storage:

Skywalking的存储,支持以ElasticSearch、Mysql、TiDB、H2等作为存储介质进行数据存储

架构设计(13)--分布式链路跟踪:skywalking原理和实践

2、skywalaking工作流程

skywalking的核心在于agent部分,下图展示了一次调用跨多个进程里agent的详细的运行过程:

架构设计(13)--分布式链路跟踪:skywalking原理和实践

这里反映了 skywalking 追踪的核心概念以及我们做的事情,就是 skywalking 怎么采集调用链。

1)、入口跟踪信息:对于入口,不管外围调用是否前置,都会创建一个 entry span,然后走 Extract ,提取前置上下文,当然第一个点没有前置,所以什么都没拿到。然后会创建一个 exit span ,创建一个最出的埋点。之后会做一个 inject的操作,把当前的上下文放在 HTTP 的头里面,顺带这个 HTTP的调用发到 Service B 上。

2) 调用服务跟踪信息:Service B接收请求后 上,也会同样地创建 TraceSegment ,创建 entry ,然后 Extract 提取 ContextCarrier ,这时它与 1 肯定是不一样的,因为前面做了 inject ,注入了上下文,因此这边一定能够拿到上下文,那么它就会做一个 Segment2 和 Segment1 的绑定关系。

3)、最后面 TraceSegment3 也是一样的,Create 、Extract、exit、stop 退出来。

三、快速开始

官方文档: https://github.com/apache/skywalking/blob/v5.0.0-alpha/docs/cn/Quick-start-CN.md

基于springboot项目部署skywalking:

第一步:下载包:

进入官方release地址https://github.com/OpenSkywalking/skywalking/releases,分别下载skywalking-collector,skywalking-web,skywalking-agent,解压后,归集器和web应用都会有一个bin目录,单机模式下,不需要改配置,直接执行对应的脚本即可.  包的结构如图:

agent: 探针

bin:收集器启动脚本

config:数据收集器

webapp:web ui

架构设计(13)--分布式链路跟踪:skywalking原理和实践

第二步:启动skywalking收集器服务

启动脚本是  ./apache-skywalking-apm-bin/bin/startup.sh,启动之后我们就可以访问 http://localhost:8080/ 就可以看到skywalking的ui界面了。我这里 http://192.168.10.31:8080/

单机模式默认使用本地H2数据库,不支持集群部署。主要用于:预览、功能测试、演示和低压力系统。如果使用单机collector用于非演示环境,你可选择使用Elasticsearch作为存储实现。

架构设计(13)--分布式链路跟踪:skywalking原理和实践

第三步:配置需要监控的应用的agent探针

拷贝agent目录到所需位置,日志、插件和配置都包含在包中,不要改变目录结构。可修改agent.config配置agent.application_code=xxl-job为自己的应用名

增加JVM启动参数,-javaagent:/path/to/skywalking-agent/skywalking-agent.jar。参数值为skywalking-agent.jar的绝对路径。

启动被监控应用。

使用现成的spring boot项目client:

package com.turing.skywalking.web;

/**
 * Created by huangguisu on 2019/10/28.
 */

import org.springframework.boot.SpringApplication;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.web.client.RestTemplate;
import org.springframework.context.annotation.Bean;

@RestController
@SpringBootApplication
public class ClientApplication {
    
    @Bean
    RestTemplate restTemplate(){
        return new RestTemplate();
    }
    @GetMapping("/hello")
    public String hello(){
        return this.restTemplate().getForEntity("http://localhost:9081/hello",String.class).getBody();
    }
    @RequestMapping("test")
    public String test() {
        if (true) {
            throw new RuntimeException("aexception occured");
        }
        return "Hello World2";
    }
    public static void main(String[] args) {
        SpringApplication.run(ClientApplication.class, args);
    }
}

service:

package com.turing.skywalking.web;

/**
 * Created by huangguisu on 2019/10/28.
 */

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.ImportResource;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.bind.annotation.GetMapping;
@SpringBootApplication
@RestController
@ImportResource(locations = {"classpath:applicationContext.xml"})
public class SerivceApplication {

    @GetMapping("/hello")
    public String hello(){
        return "Hello World";
    }
    public static void main(String[] args) throws Exception {
        SpringApplication.run(SerivceApplication.class, args);

    }

}

启动client:

架构设计(13)--分布式链路跟踪:skywalking原理和实践

1)复制agent目录:cp /mnt/app/apache-skywalking-apm-bin/agent/   /mnt/app/skywalking-client/ -R

2)复制spring-annotation插件: 由于springboot都是注解实现,启动需要插件apm-spring-annotation-plugin-8.0.0.jar才能看到详细项目内部调用信息。将/agent/optional-plugins目录下的agent/optional-plugins/apm-spring-annotation-plugin-8.0.0.jar移动到/agent/plugins,

3)修改配置:skywalking-client/agent/config/agent.config

agent.service_name=skywalking-client # 如果不修改,否则默认Your_ApplicationName,控制后台就好标识出项目.

collector.backend_service  #默认127.0.0.1:11800

4)nohup启动:nohup java  -jar  -javaagent:/mnt/app/skywalking-client/agent/skywalking-agent.jar  ./skywalking-client-1.0-SNAPSHOT.jar &

启动参数可以改成:

-javaagent:/mnt/app/skywalking-client/agent/skywalking-agent.jar

-Dskywalking.agent.service_nameskywalking-client

-Dskywalking.collector.backend_service=localhost:11800

其中:

-Dskywalking.agent.service_name:用于重写agent/config/agent.config 配置文件中的服务名

-Dskywalking.collector.backend_service:用于重写agent/config/agent.config配置文件中的服务地址

启动service类似:

1)复制agent目录:cp /mnt/app/apache-skywalking-apm-bin/agent/   /mnt/app/skywalking-service/ -R

2)修改配置:skywalking-service/agent/config/agent.config

agent.service_name=skywalking-service# 如果不修改,否则默认Your_ApplicationName

3)nohup启动:nohup java  -jar  -javaagent:/mnt/app/skywalking-service/agent/skywalking-agent.jar   ./skywalking-service-1.0-SNAPSHOT.jar &

查看拓扑信息

架构设计(13)--分布式链路跟踪:skywalking原理和实践

默认skywalking会抓取100%的请求,可以修改agent.config配置文件中的agent.sample_n_per_3_secs配置项配置抓取的请求的百分比

修改skywalking收集器服务数据库存储

目前Skywalking支持h2、mysql、ElasticSearch作为数据存储

架构设计(13)--分布式链路跟踪:skywalking原理和实践

SkyWalking是默认的h2,h2是一种内存数据库,数据保存在内存中,只要服务重启或是Skywalking应用故障了,基本上所监控到的数据也就丢失了,因此h2的内存模式其实不适合于应用服务长时间监控的场景。

官网好像是推荐使用ElasticSearch。ES(ElasticSearch)是一款分布式全文检索框架,底层基于Lucene实现,是给搜索引擎专用的,搜索性能非常好。修改SkyWalking的存储配置,将h2内容注释掉,nameSpace需要与elasticsearch的cluster.name保持一致

四、skywalking与日志组件

skywalking的traceId与日志组件(log4j,logback,elk等)的集成

只要在日志配置xml中增加以下配置,则在打印日志的时候,自动把当前上下文中的traceId加入到日志中去。

1、和logback使用

文档: https://github.com/apache/skywalking/blob/v8.0.0/docs/en/setup/service-agent/java-agent/Application-toolkit-logback-1.x.md

添加依赖:

<dependency>
         <groupId>org.apache.skywalking</groupId>
         <artifactId>apm-toolkit-logback-1.x</artifactId>
         <version>{project.release.version}</version>
     </dependency>

配置:

<appender name="console" class="ch.qos.logback.core.ConsoleAppender">
        <layout class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.TraceIdPatternLogbackLayout">
             <pattern>
                 %d{yyyy-MM-dd HH:mm:ss} [%thread] %-5level %logger{36} - %tid - %msg%n
             </pattern>
        </layout>
    </appender>

2、log4j2

官方文档: https://github.com/apache/skywalking/blob/v8.0.0/docs/en/setup/service-agent/java-agent/Application-toolkit-log4j-2.x.md

添加依赖:
 <dependency>
      <groupId>org.apache.skywalking</groupId>
      <artifactId>apm-toolkit-log4j-2.x</artifactId>
      <version>{project.release.version}</version>
   </dependency>

log4j2.xml配置:

<Appenders>
      <Console name="Console" target="SYSTEM_OUT">
         <PatternLayout pattern="%d [%traceId] %-5p %c{1}:%L - %m%n"/>
      </Console>
   </Appenders>

链路中的所有节点的traceId是一样的,skywalking web发现性能差的traceId后,再去日志组件中查看日志是否有异常日志。

五、skywalking的限制

1、跨线程的场景不支持自动代理,比如任务分配,任务池,批处理的场景。

类似我们如下场景:

架构设计(13)--分布式链路跟踪:skywalking原理和实践

我们服务A需要同时调用服务C和服务D,这个时候肯定不是串行调用,而是通过线程池并发调用服务C和服务D, 我们实验这个场景,链路跟踪没有生效。这个应该是skywalking需要特殊处理。

package com.turing.skywalking.web.service;

import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;

/**
 * Created by huangguisu on 2020/6/30.
 */
@Service
public class ServiceHello {
    private abstract class CallableException implements Callable<String> {
    }
    private ExecutorService executorService = new ThreadPoolExecutor(2, 2,
            0L, TimeUnit.MILLISECONDS,
            new ArrayBlockingQueue<Runnable>(100));

    public void asynTest() {
        List<Callable<String>> tasks = new ArrayList<>();
        System.out.println("exe:asynTest" );
        tasks.add(new CallableException() {
            @Override
            public String call() {
                try {
                    RestTemplate restTemplate = new RestTemplate();
                    String postData = "{/"code/":200}";
                    String res =  restTemplate.postForEntity("http://localhost:9081/hello2",  postData, String.class).getBody();
                    return res;
                } catch (Exception e) {
                    e.printStackTrace();
                    return "";
                }
            }
        });

        tasks.add(new CallableException() {
            @Override
            public String call() {
                try {
                    RestTemplate restTemplate = new RestTemplate();
                    String postData = "{/"code/":200}";
                    String res =  restTemplate.postForEntity("http://localhost:9082/hello3",  postData, String.class).getBody();
                    return res;
                } catch (Exception e) {
                    e.printStackTrace();
                    return "";
                }
            }
        });

        try {
            List<Future<String>> mFuture = executorService.invokeAll(tasks, 10, TimeUnit.SECONDS);
            String  result1 = mFuture.get(0).get();
            if (result1.equals("")) {
                System.out.println( "result1 empty");
            } else {
                System.out.println( "Future1 result:" + result1);
            }
            String  result2 = mFuture.get(1).get();
            if (result2.equals("")) {
                System.out.println( "result2 empty");
            } else {
                System.out.println( "Future2 result:" + result1);
            }

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

原文 

https://blog.csdn.net/hguisu/article/details/107040500

本站部分文章源于互联网,本着传播知识、有益学习和研究的目的进行的转载,为网友免费提供。如有著作权人或出版方提出异议,本站将立即删除。如果您对文章转载有任何疑问请告之我们,以便我们及时纠正。

PS:推荐一个微信公众号: askHarries 或者qq群:474807195,里面会分享一些资深架构师录制的视频录像:有Spring,MyBatis,Netty源码分析,高并发、高性能、分布式、微服务架构的原理,JVM性能优化这些成为架构师必备的知识体系。还能领取免费的学习资源,目前受益良多

转载请注明原文出处:Harries Blog™ » 架构设计(13)–分布式链路跟踪:skywalking原理和实践

赞 (0)
分享到:更多 ()

评论 0

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址