collie
使用Java实现一个分布式调用链追踪系统
现在项目已经开源，欢迎提pr和star,项目地址：
分布式调用链追踪系统Collie
项目系列博客地址：
柠檬好酸啊：用Java实现一个分布式调用链追踪系统 （一）聊聊自己的想法
柠檬好酸啊：用java实现一个分布式调用链追踪系统（二）项目搭建过程中的一些注意事项
柠檬好酸啊：用java实现一个分布式调用链追踪系统（三）最核心的实现之Javassist
柠檬好酸啊：用java实现一个分布式调用链追踪系统（四）项目具体实现
柠檬好酸啊：用java实现一个分布式调用链追踪系统（五）总结
采样
我们在项目正常的使用过程中肯定不能全部的请求都采样，那样没有用而且浪费性能，所以我们需要进行采样。
首先定义一个LongAdder，每次对于框架插桩之前，都去对这个变量进行累加，如果超过了一定值则不进行采样。
public class SamplingRate {
private final static LongAdder SAMPLING_RATE = new LongAdder();
private static int CUR_SAMPLING_RATE = 10;
private static int BASE_SAMPLING_RATE = 100;
public static boolean needSampling() {
if (SAMPLING_RATE.intValue() >= BASE_SAMPLING_RATE) {
SAMPLING_RATE.reset();
}
SAMPLING_RATE.increment();
return SAMPLING_RATE.intValue() <= CUR_SAMPLING_RATE;
}
}
我这里是采用的两个变量辅助决定采样率，目前的采样率是10%，也即是10/100。
项目使用方法
涉及到agent，所以这个项目启动还是比较麻烦的，我这里写了一个脚本，可以比较方便的启动。
#!/bin/zsh
set -ex
if [ -n "$1" ]; then
mvn install
fi
cp collie-agent/target/collie-agent-1.0-SNAPSHOT-jar-with-dependencies.jar ${HOME}/.collie/collie-agent.jar
cp collie-core/target/collie-core-1.0-SNAPSHOT-jar-with-dependencies.jar ${HOME}/.collie/collie-core.jar
cp collie-spy/target/collie-spy-1.0-SNAPSHOT.jar ${HOME}/.collie/collie-spy.jar
cp collie-test/target/collie-test-1.0-SNAPSHOT.jar ${HOME}/.collie/collie-test.jar
ls ${HOME}/.collie
java -javaagent:${HOME}/.collie/collie-agent.jar=${HOME}/.collie/collie-core.jar,${HOME}/.collie/collie-spy.jar -jar ${HOME}/.collie/collie-test.jar
这里我是写死了路径的，也可以通过吧路径通过javaagent的方式传进去。
结果展示
目前我只是简单打印了一下结果：
$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$
b
e
f
o
r
e
before
b
e
f
o
r
e
$$$$$$$$$$$$$$$$
CallRecord{
transactionInfo=traceId: null, spanId: null, parentSpanId: null,
className=‘xyz.dsvshx.ioc.context.ClassPathXmlApplicationContext’,
methodName=‘getAllBeans’,
descriptor=’()Ljava/util/Map;’,
paramList=[],
throwable=null,
result=null,
startTime=1637163007077,
finishTime=0,
cntMs=0
}
$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$
a
f
t
e
r
after
a
f
t
e
r
$$$$$$$$$$$$$$$$
CallRecord{
transactionInfo=traceId: null, spanId: null, parentSpanId: null,
className=‘xyz.dsvshx.ioc.context.ClassPathXmlApplicationContext’,
methodName=‘getAllBeans’,
descriptor=’()Ljava/util/Map;’,
paramList=[],
throwable=null,
result=null,
startTime=1637163007077,
finishTime=1637163007084,
cntMs=7
}
关于前端
之前打算做，然后我想要实现的效果其实就是下面这种甘特图，我尝试这做过一些，但是前端我做起来比较吃力，后续有机会的话再做吧。
结语
目前这个项目可以说是开发完成也能使用了，本来这只是一个简单的想法，但是自己也一步步的把这个想法实践出来了，过程中也尝试过别的方案，最终也经过重构。
这个项目实现的功能非常的单一，不过好处是这个工具确实能在调试过程中发挥作用，后续我也会根据需求再继续完善这个工具。加入更多的定制化配置和更多的使用功能。
这个项目对于arthas来说可以算是九牛一毛，但是我自己感觉还是非常有意思的，我喜欢把自己的想法一步步实现的感觉，也用过很多之前没尝试过的技术。而且遗憾的是前端不完善，做的东西不能用前端展示出来。
如果你喜欢，欢迎点赞关注加收藏，后续我还会继续做一些类似的有意思的java玩具。