在rest和service体系下增加dubbo调用方式

ipu-rest-demo/pom.xml

@@ -73,6 +73,19 @@
			<groupId>com.ai.ipu</groupId>
			<artifactId>ipu-server-web</artifactId>
		</dependency>
	
		<dependency>
			<groupId>com.alibaba</groupId>
			<artifactId>dubbo</artifactId>
		</dependency>
		<dependency>
		    <groupId>com.github.sgroschupf</groupId>
		    <artifactId>zkclient</artifactId>
		</dependency>
		<dependency>
		    <groupId>com.netflix.curator</groupId>
		    <artifactId>curator-framework</artifactId>
		</dependency>
		
		<!-- msgframe相关依赖 -->
		<dependency>

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/IpuRestDemoStart.java

@@ -1,6 +1,9 @@
package com.ai.ipu.server.demo;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.ai.ipu.restful.boot.IpuRestApplication;
import com.ai.ipu.restful.spring.SpringManager;
/**
 * @author huangbo@asiainfo.com
@@ -9,7 +12,11 @@ import com.ai.ipu.restful.boot.IpuRestApplication;
 * @desc 启动的时候需要指定参数--server.port=8080
 */
public class IpuRestDemoStart {
	public static void main(String[] args) {
		IpuRestApplication.start(args);
	}
    public final static String DUBBO_CONSUMER_CONFIG = "dubbo-consumer-simple.xml";
    
    public static void main(String[] args) {
        SpringManager.registerSpringContext(
                new ClassPathXmlApplicationContext(new String[] { DUBBO_CONSUMER_CONFIG }));
        IpuRestApplication.start(args);
    }
}

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/dubbo/DubboControl.java

@@ -0,0 +1,41 @@
package com.ai.ipu.server.demo.control.dubbo;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import com.ai.ipu.basic.reflect.ReflectUtil;
import com.ai.ipu.basic.util.IpuUtility;
import com.ai.ipu.restful.spring.SpringManager;
import com.ai.ipu.service.demo.IBizService;
import com.ailk.common.data.IData;
@Controller
@RequestMapping("/dubbo")
public class DubboControl {
    @ResponseBody
    @RequestMapping("/biz")
    public IData callBizService(IData params) {
        IBizService bizService = (IBizService)SpringManager.takeSpringContext().getBean("bizService"); // 获取远程服务代理
        IData result = bizService.queryUserInfo(params); // 执行远程方法
        result.put("msg", "测试biz类型服务调用");
        return params;
    }
    
    @ResponseBody
    @RequestMapping("/common")
    public IData callCommonService(IData params) {
        String serviceName = params.getString("service_name");
        String methodName = params.getString("method_name");
        Object service = SpringManager.takeSpringContext().getBean(serviceName); 
        try {
            ReflectUtil.invokeMethod(service, methodName, new Object[]{params});
        }catch (Exception e) {
            // TODO Auto-generated catch block
            IpuUtility.error(serviceName + "服务的" + methodName + "方法调用异常:" + e.getMessage());
        }
        params.put("msg", "测试common类型服务调用");
        return params;
    }
}

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/ipu/IpuController.java

@@ -1,199 +0,0 @@
package com.ai.ipu.server.demo.control.ipu;
import java.net.URLDecoder;
import javax.servlet.http.Cookie;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.apache.log4j.Logger;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import com.ai.ipu.basic.string.EscapeUnescape;
import com.ai.ipu.basic.thread.ThreadLocalManager;
import com.ai.ipu.server.config.DataConfig;
import com.ai.ipu.server.config.MobileConfig;
import com.ai.ipu.server.frame.context.impl.AbstractContextManager;
import com.ai.ipu.server.frame.context.impl.DefaultContextManager;
import com.ai.ipu.server.frame.handle.IExceptionHandler;
import com.ai.ipu.server.frame.session.impl.AbstractSessionManager;
import com.ai.ipu.server.frame.session.impl.DefaultSessionManager;
import com.ai.ipu.server.servlet.ServletManager;
import com.ai.ipu.server.util.MobileConstant;
import com.ai.ipu.server.util.MobileUtility;
import com.ailk.common.data.IData;
import com.ailk.common.data.impl.DataMap;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2018年4月28日下午5:23:53
 * @desc 基于IPU服务端的spring mvc封装。
 */
