zipkin
#
描述Zipkin 是一个开源的分布调用链追踪系统。zipkin
插件基于 Zipkin API 规范,支持收集跟踪信息并上报给 Zipkin Collector。
该插件也支持 Apache SkyWalking 和 Jaeger,因为它们都支持了 Zipkin v1 和 v2 API。当然 zipkin
插件也可以与其他支持了 Zipkin v1 和 v2 API 格式的调用链追踪系统集成。
#
属性名称 | 类型 | 必选项 | 默认值 | 有效值 | 描述 |
---|---|---|---|---|---|
endpoint | string | 是 | Zipkin 的 HTTP 节点。例如:http://127.0.0.1:9411/api/v2/spans 。 | ||
sample_ratio | number | 是 | [0.00001, 1] | 对请求进行采样的比例。当设置为 1 时,将对所有请求进行采样。 | |
service_name | string | 否 | "APISIX" | 需要在 Zipkin 中显示的服务名称。 | |
server_addr | string | 否 | $server_addr | 当前 APISIX 实例的 IPv4 地址。 | |
span_version | integer | 否 | 2 | [1, 2] | span 类型的版本。 |
在当前版本中,每个被跟踪的请求都会创建如下所示的 span:
request
├── proxy: from the beginning of the request to the beginning of header filter
└── response: from the beginning of header filter to the beginning of log
在旧版本(将 span_version
属性设置为 1
)中,将创建如下 span:
request
├── rewrite
├── access
└── proxy
└── body_filter
note
上述 span 的名称与同名的 NGINX phase 没有联系。
#
上游服务示例Go with Gin
func GetTracer(serviceName string, port int, enpoitUrl string, rate float64) *zipkin.Tracer {
// create a reporter to be used by the tracer
reporter := httpreporter.NewReporter(enpoitUrl)
// set-up the local endpoint for our service host is ip:host
thisip, _ := GetLocalIP()
host := fmt.Sprintf("%s:%d", thisip, port)
endpoint, _ := zipkin.NewEndpoint(serviceName, host)
// set-up our sampling strategy
sampler, _ := zipkin.NewCountingSampler(rate)
// initialize the tracer
tracer, _ := zipkin.NewTracer(
reporter,
zipkin.WithLocalEndpoint(endpoint),
zipkin.WithSampler(sampler),
)
return tracer
}
func main(){
r := gin.Default()
tracer := GetTracer(...)
// use middleware to extract parentID from http header that injected by APISIX
r.Use(func(c *gin.Context) {
span := this.Tracer.Extract(b3.ExtractHTTP(c.Request))
childSpan := this.Tracer.StartSpan(spanName, zipkin.Parent(span))
defer childSpan.Finish()
c.Next()
})
}
#
启用插件以下示例展示了如何在指定路由中启用 zipkin
插件:
curl http://127.0.0.1:9080/apisix/admin/routes/1 -H 'X-API-KEY: edd1c9f034335f136f87ad84b625c8f1' -X PUT -d '
{
"methods": ["GET"],
"uri": "/index.html",
"plugins": {
"zipkin": {
"endpoint": "http://127.0.0.1:9411/api/v2/spans",
"sample_ratio": 1,
"service_name": "APISIX-IN-SG",
"server_addr": "192.168.3.50"
}
},
"upstream": {
"type": "roundrobin",
"nodes": {
"127.0.0.1:1980": 1
}
}
}'
#
测试插件首先你需要通过以下命令创建一个 Zipkin 实例:
docker run -d -p 9411:9411 openzipkin/zipkin
接下来你可以通过以下命令发起请求,该请求记录会出现在 Zipkin 中:
curl http://127.0.0.1:9080/index.html
HTTP/1.1 200 OK
...
最后你可以在浏览器中输入 http://127.0.0.1:9411/zipkin
访问 Zipkin UI 查询 traces:
#
上报到 Jaeger除了对接 Zipkin,该插件也支持将 traces 上报到 Jaeger。
首先,请使用以下命令运行 Jaeger 后端服务:
docker run -d --name jaeger \
-e COLLECTOR_ZIPKIN_HOST_PORT=:9411 \
-p 16686:16686 \
-p 9411:9411 \
jaegertracing/all-in-one:1.31
通过以下命令创建路由并启用插件:
curl http://127.0.0.1:9080/apisix/admin/routes/1 -H 'X-API-KEY: edd1c9f034335f136f87ad84b625c8f1' -X PUT -d '
{
"methods": ["GET"],
"uri": "/index.html",
"plugins": {
"zipkin": {
"endpoint": "http://127.0.0.1:9411/api/v2/spans",
"sample_ratio": 1,
"service_name": "APISIX-IN-SG",
"server_addr": "192.168.3.50"
}
},
"upstream": {
"type": "roundrobin",
"nodes": {
"127.0.0.1:1980": 1
}
}
}'
接下来你可以通过以下命令发起请求,该条请求记录将会出现在 Jaeger 中:
curl http://127.0.0.1:9080/index.html
HTTP/1.1 200 OK
...
最后你可以在浏览器中输入 http://127.0.0.1:16686
访问 Jaeger UI 查看 traces:
#
禁用插件当你需要禁用 zipkin
插件时,可以通过以下命令删除相应的 JSON 配置,APISIX 将会自动重新加载相关配置,无需重启服务:
curl http://127.0.0.1:9080/apisix/admin/routes/1 -H 'X-API-KEY: edd1c9f034335f136f87ad84b625c8f1' -X PUT -d '
{
"methods": ["GET"],
"uri": "/index.html",
"plugins": {
},
"upstream": {
"type": "roundrobin",
"nodes": {
"127.0.0.1:1980": 1
}
}
}'