java agent 能自动拦截 redis 客户端方法调用,但需按客户端类型精准增强:jedis hook sendcommand、lettuce 拦截 redischannelhandler.write、redisson 增强 commandasyncservice.async 和 eval 方法,并注意异步上下文透传与 pipeline 单命令埋点。

Java Agent 能否自动拦截 Redis 客户端方法调用
能,但取决于你用的 Redis 客户端类型和版本。主流客户端如 Jedis、Lettuce、Redisson 都可通过字节码增强(Byte Buddy 或 Java Agent 自带 Instrumentation)在不改业务代码的前提下织入 trace 上下文。关键不是“能不能”,而是“在哪一层插”——Jedis 是同步阻塞调用,直接 hook Jedis.sendCommand 或 Jedis.executeCommand;Lettuce 基于 Netty,得优先拦截 CommandHandler.dispatchCommand 或 RedisChannelHandler.write;Redisson 则要盯住 CommandAsyncService.async 和 BaseRedisClient.invoke 这类实际发起请求的方法。
为什么不能只增强 ConnectionFactory 或 JedisPool
因为连接池或工厂本身不参与命令执行,它们只负责提供连接实例。你在 JedisPool.getResource() 里加逻辑,只能拿到连接对象,无法感知后续 set("k", "v") 或 get("k") 的 span 生命周期。真正需要挂载 traceId 的是命令执行那一刻:从序列化、写入 socket、等待响应,到反序列化完成。否则 span 会漏掉网络耗时、服务端排队时间等关键段。常见错误就是只在获取连接时埋点,结果链路断成两截——上游调用完就结束,Redis 操作被当成黑盒。
如何让 trace 上下文透传进 Lettuce 的异步回调
Lettuce 默认使用 Netty EventLoop 线程执行回调,而主线程的 MDC 或 ThreadLocal 在切换线程后失效。必须在命令发出前把当前 span 封装进 CommandWrapper 或通过 CommandWrapperFactory 注入,再确保 RedisFuture 的 thenApply / whenComplete 回调中能还原上下文。实操建议:
- 用 Byte Buddy 的
Advice在RedisChannelHandler.write入口保存Tracer.currentSpan()到CommandWrapper的attributes字段 - 在
CommandWrapper.complete或CommandWrapper.exceptionally中主动 finish span - 避免依赖
ThreadLocal<span></span>,改用io.opentelemetry.context.Context+Context.current().withValue(...)包裹异步逻辑 - 确认 Lettuce 版本 ≥ 6.1,低版本需手动 patch
DefaultEndpoint的回调分发逻辑
Redisson 的泛型命令与 Lua 脚本怎么统一埋点
Redisson 把所有操作都转成 RedisExecutor.execute,但 Lua 脚本(RScheduledExecutorService 或 RScript.eval)走的是另一条路径:CommandAsyncService.eval → BaseRedisClient.eval。若只 hook 前者,Lua 脚本的 span 会丢失。正确做法是双入口增强:
- 对普通命令:拦截
CommandAsyncService.async,提取CommandData中的 command name(如"GET"、"HGETALL")和 key - 对 Lua 脚本:额外拦截
BaseRedisClient.eval和evalSha,从script参数提取哈希或脚本片段前缀用于 span 名称生成(例如"EVAL_sha256:ab12...") - 所有 span 的
db.statement属性不要拼完整脚本(可能含敏感数据),改用db.operation记录"eval",再用redis.script.sha标记哈希值 - 注意
RLock.tryLock这类封装方法内部多次调用 Redis,需识别是否为同一逻辑操作,避免重复 span
最易被忽略的是 pipeline 场景:多个命令打包发送,但 span 必须按单个命令粒度拆分,不能整个 pipeline 当一个 span —— 否则无法定位慢命令。这要求 agent 必须解析 Pipeline.flushCommands 内部的 CommandBatchService 执行链,而不是只看顶层 API 调用。
Java免费学习笔记:立即使用
解锁 Java 大师之旅:从入门到精通的终极指南