@Controller
/*增加了mobile路径后，所有的静态资源加载都会执行BasicInterceptor拦截器*/
//@RequestMapping("/mobile")
public class IpuController {
    transient static protected Logger log = Logger.getLogger(IpuController.class);
    {
        try {
            /*初始上下文管理类*/
            String ctxClassName = MobileConfig.getValue(MobileConstant.MobileConfig.CONTEXT_MANAGER,
                    DefaultContextManager.class.getName());
            String sesClassName = MobileConfig.getValue(MobileConstant.MobileConfig.SESSION_MANAGER,
                    DefaultSessionManager.class.getName());
            if (ctxClassName==null||"".equals(ctxClassName)){
                MobileUtility.error("需要指定ContextManager类");
            }
            if (sesClassName==null||"".equals(sesClassName)){
                MobileUtility.error("需要指定SessionManager类");
            }
            AbstractContextManager.initManageClass(ctxClassName);
            AbstractSessionManager.initManageClass(sesClassName);
        } catch (Exception e) {
            log.error(e.getMessage(), e);
        }
    }
    
    
    @RequestMapping("/ui")
    public void ui(HttpServletRequest request, HttpServletResponse response) {
        ServletManager.setRequest(request);
        ServletManager.setResponse(response);
        
        String pageAction = request.getParameter(MobileConstant.Server.ACTION);
        String data = request.getParameter(MobileConstant.Server.DATA);
        String key = request.getParameter(MobileConstant.Server.KEY);
        String is_context = request.getParameter(MobileConstant.Server.IS_CONTEXT);
        String isEncode = request.getParameter(MobileConstant.Server.IS_ENCODE);
        
        long startTime = System.currentTimeMillis();
        try {
            ServletManager.setPageAction(pageAction); //装载全局pageAction
            /*如果是编码的数据或上下文，就进行解码*/
            if (data != null && !"{}".equals(data) && "true".equals(isEncode)) {
                data = URLDecoder.decode(data, MobileConfig.getValue(MobileConstant.MobileConfig.ENCODE, MobileConstant.UTF_8));
            }
            boolean isContext = false;
            if ("true".equals(is_context)) {
                isContext = true;
            }
            
            //如果是加密的数据就解密
            if(key!=null){
                data = ServletManager.getSecurityHandle().requestDecrypt(key, data);
            }
            //欢迎页初始化
            if(pageAction==null){
                pageAction = MobileConfig.getValue(MobileConstant.MobileConfig.INDEX_PAGE);
            }
            
            if (log.isDebugEnabled()) {
                log.debug(">>> 进入MobileUiServlet post");
                log.debug(">>> pageAction: " + pageAction);
                log.debug(">>> data: " + data);
                log.debug(">>> isContext: " + isContext);
            }
            IData pageData = null;
            if(data==null){
                pageData = new DataMap();
            }else{
                pageData = new DataMap(data);
            }
            //读cookie,如果传入的参数中包含有某个键，cookie里面对应的同名键值将被忽略
            Cookie[] cookies = request.getCookies();     
            if(cookies!=null) {   
                for (Cookie cookie : cookies) {
                    String cookieName = cookie.getName();
                    if(!pageData.containsKey(cookieName)){
                        String cookieValue = EscapeUnescape.unescape(cookie.getValue());
                        pageData.put(cookieName, cookieValue);
                    }
                } 
             }
            ServletManager.render(pageAction, pageData, isContext);
            
        } catch (Exception e) {
            log.error("[[[[["+pageAction+"]]]]]] pageAction error", e);
            
            try {
                //语句简单明了，便于调试和排错
                IExceptionHandler eHandler = ServletManager.getExceptionHandler();
                eHandler.pageError(e, pageAction, data);
            } catch (Exception ex) {
                log.error(ex.getMessage(),ex);
            }
        } finally {
            ThreadLocalManager.removes();//请求结束时候清除ThreadLocal
        }
        
        if (log.isDebugEnabled()){
            double time = ((double) (System.currentTimeMillis() - startTime) / (double) 1000);
            log.debug("mobile servlet invoke finish, use time: " + time + "s");
        }
    }
    
