dubbo拦截器案例

ipu-service-demo/src/main/java/com/ai/ipu/service/demo/IBizService.java

@@ -16,4 +16,11 @@ public interface IBizService {
     * @desc: 用户信息查询
     */
    public IData queryUserInfo(IData param);
    
    /**
     * @author huangbo@asiainfo.com
     * @title: triggerException
     * @desc: 触发业务异常
     */
    public IData triggerException(IData param);
}

ipu-service-demo/src/main/java/com/ai/ipu/service/demo/impl/BizService.java

@@ -22,4 +22,9 @@ public class BizService implements IBizService{
        result.put("msg", "成功返回结果!");
        return result;
    }
    
    public IData triggerException(IData param) {
        // TODO Auto-generated method stub
        throw new RuntimeException("业务异常");
    }
}

ipu-service-demo/src/main/java/com/ai/ipu/service/demo/interceptor/ServiceInterceptor.java

@@ -0,0 +1,37 @@
package com.ai.ipu.service.demo.interceptor;
import com.ai.ipu.service.dubbo.interceptor.IServiceInterceptor;
import com.ailk.common.data.IData;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2018年3月7日下午3:58:40
 * @desc 拦截器服务案例，onInvoke没有测试通过
 */
public class ServiceInterceptor implements IServiceInterceptor {
    public void onInvoke(Object ... params) {
        // TODO Auto-generated method stub
        for(Object param : params){
            System.out.println("服务入参:" + param);
        }
    }
    public void onReturn(Object result, Object ... params) {
        // TODO Auto-generated method stub
        System.out.println("服务返回：" + result);
        for(Object param : params){
            System.out.println("服务入参:" + param);
        }
    }
    public void onThrow(Throwable ex, Object ... params) {
        // TODO Auto-generated method stub
        System.out.println("异常情况：" + ex);
        for(Object param : params){
            System.out.println("服务入参:" + param);
        }
    }
}

ipu-service-demo/src/main/resources/dubbo-provider-mult.xml

@@ -18,11 +18,14 @@
    <!-- 服务注册配置 start=========================== -->
    <dubbo:service interface="com.ai.ipu.service.demo.IBizService" ref="bizService"/>
    <bean id="bizService" class="com.ai.ipu.service.demo.impl.BizService"/>
    <!-- 服务上下文 -->
    <dubbo:service interface="com.ai.ipu.service.demo.IContextService" ref="contextService"/>
    <bean id="contextService" class="com.ai.ipu.service.demo.impl.ContextService"/>
    <!-- 异步服务 -->
    <dubbo:service interface="com.ai.ipu.service.demo.IAsyncService" ref="asyncService"/>
    <bean id="asyncService" class="com.ai.ipu.service.demo.impl.AsyncService"/>
    
    <!-- 服务回调 -->
    <dubbo:service interface="com.ai.ipu.service.demo.ICallbackService" ref="callbackService" connections="1" callbacks="1000">
	    <dubbo:method name="addListener">
	        <dubbo:argument index="1" callback="true" />

ipu-service-demo/src/main/resources/dubbo-provider-simple.xml

@@ -25,11 +25,14 @@
    <!-- 服务注册配置 start=========================== -->
    <dubbo:service interface="com.ai.ipu.service.demo.IBizService" ref="bizService"/>
    <bean id="bizService" class="com.ai.ipu.service.demo.impl.BizService"/>
    <!-- 服务上下文 -->
    <dubbo:service interface="com.ai.ipu.service.demo.IContextService" ref="contextService"/>
    <bean id="contextService" class="com.ai.ipu.service.demo.impl.ContextService"/>
    <!-- 异步服务 -->
    <dubbo:service interface="com.ai.ipu.service.demo.IAsyncService" ref="asyncService"/>
    <bean id="asyncService" class="com.ai.ipu.service.demo.impl.AsyncService"/>
    
    <!-- 服务回调 -->
	<dubbo:service interface="com.ai.ipu.service.demo.ICallbackService" ref="callbackService" connections="1" callbacks="1000">
	    <dubbo:method name="addListener">
	        <dubbo:argument index="1" callback="true" />

ipu-service-demo/src/main/resources/dubbo-provider-zoo.xml

@@ -23,11 +23,14 @@
    <!-- 服务注册配置 start=========================== -->
    <dubbo:service interface="com.ai.ipu.service.demo.IBizService" ref="bizService"/>
    <bean id="bizService" class="com.ai.ipu.service.demo.impl.BizService"/>
    <!-- 服务上下文 -->
    <dubbo:service interface="com.ai.ipu.service.demo.IContextService" ref="contextService"/>
    <bean id="contextService" class="com.ai.ipu.service.demo.impl.ContextService"/>
    <!-- 异步服务 -->
    <dubbo:service interface="com.ai.ipu.service.demo.IAsyncService" ref="asyncService"/>
    <bean id="asyncService" class="com.ai.ipu.service.demo.impl.AsyncService"/>
    
    <!-- 服务回调 -->
    <dubbo:service interface="com.ai.ipu.service.demo.ICallbackService" ref="callbackService" connections="1" callbacks="1000">
	    <dubbo:method name="addListener">
	        <dubbo:argument index="1" callback="true" />

ipu-service-demo/src/test/java/com/ai/ipu/service/demo/impl/InterceptorServiceTest.java

@@ -0,0 +1,39 @@
package com.ai.ipu.service.demo.impl;
import junit.framework.TestCase;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.ai.ipu.service.DubboServiceStart;
import com.ai.ipu.service.demo.IBizService;
import com.ailk.common.data.IData;
import com.ailk.common.data.impl.DataMap;
public class InterceptorServiceTest extends TestCase{
    private ClassPathXmlApplicationContext context;
    
