数列科技开源全链路压测平台Takin-总结

灰太狼 2022-10-11 00:43 313阅读 0赞

### 文章目录 ###

*  全链路压测基本思路
 *  Takin细节点
 *   *  全链路保存一些标识
     *  拦截器实现数据埋点上报
     *   *  com.pamirs.pradar.interceptor.BaseInterceptor
     *  MQ改写topic
     *  改写jdbc
     *  redis影子缓存

# 全链路压测基本思路 #

*  [阿里中间件-全链路压测 总结][-_]
 *  [首个生产环境全链路压测平台Takin正式开源][Takin]

基本就是先染色，然后分发到对应的影子表，影子缓存，然后进行上报数据统计

# Takin细节点 #

## 全链路保存一些标识 ##

比如说标识下这些数据是测试数据，然后在全链路进行传递，这个在阿里开源全链路追踪日志框架SofaTrace的实现。

**上代码**  
com.pamirs.attach.plugin.shadowjob.obj.quartz.PtJob  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODMzNjY1OA_size_16_color_FFFFFF_t_70]  
比如说job的重写，在执行前会写入一些参数。

**PradarInternalService.startTrace**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODMzNjY1OA_size_16_color_FFFFFF_t_70 1]  
会把一些traceId，唯一id set到上下文context里面

**InvokeContext.set(ctx);**

static private final TransmittableThreadLocal<InvokeContext> threadLocal
                = new TransmittableThreadLocal<InvokeContext>();

关键代码出现*TransmittableThreadLocal*

## 拦截器实现数据埋点上报 ##

这个功能可以应对rpc，或者服务请求的参数上报

### com.pamirs.pradar.interceptor.BaseInterceptor ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODMzNjY1OA_size_16_color_FFFFFF_t_70 2]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODMzNjY1OA_size_16_color_FFFFFF_t_70 3]  
把相关traceId跟RpcId，还有日志类型塞进去。

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODMzNjY1OA_size_16_color_FFFFFF_t_70 4]  
把日志往queue里面塞，然后通过线程poll出来进行上报  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODMzNjY1OA_size_16_color_FFFFFF_t_70 5]

## MQ改写topic ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODMzNjY1OA_size_16_color_FFFFFF_t_70 6]  
这个小生不才，看不太懂在哪里增强了，理解为可以根据agent去增强类的相关方法。

**com.pamirs.attach.plugin.alibaba.rocketmq.interceptor.MQProducerSendInterceptor**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODMzNjY1OA_size_16_color_FFFFFF_t_70 7]  
这里进行改下topic

## 改写jdbc ##

**com.pamirs.attach.plugin.apache.tomcatjdbc.interceptor.TomcatJdbcDataSourceProxyGetConnectionInterceptor**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODMzNjY1OA_size_16_color_FFFFFF_t_70 8]  
也是去增强类的方法，然后拿到影子库的connection

## redis影子缓存 ##

**com.pamirs.attach.plugin.common.datasource.redisserver.AbstractRedisServerFactory\#getClient**

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODMzNjY1OA_size_16_color_FFFFFF_t_70 9]

重写JedisFactory  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODMzNjY1OA_size_16_color_FFFFFF_t_70 10]  
以及redission，重写config方法

[-_]: https://blog.csdn.net/weixin_38336658/article/details/118103775?spm=1001.2014.3001.5501
[Takin]: https://mp.weixin.qq.com/s?__biz=MzAwMDU1MTE1OQ==&mid=2653556037&idx=1&sn=82c7fa25dfee918c4483af48b7d7ede8&chksm=81399cddb64e15cbac531c0702d354f0c89d60bdf56a2209d97fe634e7daa5492d6a6e90a122&mpshare=1&scene=24&srcid=0625daKGyyzJDNr8AoLM4f8i&sharer_sharetime=1624592396730&sharer_shareid=cded50ac01d784d35c8ca2a1912ee86e#rd
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODMzNjY1OA_size_16_color_FFFFFF_t_70]: /images/20221005/bb38bf5b52af41f59e5ab52fa5a6ef9f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODMzNjY1OA_size_16_color_FFFFFF_t_70 1]: /images/20221005/a6f7c35d5e4c44338d62dc3226324b1b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODMzNjY1OA_size_16_color_FFFFFF_t_70 2]: /images/20221005/ba5202b1bef547ddb9f51adafcfe4933.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODMzNjY1OA_size_16_color_FFFFFF_t_70 3]: /images/20221005/7a7da883647347b5a421aa5f7a5a99f3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODMzNjY1OA_size_16_color_FFFFFF_t_70 4]: /images/20221005/1020a10c5fa34c8a8a62ff9bc285b1a2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODMzNjY1OA_size_16_color_FFFFFF_t_70 5]: /images/20221005/1ec206dc624b4fe1966f28daf0c21140.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODMzNjY1OA_size_16_color_FFFFFF_t_70 6]: /images/20221005/28449a8e7c96462fb568846077c8e92a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODMzNjY1OA_size_16_color_FFFFFF_t_70 7]: /images/20221005/65e21115c9d8406298f906e6bf028b6a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODMzNjY1OA_size_16_color_FFFFFF_t_70 8]: /images/20221005/e8a0cbe626e346f4bbb81693ef82886e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODMzNjY1OA_size_16_color_FFFFFF_t_70 9]: /images/20221005/fc2ba630577e4eb2a04482f6daabcd9d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODMzNjY1OA_size_16_color_FFFFFF_t_70 10]: /images/20221005/0dcea00441094db5bcfed4074f42ed0a.png