OpenTelemetry-go的SDK使用方法详解

# 安装核心模块
go get go.opentelemetry.io/otel \
       go.opentelemetry.io/otel/trace
# 安装导出器,这里导出器使用的是stdout
go get go.opentelemetry.io/otel/sdk \
         go.opentelemetry.io/otel/exporters/stdout/stdouttrace
# 因为我们需要使用jaeger所以要导入jaeger导出器
go get -u go.opentelemetry.io/otel/exporters/jaeger

package main
import (
	"context"
	"fmt"
	"go.opentelemetry.io/otel"
	"go.opentelemetry.io/otel/attribute"
	"go.opentelemetry.io/otel/exporters/jaeger"
	"go.opentelemetry.io/otel/sdk/resource"
	"go.opentelemetry.io/otel/sdk/trace"
	semconv "go.opentelemetry.io/otel/semconv/v1.12.0"
)
// 计算斐波那契队列
func Fibonacci(n uint) (uint64, error) {
	if n <= 1 {
		return uint64(n), nil
	}

	var n2, n1 uint64 = 0, 1
	for i := uint(2); i < n; i++ {
		n2, n1 = n1, n1+n2
	}

	return n2 + n1, nil
}
// 这里模拟服务之间的掉用的效果.
func Run(ctx context.Context) {
	_, span := otel.Tracer("nihao").Start(ctx, "two")
	defer span.End()
	fibonacci, err := Fibonacci(20)
	if err != nil {
		return
	}
	fmt.Println(fibonacci)
}
// newExporter returns a console exporter.
// 创建导出器,对于链路追踪服务器的选择就是在这里配置
// 下面是基于jaeger的导出器.
// 这里需要注意,在使用jaeger导出器的时候传输格式是jaeger.thrift over HTTP
// 所以在配置url时请使用14268端口 与/api/traces
func newExporter(url string) (*jaeger.Exporter, error) {
	return jaeger.New(jaeger.WithCollectorEndpoint(jaeger.WithEndpoint(url)))
}

// 资源是一种特殊类型的属性，适用于进程生成的所有跨度。这些应该用于表示有关非临时进程的底层元数据
// 例如，进程的主机名或其实例 ID
func newResource() *resource.Resource {
	r, _ := resource.Merge(
		resource.Default(),
		resource.NewWithAttributes(
			semconv.SchemaURL,
			semconv.ServiceNameKey.String("fib"),
			semconv.ServiceVersionKey.String("v0.1.0"),
			attribute.String("environment", "demo"),
		),
	)
	return r
}

// 主函数
func main() {
	url := "http://collector.tl.com:31498/api/traces"
	// 创建导出器
	exp, _ := newExporter(url)
	// 创建链路生成器,这里将导出器与资源信息配置进去.
	tp := trace.NewTracerProvider(
		trace.WithBatcher(exp),
		trace.WithResource(newResource()),
	)
	// 结束时关闭链路生成器
	defer func() {
		if err := tp.Shutdown(context.Background()); err != nil {
			fmt.Println(err)
		}
	}()

	// 将创建的生成器设置为全局变量.
	// 这样直接使用otel.Tracer就可以创建链路.
	// 否则 就要使用 tp.Tracer的形式创建链路.
	otel.SetTracerProvider(tp)
	newCtx, span := otel.Tracer("nihao").Start(context.Background(), "one")
	Run(newCtx)
	span.End()
}

// 配置jaeger服务器
jaeger.WithCollectorEndpoint(jaeger.WithEndpoint(url))
// 参数是一个options ...CollectorEndpointOption所以让我们看一下都有哪些配置
jaeger.WithEndpoint(endpoint string) // 配置服务器地址
jaeger.WithUsername(username string) // 配置用户名
jaeger.WithPassword(password string) // 配置密码
jaeger.WithHTTPClient(client *http.Client) //设置用于发送给jeager服务器所用到的client,有默认.这里可以设置

// 配置jaeger-agent 代理地址
jaeger.WithAgentEndpoint()
// 参数是options ...AgentEndpointOption
jaeger.WithAgentHost(host string) // 设置代理host
jaeger.WithAgentPort(port string) // 设置代理端口
jaeger.WithLogger(logger *log.Logger) // 设置日志系统
jaeger.WithDisableAttemptReconnecting() // 设置禁止重新连接UDP
jaeger.WithAttemptReconnectingInterval(interval time.Duration) // 设置代理解析jaeger服务器之间的时间间隔
jaeger.WithMaxPacketSize(size int) // 设置UDP传输的最大包

// merge 只是合并下面的两组资源.
r, _ := resource.Merge(
        // 设置默认的资源. 进程id等
		resource.Default(),
        // 设置自定义属性
		resource.NewWithAttributes(
			semconv.SchemaURL,
			semconv.ServiceNameKey.String("fib"),
			semconv.ServiceVersionKey.String("v0.1.0"),
            // 我们可以使用该方法,来进行添加自定义属性
			attribute.String("environment", "demo"),
		),
	)

	// 创建生成器,这里配置了资源与 导出器.
tp := trace.NewTracerProvider(
		trace.WithBatcher(exp),
		trace.WithResource(newResource()),
	)
// 下面让我们看一下它都有哪些配置
// 这里创建的是批量处理导出器,也就是我们常用的
WithBatcher(e SpanExporter, opts ...BatchSpanProcessorOption)
// 这里可以添加别的导出器,也就是说可以同时发送给jaeger与zipkin
WithSpanProcessor(sp SpanProcessor)
// 配置资源
WithResource(r *resource.Resource)
// Tracers id与span id生成器,默认为随机数
WithIDGenerator(g IDGenerator)
// 设置采样数
WithSampler(s Sampler)
// 设置属性,资源的数量
WithSpanLimits(sl SpanLimits)
WithRawSpanLimits(limits SpanLimits)

otel.SetTracerProvider(tp)

ctx := context.TODO()
span := trace.SpanFromContext(ctx)

span.SetStatus(codes.Error, "operationThatCouldFail failed")

span.SetAttributes(attribute.Bool("isTrue", true), attribute.String("stringAttr", "hi!"))

span.RecordError(err)

span.AddEvent("Acquiring lock")

defer func() {
		if err := tp.Shutdown(context.Background()); err != nil {
			fmt.Println(err)
		}
	}()