package main
import (
"os"
"time"
"github.com/gin-gonic/gin"
"github.com/opentracing/opentracing-go"
zkOt "github.com/openzipkin-contrib/zipkin-go-opentracing"
"github.com/openzipkin/zipkin-go"
zkHttp "github.com/openzipkin/zipkin-go/reporter/http"
)
// 第一步: 开一个全局变量
var zkTracer opentracing.Tracer
func main() {
// 第二步: 初始化 tracer
{
reporter := zkHttp.NewReporter("http://localhost:9411/api/v2/spans")
defer reporter.Close()
endpoint, err := zipkin.NewEndpoint("main3", "localhost:80")
if err != nil {
log.Fatalf("unable to create local endpoint: %+v\n", err)
}
nativeTracer, err := zipkin.NewTracer(reporter, zipkin.WithLocalEndpoint(endpoint))
if err != nil {
log.Fatalf("unable to create tracer: %+v\n", err)
}
zkTracer = zkOt.Wrap(nativeTracer)
opentracing.SetGlobalTracer(zkTracer)
}
r := gin.Default()
// 第三步: 添加一个 middleWare, 为每一个请求添加span
r.Use(func(c *gin.Context) {
span := zkTracer.StartSpan(c.FullPath())
defer span.Finish()
c.Next()
})
r.GET("/",
func(c *gin.Context) {
time.Sleep(500 * time.Millisecond)
c.JSON(200, gin.H{"code": 200, "msg": "OK"})
})
r.GET("/app",
func(c *gin.Context) {
time.Sleep(500 * time.Millisecond)
c.JSON(200, gin.H{"code": 200, "msg": "OK"})
})
r.Run(":80")
}
Golang-06 为gin框架添加zipkin
©著作权归作者所有,转载或内容合作请联系作者
- 文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
- 文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
- 文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
推荐阅读更多精彩内容
- HTTPS配置步骤: 首先在阿里云搞定ICP域名备案 添加一个子域名 给子域名申请免费 SSL 证书, 然后下载证...
- 一、安装Gin框架1.查看配置环境 注意：所有下载的包都会默认放在GOPATH，因此这个目录是必须的，且一般包含s...
- ## 简介 因为工作上的需求，由于两个项目都是管理类型的，故在项目开始之处就考虑做一个能够快速开发应用的框架，考虑...
