AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

基于JavaAgent的全链路监控六《开发应用级监控》

2022-01-12 358
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
应用实时监控服务-可观测链路OpenTelemetry版，每月50GB免费额度
简介： 在我们的监控程序中，需要对各种模块进行监控；servlet、rpc、http、jdbc、redis、logic等，那么我们在设计监控程序时就需要对监控的程序进行模块化开发，可以在需要的时候进行组装配置即可，以方便我们监控程序的扩展和可控制性。这一章节我们把监控模块剥离，采用工厂模式进行调用｛目前是静态工厂在我们实际使用中可以把工厂做成动态配置化｝。

12.jpg

案例简述

在我们的监控程序中，需要对各种模块进行监控；servlet、rpc、http、jdbc、redis、logic等，那么我们在设计监控程序时就需要对监控的程序进行模块化开发，可以在需要的时候进行组装配置即可，以方便我们监控程序的扩展和可控制性。这一章节我们把监控模块剥离，采用工厂模式进行调用｛目前是静态工厂在我们实际使用中可以把工厂做成动态配置化｝。

环境准备

1、IntelliJ IDEA Community Edition

2、jdk1.8.0_45 64位

配置信息

（路径相关修改为自己的）

1、配置位置：Run/Debug Configurations -> VM options

2、配置内容：-javaagent:E:\itstack\GIT\itstack.org\itstack-demo-agent\itstack-demo-agent-06\target\itstack-demo-agent-06-1.0.0-SNAPSHOT.jar=testargs

代码示例

itstack-demo-agent-06
├── pom.xml
└── src
    ├── main
    │   ├── java
    │   │   └── org.itstack.demo.agent
    │   │       ├── plugin
    │   │       │   ├── impl
    │   │       │   │   ├── jvm
    │   │       │   │   │   ├── JvmAdvice.java
    │   │       │   │   │   ├── JvmPlugin.java
    │   │       │   │   │   └── JvmStack.java
    │   │       │   │   └── link
    │   │       │   │       ├── LinkAdvice.java
    │   │       │   │       └── LinkPlugin.java
    │   │       │   ├── InterceptPoint.java
    │   │       │   ├── IPlugin.java
    │   │       │   └── PluginFactory.java
    │   │       │
    │   │       ├── track
    │   │       │   ├── Span.java
    │   │       │   ├── TrackContext.java
    │   │       │   └── TrackManager.java
    │   │       └── MyAgent.java
    │   └── resources
    │       └── META-INF
    │           └── MANIFEST.MF
    └── test
         └── java
             └── org.itstack.demo.test
                 └── ApiTest.java

JvmAdvice.java

/**
 * 博客：http://itstack.org
 * 论坛：http://bugstack.cn
 * 公众号：bugstack虫洞栈  ｛获取学习源码｝
 * create by fuzhengwei on 2019
 */
public class JvmAdvice {
    @Advice.OnMethodExit()
    public static void exit() {
        JvmStack.printMemoryInfo();
        JvmStack.printGCInfo();
    }
}

JvmPlugin.java

/**
 * 博客：http://itstack.org
 * 论坛：http://bugstack.cn
 * 公众号：bugstack虫洞栈  ｛获取学习源码｝
 * create by fuzhengwei on 2019
 */
public class JvmPlugin implements IPlugin {
    @Override
    public String name() {
        return "jvm";
    }
    @Override
    public InterceptPoint[] buildInterceptPoint() {
        return new InterceptPoint[]{
                new InterceptPoint() {
                    @Override
                    public ElementMatcher<TypeDescription> buildTypesMatcher() {
                        return ElementMatchers.nameStartsWith("org.itstack.demo.test");
                    }
                    @Override
                    public ElementMatcher<MethodDescription> buildMethodsMatcher() {
                        return ElementMatchers.isMethod()
                                .and(ElementMatchers.any())
                                .and(ElementMatchers.not(ElementMatchers.nameStartsWith("main")));
                    }
                }
        };
    }
    @Override
    public Class adviceClass() {
        return JvmAdvice.class;
    }
}

LinkAdvice.java

/**
 * 博客：http://itstack.org
 * 论坛：http://bugstack.cn
 * 公众号：bugstack虫洞栈  ｛获取学习源码｝
 * create by fuzhengwei on 2019
 */
