OpenTelemetry-2.Go接入Jaeger（grpc，gin-http）

目录

1.什么是OpenTelemetry

2.搭建jaeger

3.链路追踪

本地调用

远程调用

GRPC

proto

server端

client端

Gin-HTTP

调用流程

api1

api2

grpc

4.完整代码

1.什么是OpenTelemetry

参考：OpenTelemetry-1.介绍-CSDN博客

2.搭建jaeger

参考：Jaeger分布式链路追踪工具-CSDN博客

3.链路追踪

本地调用

package mainimport ("context""log""time""go.opentelemetry.io/otel""go.opentelemetry.io/otel/attribute""go.opentelemetry.io/otel/exporters/jaeger""go.opentelemetry.io/otel/sdk/resource"tracesdk "go.opentelemetry.io/otel/sdk/trace"semconv "go.opentelemetry.io/otel/semconv/v1.17.0"
)const (service     = "local"environment = "dev"id          = 1
)// tracerProvider returns an OpenTelemetry TracerProvider configured to use
// the Jaeger exporter that will send spans to the provided url. The returned
// TracerProvider will also use a Resource configured with all the information
// about the application.
func tracerProvider(url string) (*tracesdk.TracerProvider, error) {// Create the Jaeger exporterexp, err := jaeger.New(jaeger.WithCollectorEndpoint(jaeger.WithEndpoint(url)))if err != nil {return nil, err}tp := tracesdk.NewTracerProvider(// Always be sure to batch in production.tracesdk.WithBatcher(exp),// Record information about this application in a Resource.tracesdk.WithResource(resource.NewWithAttributes(semconv.SchemaURL,semconv.ServiceName(service),attribute.String("environment", environment),attribute.Int64("ID", id),)),)return tp, nil
}func main() {tp, err := tracerProvider("http://10.128.175.196:14268/api/traces")if err != nil {log.Fatal(err)}// Register our TracerProvider as the global so any imported// instrumentation in the future will default to using it.otel.SetTracerProvider(tp)ctx, cancel := context.WithCancel(context.Background())defer cancel()// Cleanly shutdown and flush telemetry when the application exits.defer func(ctx context.Context) {// Do not make the application hang when it is shutdown.ctx, cancel = context.WithTimeout(ctx, time.Second*5)defer cancel()if err := tp.Shutdown(ctx); err != nil {log.Fatal(err)}}(ctx)tr := tp.Tracer("component-main")ctx, span := tr.Start(ctx, "foo")defer span.End()bar(ctx)
}func bar(ctx context.Context) {// Use the global TracerProvider.tr := otel.Tracer("component-bar")_, span := tr.Start(ctx, "bar")span.SetAttributes(attribute.Key("testset").String("value"))defer span.End()// Do bar...
}

 参考：opentelemetry-go/example/jaeger/main.go at v1.16.0 · open-telemetry/opentelemetry-go · GitHub

远程调用

grpc

