kazusa
/
skywalking-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

增加测试节点深度

This commit is contained in:
zhangxin10 2015-11-19 18:41:18 +08:00
parent 01b4ae5ca5
commit 14ec88c327
13 changed files with 188 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainA.java
View File

@ -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() {

6
skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainB.java
View File

@ -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() {

6
skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainC.java
View File

@ -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() {

5
skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainD.java
View File

@ -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");
}

20
skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainE.java
View File

@ -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;
}
}

5
skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainF.java
View File

@ -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");
}
}

28
skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainG.java Normal file
View File

@ -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;
}
}

28
skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainH.java Normal file
View File

@ -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;
}
}

27
skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainI.java Normal file
View File

@ -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;
}
}

26
skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainJ.java Normal file
View File

@ -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;
}
}

15
skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/CallChainK.java Normal file
View File

@ -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));
}
}

9
skywalking-sdk-plugin/spring-plugin/src/test/java/com/ai/cloud/skywalking/plugin/spring/common/TestBuriedPoint.java
View File

@ -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());
}
}

18
skywalking-sdk-plugin/spring-plugin/src/test/resources/springConfig-common.xml
View File

@ -8,7 +8,23 @@
<bean id="postProcess1"
class="com.ai.cloud.skywalking.plugin.spring.TracingEnhanceProcessor">
</bean>
<bean id="callChainE" class="com.ai.cloud.skywalking.plugin.spring.common.CallChainE"/>
<bean id="callChainK" class="com.ai.cloud.skywalking.plugin.spring.common.CallChainK"/>
<bean id="callChainJ" class="com.ai.cloud.skywalking.plugin.spring.common.CallChainJ">
<property name="callChainK" ref="callChainK"/>
</bean>
<bean id="callChainI" class="com.ai.cloud.skywalking.plugin.spring.common.CallChainI">
<property name="callChainJ" ref="callChainJ"/>
</bean>
<bean id="callChainH" class="com.ai.cloud.skywalking.plugin.spring.common.CallChainH">
<property name="callChainI" ref="callChainI"/>
</bean>
<bean id="callChainG" class="com.ai.cloud.skywalking.plugin.spring.common.CallChainG">
<property name="callChainH" ref="callChainH"/>
</bean>
<bean id="callChainE" class="com.ai.cloud.skywalking.plugin.spring.common.CallChainE">
<property name="callChainG" ref="callChainG"/>
</bean>
<bean id="callChainF" class="com.ai.cloud.skywalking.plugin.spring.common.CallChainF"/>
<bean id="callChainC" class="com.ai.cloud.skywalking.plugin.spring.common.CallChainC">
<property name="callChainE" ref="callChainE"/>