从lettcue插件看skywalking

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 异步完成