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

完成Dubbo调用

This commit is contained in:
zhangxin10 2015-11-18 21:27:33 +08:00
parent 039aa743f1
commit 6b33707b11
10 changed files with 91 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
skywalking-sdk-plugin/dubbo-plugin/src/main/java/com/ai/cloud/skywalking/plugin/dubbo/SWDubboEnhanceFilter.java
View File

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

1
skywalking-sdk-plugin/dubbo-plugin/src/main/resources/META-INF/dubbo/com.alibaba.dubbo.rpc.Filter Normal file
View File

@ -0,0 +1 @@
swEnhanceFilter=com.ai.cloud.skywalking.plugin.dubbo.SWDubboEnhanceFilter

15
skywalking-sdk-plugin/dubbo-plugin/src/test/java/com/ai/cloud/skywalking/plugin/test/dubbo/consumer/DubboConsumer.java Normal file
View File

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

11
skywalking-sdk-plugin/dubbo-plugin/src/test/java/com/ai/cloud/skywalking/plugin/test/dubbo/impl/DubboInterAImpl.java Normal file
View File

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

17
skywalking-sdk-plugin/dubbo-plugin/src/test/java/com/ai/cloud/skywalking/plugin/test/dubbo/impl/DubboStart.java Normal file
View File

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

6
skywalking-sdk-plugin/dubbo-plugin/src/test/java/com/ai/cloud/skywalking/plugin/test/dubbo/interfaces/IDubboInterA.java Normal file
View File

@ -0,0 +1,6 @@
package com.ai.cloud.skywalking.plugin.test.dubbo.interfaces;
public interface IDubboInterA {
void doBusiness(String paramA);
}

13
skywalking-sdk-plugin/dubbo-plugin/src/test/resources/consumer/dubbo-consumer.xml Normal file
View File

@ -0,0 +1,13 @@
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
<dubbo:application name="skywalking-consumer"/>
<dubbo:registry address="zookeeper://127.0.0.1:2181"/>
<dubbo:consumer filter="swEnhanceFilter"/>
<dubbo:reference id="dubboInterA" interface="com.ai.cloud.skywalking.plugin.test.dubbo.interfaces.IDubboInterA"/>
</beans>

8
skywalking-sdk-plugin/dubbo-plugin/src/test/resources/log4j.properties Normal file
View File

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

18
skywalking-sdk-plugin/dubbo-plugin/src/test/resources/provider/dubbo-provider.xml Normal file
View File

@ -0,0 +1,18 @@
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
<dubbo:application name="skywalking-provider"/>
<dubbo:registry address="zookeeper://127.0.0.1:2181"/>
<dubbo:protocol name="dubbo" port="20880"/>
<bean id="dubboInterA" class="com.ai.cloud.skywalking.plugin.test.dubbo.impl.DubboInterAImpl"/>
<dubbo:service interface="com.ai.cloud.skywalking.plugin.test.dubbo.interfaces.IDubboInterA" ref="dubboInterA"/>
</beans>

0
skywalking-sdk-plugin/dubbo-plugin/src/test/resources/springContext.xml Normal file
View File