Golang并行Webhook请求中parent traceID被覆盖问题求解

核心问题在于你使用了slog.SetDefault(newLogger)全局修改默认日志器，并发场景下多个请求会互相覆盖这个全局设置，导致traceID和parentTraceID混乱。另外处理器中直接创建context.Background()而不是复用Gin请求上下文，也会导致上下文传递链断裂。

以下是具体解决方案：

1. 避免全局修改slog，为每个请求创建独立日志器 #

放弃使用slog.SetDefault，改为将每个请求的专属日志器存储到请求上下文中，后续函数从上下文获取日志器即可，而非依赖全局默认。

修改InitSlog函数，不再设置全局日志器，而是返回绑定了日志器和traceID的上下文：

func InitSlog(parentCtx context.Context, tracer *string, parentTracer string) (context.Context, *slog.Logger, string) {
    logger := slog.New(
        slogFormatter.NewFormatterHandler(
            slogFormatter.HTTPRequestFormatter(false),
            slogFormatter.HTTPResponseFormatter(false),
        )(
            slog.NewJSONHandler(os.Stdout, &slog.HandlerOptions{
                AddSource: true,
            }),
        ),
    )

    var traceID string
    if tracer == nil || *tracer == "" {
        traceID = generateCorrelationID()
    } else {
        traceID = *tracer
    }

    // 为当前请求创建带trace标识的日志器
    reqLogger := logger.With("traceID", traceID, "parentTraceID", parentTracer)
    
    // 将日志器和traceID存入上下文
    ctx := context.WithValue(parentCtx, constants.RequestLoggerKey, reqLogger)
    ctx = context.WithValue(ctx, constants.TraceIDKey, traceID)

    return ctx, reqLogger, traceID
}

2. 正确复用Gin请求上下文 #

在Webhook处理器中，直接使用Gin提供的c.Request.Context()作为父上下文，不要重新创建context.Background()：

func Handlewebhook(c *gin.Context) {
    // 复用Gin的请求上下文，保证上下文传递链完整
    ctx, _, traceID := utils.InitSlog(c.Request.Context(), nil, "")
    // 将更新后的上下文绑定回Gin上下文，方便后续中间件/处理器使用
    c.Request = c.Request.WithContext(ctx)

    // 后续业务逻辑中，可直接从ctx获取日志器或traceID
    // 例如：logger := ctx.Value(constants.RequestLoggerKey).(*slog.Logger)
    // logger.Info("开始处理Webhook请求")
}

3. 在后续函数/Google Cloud Task中传递上下文 #

在调用其他函数或创建Google Cloud Task时，直接传递当前请求的上下文，从中获取traceID：

// 示例：业务处理函数
func processWebhook(ctx context.Context) error {
    traceID, ok := ctx.Value(constants.TraceIDKey).(string)
    if !ok {
        return errors.New("无法获取traceID")
    }

    // 创建Google Cloud Task时，将traceID作为参数或元数据传递
    task := &taskqueue.Task{
        Payload: []byte(fmt.Sprintf(`{"traceID":"%s"}`, traceID)),
        // 其他任务配置...
    }
    // 提交任务逻辑...

    // 使用上下文绑定的日志器记录日志
    if logger, ok := ctx.Value(constants.RequestLoggerKey).(*slog.Logger); ok {
        logger.Info("Google Cloud Task创建成功", "taskID", task.ID)
    }
    return nil
}

关键说明 #

• 每个请求的日志器是独立实例，不会被其他请求覆盖，彻底解决并发场景下的trace标识混乱问题。
• 全程复用请求上下文，保证traceID和日志器的传递链路完整。
• 不再依赖全局slog实例，避免了全局状态带来的并发安全风险。

内容的提问来源于stack exchange，提问作者Manzurul Hoque Rumi