proto
syntax = "proto3"; // 指定proto版本
package hello_grpc;     // 指定默认包名// 指定golang包名
option go_package = "/hello_grpc";//定义rpc服务
service HelloService {// 定义函数rpc SayHello (HelloRequest) returns (HelloResponse) {}
}// HelloRequest 请求内容
message HelloRequest {string name = 1;string message = 2;
}// HelloResponse 响应内容
message HelloResponse{string name = 1;string message = 2;
}
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// 	protoc-gen-go v1.33.0
// 	protoc        v3.9.0
// source: grpc_proto/hello.protopackage hello_grpcimport (context "context"grpc "google.golang.org/grpc"codes "google.golang.org/grpc/codes"status "google.golang.org/grpc/status"protoreflect "google.golang.org/protobuf/reflect/protoreflect"protoimpl "google.golang.org/protobuf/runtime/protoimpl"reflect "reflect"sync "sync"
)const (// Verify that this generated code is sufficiently up-to-date._ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)// Verify that runtime/protoimpl is sufficiently up-to-date._ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)// HelloRequest 请求内容
type HelloRequest struct {state         protoimpl.MessageStatesizeCache     protoimpl.SizeCacheunknownFields protoimpl.UnknownFieldsName    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
}func (x *HelloRequest) Reset() {*x = HelloRequest{}if protoimpl.UnsafeEnabled {mi := &file_grpc_proto_hello_proto_msgTypes[0]ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))ms.StoreMessageInfo(mi)}
}func (x *HelloRequest) String() string {return protoimpl.X.MessageStringOf(x)
}func (*HelloRequest) ProtoMessage() {}func (x *HelloRequest) ProtoReflect() protoreflect.Message {mi := &file_grpc_proto_hello_proto_msgTypes[0]if protoimpl.UnsafeEnabled && x != nil {ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))if ms.LoadMessageInfo() == nil {ms.StoreMessageInfo(mi)}return ms}return mi.MessageOf(x)
}// Deprecated: Use HelloRequest.ProtoReflect.Descriptor instead.
func (*HelloRequest) Descriptor() ([]byte, []int) {return file_grpc_proto_hello_proto_rawDescGZIP(), []int{0}
}func (x *HelloRequest) GetName() string {if x != nil {return x.Name}return ""
}func (x *HelloRequest) GetMessage() string {if x != nil {return x.Message}return ""
}// HelloResponse 响应内容
type HelloResponse struct {state         protoimpl.MessageStatesizeCache     protoimpl.SizeCacheunknownFields protoimpl.UnknownFieldsName    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
}func (x *HelloResponse) Reset() {*x = HelloResponse{}if protoimpl.UnsafeEnabled {mi := &file_grpc_proto_hello_proto_msgTypes[1]ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))ms.StoreMessageInfo(mi)}
}func (x *HelloResponse) String() string {return protoimpl.X.MessageStringOf(x)
}func (*HelloResponse) ProtoMessage() {}func (x *HelloResponse) ProtoReflect() protoreflect.Message {mi := &file_grpc_proto_hello_proto_msgTypes[1]if protoimpl.UnsafeEnabled && x != nil {ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))if ms.LoadMessageInfo() == nil {ms.StoreMessageInfo(mi)}return ms}return mi.MessageOf(x)
}// Deprecated: Use HelloResponse.ProtoReflect.Descriptor instead.
func (*HelloResponse) Descriptor() ([]byte, []int) {return file_grpc_proto_hello_proto_rawDescGZIP(), []int{1}
}func (x *HelloResponse) GetName() string {if x != nil {return x.Name}return ""
}func (x *HelloResponse) GetMessage() string {if x != nil {return x.Message}return ""
}var File_grpc_proto_hello_proto protoreflect.FileDescriptorvar file_grpc_proto_hello_proto_rawDesc = []byte{0x0a, 0x16, 0x67, 0x72, 0x70, 0x63, 0x5f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x68, 0x65, 0x6c,0x6c, 0x6f, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x0a, 0x68, 0x65, 0x6c, 0x6c, 0x6f, 0x5f,0x67, 0x72, 0x70, 0x63, 0x22, 0x3c, 0x0a, 0x0c, 0x48, 0x65, 0x6c, 0x6c, 0x6f, 0x52, 0x65, 0x71,0x75, 0x65, 0x73, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01,0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x6d, 0x65, 0x73, 0x73,0x61, 0x67, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61,0x67, 0x65, 0x22, 0x3d, 0x0a, 0x0d, 0x48, 0x65, 0x6c, 0x6c, 0x6f, 0x52, 0x65, 0x73, 0x70, 0x6f,0x6e, 0x73, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28,0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61,0x67, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67,0x65, 0x32, 0x51, 0x0a, 0x0c, 0x48, 0x65, 0x6c, 0x6c, 0x6f, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63,0x65, 0x12, 0x41, 0x0a, 0x08, 0x53, 0x61, 0x79, 0x48, 0x65, 0x6c, 0x6c, 0x6f, 0x12, 0x18, 0x2e,0x68, 0x65, 0x6c, 0x6c, 0x6f, 0x5f, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x48, 0x65, 0x6c, 0x6c, 0x6f,0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x19, 0x2e, 0x68, 0x65, 0x6c, 0x6c, 0x6f, 0x5f,0x67, 0x72, 0x70, 0x63, 0x2e, 0x48, 0x65, 0x6c, 0x6c, 0x6f, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,0x73, 0x65, 0x22, 0x00, 0x42, 0x0d, 0x5a, 0x0b, 0x2f, 0x68, 0x65, 0x6c, 0x6c, 0x6f, 0x5f, 0x67,0x72, 0x70, 0x63, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
}var (file_grpc_proto_hello_proto_rawDescOnce sync.Oncefile_grpc_proto_hello_proto_rawDescData = file_grpc_proto_hello_proto_rawDesc
)func file_grpc_proto_hello_proto_rawDescGZIP() []byte {file_grpc_proto_hello_proto_rawDescOnce.Do(func() {file_grpc_proto_hello_proto_rawDescData = protoimpl.X.CompressGZIP(file_grpc_proto_hello_proto_rawDescData)})return file_grpc_proto_hello_proto_rawDescData
}var file_grpc_proto_hello_proto_msgTypes = make([]protoimpl.MessageInfo, 2)
var file_grpc_proto_hello_proto_goTypes = []interface{}{(*HelloRequest)(nil),  // 0: hello_grpc.HelloRequest(*HelloResponse)(nil), // 1: hello_grpc.HelloResponse
}
var file_grpc_proto_hello_proto_depIdxs = []int32{0, // 0: hello_grpc.HelloService.SayHello:input_type -> hello_grpc.HelloRequest1, // 1: hello_grpc.HelloService.SayHello:output_type -> hello_grpc.HelloResponse1, // [1:2] is the sub-list for method output_type0, // [0:1] is the sub-list for method input_type0, // [0:0] is the sub-list for extension type_name0, // [0:0] is the sub-list for extension extendee0, // [0:0] is the sub-list for field type_name
}func init() { file_grpc_proto_hello_proto_init() }
func file_grpc_proto_hello_proto_init() {if File_grpc_proto_hello_proto != nil {return}if !protoimpl.UnsafeEnabled {file_grpc_proto_hello_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {switch v := v.(*HelloRequest); i {case 0:return &v.statecase 1:return &v.sizeCachecase 2:return &v.unknownFieldsdefault:return nil}}file_grpc_proto_hello_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {switch v := v.(*HelloResponse); i {case 0:return &v.statecase 1:return &v.sizeCachecase 2:return &v.unknownFieldsdefault:return nil}}}type x struct{}out := protoimpl.TypeBuilder{File: protoimpl.DescBuilder{GoPackagePath: reflect.TypeOf(x{}).PkgPath(),RawDescriptor: file_grpc_proto_hello_proto_rawDesc,NumEnums:      0,NumMessages:   2,NumExtensions: 0,NumServices:   1,},GoTypes:           file_grpc_proto_hello_proto_goTypes,DependencyIndexes: file_grpc_proto_hello_proto_depIdxs,MessageInfos:      file_grpc_proto_hello_proto_msgTypes,}.Build()File_grpc_proto_hello_proto = out.Filefile_grpc_proto_hello_proto_rawDesc = nilfile_grpc_proto_hello_proto_goTypes = nilfile_grpc_proto_hello_proto_depIdxs = nil
}// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConnInterface// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion6// HelloServiceClient is the client API for HelloService service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type HelloServiceClient interface {// 定义函数SayHello(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (*HelloResponse, error)
}type helloServiceClient struct {cc grpc.ClientConnInterface
}func NewHelloServiceClient(cc grpc.ClientConnInterface) HelloServiceClient {return &helloServiceClient{cc}
}func (c *helloServiceClient) SayHello(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (*HelloResponse, error) {out := new(HelloResponse)err := c.cc.Invoke(ctx, "/hello_grpc.HelloService/SayHello", in, out, opts...)if err != nil {return nil, err}return out, nil
}// HelloServiceServer is the server API for HelloService service.
type HelloServiceServer interface {// 定义函数SayHello(context.Context, *HelloRequest) (*HelloResponse, error)
}// UnimplementedHelloServiceServer can be embedded to have forward compatible implementations.
type UnimplementedHelloServiceServer struct {
}func (*UnimplementedHelloServiceServer) SayHello(context.Context, *HelloRequest) (*HelloResponse, error) {return nil, status.Errorf(codes.Unimplemented, "method SayHello not implemented")
}func RegisterHelloServiceServer(s *grpc.Server, srv HelloServiceServer) {s.RegisterService(&_HelloService_serviceDesc, srv)
}func _HelloService_SayHello_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {in := new(HelloRequest)if err := dec(in); err != nil {return nil, err}if interceptor == nil {return srv.(HelloServiceServer).SayHello(ctx, in)}info := &grpc.UnaryServerInfo{Server:     srv,FullMethod: "/hello_grpc.HelloService/SayHello",}handler := func(ctx context.Context, req interface{}) (interface{}, error) {return srv.(HelloServiceServer).SayHello(ctx, req.(*HelloRequest))}return interceptor(ctx, in, info, handler)
}var _HelloService_serviceDesc = grpc.ServiceDesc{ServiceName: "hello_grpc.HelloService",HandlerType: (*HelloServiceServer)(nil),Methods: []grpc.MethodDesc{{MethodName: "SayHello",Handler:    _HelloService_SayHello_Handler,},},Streams:  []grpc.StreamDesc{},Metadata: "grpc_proto/hello.proto",
}
server端
package mainimport ("context""fmt""go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc""go.opentelemetry.io/otel""go.opentelemetry.io/otel/attribute""go.opentelemetry.io/otel/exporters/jaeger""go.opentelemetry.io/otel/propagation""go.opentelemetry.io/otel/sdk/resource"tracesdk "go.opentelemetry.io/otel/sdk/trace"semconv "go.opentelemetry.io/otel/semconv/v1.17.0""go_otel/2go_grpc/grpc_proto/hello_grpc""google.golang.org/grpc""google.golang.org/grpc/grpclog""log""net"
)const (service     = "grpc_server"environment = "dev"id          = 2
)var tracer = otel.Tracer(service)// HelloServer 得有一个结构体，需要实现这个服务的全部方法,叫什么名字不重要
type HelloServer struct {
}func (HelloServer) SayHello(ctx context.Context, request *hello_grpc.HelloRequest) (*hello_grpc.HelloResponse, error) {fmt.Println("入参：", request.Name, request.Message)_, span := tracer.Start(ctx, "grpc")span.SetAttributes(attribute.Key("request.Name").String(request.Name))span.SetAttributes(attribute.Key("request.Message").String(request.Message))defer span.End()return &hello_grpc.HelloResponse{Name:    "server",Message: "hello " + request.Name,}, nil
}func tracerProvider() (*tracesdk.TracerProvider, error) {// Create the Jaeger exporterexp, err := jaeger.New(jaeger.WithCollectorEndpoint(jaeger.WithEndpoint("http://10.128.175.196:14268/api/traces")))if err != nil {return nil, err}tp := tracesdk.NewTracerProvider(// Always be sure to batch in production.tracesdk.WithSampler(tracesdk.AlwaysSample()),tracesdk.WithBatcher(exp),tracesdk.WithResource(resource.NewWithAttributes(semconv.SchemaURL,semconv.ServiceName(service),attribute.String("environment", environment),attribute.Int64("ID", id),),),)// Register our TracerProvider as the global so any imported// instrumentation in the future will default to using it.otel.SetTracerProvider(tp)otel.SetTextMapPropagator(propagation.NewCompositeTextMapPropagator(propagation.TraceContext{}, propagation.Baggage{}))return tp, nil
}func main() {tp, err := tracerProvider()if err != nil {log.Fatal(err)}// Cleanly shutdown and flush telemetry when the application exits.defer func() {if err := tp.Shutdown(context.Background()); err != nil {log.Fatal(err)}}()// grpclisten, err := net.Listen("tcp", ":8080")if err != nil {grpclog.Fatalf("Failed to listen: %v", err)}// 创建一个gRPC服务器实例。s := grpc.NewServer(//引入grpc-middleware定义的拦截器grpc.ChainUnaryInterceptor(//openTelemetry 链路追踪otelgrpc.UnaryServerInterceptor(otelgrpc.WithTracerProvider(tp)),),)server := HelloServer{}// 将server结构体注册为gRPC服务。hello_grpc.RegisterHelloServiceServer(s, &server)fmt.Println("grpc server running :8080")// 开始处理客户端请求。err = s.Serve(listen)
}
client端
package mainimport ("context""fmt""go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc""go.opentelemetry.io/otel""go.opentelemetry.io/otel/attribute""go.opentelemetry.io/otel/exporters/jaeger""go.opentelemetry.io/otel/propagation""go.opentelemetry.io/otel/sdk/resource"tracesdk "go.opentelemetry.io/otel/sdk/trace""go.opentelemetry.io/otel/semconv/v1.17.0""go_otel/2go_grpc/grpc_proto/hello_grpc""google.golang.org/grpc""google.golang.org/grpc/credentials/insecure""log""os""time"
)const (service     = "grpc_client"environment = "dev"id          = 2
)func tracerProvider() (*tracesdk.TracerProvider, error) {// Create the Jaeger exporterexp, err := jaeger.New(jaeger.WithCollectorEndpoint(jaeger.WithEndpoint("http://10.128.175.196:14268/api/traces")))if err != nil {return nil, err}tp := tracesdk.NewTracerProvider(// Always be sure to batch in production.tracesdk.WithSampler(tracesdk.AlwaysSample()),tracesdk.WithBatcher(exp),tracesdk.WithResource(resource.NewWithAttributes(semconv.SchemaURL,semconv.ServiceName(service),attribute.String("environment", environment),attribute.Int64("ID", id),),),)// Register our TracerProvider as the global so any imported// instrumentation in the future will default to using it.otel.SetTracerProvider(tp)otel.SetTextMapPropagator(propagation.NewCompositeTextMapPropagator(propagation.TraceContext{}, propagation.Baggage{}))return tp, nil
}func main() {//创建traceProvidertp, err := tracerProvider()if err != nil {fmt.Println("NewTracerProvider err:", err)os.Exit(1)}conn, err := grpc.Dial("localhost:8080", grpc.WithTransportCredentials(insecure.NewCredentials()),//Unary拦截器grpc.WithChainUnaryInterceptor(//openTelemetry 链路追踪otelgrpc.UnaryClientInterceptor(otelgrpc.WithTracerProvider(tp)),),//Stream拦截器grpc.WithChainStreamInterceptor(func(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, streamer grpc.Streamer, opts ...grpc.CallOption) (grpc.ClientStream, error) {// Pre-processing logics := time.Now()cs, err := streamer(ctx, desc, cc, method, opts...)// Post-processing logiclog.Printf("method: %s, latency: %s\n", method, time.Now().Sub(s))return cs, err}),)defer func() {println("关闭TracerProvider。所有注册的跨度处理器都会按照它们注册的顺序关闭，并释放所有持有的计算资源。")if err := tp.Shutdown(context.Background()); err != nil {panic(err)}}()if err != nil {log.Fatalf("connection failed,err:%s", err)}// 初始化客户端client := hello_grpc.NewHelloServiceClient(conn)result, err := client.SayHello(context.Background(), &hello_grpc.HelloRequest{Name:    "client",Message: "hello",})fmt.Println(result, err)}

gin-http

调用流程

api1 ----> api2 ----> grpc

api1
package mainimport ("context""fmt""github.com/gin-gonic/gin""go.opentelemetry.io/contrib/instrumentation/github.com/gin-gonic/gin/otelgin""go.opentelemetry.io/otel""go.opentelemetry.io/otel/attribute""go.opentelemetry.io/otel/codes""go.opentelemetry.io/otel/exporters/jaeger""go.opentelemetry.io/otel/propagation""go.opentelemetry.io/otel/sdk/resource"tracesdk "go.opentelemetry.io/otel/sdk/trace"semconv "go.opentelemetry.io/otel/semconv/v1.17.0"oteltrace "go.opentelemetry.io/otel/trace""log""net/http"modahttp "github.com/webws/go-moda/transport/http"
)const (service     = "api1"environment = "dev"id          = 3
)var tracer = otel.Tracer(service)func tracerProvider() (*tracesdk.TracerProvider, error) {// Create the Jaeger exporterexp, err := jaeger.New(jaeger.WithCollectorEndpoint(jaeger.WithEndpoint("http://10.128.175.196:14268/api/traces")))if err != nil {return nil, err}tp := tracesdk.NewTracerProvider(// Always be sure to batch in production.tracesdk.WithSampler(tracesdk.AlwaysSample()),tracesdk.WithBatcher(exp),tracesdk.WithResource(resource.NewWithAttributes(semconv.SchemaURL,semconv.ServiceName(service),attribute.String("environment", environment),attribute.Int64("ID", id),),),)// Register our TracerProvider as the global so any imported// instrumentation in the future will default to using it.otel.SetTracerProvider(tp)otel.SetTextMapPropagator(propagation.NewCompositeTextMapPropagator(propagation.TraceContext{}, propagation.Baggage{}))return tp, nil
}func main() {tp, err := tracerProvider()if err != nil {log.Fatal(err)}// Cleanly shutdown and flush telemetry when the application exits.defer func() {if err := tp.Shutdown(context.Background()); err != nil {log.Fatal(err)}}()r := gin.New()r.Use(otelgin.Middleware("gin-api1"))loadRoutes(r)fmt.Println("api1 start 8081")r.Run(":8081")
}func loadRoutes(r *gin.Engine) {r.GET("/ping", pingFunc)
}func pingFunc(c *gin.Context) {tracerCtx, span := tracer.Start(c.Request.Context(), "pingFunc",oteltrace.WithAttributes(attribute.String("key-pingFunc", "val-pingFunc")))defer span.End()callApi2(tracerCtx)c.JSON(http.StatusOK, gin.H{"message": "pong",})
}func callApi2(ctx context.Context) {// tracerfmt.Println("on callApi2")tracerCtx, span := tracer.Start(ctx, "callApi2")span.AddEvent("starting callApi2")span.SetAttributes(attribute.Key("key_callApi2").String("value_callApi2"))defer span.End()// 打印TraceID SpanIDspanCtx := oteltrace.SpanContextFromContext(ctx)fmt.Println(spanCtx.TraceID())fmt.Println(spanCtx.SpanID())// 调用api2url := fmt.Sprintf("http://localhost:8082/ping")defer span.End()_, err := modahttp.CallAPI(tracerCtx, url, "GET", nil)if err != nil {fmt.Printf("call api2 error: %v", err)span.SetStatus(codes.Error, err.Error())}
}
api2
package mainimport ("context""fmt""github.com/gin-gonic/gin""go.opentelemetry.io/contrib/instrumentation/github.com/gin-gonic/gin/otelgin""go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc""go.opentelemetry.io/otel""go.opentelemetry.io/otel/attribute""go.opentelemetry.io/otel/exporters/jaeger""go.opentelemetry.io/otel/propagation""go.opentelemetry.io/otel/sdk/resource"tracesdk "go.opentelemetry.io/otel/sdk/trace"semconv "go.opentelemetry.io/otel/semconv/v1.17.0"oteltrace "go.opentelemetry.io/otel/trace""go_otel/3Gin-HTTP/grpc/grpc_proto/hello_grpc""google.golang.org/grpc""google.golang.org/grpc/credentials/insecure""log""net/http"
)const (service     = "api2"environment = "dev"id          = 2
)var tracer = otel.Tracer(service)func tracerProvider() (*tracesdk.TracerProvider, error) {// Create the Jaeger exporterexp, err := jaeger.New(jaeger.WithCollectorEndpoint(jaeger.WithEndpoint("http://10.128.175.196:14268/api/traces")))if err != nil {return nil, err}tp := tracesdk.NewTracerProvider(// Always be sure to batch in production.tracesdk.WithSampler(tracesdk.AlwaysSample()),tracesdk.WithBatcher(exp),tracesdk.WithResource(resource.NewWithAttributes(semconv.SchemaURL,semconv.ServiceName(service),attribute.String("environment", environment),attribute.Int64("ID", id),),),)// Register our TracerProvider as the global so any imported// instrumentation in the future will default to using it.otel.SetTracerProvider(tp)otel.SetTextMapPropagator(propagation.NewCompositeTextMapPropagator(propagation.TraceContext{}, propagation.Baggage{}))return tp, nil
}func main() {tp, err := tracerProvider()if err != nil {log.Fatal(err)}// Cleanly shutdown and flush telemetry when the application exits.defer func() {if err := tp.Shutdown(context.Background()); err != nil {log.Fatal(err)}}()r := gin.New()r.Use(otelgin.Middleware("gin-api2"))loadRoutes(r)fmt.Println("api2 start 8082")r.Run(":8082")
}func loadRoutes(r *gin.Engine) {r.GET("/ping", pingFunc)
}func pingFunc(c *gin.Context) {fmt.Println("on pingFunc")ctx, span := tracer.Start(c.Request.Context(), "pingFunc")defer span.End()callGrpc(ctx)c.JSON(http.StatusOK, gin.H{"message": "pong",})
}func callGrpc(ctx context.Context) {fmt.Println("on callGrpc")ctx, span := tracer.Start(ctx, "callGrpc")defer span.End()// 打印TraceID SpanIDspanCtx := oteltrace.SpanContextFromContext(ctx)fmt.Println(spanCtx.TraceID())fmt.Println(spanCtx.SpanID())// 连接服务器options := make([]grpc.DialOption, 0)options = append(options, grpc.WithTransportCredentials(insecure.NewCredentials()),grpc.WithUnaryInterceptor(otelgrpc.UnaryClientInterceptor()),grpc.WithStreamInterceptor(otelgrpc.StreamClientInterceptor()))conn, err := grpc.DialContext(ctx, "localhost:8083", options...)if err != nil {panic(err)}defer conn.Close()// 初始化客户端client := hello_grpc.NewHelloServiceClient(conn)result, err := client.SayHello(ctx, &hello_grpc.HelloRequest{Name:    "client",Message: "hello",})fmt.Println(result, err)
}
grpc
package mainimport ("context""fmt""go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc""go.opentelemetry.io/otel""go.opentelemetry.io/otel/attribute""go.opentelemetry.io/otel/exporters/jaeger""go.opentelemetry.io/otel/propagation""go.opentelemetry.io/otel/sdk/resource"tracesdk "go.opentelemetry.io/otel/sdk/trace"semconv "go.opentelemetry.io/otel/semconv/v1.17.0"oteltrace "go.opentelemetry.io/otel/trace""go_otel/3Gin-HTTP/grpc/grpc_proto/hello_grpc""google.golang.org/grpc""google.golang.org/grpc/grpclog""log""net"
)const (service     = "remote-grpc"environment = "dev"id          = 3
)var tracer = otel.Tracer(service)// HelloServer 得有一个结构体，需要实现这个服务的全部方法,叫什么名字不重要
type HelloServer struct {
}func (HelloServer) SayHello(ctx context.Context, request *hello_grpc.HelloRequest) (*hello_grpc.HelloResponse, error) {fmt.Println("on grpc SayHello")_, span := tracer.Start(ctx, "SayHello",oteltrace.WithAttributes(attribute.String("key-pingFunc", "val-pingFunc")))defer span.End()spanCtx := oteltrace.SpanContextFromContext(ctx)fmt.Println(spanCtx.SpanID())fmt.Println(spanCtx.TraceID())fmt.Println("入参：", request.Name, request.Message)return &hello_grpc.HelloResponse{Name:    "server",Message: "hello " + request.Name,}, nil
}func tracerProvider() (*tracesdk.TracerProvider, error) {// Create the Jaeger exporterexp, err := jaeger.New(jaeger.WithCollectorEndpoint(jaeger.WithEndpoint("http://10.128.175.196:14268/api/traces")))if err != nil {return nil, err}tp := tracesdk.NewTracerProvider(// Always be sure to batch in production.tracesdk.WithSampler(tracesdk.AlwaysSample()),tracesdk.WithBatcher(exp),tracesdk.WithResource(resource.NewWithAttributes(semconv.SchemaURL,semconv.ServiceName(service),attribute.String("environment", environment),attribute.Int64("ID", id),),),)// Register our TracerProvider as the global so any imported// instrumentation in the future will default to using it.otel.SetTracerProvider(tp)otel.SetTextMapPropagator(propagation.NewCompositeTextMapPropagator(propagation.TraceContext{}, propagation.Baggage{}))return tp, nil
}func main() {tp, err := tracerProvider()if err != nil {log.Fatal(err)}// Cleanly shutdown and flush telemetry when the application exits.defer func() {if err := tp.Shutdown(context.Background()); err != nil {log.Fatal(err)}}()// grpcfmt.Println("grpc start 8083")listen, err := net.Listen("tcp", ":8083")if err != nil {grpclog.Fatalf("Failed to listen: %v", err)}// 创建一个gRPC服务器实例。// 添加拦截器(grpc集成OpenTelemetry主要是调用(otelgrpc.UnaryServerInterceptor())s := grpc.NewServer(grpc.UnaryInterceptor(otelgrpc.UnaryServerInterceptor()))server := HelloServer{}// 将server结构体注册为gRPC服务。hello_grpc.RegisterHelloServiceServer(s, &server)// 开始处理客户端请求。err = s.Serve(listen)
}

4.完整代码

go_opentelemetry_study: Golang使用OpenTelemetry

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://xiahunao.cn/news/2980974.html

如若内容造成侵权/违法违规/事实不符，请联系瞎胡闹网进行投诉反馈，一经查实，立即删除！

相关文章

第100+6步 ChatGPT文献复现：ARIMAX预测新冠

第100+6步 ChatGPT文献复现：ARIMAX预测新冠

基于WIN10的64位系统演示 一、写在前面 我们继续来解读ARIMAX模型文章，这一轮带来的是： 《PLoS One》杂志的2022年一篇题目为《A data-driven eXtreme gradient boosting machine learning model to predict COVID-19 transmission with meteorologic…
阅读更多...
Android视角看鸿蒙第十二课-鸿蒙的布局之相对布局RelativeContainer

Android视角看鸿蒙第十二课-鸿蒙的布局之相对布局RelativeContainer

Android视角看鸿蒙第十二课-鸿蒙的布局之相对布局RelativeContainer 导读 相对布局和线性、层叠布局一样都是类似于Android布局的，之前两篇文章已经了解线性、层叠布局的使用方法，这篇文章一起来学习下鸿蒙中的相对布局。 之前的文章中，我偶…
阅读更多...
【驱动】AM437x中出现很多bioset进程，杀不掉，有影响吗？

【驱动】AM437x中出现很多bioset进程，杀不掉，有影响吗？

1、问题描述 查看linux系统进程时，发现很多bioset进程 2、问题分析 1）bioset进程是内核线程 这些bioset进程与Linux内核的块I/O（Block Input/Output）层有关，它们是内核线程，不是用户空间的进程。 Linux的块I/O层负责管理磁盘和其他块设备的数据传输。当系统读写磁盘…
阅读更多...
【python程序打包教程】PyInstaller一键打包Python程序为独立可执行exe文件

【python程序打包教程】PyInstaller一键打包Python程序为独立可执行exe文件

《博主简介》 小伙伴们好，我是阿旭。专注于人工智能、AIGC、python、计算机视觉相关分享研究。 ✌更多学习资源，可关注公-仲-hao:【阿旭算法与机器学习】，共同学习交流~ 👍感谢小伙伴们点赞、关注！ 《------往期经典推…
阅读更多...
AI大模型探索之路-认知篇4：大语言模型预训练基础认知

AI大模型探索之路-认知篇4：大语言模型预训练基础认知

文章目录 前言一、预训练流程分析二、预训练两大挑战三、预训练网络通信四、预训练数据并行五、预训练模型并行六、预训练3D并行七、预训练代码示例总结 前言 在人工智能的宏伟蓝图中，大语言模型（LLM）的预训练是构筑智慧之塔的基石。预训练过…
阅读更多...
嵌入式s5p5818核心板介绍

嵌入式s5p5818核心板介绍

底板寻址空间介绍 s5p6818 寻址空间采用统一编址方式进行管理 寻址空间映射图： 独立寻址：片内片外存储器只能选择其中一个 统一寻址：片内片外存储器都能使用，且使用的是同一片连续的寻址空间 reserved保留，Normaol …
阅读更多...
Ubuntu20.04安装redis5.0.7

Ubuntu20.04安装redis5.0.7

redis下载命令： wget https://download.redis.io/releases/redis-5.0.7.tar.gz 解压到 opt目录下 tar -zxvf redis-5.0.7.tar.gz -C /opt apt install -y gcc # 安装gccapt install make # 安装make 后面执行make一直报错 make报错后清除： make …
阅读更多...
【03-掌握Scikit-learn：深入机器学习的实用技术】

【03-掌握Scikit-learn：深入机器学习的实用技术】

文章目录 前言数据预处理缺失值处理数据缩放特征选择模型训练参数调整模型评估总结前言 经过了对Python和Scikit-learn的基础安装及简单应用，我们现在将更深入地探究Scikit-learn的实用技术，以进一步提升我们的数据科学技能。在本文中，我们将涵盖数据预处理、特征选择、模型…
阅读更多...
WebSocket的原理、作用、常见注解和生命周期的简单介绍，附带SpringBoot示例

WebSocket的原理、作用、常见注解和生命周期的简单介绍，附带SpringBoot示例

文章目录 WebSocket是什么WebSocket的原理WebSocket的作用全双工和半双工客户端【浏览器】API服务端 【Java】APIWebSocket的生命周期WebSocket的常见注解SpringBoot简单代码示例 WebSocket是什么 WebSocket是一种 通信协议 ，它在 客户端和服务器之间建立了一个双向…
阅读更多...
Vue3中使用无缝滚动插件vue3-seamless-scroll

Vue3中使用无缝滚动插件vue3-seamless-scroll

官网：https://www.npmjs.com/package/vue-seamless-scroll 1、实现效果文字描述： 表格中的列数据进行横向无缝滚动，某一列进行筛选的时候，重新请求后端的数据，进行刷新 2、安装：npm i vue3-seamless-scrol…
阅读更多...
Git和Github绑定

Git和Github绑定

天行健，君子以自强不息；地势坤，君子以厚德载物。 每个人都有惰性，但不断学习是好好生活的根本，共勉！ 文章均为学习整理笔记，分享记录为主，如有错误请指正，共同学习进步。…
阅读更多...
基于RT-Thread的智能家居助手

基于RT-Thread的智能家居助手

一、项目简介 智能家居助手主要基于RT-Thread开发的，该系统主要分为语音子系统，环境监测子系统，智能控制子系统，智能网关子系统，音乐播放器，云端以及应用软件七大部分。语音子系统可通过语音进行人机交互来…
阅读更多...
SMT工艺上出现焊锡球，将有什么影响？

SMT工艺上出现焊锡球，将有什么影响？

在表面贴装技术（SMT）加工过程中，可能会出现焊锡球形成的问题，焊锡球的存在不仅影响产品的外观质量，还可能导致电路短路，从而影响产品性能和可靠性，所以必须提前了解焊锡球的形成原因&#xff0c…
阅读更多...
Tensorflow2.0笔记 - BatchNormalization

Tensorflow2.0笔记 - BatchNormalization

本笔记记录BN层相关的代码。关于BatchNormalization，可以自行百度，或参考这里： 一文读懂Batch Normalization - 知乎神经网络基础系列： 《深度学习中常见激活函数的原理和特点》《过拟合: dropout原理和在模型中的多种应用》深度…
阅读更多...
（五）AB测试及两个案例 学习简要笔记 #统计学 #CDA学习打卡

（五）AB测试及两个案例 学习简要笔记 #统计学 #CDA学习打卡

目录 一. AB测试简介 1）假设检验的一般步骤 2）基于假设检验的AB测试步骤 二. 案例1：使用基于均值的假设检验进行AB测试 1）原始数据 2）提出原假设H0和备择假设H1 3）使用均值之差的t检验，计…
阅读更多...
Electron+Vue3+ElectronForge整合 - 打包时整合 -分步打包

Electron+Vue3+ElectronForge整合 - 打包时整合 -分步打包

说明 本文介绍一下 Electron Vue3 的打包整合的基本操作。实现的效果是 ： 1、一个正常的Vue3项目； 2、整合加入 Electron 框架 ：开发时 Electron 加载的是开发的vue项目； 3、完成打包时整合：3.1 先完成vue3项目的正常…
阅读更多...
vue3 引入@tsparticles/vue3和@tsparticles/slim 实现粒子特效

vue3 引入@tsparticles/vue3和@tsparticles/slim 实现粒子特效

1.安装： yarn add tsparticles/vue3 tsparticles/slim2.main.ts 引入 import Particles from "tsparticles/vue3"; import { loadSlim } from "tsparticles/slim";app.use(Particles as any, {init: async (engine: any) > {await loadSli…
阅读更多...
如何在 Flutter 中制作多种颜色的 TextField

如何在 Flutter 中制作多种颜色的 TextField

TextField widget 本身并不施加任何样式。相反，它会要求 TextEditingController 生成一个样式化的 TextSpan 对象，即一段带有样式的文本。 TextField 将其样式传递给 TextEditingController ，默认实现只是将其放入 TextSpan 对象中&#xff0…
阅读更多...
光纤网络电力控制系统设计方案：623-6U CPCI的光纤网络电力控制系统

光纤网络电力控制系统设计方案：623-6U CPCI的光纤网络电力控制系统

6U CPCI的光纤网络电力控制系统 一、设备概述 柔性直流输电系统中用于控制与测量的FS系统，适用于风电和太阳能发电的并网快速数值计算和闭环控制，以及与直流输电系统的换流器有关的特殊控制功能，包括门控单元的信号处理。该控制板的最大…
阅读更多...
【C语言回顾】操作符详解

【C语言回顾】操作符详解

前言1. 操作符分类2. 二进制和进制转换2.1 二进制2.2 进制转换2.2.1 二进制转十进制2.2.2 二进制转八进制2.2.3 二进制转十六进制 3. 原码、反码、补码4. 移位操作符4.1 左移操作符4.2 右移操作符 5. 位操作符6. 单目操作符7. 逗号表达式8. 下标引用操作符9. 函数调用操作符10.…
阅读更多...
最新文章

Copyright @ 2022~2023