案例工程代码结构调整

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

@@ -2,6 +2,12 @@ package com.ai.ipu.service.demo;
import com.ailk.common.data.IData;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2018年3月6日下午3:46:58
 * @desc 服务异步调用案例
 */
public interface IAsyncService {
    public IData findFoo() throws Exception;

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

@@ -0,0 +1,19 @@
package com.ai.ipu.service.demo;
import com.ailk.common.data.IData;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2018年3月6日下午3:41:56
 * @desc 业务服务调用案例
 */
public interface IBizService {
    
    /**
     * @author huangbo@asiainfo.com
     * @title: queryUserInfo
     * @desc: 用户信息查询
     */
    public IData queryUserInfo(IData param);
}

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

@@ -2,10 +2,14 @@ package com.ai.ipu.service.demo;
import com.ailk.common.data.IData;
public interface IDemoService {
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2018年3月6日下午3:43:56
 * @desc 获取服务上下文案例
 */
public interface IContextService {
    public IData queryUserInfo(IData param);
    
    /**
     * @author huangbo@asiainfo.com
     * @title: takeRpcContext

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

@@ -0,0 +1,25 @@
package com.ai.ipu.service.demo.impl;
import com.ai.ipu.service.demo.IBizService;
import com.ailk.common.data.IData;
import com.ailk.common.data.impl.DataMap;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2018年3月6日下午3:43:13
 * @desc TODO(描述类作用)
 */
public class BizService implements IBizService{
    public IData queryUserInfo(IData param) {
        // TODO Auto-generated method stub
        /*校验参数*/
        /*参数准备*/
        /*获取结果*/
        IData result = new DataMap();
        result.put("param", param);
        result.put("msg", "成功返回结果!");
        return result;
    }
}

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

@@ -2,23 +2,12 @@ package com.ai.ipu.service.demo.impl;
import java.util.Map;
import com.ai.ipu.service.demo.IDemoService;
import com.ai.ipu.service.demo.IContextService;
import com.ailk.common.data.IData;
import com.ailk.common.data.impl.DataMap;
import com.alibaba.dubbo.rpc.RpcContext;
public class DemoService implements IDemoService{
    public IData queryUserInfo(IData param) {
        // TODO Auto-generated method stub
        /*校验参数*/
        /*参数准备*/
        /*获取结果*/
        IData result = new DataMap();
        result.put("param", param);
        result.put("msg", "成功返回结果!");
        return result;
    }
public class ContextService implements IContextService{
    /**
     * 获取上下文信息

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

@@ -16,8 +16,10 @@
    <!-- 全局配置 end=========================== -->
    
    <!-- 服务注册配置 start=========================== -->
    <dubbo:service interface="com.ai.ipu.service.demo.IDemoService" ref="demoService"/>
    <bean id="demoService" class="com.ai.ipu.service.demo.impl.DemoService"/>
    <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"/>
    <!-- 服务注册配置 end =========================== -->

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

@@ -23,8 +23,10 @@
    <!-- 全局配置 end=========================== -->
    
    <!-- 服务注册配置 start=========================== -->
    <dubbo:service interface="com.ai.ipu.service.demo.IDemoService" ref="demoService"/>
    <bean id="demoService" class="com.ai.ipu.service.demo.impl.DemoService"/>
    <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"/>
    <!-- 服务注册配置 end =========================== -->

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

@@ -21,8 +21,10 @@
    <!-- 全局配置 end=========================== -->
    
    <!-- 服务注册配置 start=========================== -->
    <dubbo:service interface="com.ai.ipu.service.demo.IDemoService" ref="demoService"/>
    <bean id="demoService" class="com.ai.ipu.service.demo.impl.DemoService"/>
    <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"/>
    <!-- 服务注册配置 end =========================== -->

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

@@ -0,0 +1,29 @@
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 BizServiceTest 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 testQueryUserInfo() {
        // TODO Auto-generated method stub
        IBizService contextService = (IBizService)context.getBean("bizService"); // 获取远程服务代理
        IData result = contextService.queryUserInfo(new DataMap()); // 执行远程方法
        System.out.println(result); // 显示调用结果
    }
}

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

@@ -5,13 +5,13 @@ import junit.framework.TestCase;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.ai.ipu.service.DubboServiceStart;
import com.ai.ipu.service.demo.IDemoService;
import com.ai.ipu.service.demo.IContextService;
import com.ai.ipu.service.dubbo.DubboContextData;
import com.ailk.common.data.IData;
import com.ailk.common.data.impl.DataMap;
import com.alibaba.dubbo.rpc.RpcContext;
public class DemoServiceTest extends TestCase{
public class ContextServiceTest extends TestCase{
    private ClassPathXmlApplicationContext context;
    
    @Override
@@ -21,13 +21,6 @@ public class DemoServiceTest extends TestCase{
        context.start();
    }
    
    public void testQueryUserInfo() {
        // TODO Auto-generated method stub
        IDemoService demoService = (IDemoService)context.getBean("demoService"); // 获取远程服务代理
        IData result = demoService.queryUserInfo(new DataMap()); // 执行远程方法
        System.out.println(result); // 显示调用结果
    }
    
    /**
     * @author huangbo@asiainfo.com
     * @title: takeRpcContext
@@ -40,8 +33,8 @@ public class DemoServiceTest extends TestCase{
        DubboContextData contextData = new DubboContextData();
        contextData.put("context_info", "上下文信息");
        RpcContext.getContext().setAttachments(contextData);
        IDemoService demoService = (IDemoService)context.getBean("demoService"); // 获取远程服务代理
        IData result = demoService.takeRpcContext(); // 执行远程方法
        IContextService contextService = (IContextService)context.getBean("contextService"); // 获取远程服务代理
        IData result = contextService.takeRpcContext(); // 执行远程方法
        System.out.println(result); // 显示调用结果
    }

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

@@ -13,7 +13,8 @@
    <!-- 全局配置 end=========================== -->
	
	<!-- 服务注册配置 start=========================== -->
	<dubbo:reference id="demoService" interface="com.ai.ipu.service.demo.IDemoService" />
    <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"/>

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

@@ -12,7 +12,8 @@
	<!-- 全局配置 end=========================== -->
	
	<!-- 服务注册配置 start=========================== -->
	<dubbo:reference id="demoService" interface="com.ai.ipu.service.demo.IDemoService" />
	<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"/>

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

@@ -13,10 +13,11 @@
	<!-- 全局配置 end=========================== -->
	
	<!-- 开发阶段可使用直连模式 -->
	<!-- <dubbo:reference id="demoService" interface="com.ai.ipu.service.demo.IDemoService" url="dubbo://localhost:20880"/> -->
	<!-- <dubbo:reference id="demoService" interface="com.ai.ipu.service.demo.IContextService" url="dubbo://localhost:20880"/> -->
	
	<!-- 服务注册配置 start=========================== -->
	<dubbo:reference id="demoService" interface="com.ai.ipu.service.demo.IDemoService" />
	<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"/>