zipkin

该插件也支持 Apache SkyWalking 和 ,因为它们都支持了 Zipkin v1 和 API。当然 zipkin 插件也可以与其他支持了 Zipkin v1 和 v2 API 格式的调用链追踪系统集成。

在当前版本中,每个被跟踪的请求都会创建如下所示的 span:

在旧版本(将 span_version 属性设置为 1)中,将创建如下 span:

  1. request
  2. ├── rewrite
  3. ├── access
  4. └── proxy
  5. └── body_filter
note

上述 span 的名称与同名的 NGINX phase 没有联系。

Go with Gin

  1. func GetTracer(serviceName string, port int, enpoitUrl string, rate float64) *zipkin.Tracer {
  2. // create a reporter to be used by the tracer
  3. reporter := httpreporter.NewReporter(enpoitUrl)
  4. // set-up the local endpoint for our service host is ip:host
  5. thisip, _ := GetLocalIP()
  6. host := fmt.Sprintf("%s:%d", thisip, port)
  7. endpoint, _ := zipkin.NewEndpoint(serviceName, host)
  8. // set-up our sampling strategy
  9. sampler, _ := zipkin.NewCountingSampler(rate)
  10. // initialize the tracer
  11. tracer, _ := zipkin.NewTracer(
  12. reporter,
  13. zipkin.WithLocalEndpoint(endpoint),
  14. zipkin.WithSampler(sampler),
  15. return tracer
  16. }
  17. func main(){
  18. r := gin.Default()
  19. tracer := GetTracer(...)
  20. // use middleware to extract parentID from http header that injected by APISIX
  21. r.Use(func(c *gin.Context) {
  22. span := this.Tracer.Extract(b3.ExtractHTTP(c.Request))
  23. childSpan := this.Tracer.StartSpan(spanName, zipkin.Parent(span))
  24. defer childSpan.Finish()
  25. c.Next()
  26. })
  27. }
  1. curl http://127.0.0.1:9180/apisix/admin/routes/1 -H 'X-API-KEY: edd1c9f034335f136f87ad84b625c8f1' -X PUT -d '
  2. {
  3. "methods": ["GET"],
  4. "uri": "/index.html",
  5. "plugins": {
  6. "zipkin": {
  7. "endpoint": "http://127.0.0.1:9411/api/v2/spans",
  8. "sample_ratio": 1,
  9. "service_name": "APISIX-IN-SG",
  10. "server_addr": "192.168.3.50"
  11. }
  12. },
  13. "type": "roundrobin",
  14. "127.0.0.1:1980": 1
  15. }
  16. }
  17. }'

首先你需要通过以下命令创建一个 Zipkin 实例:

接下来你可以通过以下命令发起请求,该请求记录会出现在 Zipkin 中:

  1. curl http://127.0.0.1:9080/index.html
  1. HTTP/1.1 200 OK
  2. ...

最后你可以在浏览器中输入 http://127.0.0.1:9411/zipkin 访问 Zipkin UI 查询 traces:

zipkin web-ui

上报到 Jaeger

首先,请使用以下命令运行 Jaeger 后端服务:

  1. docker run -d --name jaeger \
  2. -e COLLECTOR_ZIPKIN_HOST_PORT=:9411 \
  3. -p 16686:16686 \
  4. -p 9411:9411 \
  5. jaegertracing/all-in-one:1.31

通过以下命令创建路由并启用插件:

接下来你可以通过以下命令发起请求,该条请求记录将会出现在 Jaeger 中:

  1. curl http://127.0.0.1:9080/index.html
  1. HTTP/1.1 200 OK
  2. ...

最后你可以在浏览器中输入 http://127.0.0.1:16686 访问 Jaeger UI 查看 traces:

jaeger web-ui

当你需要禁用 zipkin 插件时,可以通过以下命令删除相应的 JSON 配置,APISIX 将会自动重新加载相关配置,无需重启服务:

  1. curl http://127.0.0.1:9180/apisix/admin/routes/1 -H 'X-API-KEY: edd1c9f034335f136f87ad84b625c8f1' -X PUT -d '
  2. {
  3. "methods": ["GET"],
  4. "uri": "/index.html",
  5. "plugins": {
  6. },
  7. "upstream": {
  8. "type": "roundrobin",
  9. "nodes": {
  10. "127.0.0.1:1980": 1
  11. }