Netty 实战篇：为 Netty RPC 框架引入调用链追踪，实现链路透明化
本文将为 RPC 框架集成调用链追踪功能，支持链路 ID 透传、服务调用耗时分析、错误定位等，打通链路透明化的“最后一公里”。
一、为什么需要链路追踪？
在微服务环境中，一个请求可能会经过多个服务节点：
客户端 → 服务A → 服务B → 服务C如果出现错误或性能瓶颈，没有调用链信息，我们将很难定位是哪一环出了问题。
✅ 链路追踪的好处：
-
日志打通：请求链条统一记录
-
问题定位：快速分析慢请求或异常服务
-
性能分析：识别瓶颈服务
二、链路追踪核心设计
1. 全局唯一请求 ID（TraceId）
每次请求生成一个 UUID，在调用过程中携带并透传。
2. RpcRequest 中增加 traceId 字段
public class RpcRequest implements Serializable {private String serviceName;private String method;private Object[] params;private String traceId; // 新增字段// ...
}
3. 服务端读取 traceId 并记录日志
if (request.getTraceId() != null) {MDC.put("traceId", request.getTraceId());
}
log.info("收到 RPC 请求：{}", request);
三、自动生成 traceId
我们可以使用 Filter 或拦截器的方式实现自动化：
public class TraceInterceptor {public static RpcRequest wrapRequest(RpcRequest req) {if (StringUtils.isEmpty(req.getTraceId())) {req.setTraceId(UUID.randomUUID().toString());}return req;}
}
使用示例：
RpcRequest wrapped = TraceInterceptor.wrapRequest(originalRequest);
channel.writeAndFlush(wrapped);
四、集成日志 MDC（Mapped Diagnostic Context）
建议使用 logback 日志框架，并在 logback.xml 中加上 traceId：
<pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - [%X{traceId}] %msg%n</pattern>
这样日志中就会自动记录每次请求的 traceId。
五、日志效果示例
11:03:21.873 [nioEventLoopGroup-3-1] INFO RpcServerHandler - [d5af2f29-4c7f-4d20-bf80-1ff4ea6c8e0a] 收到 RPC 请求：HelloService.hello("Netty")
11:03:21.876 [nioEventLoopGroup-3-1] INFO RpcServerHandler - [d5af2f29-4c7f-4d20-bf80-1ff4ea6c8e0a] RPC 响应已发送
六、统一日志追踪上下文封装
我们可以封装一个 RpcContext 类：
public class RpcContext {private static final ThreadLocal<String> TRACE_ID = new ThreadLocal<>();public static void setTraceId(String id) {TRACE_ID.set(id);MDC.put("traceId", id);}public static String getTraceId() {return TRACE_ID.get();}public static void clear() {TRACE_ID.remove();MDC.remove("traceId");}
}
然后在服务端收到请求时：
RpcContext.setTraceId(request.getTraceId());
在服务端返回后：
RpcContext.clear();
七、与外部追踪系统整合（可选）
-
可将 traceId 透传到 Zipkin、SkyWalking 等系统
-
提供 HTTP → RPC → MQ 等链路打通能力
-
推荐在 header/元数据中统一携带 traceId
八、总结
通过本篇内容，我们为 Netty RPC 框架增加了链路追踪能力，实现了：
✅ 请求唯一 ID 自动生成与透传
✅ 日志追踪上下文自动注入
✅ 多服务节点日志打通能力
✅ 可拓展对接 SkyWalking/Zipkin 的能力