public class LinkAdvice {
    @Advice.OnMethodEnter()
    public static void enter(@Advice.Origin("#t") String className, @Advice.Origin("#m") String methodName) {
        Span currentSpan = TrackManager.getCurrentSpan();
        if (null == currentSpan) {
            String linkId = UUID.randomUUID().toString();
            TrackContext.setLinkId(linkId);
        }
        TrackManager.createEntrySpan();
    }
    @Advice.OnMethodExit()
    public static void exit(@Advice.Origin("#t") String className, @Advice.Origin("#m") String methodName) {
        Span exitSpan = TrackManager.getExitSpan();
        if (null == exitSpan) return;
        System.out.println("链路追踪(MQ)：" + exitSpan.getLinkId() + " " + className + "." + methodName + " 耗时：" + (System.currentTimeMillis() - exitSpan.getEnterTime().getTime()) + "ms");
    }
}

LinkPlugin.java

/**
 * 博客：http://itstack.org
 * 论坛：http://bugstack.cn
 * 公众号：bugstack虫洞栈  ｛获取学习源码｝
 * create by fuzhengwei on 2019
 */
public class LinkPlugin implements IPlugin {
    @Override
    public String name() {
        return "link";
    }
    @Override
    public InterceptPoint[] buildInterceptPoint() {
        return new InterceptPoint[]{
                new InterceptPoint() {
                    @Override
                    public ElementMatcher<TypeDescription> buildTypesMatcher() {
                        return ElementMatchers.nameStartsWith("org.itstack.demo.test");
                    }
                    @Override
                    public ElementMatcher<MethodDescription> buildMethodsMatcher() {
                        return ElementMatchers.isMethod()
                                .and(ElementMatchers.any())
                                .and(ElementMatchers.not(ElementMatchers.nameStartsWith("main")));
                    }
                }
        };
    }
    @Override
    public Class adviceClass() {
        return LinkAdvice.class;
    }
}

InterceptPoint.java

/**
 * 拦截点
 * 博客：http://itstack.org
 * 论坛：http://bugstack.cn
 * 公众号：bugstack虫洞栈  ｛获取学习源码｝
 * create by fuzhengwei on 2019
 */
public interface InterceptPoint {
    //类匹配规则
    ElementMatcher<TypeDescription> buildTypesMatcher();
    //方法匹配规则
    ElementMatcher<MethodDescription> buildMethodsMatcher();
}

IPlugin.java

/**
 * 监控组件
 * 博客：http://itstack.org
 * 论坛：http://bugstack.cn
 * 公众号：bugstack虫洞栈  ｛获取学习源码｝
 * create by fuzhengwei on 2019
 */
public interface IPlugin {
    //名称
    String name();
    //监控点
    InterceptPoint[] buildInterceptPoint();
    //拦截器类
    Class adviceClass();
}

PluginFactory.java

/**
 * 博客：http://itstack.org
 * 论坛：http://bugstack.cn
 * 公众号：bugstack虫洞栈  ｛获取学习源码｝
 * create by fuzhengwei on 2019
 */
public class PluginFactory {
    public static List<IPlugin> pluginGroup = new ArrayList<>();
    static {
        //链路监控
        pluginGroup.add(new LinkPlugin());
        //Jvm监控
        pluginGroup.add(new JvmPlugin());
    }
}

TrackManager.java

/**
 * 追踪管控
 * 博客：http://itstack.org
 * 论坛：http://bugstack.cn
 * 公众号：bugstack虫洞栈  ｛获取学习源码｝
 * create by fuzhengwei on 2019
 */
public class TrackManager {
    private static final ThreadLocal<Stack<Span>> track = new ThreadLocal<>();
    private static Span createSpan() {
        Stack<Span> stack = track.get();
        if (stack == null) {
            stack = new Stack<>();
            track.set(stack);
        }
        String linkId;
        if (stack.isEmpty()) {
            linkId = TrackContext.getLinkId();
            if (linkId == null) {
                linkId = "nvl";
                TrackContext.setLinkId(linkId);
            }
        } else {
            Span span = stack.peek();
            linkId = span.getLinkId();
            TrackContext.setLinkId(linkId);
        }
        return new Span(linkId);
    }
    public static Span createEntrySpan() {
        Span span = createSpan();
        Stack<Span> stack = track.get();
        stack.push(span);
        return span;
    }
    public static Span getExitSpan() {
        Stack<Span> stack = track.get();
        if (stack == null || stack.isEmpty()) {
            TrackContext.clear();
            return null;
        }
        return stack.pop();
    }
    public static Span getCurrentSpan() {
        Stack<Span> stack = track.get();
        if (stack == null || stack.isEmpty()) {
            return null;
        }
        return stack.peek();
    }
}

MyAgent.java

