org.apache.skywalking:apm-toolkit-trace:- 用途: 这是 Apache SkyWalking 的一个工具包，用于追踪和监控微服务架构的应用。它提供了一种简单的方式来为 Java 应用程序插入追踪逻辑，帮助开发者收集应用执行的性能数据。
- 功能: 包括分布式追踪、性能分析、错误监控等。开发者可以通过这个工具包将追踪数据发送到 SkyWalking 的后端服务，后端服务会对这些数据进行处理和可视化。
com.alibaba.arms.apm:arms-sdk:- 用途: 这是阿里巴巴的 APM SDK，目的是为了监控和分析应用的性能，尤其是在分布式应用和微服务架构中。它提供了一套完整的 API，用于记录性能数据和上下文信息。
- 功能: 包括事务追踪、业务监控、错误日志收集等，可以帮助开发者理解业务请求的流转情况和性能瓶颈。
总的来说，这两个依赖库都是为了帮助开发者监控和优化应用程序的性能，不同的是它们分别来源于不同的开源项目。使用这些工具可以使开发者更准确地了解和提高应用的运行效率。
1. 引入依赖
<dependency><groupId>com.alibaba.arms.apm</groupId><artifactId>arms-sdk</artifactId><version>1.7.5</version></dependency><dependency><groupId>org.apache.skywalking</groupId><artifactId>apm-toolkit-trace</artifactId><version>8.7.0</version><scope>provided</scope></dependency>2 .TraceCtx抽象类
主要用于实现分布式追踪（Tracing）的上下文管理。分布式追踪是一种记录请求在微服务或不同系统之间流动的方式，用来分析和监控系统的性能和行为。
- 该类采用了工厂模式（Factory Pattern），根据环境动态选择合适的追踪上下文实现。
publicabstractclassTraceCtx{privatestaticTraceCtxtraceCtx;static{if(ClassUtils.isPresent("com.alibaba.arms.tracing.Tracer",null)){traceCtx=newArmsTraceCtx();}elseif(ClassUtils.isPresent("org.apache.skywalking.apm.toolkit.trace.TraceContext",null)){traceCtx=newSkywalkingTraceCtx();}else{traceCtx=newPseudoTraceCtx();}}publicstaticTraceCtxget(){returntraceCtx;}publicabstractStringtraceId();publicabstractStringspanId();publicabstractStringsegmentId();publicabstractvoidtag(Stringkey,Stringvalue);publicabstractvoidputCorrelation(Stringkey,Stringvalue);publicabstractRunnabletraceRunnable(Runnabler);publicabstract<V>Callable<V>traceCallable(Callable<V>c);}2.1. ArmsTraceCtx实现类
用于与阿里巴巴的 ARMS（应用性能管理与服务监控）工具集成，提供分布式追踪的上下文管理功能。
importcom.alibaba.arms.sdk.v1.async.TraceCallable;importcom.alibaba.arms.sdk.v1.async.TraceRunnable;importcom.alibaba.arms.tracing.Span;importcom.alibaba.arms.tracing.Tracer;importjava.util.concurrent.Callable;publicclassArmsTraceCtxextendsTraceCtx{@OverridepublicStringtraceId(){Spanspan=Tracer.builder().getSpan();returnspan.getTraceId();}@OverridepublicStringspanId(){return"Arms-1";}@OverridepublicStringsegmentId(){Spanspan=Tracer.builder().getSpan();returnspan.getRpcId();}@Overridepublicvoidtag(Stringkey,Stringvalue){Spanspan=Tracer.builder().getSpan();span.setTag(key,value);}@OverridepublicvoidputCorrelation(Stringkey,Stringvalue){}@OverridepublicRunnabletraceRunnable(Runnabler){returnTraceRunnable.asyncEntry(r);}@Overridepublic<V>Callable<V>traceCallable(Callable<V>c){returnTraceCallable.asyncEntry(c);}}2.2. SkywalkingTraceCtx实现类
用于与 Apache SkyWalking 进行集成的类，它用于处理和管理分布式追踪上下文（Trace Context）。
importorg.apache.skywalking.apm.toolkit.trace.ActiveSpan;importorg.apache.skywalking.apm.toolkit.trace.CallableWrapper;importorg.apache.skywalking.apm.toolkit.trace.RunnableWrapper;importorg.apache.skywalking.apm.toolkit.trace.TraceContext;importjava.util.concurrent.Callable;publicclassSkywalkingTraceCtxextendsTraceCtx{@OverridepublicStringtraceId(){returnTraceContext.traceId();}@OverridepublicStringspanId(){returnTraceContext.spanId()+"";}@OverridepublicStringsegmentId(){returnTraceContext.segmentId();}@Overridepublicvoidtag(Stringkey,Stringvalue){ActiveSpan.tag(key,value);}@OverridepublicvoidputCorrelation(Stringkey,Stringvalue){TraceContext.putCorrelation(key,value);}@OverridepublicRunnabletraceRunnable(Runnabler){returnRunnableWrapper.of(r);}@Overridepublic<V>Callable<V>traceCallable(Callable<V>c){returnCallableWrapper.of(c);}}2.3. PseudoTraceCtx实现类
用于模拟或占位的追踪上下文实现，可以用于测试或验证代码逻辑而不依赖于实际的追踪系统。
importjava.util.concurrent.Callable;publicclassPseudoTraceCtxextendsTraceCtx{@OverridepublicStringtraceId(){return"Pseudo-1";}@OverridepublicStringspanId(){return"Pseudo-1";}@OverridepublicStringsegmentId(){return"Pseudo-1";}@Overridepublicvoidtag(Stringkey,Stringvalue){}@OverridepublicvoidputCorrelation(Stringkey,Stringvalue){}@OverridepublicRunnabletraceRunnable(Runnabler){returnr;}@Overridepublic<V>Callable<V>traceCallable(Callable<V>c){returnc;}}3. 线程工厂
publicclassNamedThreadFactoryimplementsThreadFactory{protectedstaticfinalAtomicIntegerPOOL_SEQ=newAtomicInteger(1);protectedfinalAtomicIntegermThreadNum;protectedfinalStringmPrefix;protectedfinalbooleanmDaemon;publicNamedThreadFactory(){this("pool-"+POOL_SEQ.getAndIncrement(),false);}publicNamedThreadFactory(Stringprefix){this(prefix,false);}publicNamedThreadFactory(Stringprefix,booleandaemon){this.mThreadNum=newAtomicInteger(1);this.mPrefix=prefix+"-thread-";this.mDaemon=daemon;}publicThreadnewThread(Runnablerunnable){Stringname=this.mPrefix+this.mThreadNum.getAndIncrement();Threadret=newThread(runnable,name);ret.setDaemon(this.mDaemon);returnret;}}4. 线程池参数
@Data@Configuration@ConfigurationProperties(prefix="thread.pool")publicclassThreadPoolProperties{privatePoolVopoolVo=newPoolVo();@Data@ConfigurationpublicclassPoolVo{privatebooleanenabled=true;privateStringnamePrefix="ol-threadPool";privateintcoreSize=200;privateintmaxSize=200;privatelongkeepAliveSeconds=600;privateintqueueSize=100;}}5. 线程池配置类
@Slf4j@ConfigurationpublicclassThreadPoolConfig{@AutowiredprivateThreadPoolPropertiesthreadPoolProperties;@ConditionalOnProperty(value="thread.pool.poolVo.enabled",havingValue="true")@Bean(name="oldThreadPoolExecutor")publicThreadPoolExecutorolRvdcThreadPoolExecutor(){ThreadPoolProperties.PoolVopoolVo=threadPoolProperties.getPoolVo();ThreadPoolExecutorthreadPoolExecutor=newThreadPoolExecutor(poolVo.getCoreSize(),poolVo.getMaxSize(),poolVo.getKeepAliveSeconds(),TimeUnit.SECONDS,newLinkedBlockingQueue<Runnable>(),newNamedThreadFactory(poolVo.getNamePrefix()),newThreadPoolExecutor.AbortPolicy());log.info("======================= ThreadPool initialize success. =======================");returnthreadPoolExecutor;}}6. 使用示例
@RestControllerpublicclassDemoController{@AutowiredprivateThreadPoolExecutorthreadPoolExecutor;@GetMapping("/test")publicvoidtest(){Runnablerunnable=TraceCtx.get().traceRunnable(()->{for(inti=0;i<10;i++){System.out.println("i = "+i);}});System.out.println(runnable);threadPoolExecutor.execute(runnable);}}
