Go语言Echo集成OpenTelemetry无数据上报至Jaeger问题排查

核心问题定位：OpenTelemetry初始化不完整 #

你目前只初始化了Tracer，但缺少**Exporter（导出器）和TracerProvider（追踪提供者）**的配置——这是Jaeger收不到数据的核心原因，链路数据仅在内存流转，并未导出到Jaeger实例。

步骤1：完成OpenTelemetry全局初始化（main.go） #

在main.go里完整配置Jaeger Exporter和全局TracerProvider，让所有包的追踪逻辑复用统一配置，实现开箱即用的自动追踪：

package main

import (
    "context"
    "log"
    "time"

    "go.opentelemetry.io/otel"
    "go.opentelemetry.io/otel/exporters/jaeger"
    "go.opentelemetry.io/otel/sdk/resource"
    sdktrace "go.opentelemetry.io/otel/sdk/trace"
    semconv "go.opentelemetry.io/otel/semconv/v1.21.0"
    "your-project-path/httpserver"
)

func initOTel(ctx context.Context) (func(context.Context) error, error) {
    // 1. 创建Jaeger Exporter，指定本地Jaeger的gRPC端点（默认4317）
    exporter, err := jaeger.New(jaeger.WithCollectorEndpoint(jaeger.WithEndpoint("http://localhost:4317")))
    if err != nil {
        return nil, err
    }

    // 2. 创建TracerProvider，设置全采样（调试阶段用）和服务标识
    tracerProvider := sdktrace.NewTracerProvider(
        sdktrace.WithBatcher(exporter),
        sdktrace.WithResource(resource.NewWithAttributes(
            semconv.SchemaURL,
            semconv.ServiceName("echo-http-server"), // Jaeger中显示的服务名
            semconv.DeploymentEnvironment("local"),
        )),
        sdktrace.WithSampler(sdktrace.AlwaysSample()),
    )

    // 3. 设置全局TracerProvider，其他包可直接通过otel.Tracer()获取实例
    otel.SetTracerProvider(tracerProvider)

    // 返回关闭函数，程序退出时清理资源
    return tracerProvider.Shutdown, nil
}

func main() {
    ctx := context.Background()

    // 初始化OpenTelemetry
    shutdown, err := initOTel(ctx)
    if err != nil {
        log.Fatalf("OTel初始化失败: %v", err)
    }
    defer func() {
        if err := shutdown(ctx); err != nil {
            log.Fatalf("OTel关闭失败: %v", err)
        }
    }()

    // 启动HTTP服务器
    if err := httpserver.Start(); err != nil {
        log.Fatalf("服务器启动失败: %v", err)
    }
}

步骤2：调整Echo中间件顺序 #

确保otelecho.Middleware在所有路由注册之前，且RequestID中间件优先于otel中间件（方便关联日志与链路）：

package httpserver

import (
    "your-project-path/handlers"
    "github.com/labstack/echo/v4"
    "github.com/labstack/echo/v4/middleware"
    "go.opentelemetry.io/contrib/instrumentation/github.com/labstack/echo/otelecho"
    "go.uber.org/zap"
)

func Start() error {
    e := echo.New()
    e.Validator = validator
    e.HTTPErrorHandler = handlers.CustomHTTPErrorHandler

    // 中间件顺序：基础保障 -> 标识类 -> 观测类
    e.Use(middleware.Recover())
    e.Use(middleware.RequestID())
    e.Use(echozap.ZapLogger(logger))
    e.Use(echoprometheus.NewMiddleware("http"))
    e.Use(otelecho.Middleware("echo-http-server")) // 自动为每个HTTP请求创建根Span

    // 注册路由
    e.GET("/health", handlers.HealthCheck)
    // ...其他路由

    return e.Start(":8080")
}

步骤3：多包结构下的自动链路关联 #

无需为每个端点手动创建Span，只需做到两点：

1. 所有HTTP请求都经过otelecho.Middleware，它会自动生成请求根Span
2. 其他包的业务函数使用从请求上下文传递的ctx创建子Span，自动关联根链路：

// service包示例
package service

import (
    "context"
    "go.opentelemetry.io/otel"
)

func DoBusiness(ctx context.Context, param string) error {
    // 自动创建子Span，关联HTTP请求的根Span
    tracer := otel.Tracer("service")
    ctx, span := tracer.Start(ctx, "DoBusiness")
    defer span.End()

    // 业务逻辑...
    if err := someDBOperation(ctx); err != nil {
        span.RecordError(err)
        return err
    }

    return nil
}

步骤4：修复错误处理中的Span记录 #

在CustomHTTPErrorHandler中先判断Span是否处于录制状态，避免空指针panic：

func CustomHTTPErrorHandler(err error, c echo.Context) {
    ctx := c.Request().Context()
    if span := trace.SpanFromContext(ctx); span.IsRecording() {
        span.RecordError(err)
        span.SetAttributes(attribute.String("error.detail", err.Error()))
    }

    // 原有错误响应逻辑
    c.JSON(http.StatusInternalServerError, map[string]string{"error": err.Error()})
}

步骤5：验证Jaeger连接 #

• 确保本地Jaeger实例正常运行，默认UI地址为http://localhost:16686
• 若使用HTTP协议导出，将Exporter配置改为：

  exporter, err := jaeger.New(jaeger.WithCollectorEndpoint(jaeger.WithEndpoint("http://localhost:4318/v1/traces")))
  

• 启动应用后访问接口，在Jaeger UI搜索服务名echo-http-server即可查看链路数据。

内容的提问来源于stack exchange，提问作者Arthur S