/**
 * 博客：http://itstack.org
 * 论坛：http://bugstack.cn
 * 公众号：bugstack虫洞栈  ｛获取学习源码｝
 * create by fuzhengwei on 2019
 */
public class MyAgent {
    //JVM 首先尝试在代理类上调用以下方法
    public static void premain(String agentArgs, Instrumentation inst) {
        System.out.println("基于javaagent链路追踪｛源码微信公众号：bugstack虫洞栈｝");
        System.out.println("==========================================================\r\n");
        AgentBuilder agentBuilder = new AgentBuilder.Default();
        List<IPlugin> pluginGroup = PluginFactory.pluginGroup;
        for (IPlugin plugin : pluginGroup) {
            InterceptPoint[] interceptPoints = plugin.buildInterceptPoint();
            for (InterceptPoint point : interceptPoints) {
                AgentBuilder.Transformer transformer = (builder, typeDescription, classLoader, javaModule) -> {
                    builder = builder.visit(Advice.to(plugin.adviceClass()).on(point.buildMethodsMatcher()));
                    return builder;
                };
                agentBuilder = agentBuilder.type(point.buildTypesMatcher()).transform(transformer).asDecorator();
            }
        }
        //监听
        AgentBuilder.Listener listener = new AgentBuilder.Listener() {
            @Override
            public void onDiscovery(String s, ClassLoader classLoader, JavaModule javaModule, boolean b) {
            }
            @Override
            public void onTransformation(TypeDescription typeDescription, ClassLoader classLoader, JavaModule javaModule, boolean b, DynamicType dynamicType) {
                System.out.println("onTransformation：" + typeDescription);
            }
            @Override
            public void onIgnored(TypeDescription typeDescription, ClassLoader classLoader, JavaModule javaModule, boolean b) {
            }
            @Override
            public void onError(String s, ClassLoader classLoader, JavaModule javaModule, boolean b, Throwable throwable) {
            }
            @Override
            public void onComplete(String s, ClassLoader classLoader, JavaModule javaModule, boolean b) {
            }
        };
        agentBuilder.with(listener).installOn(inst);
    }
}

MANIFEST.MF

Manifest-Version: 1.0
Premain-Class: org.itstack.demo.agent.MyAgent
Can-Redefine-Classes: true

ApiTest.java

**
 * 链路追踪
 * VM options：
 * -javaagent:E:\itstack\GIT\itstack.org\itstack-demo-agent\itstack-demo-agent-06\target\itstack-demo-agent-06-1.0.0-SNAPSHOT.jar=testargs
 *
 * 按需打开需要测试的模块
 * 链路监控
 * pluginGroup.add(new LinkPlugin());
 * Jvm监控
 * pluginGroup.add(new JvmPlugin());
 *
 * 博客：http://itstack.org
 * 论坛：http://bugstack.cn
 * 公众号：bugstack虫洞栈  ｛获取学习源码｝
 * create by fuzhengwei on 2019
 *
 */