    @RequestMapping("/data")
    public void data(HttpServletRequest request, HttpServletResponse response) throws Exception {
        ServletManager.setRequest(request);
        ServletManager.setResponse(response);
        String dataAction = request.getParameter(MobileConstant.Server.ACTION);
        String data = request.getParameter(MobileConstant.Server.DATA);
        String key = request.getParameter(MobileConstant.Server.KEY);
        long startTime = System.currentTimeMillis();
        
        Object result = null;
        try {
            ServletManager.setDataAction(dataAction); //装载全局dataAction，需要多次装载，适应多次调用。
            // 如果是加密的数据就解密
            if ("true".equals(MobileConfig.getValue(MobileConstant.MobileConfig.PRODUCT_MODE)) // 配置productMode=true防止拼串访问
                    || (key != null && DataConfig.isEncrypt(dataAction))) {
                data = ServletManager.getSecurityHandle().requestDecrypt(key, data);
            }
            
            if (log.isDebugEnabled()) {
                log.debug(">>> 进入MobileDataServlet post");
                log.debug(">>> dataAction: " + dataAction);
                log.debug(">>> data: " + data);
            }
            
            IData param = data==null?new DataMap():new DataMap(data);
            result = ServletManager.getBizData(dataAction, param);
        } catch (Exception e) {
            log.error("[[[[["+dataAction+"]]]]]] dataAction error", e);
            try {
                result = ServletManager.getExceptionHandler().dataError(e, dataAction, data);
            } catch (Exception ex) {
                result = ex.getMessage();
                log.error(ex.getMessage(), ex);
            }
        }finally{
            try {
                ServletManager.doResponse(result);
            } catch (Exception e) {
                log.error(e.getMessage(), e);
                String outError = "返回信息加密异常："+e.getMessage();
                response.setHeader("content-type", "text/html; charset=" + ServletManager.encode);
                response.setHeader("Content-Length", "" + outError.getBytes(ServletManager.encode).length);
                // update by huangbo jcl的BUG已经修复，不用再处理
                //outError = outError.replaceAll("\\\\r|\\\\t|\\\\n", "");// 过滤换行制表符
                if(log.isDebugEnabled()){
                    log.debug(">>> doResponse outstr: " + outError);
                }
                response.getWriter().print(outError);
                response.getWriter().flush();
            }finally{
                ThreadLocalManager.removes();//请求结束时候清除ThreadLocal
            }
        }
        
        if (log.isDebugEnabled()){
            double time = ((double) (System.currentTimeMillis() - startTime) / (double) 1000);
            log.debug("mobiledata servlet invoke finish, use time: " + time + "s");
        }
    }
}

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

@@ -0,0 +1,26 @@
package com.ai.ipu.service.demo;
import com.ailk.common.data.IData;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2018年10月23日下午7:25:11
 * @desc 业务服务调用案例
 */
public interface IBizService {
    /**
     * @author huangbo@asiainfo.com
     * @title: queryUserInfo
     * @desc: 用户信息查询
     */
    public IData queryUserInfo(IData param);
    
    /**
     * @author huangbo@asiainfo.com
     * @title: triggerException
     * @desc: 触发业务异常
     */
    public IData triggerException(IData param);
}

