diff --git a/skywalking-sdk-plugin/spring-plugin/pom.xml b/skywalking-sdk-plugin/spring-plugin/pom.xml index ad274276c..861349f48 100644 --- a/skywalking-sdk-plugin/spring-plugin/pom.xml +++ b/skywalking-sdk-plugin/spring-plugin/pom.xml @@ -18,6 +18,11 @@ + + com.ai.cloud + skywalking-auth + 1.0-SNAPSHOT + junit junit 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 39155f30f..e169e49d1 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 @@ -6,7 +6,7 @@ public class CallChainD { @Tracing public void doBusiness() { - System.out.println("three"); + //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 949df2ef4..7e98dde67 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 @@ -6,6 +6,6 @@ public class CallChainE { @Tracing public void doBusiness() { - System.out.println("I'm here"); + // System.out.println("I'm here"); } } 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 dcb5f316f..4eb5ad0b9 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 @@ -6,6 +6,6 @@ public class CallChainF { @Tracing public void doBusiness() { - System.out.println("me too"); + //System.out.println("me too"); } } 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 323082f98..7d2103dc6 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 @@ -2,11 +2,56 @@ package com.ai.cloud.skywalking.plugin.spring.common; import org.springframework.context.support.ClassPathXmlApplicationContext; -public class TestBuriedPoint { +import java.util.Timer; +import java.util.TimerTask; +import java.util.concurrent.CountDownLatch; +import java.util.concurrent.atomic.AtomicInteger; - public static void main(String[] args) { +public class TestBuriedPoint extends Thread { + + private static final int MAX_THREAD_SIZE = 1; + private CallChainA callChainA; + AtomicInteger atomicInteger = new AtomicInteger(); + + public TestBuriedPoint(CallChainA callChainA) { + this.callChainA = callChainA; + } + + private Timer timer = new Timer(Thread.currentThread().getName()); + + public TestBuriedPoint() { + timer.schedule(new TimerTask() { + @Override + public void run() { + System.out.println(atomicInteger.get()); + } + }, 1000); + + } + + @Override + public void run() { + while (true) { + try { + Thread.sleep(2L); + } catch (InterruptedException e) { + e.printStackTrace(); + } + callChainA.doBusiness(); + System.out.println(Thread.currentThread().getName() + "\t" + atomicInteger.incrementAndGet()); + + } + } + + public static void main(String[] args) throws InterruptedException { ClassPathXmlApplicationContext classPathXmlApplicationContext = new ClassPathXmlApplicationContext("classpath*:springConfig-common.xml"); CallChainA callChainA = classPathXmlApplicationContext.getBean(CallChainA.class); - callChainA.doBusiness(); + CountDownLatch countDownLatch = new CountDownLatch(10); + for (int i = 0; i < MAX_THREAD_SIZE; i++) { + new TestBuriedPoint(callChainA).start(); + } + + countDownLatch.await(); + } }