APM系统

1. APM (Application Performance Management) 即应用性能管理系统，APM系统是可以帮助理解系统行为、用于分析性能问题的工具，以便发生故障的时候，能够快速定位和解决问题。它主要有三个方面的内容，分别是 Logs(日志)、Traces(链路追踪) 和 Metrics(报表统计)。以后大家接触任何一个 APM 系统的时候，都可以从这三个方面去分析它到底是什么样的一个系统。

分布式链路追踪(SkyWalking)

1. 官网

2. 整体架构包含如下三个组成部分：
   2.1 探针(agent)负责进行数据的收集
   2.2 可观测性分析平台OAP(Observability Analysis Platform)，接收探针发送的数据，将数据存储到对应的存储介质上，比如ES、MySQL、H2数据库等
   2.3 SkyWalking会提供单独的UI进行数据的查看，UI会调用OAP提供的接口

   
   
   

   SkyWalking-配置

SkyWalking-UI

3. SkyWalking日志框架的使用
   3.1 引入POM

        <!-- SkyWalking对 Logback 的集成 -->
        <dependency>
            <groupId>org.apache.skywalking</groupId>
            <artifactId>apm-toolkit-logback-1.x</artifactId>
            <version>6.6.0</version>
        </dependency>
        <!-- SkyWalking工具类 -->
        <dependency>
            <groupId>org.apache.skywalking</groupId>
            <artifactId>apm-toolkit-trace</artifactId>
            <version>6.6.0</version>
        </dependency>

3.2 代码示例

示例代码

3.3 UI效果图

请求链路

日志链路

3.4 如何将链路ID记录到项目日志平台中去

修改日志配置

2022-09-19 10:21:51.521  INFO 18611 TID:22.37.15782305114330001 --- [nio-8079-exec-1] c.i.s.l.s.controller.DemoController      : 测试日志

根据链路ID查询日志

4. SkyWalking其他功能
   4.1 SkyWalking也支持其他组件的链路追踪，例如Spring MVC，Dubbo，MySQL，Redis，MongoDB，ES，RabbitMQ等，代码是无侵入的，只需要引入SkyWalking的依赖和配置即可，这里不再举例。

5. java agent(探针)
   5.1 探针的优势：不修改原有项目一行代码就可以进行集成。SkyWalking服务挂了也不会影响到业务

package org.apache.skywalking.apm.toolkit.trace;

public class TraceContext {
    public TraceContext() {
    }

    //获取链路ID的方法
    //SkyWalking探针会对这个方法做增强，在项目运行时，会返回链路ID
    //如果SkyWalking挂了，那么这个获取链路ID的方法就会直接返回空字符串，当前业务不会因为SkyWalking挂了而导致报错
    public static String traceId() {
        return "";
    }
}

5.2 如何实现一个简单的探针。例如在没有修改代码的情况下，利用java agent统计项目中所有方法的耗时，SkyWalking也是基于这些技术来实现链路追踪的。

        <dependency>
            <groupId>net.bytebuddy</groupId>
            <artifactId>byte-buddy</artifactId>
            <version>1.9.2</version>
        </dependency>
        <dependency>
            <groupId>net.bytebuddy</groupId>
            <artifactId>byte-buddy-agent</artifactId>
            <version>1.9.2</version>
        </dependency>

    public static void premain(String agentArgs, Instrumentation inst) {
        //创建一个转换器，转换器可以修改类的实现
        //ByteBuddy对java agent提供了转换器的实现，直接使用即可
        AgentBuilder.Transformer transformer = new AgentBuilder.Transformer() {
            public DynamicType.Builder<?> transform(DynamicType.Builder<?> builder, TypeDescription typeDescription, ClassLoader classLoader, JavaModule javaModule) {
                return builder
                        // 拦截任意方法
                        .method(ElementMatchers.<MethodDescription>any())
                        // 拦截到的方法委托给TimeInterceptor
                        .intercept(MethodDelegation.to(MyInterceptor.class));
            }
        };
        new AgentBuilder // Byte Buddy专门有个AgentBuilder来处理Java Agent的场景
                .Default()
                // 根据包名前缀拦截类
                .type(ElementMatchers.nameStartsWith("com.levi"))
                // 拦截到的类由transformer处理
                .transform(transformer)
                .installOn(inst);
    }
}

public class MyInterceptor {

    @RuntimeType
    public static Object intercept(@Origin Method method, @SuperCall Callable<?> callable) throws Exception {
        long start = System.currentTimeMillis();
        try {
            //执行原方法
            return callable.call();
        } finally {
            //打印调用时长
            System.out.println(method.getName() + ":" + (System.currentTimeMillis() - start) + "ms");
        }
    }
}

• VM设置 -javaagent:C:\Users\Administrator\agent-demo.jar

  
  
  

  VM设置

• 运行结果

  
  
  

  运行结果