diff --git a/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainA.java b/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainA.java index 9b2cf5c58..451f3d7cf 100644 --- a/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainA.java +++ b/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainA.java @@ -2,16 +2,20 @@ package com.ai.cloud.skywalking.plugin.spring.common; import com.ai.cloud.skywalking.plugin.spring.Tracing; +import java.util.concurrent.ThreadLocalRandom; + public class CallChainA { private CallChainB callChainB; private CallChainD callChainD; private CallChainF callChainF; @Tracing - public void doBusiness() { + public void doBusiness() throws InterruptedException { + Thread.sleep(ThreadLocalRandom.current().nextInt(10)); callChainB.doBusiness(); callChainD.doBusiness(); callChainF.doBusiness(); + Thread.sleep(ThreadLocalRandom.current().nextInt(10)); } public CallChainB getCallChainB() { diff --git a/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainB.java b/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainB.java index df8d21b64..4d5741faf 100644 --- a/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainB.java +++ b/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainB.java @@ -2,13 +2,17 @@ package com.ai.cloud.skywalking.plugin.spring.common; import com.ai.cloud.skywalking.plugin.spring.Tracing; +import java.util.concurrent.ThreadLocalRandom; + public class CallChainB { private CallChainC callChainC; @Tracing - public void doBusiness() { + public void doBusiness() throws InterruptedException { + Thread.sleep(ThreadLocalRandom.current().nextInt(10)); callChainC.doBusiness(); + Thread.sleep(ThreadLocalRandom.current().nextInt(10)); } public CallChainC getCallChainC() { diff --git a/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainC.java b/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainC.java index 1b5b7ed13..5e5ca8310 100644 --- a/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainC.java +++ b/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainC.java @@ -2,13 +2,17 @@ package com.ai.cloud.skywalking.plugin.spring.common; import com.ai.cloud.skywalking.plugin.spring.Tracing; +import java.util.concurrent.ThreadLocalRandom; + public class CallChainC { private CallChainE callChainE; @Tracing - public void doBusiness() { + public void doBusiness() throws InterruptedException { + Thread.sleep(ThreadLocalRandom.current().nextInt(10)); callChainE.doBusiness(); + Thread.sleep(ThreadLocalRandom.current().nextInt(10)); } public CallChainE getCallChainE() { diff --git a/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainD.java b/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainD.java index e169e49d1..e6e52d387 100644 --- a/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainD.java +++ b/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainD.java @@ -2,10 +2,13 @@ package com.ai.cloud.skywalking.plugin.spring.common; import com.ai.cloud.skywalking.plugin.spring.Tracing; +import java.util.concurrent.ThreadLocalRandom; + public class CallChainD { @Tracing - public void doBusiness() { + public void doBusiness() throws InterruptedException { + Thread.sleep(ThreadLocalRandom.current().nextInt(10)); //System.out.println("three"); } diff --git a/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainE.java b/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainE.java index 7e98dde67..0a7125e75 100644 --- a/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainE.java +++ b/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainE.java @@ -1,11 +1,27 @@ package com.ai.cloud.skywalking.plugin.spring.common; +import com.ai.cloud.skywalking.api.BusinessKeyAppender; import com.ai.cloud.skywalking.plugin.spring.Tracing; +import java.util.concurrent.ThreadLocalRandom; + public class CallChainE { + private CallChainG callChainG; + @Tracing - public void doBusiness() { - // System.out.println("I'm here"); + public void doBusiness() throws InterruptedException { + Thread.sleep(ThreadLocalRandom.current().nextInt(10)); + BusinessKeyAppender.trace("key-value"); + callChainG.doBusiness(); + Thread.sleep(ThreadLocalRandom.current().nextInt(10)); + } + + public CallChainG getCallChainG() { + return callChainG; + } + + public void setCallChainG(CallChainG callChainG) { + this.callChainG = callChainG; } } diff --git a/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainF.java b/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainF.java index 4eb5ad0b9..6796772b7 100644 --- a/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainF.java +++ b/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainF.java @@ -2,10 +2,13 @@ package com.ai.cloud.skywalking.plugin.spring.common; import com.ai.cloud.skywalking.plugin.spring.Tracing; +import java.util.concurrent.ThreadLocalRandom; + public class CallChainF { @Tracing - public void doBusiness() { + public void doBusiness() throws InterruptedException { + Thread.sleep(ThreadLocalRandom.current().nextInt(10)); //System.out.println("me too"); } } diff --git a/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainG.java b/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainG.java new file mode 100644 index 000000000..24186d837 --- /dev/null +++ b/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainG.java @@ -0,0 +1,28 @@ +package com.ai.cloud.skywalking.plugin.spring.common; + +import com.ai.cloud.skywalking.api.BusinessKeyAppender; +import com.ai.cloud.skywalking.plugin.spring.Tracing; + +import java.util.concurrent.ThreadLocalRandom; + +public class CallChainG { + + private CallChainH callChainH; + + @Tracing + public void doBusiness() throws InterruptedException { + Thread.sleep(ThreadLocalRandom.current().nextInt(10)); + BusinessKeyAppender.trace("key-value"); + callChainH.doBusiness(); + Thread.sleep(ThreadLocalRandom.current().nextInt(10)); + + } + + public CallChainH getCallChainH() { + return callChainH; + } + + public void setCallChainH(CallChainH callChainH) { + this.callChainH = callChainH; + } +} diff --git a/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainH.java b/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainH.java new file mode 100644 index 000000000..04de8bbcf --- /dev/null +++ b/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainH.java @@ -0,0 +1,28 @@ +package com.ai.cloud.skywalking.plugin.spring.common; + +import com.ai.cloud.skywalking.api.BusinessKeyAppender; +import com.ai.cloud.skywalking.plugin.spring.Tracing; + +import java.util.concurrent.ThreadLocalRandom; + +public class CallChainH { + + private CallChainI callChainI; + + @Tracing + public void doBusiness() throws InterruptedException { + Thread.sleep(ThreadLocalRandom.current().nextInt(10)); + BusinessKeyAppender.trace("key-value"); + callChainI.doBusiness(); + Thread.sleep(ThreadLocalRandom.current().nextInt(10)); + + } + + public CallChainI getCallChainI() { + return callChainI; + } + + public void setCallChainI(CallChainI callChainI) { + this.callChainI = callChainI; + } +} diff --git a/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainI.java b/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainI.java new file mode 100644 index 000000000..37074d455 --- /dev/null +++ b/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainI.java @@ -0,0 +1,27 @@ +package com.ai.cloud.skywalking.plugin.spring.common; + +import com.ai.cloud.skywalking.api.BusinessKeyAppender; +import com.ai.cloud.skywalking.plugin.spring.Tracing; + +import java.util.concurrent.ThreadLocalRandom; + +public class CallChainI { + private CallChainJ callChainJ; + + @Tracing + public void doBusiness() throws InterruptedException { + Thread.sleep(ThreadLocalRandom.current().nextInt(10)); + BusinessKeyAppender.trace("key-value"); + callChainJ.doBusiness(); + Thread.sleep(ThreadLocalRandom.current().nextInt(10)); + + } + + public CallChainJ getCallChainJ() { + return callChainJ; + } + + public void setCallChainJ(CallChainJ callChainJ) { + this.callChainJ = callChainJ; + } +} diff --git a/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainJ.java b/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainJ.java new file mode 100644 index 000000000..8f1828f80 --- /dev/null +++ b/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainJ.java @@ -0,0 +1,26 @@ +package com.ai.cloud.skywalking.plugin.spring.common; + +import com.ai.cloud.skywalking.api.BusinessKeyAppender; +import com.ai.cloud.skywalking.plugin.spring.Tracing; + +import java.util.concurrent.ThreadLocalRandom; + +public class CallChainJ { + private CallChainK callChainK; + @Tracing + public void doBusiness() throws InterruptedException { + Thread.sleep(ThreadLocalRandom.current().nextInt(10)); + BusinessKeyAppender.trace("key-value"); + callChainK.doBusiness(); + Thread.sleep(ThreadLocalRandom.current().nextInt(10)); + + } + + public CallChainK getCallChainK() { + return callChainK; + } + + public void setCallChainK(CallChainK callChainK) { + this.callChainK = callChainK; + } +} diff --git a/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainK.java b/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainK.java new file mode 100644 index 000000000..8516ac318 --- /dev/null +++ b/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainK.java @@ -0,0 +1,15 @@ +package com.ai.cloud.skywalking.plugin.spring.common; + +import com.ai.cloud.skywalking.api.BusinessKeyAppender; +import com.ai.cloud.skywalking.plugin.spring.Tracing; + +import java.util.concurrent.ThreadLocalRandom; + +public class CallChainK { + @Tracing + public void doBusiness() throws InterruptedException { + Thread.sleep(ThreadLocalRandom.current().nextInt(10)); + BusinessKeyAppender.trace("key-value"); + Thread.sleep(ThreadLocalRandom.current().nextInt(10)); + } +} diff --git a/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/TestBuriedPoint.java b/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/TestBuriedPoint.java index 7d2103dc6..395a85df0 100644 --- a/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/TestBuriedPoint.java +++ b/skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/TestBuriedPoint.java @@ -31,15 +31,18 @@ public class TestBuriedPoint extends Thread { @Override public void run() { - while (true) { + for (int i = 0 ; i < 1; i++) { try { Thread.sleep(2L); } catch (InterruptedException e) { e.printStackTrace(); } - callChainA.doBusiness(); + try { + callChainA.doBusiness(); + } catch (InterruptedException e) { + e.printStackTrace(); + } System.out.println(Thread.currentThread().getName() + "\t" + atomicInteger.incrementAndGet()); - } } diff --git a/skywalking-sdk-plugin/spring-plugin/src/test/resources/springConfig-common.xml b/skywalking-sdk-plugin/spring-plugin/src/test/resources/springConfig-common.xml index 0644af241..70d564414 100644 --- a/skywalking-sdk-plugin/spring-plugin/src/test/resources/springConfig-common.xml +++ b/skywalking-sdk-plugin/spring-plugin/src/test/resources/springConfig-common.xml @@ -8,7 +8,23 @@ - + + + + + + + + + + + + + + + + +