php小編小新今天為大家介紹一種強大的工具——OpenTelemetry，它可以幫助開發(fā)者在不同的服務(wù)中實現(xiàn)統(tǒng)一的范圍管理。在現(xiàn)代的分布式系統(tǒng)中，應(yīng)用程序通常由多個微服務(wù)組成，每個微服務(wù)都有自己的日志、指標和追蹤信息。OpenTelemetry提供了一種簡單而強大的方式來集成和管理這些信息，使得開發(fā)者能夠更好地理解和調(diào)試整個系統(tǒng)的性能和行為。無論是在本地開發(fā)環(huán)境還是在生產(chǎn)環(huán)境中，OpenTelemetry都能幫助開發(fā)者更好地理解和優(yōu)化他們的應(yīng)用程序。

我剛剛開始使用 opentelemetry，并為此創(chuàng)建了兩個（微）服務(wù)：standard 和 geomap。

最終用戶向standard服務(wù)發(fā)送請求，后者又向geomap發(fā)送請求以獲取信息，然后再將結(jié)果返回給最終用戶。我使用 gr電腦端 進行所有通信。

我已經(jīng)對我的功能進行了這樣的檢測：

對于標準：

type standardservice struct {
    pb.unimplementedstandardserviceserver
}

func (s *standardservice) getstandard(ctx context.context, in *pb.getstandardrequest) (*pb.getstandardresponse, error) {

    conn, _:= createclient(ctx, geomapsvcaddr)
    defer conn1.close()

    newctx, span1 := otel.tracer(name).start(ctx, "getstandard")
    defer span1.end()

    countryinfo, err := pb.newgeomapserviceclient(conn).getcountry(newctx,
        &pb.getcountryrequest{
            name: in.name,
        })

    //...

    return &pb.getstandardresponse{
        standard: standard,
    }, nil

}

func createclient(ctx context.context, svcaddr string) (*gr電腦端.clientconn, error) {
    return gr電腦端.dialcontext(ctx, svcaddr,
        gr電腦端.withtransportcredentials(insecure.newcredentials()),
        gr電腦端.withunaryinterceptor(otelgr電腦端.unaryclientinterceptor()),
    )
}

對于地理地圖：

type geomapservice struct {
    pb.unimplementedgeomapserviceserver
}

func (s *geomapservice) getcountry(ctx context.context, in *pb.getcountryrequest) (*pb.getcountryresponse, error) {

    _, span := otel.tracer(name).start(ctx, "getcountry")
    defer span.end()

    span.setattributes(attribute.string("country", in.name))

    span.addevent("retrieving country info")

    //...
    
    span.addevent("country info retrieved")

    return &pb.getcountryresponse{
        country: &country,
    }, nil

}

這兩個服務(wù)都配置為將其跨度發(fā)送到 jaeger 后端并共享幾乎相同的主要功能（評論中指出了細微的差異）：

const (
    name        = "mapedia"
    service     = "geomap" //or standard
    environment = "production"
    id          = 1
)

func tracerProvider(url string) (*tracesdk.TracerProvider, error) {
    // Create the Jaeger exporter
    exp, 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("localhost:14268/api/traces")
    if err != nil {
        log.Fatal(err)
    }

    defer func() {
        if err := tp.Shutdown(context.Background()); err != nil {
            log.Fatal(err)
        }
    }()
    otel.SetTracerProvider(tp)

    listener, err := net.Listen("tcp", ":"+port)
    if err != nil {
        panic(err)
    }

    s := gr電腦端.NewServer(
        gr電腦端.UnaryInterceptor(otelgr電腦端.UnaryServerInterceptor()),
    )
    reflection.Register(s)
    pb.RegisterGeoMapServiceServer(s, &geomapService{}) // or pb.RegisterStandardServiceServer(s, &standardService{})
    if err := s.Serve(listener); err != nil {
        log.Fatalf("Failed to serve: %v", err)
    }
}

當(dāng)我查看最終用戶對標準服務(wù)的請求生成的跟蹤時，我可以看到它正如預(yù)期的那樣，調(diào)用其geomap服務(wù)：

但是，我沒有看到已添加到子范圍的任何屬性或事件（我在檢測 geomap< 的 getcountry 函數(shù)時添加了一個屬性和 2 個事件/em>）。

然而，我注意到這些屬性在另一個單獨的跟蹤中可用（在 jaeger 中的“geomap”服務(wù)下可用），其跨度 id 與標準服務(wù)中的子跨度完全無關(guān)：

現(xiàn)在我期望的是有一個跟蹤，并查看與 標準 范圍內(nèi)的子范圍中的 geomap 相關(guān)的所有屬性/事件。如何從這里得到預(yù)期的結(jié)果？

func createclient(ctx context.context, svcaddr string) (*gr電腦端.clientconn, error) {
    return gr電腦端.dialcontext(ctx, svcaddr,
        gr電腦端.withtransportcredentials(insecure.newcredentials()),
        gr電腦端.withunaryinterceptor(otelgr電腦端.unaryclientinterceptor()),
    )
}

func (s *standardservice) getstandard(ctx context.context, in *pb.getstandardrequest) (*pb.getstandardresponse, error) {
    newctx, span1 := otel.tracer(name).start(ctx, "getstandard")
    defer span1.end()

    conn, _:= createclient(newctx, geomapsvcaddr)
    defer conn.close()

    countryinfo, err := pb.newgeomapserviceclient(conn).getcountry(newctx,
        &pb.getcountryrequest{
            name: in.name,
        })

    //...

    return &pb.getstandardresponse{
        standard: standard,
    }, nil
}

otel.settextmappropagator(propagation.tracecontext{})

ctx, span := otel.tracer(name).start(ctx, "getcountry")
sc := trace.spancontextfromcontext(ctx)
log.printf("trace id: %s, span id: %s", sc.traceid(), sc.spanid())
defer span.end()

newCtx, span1 := otel.Tracer(name).Start(ctx, "GetStandard")
sc := trace.SpanContextFromContext(newCtx)
log.Printf("Trace ID: %s, Span ID: %s", sc.TraceID(), sc.SpanID())
defer span1.End()