    @Override
    protected void setUp() throws Exception {
        // TODO Auto-generated method stub
        context = new ClassPathXmlApplicationContext(new String[] { DubboServiceStart.DUBBO_CONSUMER_CONFIG });
        context.start();
    }
    public void testInterceptorService() {
        // TODO Auto-generated method stub
        IBizService contextService = (IBizService)context.getBean("interceptorService"); // 获取远程服务代理
        IData param = new DataMap();
        param.put("key", "入参");
        IData result = contextService.queryUserInfo(param); // 执行远程方法
        System.out.println(result); // 显示调用结果
    }
    
    public void testTriggerException() {
        // TODO Auto-generated method stub
        IBizService contextService = (IBizService)context.getBean("interceptorService"); // 获取远程服务代理
        IData param = new DataMap();
        param.put("key", "入参");
        IData result = contextService.triggerException(param); // 执行远程方法
        System.out.println(result); // 显示调用结果
    }
}

ipu-service-demo/src/test/resources/dubbo-consumer-mult.xml

@@ -20,6 +20,15 @@
		<dubbo:method name="findFoo" async="true" timeout="3500"/>
		<dubbo:method name="findBar" async="true" timeout="5500"/>
	</dubbo:reference>
	<!-- 服务回调 -->
	<dubbo:reference id="callbackService" interface="com.ai.ipu.service.demo.ICallbackService" />
	
	<!-- 服务拦截 -->
	<bean id="serviceInterceptor" class="com.ai.ipu.service.demo.interceptor.ServiceInterceptor" />
	<dubbo:reference id="interceptorService" interface="com.ai.ipu.service.demo.IBizService">
		<!-- oninvoke="serviceInterceptor.onInvoke" -->
		<dubbo:method name="queryUserInfo" async="true" onreturn="serviceInterceptor.onReturn"/>
		<dubbo:method name="triggerException" onthrow="serviceInterceptor.onThrow"/>
	</dubbo:reference>
	<!-- 服务注册配置 end =========================== -->
</beans>

ipu-service-demo/src/test/resources/dubbo-consumer-simple.xml

@@ -1,24 +1,36 @@
<?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"
	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.xsd
	http://code.alibabatech.com/schema/dubbo 
	http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
	<!-- 全局配置 start=========================== -->
	<dubbo:application name="ipu-service-demo"/>
	<dubbo:application name="ipu-service-demo" />
	<dubbo:registry address="127.0.0.1:20880" />
	<!-- 全局配置 end=========================== -->
	
	<!-- 服务注册配置 start=========================== -->
	<dubbo:reference id="bizService" interface="com.ai.ipu.service.demo.IBizService" />
	<dubbo:reference id="contextService" interface="com.ai.ipu.service.demo.IContextService" />
	<dubbo:reference id="bizService"
		interface="com.ai.ipu.service.demo.IBizService" />
	<dubbo:reference id="contextService"
		interface="com.ai.ipu.service.demo.IContextService" />
	<!-- 两级超时配置 -->
	<dubbo:reference id="asyncService" interface="com.ai.ipu.service.demo.IAsyncService" timeout="3000" >
		<dubbo:method name="findFoo" async="true" timeout="3500"/>
		<dubbo:method name="findBar" async="true" timeout="5500"/>
	<dubbo:reference id="asyncService"
		interface="com.ai.ipu.service.demo.IAsyncService" timeout="3000">
		<dubbo:method name="findFoo" async="true" timeout="3500" />
		<dubbo:method name="findBar" async="true" timeout="5500" />
	</dubbo:reference>
	<!-- 服务回调 -->
	<dubbo:reference id="callbackService"
		interface="com.ai.ipu.service.demo.ICallbackService" />
		
	<!-- 服务拦截 -->
	<bean id="serviceInterceptor" class="com.ai.ipu.service.demo.interceptor.ServiceInterceptor" />
	<dubbo:reference id="interceptorService" interface="com.ai.ipu.service.demo.IBizService">
		<!-- oninvoke="serviceInterceptor.onInvoke" -->
		<dubbo:method name="queryUserInfo" async="true" onreturn="serviceInterceptor.onReturn"/>
		<dubbo:method name="triggerException" onthrow="serviceInterceptor.onThrow"/>
	</dubbo:reference>
	<dubbo:reference id="callbackService" interface="com.ai.ipu.service.demo.ICallbackService" />
	<!-- 服务注册配置 end =========================== -->
</beans>

ipu-service-demo/src/test/resources/dubbo-consumer-zoo.xml

@@ -23,7 +23,16 @@
		<dubbo:method name="findFoo" async="true" timeout="3500"/>
		<dubbo:method name="findBar" async="true" timeout="5500"/>
	</dubbo:reference>
	<!-- 服务回调 -->
	<dubbo:reference id="callbackService" interface="com.ai.ipu.service.demo.ICallbackService" />
	
	<!-- 服务拦截 -->
	<bean id="serviceInterceptor" class="com.ai.ipu.service.demo.interceptor.ServiceInterceptor" />
	<dubbo:reference id="interceptorService" interface="com.ai.ipu.service.demo.IBizService">
		<!-- oninvoke="serviceInterceptor.onInvoke" -->
		<dubbo:method name="queryUserInfo" async="true" onreturn="serviceInterceptor.onReturn"/>
		<dubbo:method name="triggerException" onthrow="serviceInterceptor.onThrow"/>
	</dubbo:reference>
	<!-- 服务注册配置 end =========================== -->
</beans>