public class ApiTest {
    public static void main(String[] args) {
        //线程一
        new Thread(() -> new ApiTest().http_lt1("哪咤")).start();
        //线程二
        new Thread(() -> {
            new ApiTest().http_lt2("悟空");
        }).start();
    }
    public void http_lt1(String name) {
        try {
            Thread.sleep((long) (Math.random() * 500));
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("测试结果：hi1 " + name);
        http_lt2(name);
    }
    public void http_lt2(String name) {
        try {
            Thread.sleep((long) (Math.random() * 500));
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("测试结果：hi2 " + name);
        http_lt3(name);
    }
    public void http_lt3(String name) {
        try {
            Thread.sleep((long) (Math.random() * 500));
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("测试结果：hi3 " + name);
    }
}

测试结果

基于javaagent链路追踪｛源码微信公众号：bugstack虫洞栈｝
==========================================================
onTransformation：class org.itstack.demo.test.ApiTest
测试结果：hi2 悟空
测试结果：hi1 哪咤
测试结果：hi3 悟空
链路追踪(MQ)：608a1cbf-ef1f-4195-bdc7-c3729a114f8d org.itstack.demo.test.ApiTest.http_lt3 耗时：111ms
测试结果：hi2 哪咤
init: 192MB  max: 2708MB     used: 43MB  committed: 184MB    use rate: 23%
init: 2MB    max: 0MB    used: 13MB  committed: 14MB     use rate: 95%
name: PS Scavenge    count:0     took:0  pool name:[PS Eden Space, PS Survivor Space]
name: PS MarkSweep   count:0     took:0  pool name:[PS Eden Space, PS Survivor Space, PS Old Gen]
-------------------------------------------------------------------------------------------------
链路追踪(MQ)：608a1cbf-ef1f-4195-bdc7-c3729a114f8d org.itstack.demo.test.ApiTest.http_lt2 耗时：338ms
init: 192MB  max: 2708MB     used: 43MB  committed: 184MB    use rate: 23%
init: 2MB    max: 0MB    used: 13MB  committed: 14MB     use rate: 95%
name: PS Scavenge    count:0     took:0  pool name:[PS Eden Space, PS Survivor Space]
name: PS MarkSweep   count:0     took:0  pool name:[PS Eden Space, PS Survivor Space, PS Old Gen]
-------------------------------------------------------------------------------------------------
测试结果：hi3 哪咤
链路追踪(MQ)：2f28ed75-650a-4f0f-bd69-fe0709a8985e org.itstack.demo.test.ApiTest.http_lt3 耗时：221ms
init: 192MB  max: 2708MB     used: 43MB  committed: 184MB    use rate: 23%
init: 2MB    max: 0MB    used: 13MB  committed: 14MB     use rate: 95%
name: PS Scavenge    count:0     took:0  pool name:[PS Eden Space, PS Survivor Space]
name: PS MarkSweep   count:0     took:0  pool name:[PS Eden Space, PS Survivor Space, PS Old Gen]
-------------------------------------------------------------------------------------------------
链路追踪(MQ)：2f28ed75-650a-4f0f-bd69-fe0709a8985e org.itstack.demo.test.ApiTest.http_lt2 耗时：316ms
init: 192MB  max: 2708MB     used: 43MB  committed: 184MB    use rate: 23%
init: 2MB    max: 0MB    used: 13MB  committed: 14MB     use rate: 95%
name: PS Scavenge    count:0     took:0  pool name:[PS Eden Space, PS Survivor Space]
name: PS MarkSweep   count:0     took:0  pool name:[PS Eden Space, PS Survivor Space, PS Old Gen]
-------------------------------------------------------------------------------------------------
链路追踪(MQ)：2f28ed75-650a-4f0f-bd69-fe0709a8985e org.itstack.demo.test.ApiTest.http_lt1 耗时：547ms
init: 192MB  max: 2708MB     used: 43MB  committed: 184MB    use rate: 23%
init: 2MB    max: 0MB    used: 13MB  committed: 14MB     use rate: 95%
name: PS Scavenge    count:0     took:0  pool name:[PS Eden Space, PS Survivor Space]
name: PS MarkSweep   count:0     took:0  pool name:[PS Eden Space, PS Survivor Space, PS Old Gen]
-------------------------------------------------------------------------------------------------
Process finished with exit code 0


文章标签：
云消息队列 MQ
可观测链路 OpenTelemetry 版
Java
开发工具
NoSQL
监控
Redis
git
数据库连接
相关实践学习
消息队列RocketMQ版：基础消息收发功能体验
本实验场景介绍消息队列RocketMQ版的基础消息收发功能，涵盖实例创建、Topic、Group资源创建以及消息收发体验等基础功能模块。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列：消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验：基于MNS，0基础轻松构建 Web Client 本节课带您一起基于MNS，0基础轻松构建 Web Client
小傅哥
目录
相关文章
阿里云云原生
|
4月前
|
监控 Kubernetes Go
全链路追踪 & 性能监控，GO 应用可观测全面升级
当前，大多数面向 Golang 应用的监控能力主要是通过 SDK 方式接入，需要开放人员手动进行埋点，会存在一定问题。对此，可观测 Go Agent 应运而生。本文介绍的阿里云可观测 Go Agent 方案，能通过无侵入的方式实现应用监控能力。
阿里云云原生
108732 25
hh真是个慢性子
|
3月前
|
Prometheus 监控 Cloud Native
【监控】prometheus传统环境监控告警常用配置
【监控】prometheus传统环境监控告警常用配置
hh真是个慢性子
106 0
【监控】prometheus传统环境监控告警常用配置
陌陌谣
|
JSON 监控 数据可视化
实时日志分析：通过Golang编写实时日志分析模块，加强公司监控管理软件的日志监控功能
在当今数字化时代，企业面临着庞大而复杂的网络环境，对实时监控和日志分析的需求变得日益迫切。本文将介绍如何使用Golang编写实时日志分析模块，以增强公司监控管理软件的日志监控功能。通过本文的指导，你将能够建立一个定制的实时日志分析系统，更好地监测和管理公司的网络活动。
陌陌谣
335 0
DevOps和k8s全栈技术
|
存储 消息中间件 监控
代码级别监控：常见的全链路监控工具介绍
代码级别监控：常见的全链路监控工具介绍
DevOps和k8s全栈技术
164 0
岩风在路上
|
Prometheus 监控 Cloud Native
业务端skywalking接入方案
业务端skywalking接入方案
岩风在路上
761 1
在下uptown
|
存储 监控 前端开发
【SkyWalking】从零接入全链路追踪解决方案
Skywalking是一个国产的开源框架，2015年有吴晟个人开源,2017年加入Apache孵化器，国人开源的产品，本次分享下从零接入SkyWalking。
在下uptown
696 0
【SkyWalking】从零接入全链路追踪解决方案
怒放de生命
|
存储 监控 数据可视化
链路监控(skywalking)集成
链路监控(skywalking)集成
怒放de生命
282 0
链路监控(skywalking)集成
小盒子的技术分享
|
SQL 存储 监控
如何使用skywalking 进行全链路监控
skywalking-nginx-lua[2] 这是 skywalking 的另一个项目，可以通过它来对nginx进行监控。skywalking-nginx-lua 是使用lua来织入 agent 的。所以要求你的 nginx 要么有 lua 模块，要么用 openResty 这样的自带 Lua 功能模块的软件。
小盒子的技术分享
941 0
如何使用skywalking 进行全链路监控
中间件小哥
|
缓存 搜索推荐 Java
Java应用全链路启动速度提升至15s，阿里云SAE能力再升级
Java 作为一门面向对象编程语言，在性能方面的卓越表现独树一帜。但在高性能的背后，Java 的启动性能差也令人印象深刻，大家印象中的 Java 笨重、缓慢的印象也大多来源于此，高性能和快启动速度似乎有一些相悖。
中间件小哥
4353 5
Java应用全链路启动速度提升至15s，阿里云SAE能力再升级
xaubllxwtvaqiu
|
SQL 存储 监控
核心特性—全链路监控和审计
PolarDB-X带有丰富的监控和审计功能，帮助您实时观测数据库的各项性能指标和运行状态。
xaubllxwtvaqiu
160 0

热门文章

最新文章

  • 1
    尝鲜：如何搭建一个简单的webrtc服务器
  • 2
    从零开始：阿里云上Kubernetes集群的搭建与部署
  • 3
    面试必问的4种单点登录的实现方式，你知道几个？
  • 4
    Github Pages+Hexo+阿里云域名绑定
  • 5
    测试开启MySQL performance_schema后对性能的影响
  • 6
    阿里云视频云总经理何亚明：基于倚天的视频云原生业务新范式
  • 7
    Windows SDK编程(Delphi版) 之 消息框和菜单资源
  • 8
    三级侧边栏-树形菜单案例效果
  • 9
    U盘故障详细维修方法
  • 10
    1、Windows API函数归总，网络函数、消息函数、文件处理
  • 1
    如何在项目中保证 Web 组件化的性能
    15
  • 2
    如何在项目中高效地进行 Web 组件化开发
    14
  • 3
    Vue3中v-model在处理自定义组件双向数据绑定时，如何避免循环引用？
    15
  • 4
    Vue3中v-model在处理自定义组件双向数据绑定时有哪些注意事项？
    102
  • 5
    在 Vue 3 中，如何使用 v-model 来处理自定义组件的双向数据绑定？
    20
  • 6
    网络漏洞
    16
  • 7
    网络安全
    14
  • 8
    完整性
    14
  • 9
    可用性
    97
  • 10
    可靠性
    13

    • 相关课程

    更多
  • 业务全链路追踪最佳实践
  • 运维监控系统
  • 分布式链路追踪Skywalking
  • 日志服务 SLS 可观测数据分析平台介绍
  • 大数据分析之企业级网站流量运营分析系统开发实战（第二阶段）
  • 大数据分析之企业级网站流量运营分析系统开发实战（第四阶段）

    • 相关电子书

    更多
  • Elasticsearch全观测技术解析与应用（构建日志、指标、APM统一观测平台）
  • 基于资产配置业务场景下的全链路监控平台
  • 基于资产配置业务场景下全链路监控平台

    • 相关实验场景

    更多
  • 配置流程编排实现根据天气情况播放歌曲
  • 在SAE控制台极速部署个人LLM效能工具
  • 基于生命周期管理的存储成本优化
  • 云原生场景自动化响应ECS系统事件
  • 基于DTS构建一站式实时数据服务
  • 基于OpenTelemetry构建全链路追踪与监控
    • 下一篇
    无影云桌面