实现一个2层深度的链
以上代码,仅产生了一个span,也就是一个方法调用。接下来,我们看一下如何完成一个多层的调用链条。接下来还是要修改LoveYou类。我们把调用方法hello
拆解一下,拆成dispatch
和hello
两个方法,并在hello方法里sleep一秒钟。
期望生成两条trace信息。
dispatch
public void dispatch(String cmd, String content) {
Span span = tracer.buildSpan("dispatch").start();
tracer.activateSpan(span);
if (cmd.equals("hello")) {
this.hello(content);
}
if (null != span) {
span.setTag("cmd", cmd);
span.finish();
}
}
hello
public void hello(String name) {Span span = tracer.buildSpan("hello").start();
tracer.activateSpan(span);
System.out.println("Hello " + name);
try {
Thread.sleep(TimeUnit.SECONDS.toMillis(1));
} catch (InterruptedException e) {
e.printStackTrace();
}
span.setTag("name", name);
span.log("Love service say hello to " + name);
span.finish();
}
与示例一不同的是,每次生成span之后,我们还要将其激活一下
scope
中。这样,链条就串起来了。
以下是程序运行后的效果。
采样
有时候,我们的服务QPS非常高,瞬间能够生成大量的trace信息。这些信息是非常相近的,且会给存储产生很大的压力。
如果不需要统计一些QPS之类的信息,就可以使用sampler,仅收集部分trace。
还记得我们使用javaapi构建的jaeger实例么?其中,有这么一行代码:
.withSampler(new ConstSampler(true))
这就是最简单的采样
,意思是收集所有的信息。jaeger支持四种不同的采样类型。
Constant
这是一个布尔开关,如果sampler.param=1
,则代表收集所有的trace,如果为0
,则代表什么都不收集。
Probabilistic
基于概率进行采样,比如sampler.param=0.1,则代表有1/10的trace将被收集。
Rate Limiting
限流方式,使用令牌桶限流。 sampler.param=2.0
则代表每秒有2个trace被收集,超出的将被抛弃。
Remote
通过远程配置方式配置,这也是默认的方式。比如在Collector中配置strategies.json
{
"service_strategies": [
{
"service": "foo",
"type": "probabilistic",
"param": 0.8,
"operation_strategies": [
{
"operation": "op1",
"type": "probabilistic",
"param": 0.2
},
{
"operation": "op2",
"type": "probabilistic",
"param": 0.4
}
]
},
{
"service": "bar",
"type": "ratelimiting",
"param": 5
}
],
"default_strategy": {
"type": "probabilistic",
"param": 0.5
}
}
通过OpenTracing的Api,可以很容易的实现调用链功能。但可以看到,由于存在各种各样的客户端,主要工作量就集中在对这些客户端的兼容上。比如线程池、SpringCloud、MQ、数据库连接池等等等等。
使用Aop可以省去一些编码和侵入,但可控制性会弱一些。
接下来,我们给一个简单的OkHttp+SpringBoot调用,也就是分布式应用,添加trace功能。