diff --git a/skywalking-sdk-plugin/dubbo-plugin/src/main/java/com/ai/cloud/skywalking/plugin/dubbo/SWDubboEnhanceFilter.java b/skywalking-sdk-plugin/dubbo-plugin/src/main/java/com/ai/cloud/skywalking/plugin/dubbo/SWDubboEnhanceFilter.java index 3bcbee943..fa98d79f5 100644 --- a/skywalking-sdk-plugin/dubbo-plugin/src/main/java/com/ai/cloud/skywalking/plugin/dubbo/SWDubboEnhanceFilter.java +++ b/skywalking-sdk-plugin/dubbo-plugin/src/main/java/com/ai/cloud/skywalking/plugin/dubbo/SWDubboEnhanceFilter.java @@ -5,8 +5,10 @@ import com.ai.cloud.skywalking.buriedpoint.RPCBuriedPointSender; import com.ai.cloud.skywalking.context.Span; import com.ai.cloud.skywalking.model.ContextData; import com.ai.cloud.skywalking.model.Identification; +import com.alibaba.dubbo.common.extension.Activate; import com.alibaba.dubbo.rpc.*; +@Activate public class SWDubboEnhanceFilter implements Filter { public Result invoke(Invoker invoker, Invocation invocation) throws RpcException { diff --git a/skywalking-sdk-plugin/dubbo-plugin/src/main/resources/META-INF/dubbo/com.alibaba.dubbo.rpc.Filter b/skywalking-sdk-plugin/dubbo-plugin/src/main/resources/META-INF/dubbo/com.alibaba.dubbo.rpc.Filter new file mode 100644 index 000000000..55c08d1a3 --- /dev/null +++ b/skywalking-sdk-plugin/dubbo-plugin/src/main/resources/META-INF/dubbo/com.alibaba.dubbo.rpc.Filter @@ -0,0 +1 @@ +swEnhanceFilter=com.ai.cloud.skywalking.plugin.dubbo.SWDubboEnhanceFilter \ No newline at end of file diff --git a/skywalking-sdk-plugin/dubbo-plugin/src/test/java/com/ai/cloud/skywalking/plugin/test/dubbo/consumer/DubboConsumer.java b/skywalking-sdk-plugin/dubbo-plugin/src/test/java/com/ai/cloud/skywalking/plugin/test/dubbo/consumer/DubboConsumer.java new file mode 100644 index 000000000..dfd9d0d34 --- /dev/null +++ b/skywalking-sdk-plugin/dubbo-plugin/src/test/java/com/ai/cloud/skywalking/plugin/test/dubbo/consumer/DubboConsumer.java @@ -0,0 +1,15 @@ +package com.ai.cloud.skywalking.plugin.test.dubbo.consumer; + +import com.ai.cloud.skywalking.plugin.test.dubbo.interfaces.IDubboInterA; +import org.springframework.context.ApplicationContext; +import org.springframework.context.support.ClassPathXmlApplicationContext; + +public class DubboConsumer { + + public static void main(String[] args) throws InterruptedException { + ApplicationContext context = new ClassPathXmlApplicationContext("classpath*:consumer/dubbo-consumer.xml"); + IDubboInterA dubboInterA = context.getBean(IDubboInterA.class); + dubboInterA.doBusiness("AAAAA"); + Thread.sleep(10000000L); + } +} diff --git a/skywalking-sdk-plugin/dubbo-plugin/src/test/java/com/ai/cloud/skywalking/plugin/test/dubbo/impl/DubboInterAImpl.java b/skywalking-sdk-plugin/dubbo-plugin/src/test/java/com/ai/cloud/skywalking/plugin/test/dubbo/impl/DubboInterAImpl.java new file mode 100644 index 000000000..c67aeebef --- /dev/null +++ b/skywalking-sdk-plugin/dubbo-plugin/src/test/java/com/ai/cloud/skywalking/plugin/test/dubbo/impl/DubboInterAImpl.java @@ -0,0 +1,11 @@ +package com.ai.cloud.skywalking.plugin.test.dubbo.impl; + +import com.ai.cloud.skywalking.plugin.test.dubbo.interfaces.IDubboInterA; +import com.alibaba.dubbo.config.annotation.Service; + +@Service +public class DubboInterAImpl implements IDubboInterA { + public void doBusiness(String paramA) { + System.out.println("param : " + paramA); + } +} diff --git a/skywalking-sdk-plugin/dubbo-plugin/src/test/java/com/ai/cloud/skywalking/plugin/test/dubbo/impl/DubboStart.java b/skywalking-sdk-plugin/dubbo-plugin/src/test/java/com/ai/cloud/skywalking/plugin/test/dubbo/impl/DubboStart.java new file mode 100644 index 000000000..bfa03f9dd --- /dev/null +++ b/skywalking-sdk-plugin/dubbo-plugin/src/test/java/com/ai/cloud/skywalking/plugin/test/dubbo/impl/DubboStart.java @@ -0,0 +1,17 @@ +package com.ai.cloud.skywalking.plugin.test.dubbo.impl; + +import org.springframework.context.support.ClassPathXmlApplicationContext; + +public class DubboStart { + + public static void main(String[] args) throws InterruptedException { + ClassPathXmlApplicationContext classPathXmlApplicationContext = new + ClassPathXmlApplicationContext("classpath*:provider/dubbo-provider.xml"); + + classPathXmlApplicationContext.start(); + + while (true) { + Thread.sleep(100000L); + } + } +} diff --git a/skywalking-sdk-plugin/dubbo-plugin/src/test/java/com/ai/cloud/skywalking/plugin/test/dubbo/interfaces/IDubboInterA.java b/skywalking-sdk-plugin/dubbo-plugin/src/test/java/com/ai/cloud/skywalking/plugin/test/dubbo/interfaces/IDubboInterA.java new file mode 100644 index 000000000..b9302a896 --- /dev/null +++ b/skywalking-sdk-plugin/dubbo-plugin/src/test/java/com/ai/cloud/skywalking/plugin/test/dubbo/interfaces/IDubboInterA.java @@ -0,0 +1,6 @@ +package com.ai.cloud.skywalking.plugin.test.dubbo.interfaces; + + +public interface IDubboInterA { + void doBusiness(String paramA); +} diff --git a/skywalking-sdk-plugin/dubbo-plugin/src/test/resources/consumer/dubbo-consumer.xml b/skywalking-sdk-plugin/dubbo-plugin/src/test/resources/consumer/dubbo-consumer.xml new file mode 100644 index 000000000..60dffa7ad --- /dev/null +++ b/skywalking-sdk-plugin/dubbo-plugin/src/test/resources/consumer/dubbo-consumer.xml @@ -0,0 +1,13 @@ + + + + + + + + + \ No newline at end of file diff --git a/skywalking-sdk-plugin/dubbo-plugin/src/test/resources/log4j.properties b/skywalking-sdk-plugin/dubbo-plugin/src/test/resources/log4j.properties new file mode 100644 index 000000000..3d6f4a1c1 --- /dev/null +++ b/skywalking-sdk-plugin/dubbo-plugin/src/test/resources/log4j.properties @@ -0,0 +1,8 @@ +#\u53ca\u65e5\u5fd7\u8f93\u51fa\u7ea7\u522b\uff0c\u5927\u4e8e\u7b49\u4e8e\u8be5\u7ea7\u522b\u7684\u65e5\u5fd7\u5c06\u88ab\u8f93\u51fa\uff08 DEBUG < INFO < WARN < ERROR < FATAL \uff09 \u8bbe\u4e3aOFF\u53ef\u4ee5\u5173\u95ed\u65e5\u5fd7 +log4j.rootLogger=info, stdout + +log4j.appender.stdout=org.apache.log4j.ConsoleAppender +log4j.appender.stdout.layout=org.apache.log4j.PatternLayout +log4j.appender.stdout.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss} %p %l %m%n + +log4j.logger.com.hshbic.cloud.openapi.develop2=INFO \ No newline at end of file diff --git a/skywalking-sdk-plugin/dubbo-plugin/src/test/resources/provider/dubbo-provider.xml b/skywalking-sdk-plugin/dubbo-plugin/src/test/resources/provider/dubbo-provider.xml new file mode 100644 index 000000000..8bb81ae9d --- /dev/null +++ b/skywalking-sdk-plugin/dubbo-plugin/src/test/resources/provider/dubbo-provider.xml @@ -0,0 +1,18 @@ + + + + + + + + + + + + + + \ No newline at end of file diff --git a/skywalking-sdk-plugin/dubbo-plugin/src/test/resources/springContext.xml b/skywalking-sdk-plugin/dubbo-plugin/src/test/resources/springContext.xml new file mode 100644 index 000000000..e69de29bb