ipu-rest-demo/src/main/resources/dev/dubbo-consumer-simple.xml

@@ -0,0 +1,19 @@
<?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.xsd
	http://code.alibabatech.com/schema/dubbo 
	http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
	<!-- 全局配置 start=========================== -->
	<dubbo:application name="ipu-rest-demo" />
	<!-- 关闭重试，延长超时 -->
	<dubbo:consumer retries="0" timeout="2000"/>	<!-- client="netty4" -->
	<dubbo:registry address="127.0.0.1:20880" /> <!-- 127.0.0.1 -->
	<!-- 全局配置 end=========================== -->
	<!-- 服务注册配置 start=========================== -->
	<dubbo:reference id="bizService"
		interface="com.ai.ipu.service.demo.IBizService" />
	<!-- 服务注册配置 end =========================== -->
</beans>

ipu-service-demo/pom.xml

@@ -2,9 +2,13 @@
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
	<modelVersion>4.0.0</modelVersion>
	<groupId>com.ai.ipu.server</groupId>
	<parent>
		<groupId>com.ai.ipu.server</groupId>
		<artifactId>ipu-service-libs</artifactId>
		<version>3.0-SNAPSHOT</version>
	</parent>
	<artifactId>ipu-service-demo</artifactId>
	<version>3.0-SNAPSHOT</version>
	<packaging>jar</packaging>
	<name>ipu-service-demo</name>
@@ -24,32 +28,29 @@
			</snapshots>
		</repository>
	</repositories>
	
	<properties>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
		<ipu>3.0-SNAPSHOT</ipu>
		<msgframe>2.0.0</msgframe>
		<!-- <msgframe>2.0.0</msgframe> -->
	</properties>
	<dependencies>
		<dependency>
			<groupId>junit</groupId>
			<artifactId>junit</artifactId>
			<version>3.8.1</version>
			<scope>test</scope>
		</dependency>
		<dependency>
			<groupId>com.ai.ipu.server</groupId>
			<artifactId>ipu-service</artifactId>
			<version>${ipu}</version>
		</dependency>
		<dependency>
			<!-- 不依赖其他jar -->
			<groupId>com.ai.wade</groupId>
			<artifactId>wade-mobile-data</artifactId>
			<version>1.0</version>
		</dependency>
		<!-- msgframe相关依赖 -->
		<dependency>
		<!-- <dependency>
		  <groupId>com.ai.aif.msgframe</groupId>
		  <artifactId>msgframe-common</artifactId>
		  <version>${msgframe}</version>
@@ -90,11 +91,6 @@
		  <version>1.3</version>
		</dependency>
		<dependency>
  			<groupId>javax.jms</groupId>
  			<artifactId>jms</artifactId>
  			<version>1.1</version>
		</dependency>
		<dependency>
		  <groupId>org.apache.kafka</groupId>
		  <artifactId>kafka-clients</artifactId>
		  <version>0.10.2.0</version>
