lettcue 的写操作是异步的。io.lettuce.core.RedisChannelWriter.write进行写入,io.lettuce.core.protocol.RedisCommand进行异步读取数据
skywalking 插件大体逻辑
- 在方法执行前,通过ContextManager创建span
- 创建span的同时,判断trace上下文是否存在,不存在则创建
- 创建AbstractTracerContext的同时,会创建TraceSegment,创建TraceSegment的同时会创建trace id
- 方法执行完后ContextManager.stopSpan()记录结束时间,以及将TraceSegment数据发到发送队列,准备发送到服务端
异步操作:
- 异步开始执行span.prepareForAsync();
- 异步结束执行span.asyncFinish ();设置结束时间
trace概念:
每个完整请求是一个trace,skywalking中还有个segment的概念,代表每个线程的trace。每个segment下有多个span,代表具体的方法操作,span分为exit span(调用外部,例如:rpc db)、entry span(入口span,比如http 入口)、local span(本地的业务方法)
RedisChannelWriterInterceptor
io.lettuce.core.RedisChannelWriter.write 的拦截器代码截图。
ContextManager.createExitSpan
创建span ,如果没有创建过trace上下文,则创建,有则获取。
创建trace 上下文
每个线程创建一个新的segment
GlobalIdGenerator.generate(); 用以生成唯一的trace id或segment id
RedisCommandCompleteMethodInterceptor
io.lettuce.core.protocol.RedisCommand
AbstractTracingSpan.asyncFinish 异步完成