Golang 学习手册
  • 主页
  • 安装
  • 参考资料
  • Q&A
  • 基础
    • Hello,world!
    • 包
    • 变量
    • 常量
    • 类型
      • 整型
      • 浮点型
      • 复数
      • 布尔型
      • 字符
      • 字符串
      • 数组
      • 切片
      • 字典
      • 指针
      • 方法
      • 结构体
      • 接口
      • 自定义类型
    • 语法
      • 判断
      • 循环
      • 错误处理
    • 协程
      • 锁
      • 等待组
      • 通道
      • 上下文
    • 测试与分析
      • 单元测试
      • 性能测试
      • 性能分析
    • 编译
      • 条件编译
      • 交叉编译
  • 高级
    • 存储
      • 键值存储
        • Etcd
    • HTTP
      • http服务基础
      • Websocket
      • 开源框架
        • Beego
        • Echo
        • Gin
        • Iris
        • Revel
        • 框架对比
      • Kubernetes风格API框架
    • RPC
      • RPCX
      • GRPC
      • grpc-gateway
    • 连接分发器
    • TLS加密
    • 链路追踪
      • skywalking
  • 项目管理
    • 代码规范
    • 包管理
    • 文档
      • GoDoc
      • Markdown
      • Swagger
    • 仓库管理
      • 分支管理
      • 问题管理
      • 里程碑管理
      • 发布管理
    • 持续集成
      • CircleCI
      • TravisCI
由 GitBook 提供支持
在本页
  1. 高级
  2. 链路追踪

skywalking

快速开始

1、下载依赖包

go get -u github.com/SkyAPM/go2sky
go get github.com/SkyAPM/go2sky-plugins/gin/v3

如果项目中同时使用到 etcd,可能会出现依赖包冲突的情况,经过测试可将上述两个依赖包降级为 0.6.0 版本

2、创建示例

package main

import (
  "fmt"
  "time"

  "github.com/SkyAPM/go2sky"
  "github.com/SkyAPM/go2sky/reporter"
  "github.com/gin-gonic/gin"

  v3 "github.com/SkyAPM/go2sky-plugins/gin/v3"
)

var (
  skyAddr = "localhost:11800
  serverName = "echo-server"
  serverPort = 8080
)

func panicErr(err error){
  if err!=nil{
    panic(err)
  }
}

func main() {
  r := gin.Default()
  // 实例化 grpc 连接到 skywalking-oap 服务
  rp, err := reporter.NewGRPCReporter(skyAddr, reporter.WithCheckInterval(5*time.Second))
  panicErr(err)
  // 实例化链路追踪器,每个追踪器对应一个注册服务,通常情况下使用单例模式
  tracer, err := go2sky.NewTracer(serverName, go2sky.WithReporter(rp))
  panicErr(err)
  // 将链路追踪器注册到 gin 中间件,自动记录入站请求
  r.Use(v3.Middleware(r, tracer))

  // 自定义接口方法,并记录调用过程
  r.GET("/hello", func(ctx *gin.Context) {
    // 创建一个 span 用于记录入站后的本地处理过程,使用 CreateLocalSpan,如果是 入站请求,则使用 CreateEntrySpan(由于中间件已完成注入,此处已省略)
    span, spanCtx, err := tracer.CreateLocalSpan(context.Request.Context())
    panicErr(err)
    // 设置当前 span 操作步骤的名称
    span.SetOperationName("SayHello")
    // 使用 span 上下文替换原本 gin 的上下文,其中包括追踪过程所记录的信息
    ctx.Request = ctx.Request.WithContext(spanCtx)

    // 记录追踪日志
    span.Log(time.Now(), serverName + ": hello")
    result := gin.H{
      "msg": "hello",
    }
    ctx.JSON(200, result)
    // 结束 span,完成一个过程记录
    span.End()
  })

  r.Run(fmt.Sprintf(":%d", serverPort))
}
上一页链路追踪下一页代码规范

最后更新于2年前