@@ -108,78 +104,6 @@
   			<groupId>com.alibaba.rocketmq</groupId>
    		<artifactId>rocketmq-client</artifactId>
    		<version>3.5.9</version>
		</dependency>
		</dependency> -->
	</dependencies>
	
	<!-- 对应开发、测试、生产三种环境 -->
	<profiles>
		<!-- 开发环境 -->
		<profile>
			<id>dev</id>
			<properties>
				<env>dev</env>
			</properties>
			<activation>
				<activeByDefault>true</activeByDefault>
			</activation>
		</profile>
		<!-- 测试环境 -->
		<profile>
			<id>test</id>
			<properties>
				<env>test</env>
			</properties>
		</profile>
		<!-- 生产环境 -->
		<profile>
			<id>pro</id>
			<properties>
				<env>pro</env>
			</properties>
		</profile>
	</profiles>
	<build>
		<plugins>
			<plugin>
				<groupId>org.apache.maven.plugins</groupId>
				<artifactId>maven-surefire-plugin</artifactId>
				<configuration>
					<!-- 跳过单元测试 -->
					<skip>true</skip>
				</configuration>
			</plugin>
			
			<plugin>
				<groupId>org.apache.maven.plugins</groupId>
				<artifactId>maven-compiler-plugin</artifactId>
				<configuration>
					<source>1.8</source>
					<target>1.8</target>
					<encoding>UTF-8</encoding>
					<!-- 这里添加本地jar -->
					<compilerArguments>
 					<!-- <bootclasspath>${JAVA_HOME}/jre/lib/rt.jar</bootclasspath> -->
 					<bootclasspath>/Library/Java/JavaVirtualMachines/jdk1.8.0_144.jdk/Contents/Home/jre/lib/rt.jar</bootclasspath>
 					<extdirs>${project.basedir}/libs</extdirs>
					</compilerArguments>
				</configuration>
			</plugin>
		</plugins>
		<resources>
            <resource>
                <directory>src/main/resources</directory>
                <!-- 资源根目录排除各环境的配置，防止在生成目录中多余其它目录 -->
                <excludes>
                    <exclude>dev/*</exclude>
                    <exclude>test/*</exclude>
                    <exclude>pro/*</exclude>
                </excludes>
            </resource>
            <resource>
                <directory>src/main/resources/${env}</directory>
                <!-- 根据输入参数动态修改相关内容 -->
				<filtering>true</filtering>
            </resource>
        </resources>
	</build>
</project>

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

@@ -2,8 +2,6 @@ package com.ai.ipu.service;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.ai.aif.msgframe.consumer.MfServiceStartup;
public class IpuServiceDemoStart {
    public final static String MODE = "simple";
    public final static String DUBBO_PROVIDER_CONFIG = "dubbo-provider-" + MODE + ".xml";
@@ -16,9 +14,9 @@ public class IpuServiceDemoStart {
        context.start();
        /*启动消息中间件的消费者服务*/
        /*启动所有的订阅*/
        MfServiceStartup.main();
        //MfServiceStartup.main();
        /*启动指定的订阅*/
//        MfConsumerClient.subscribe("myTestTopic", "*", "com.ai.ipu.service.demo.consumer.ConsumerProcessorImpl");
        //MfConsumerClient.subscribe("myTestTopic", "*", "com.ai.ipu.service.demo.consumer.ConsumerProcessorImpl");
        System.in.read(); // press any key to exit
    }
}

ipu-service-demo/src/main/java/com/ai/ipu/service/demo/consumer/ConsumerProcessorImpl.java

@@ -2,17 +2,17 @@ package com.ai.ipu.service.demo.consumer;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.ai.aif.msgframe.common.IConsumerProcessor;
import com.ai.aif.msgframe.common.exception.ConsumerException;
import com.ai.aif.msgframe.common.message.MsgFMessage;
import com.ai.aif.msgframe.common.message.MsgFTextMessage;
//import com.ai.aif.msgframe.common.IConsumerProcessor;
//import com.ai.aif.msgframe.common.exception.ConsumerException;
//import com.ai.aif.msgframe.common.message.MsgFMessage;
//import com.ai.aif.msgframe.common.message.MsgFTextMessage;
import com.ai.ipu.service.IpuServiceDemoStart;
import com.ai.ipu.service.demo.IDbService;
import com.ailk.common.data.IData;
import com.ailk.common.data.impl.DataMap;
public class ConsumerProcessorImpl implements IConsumerProcessor {
/*public class ConsumerProcessorImpl implements IConsumerProcessor {
    public Object process(MsgFMessage msg) throws ConsumerException{
        ClassPathXmlApplicationContext context = 
@@ -30,4 +30,4 @@ public class ConsumerProcessorImpl implements IConsumerProcessor {
        return true;
    }
}
}*/