在Golang的RPC服务开发中，调用链日志收集能帮助我们在分布式系统中快速定位跨服务问题。借助context传递链路标识，并在RPC的客户端与服务端拦截器中统一记录日志，是实现调用链追踪的常见做法。
为什么需要RPC调用链日志
当一次用户请求经过多个Golang微服务，且服务间使用RPC通信时，如果只记录本地日志，很难把各节点的日志关联起来。调用链日志通过统一的traceID，将一次完整调用中的所有RPC日志串联，便于排查超时、异常等问题。
核心设计思路
- 使用context.Context在RPC调用中传递traceID和spanID
- 在RPC客户端拦截器中生成或透传traceID，并打点日志
- 在RPC服务端拦截器中解析traceID，绑定到当前处理上下文
- 日志中统一输出traceID、方法名、耗时与错误
客户端拦截器示例
下面以grpc风格的客户端拦截器为例，展示如何在Golang中注入traceID并记录日志：
package main
import (
"context"
"fmt"
"time"
)
// 模拟RPC客户端拦截器
func clientInterceptor(ctx context.Context, method string) (context.Context, error) {
// 从context取traceID，没有则新建
traceID := ctx.Value("traceID")
if traceID == nil {
traceID = fmt.Sprintf("trace-%d", time.Now().UnixNano())
ctx = context.WithValue(ctx, "traceID", traceID)
}
start := time.Now()
// 模拟发起RPC
fmt.Printf("[CLIENT] traceID=%v method=%s call startn", traceID, method)
// 实际中此处调用invoke RPC
time.Sleep(10 * time.Millisecond)
fmt.Printf("[CLIENT] traceID=%v method=%s cost=%sn", traceID, method, time.Since(start))
return ctx, nil
}
func main() {
ctx := context.Background()
ctx, _ = clientInterceptor(ctx, "/user.Get")
}
服务端拦截器示例
服务端需要从传入的context中解析traceID，保证同一链路日志一致：
package main
import (
"context"
"fmt"
)
// 模拟RPC服务端拦截器
func serverInterceptor(ctx context.Context, method string) {
traceID := ctx.Value("traceID")
if traceID == nil {
traceID = "unknown"
}
fmt.Printf("[SERVER] traceID=%v method=%s handle startn", traceID, method)
// 业务逻辑处理
fmt.Printf("[SERVER] traceID=%v method=%s handle donen", traceID, method)
}
func handle(ctx context.Context) {
serverInterceptor(ctx, "/user.Get")
}
日志格式与收集建议
建议将日志以JSON结构输出，包含字段：
| 字段 | 说明 |
|---|---|
| traceID | 链路唯一标识 |
| method | RPC方法名 |
| role | client或server |
| cost_ms | 调用耗时毫秒 |
| error | 错误信息，无则为空 |
统一格式后，可将日志发送到ipipp.com提供的收集服务或自建ELK，通过traceID检索完整链路。
小结
在Golang中实现RPC调用链日志收集，关键是利用context透传traceID，并在客户端和服务端拦截器里无侵入地记录日志。实践中可结合grpc的拦截器机制或自研RPC框架的hook能力，让链路日志成为系统可观测性的基础。