java 通过反射转发请求

     在某些场景下，我们需要早service成拦截下服务请求，然后转发到相应的服务下；

     要实现这样的场景我们首先需要拦截下service层的请求，然后在获取相应的请求参数，转发下去；

     以下例子是将服务通过dubbo发布成webService然后调用；

     可以通过有storm测试；

     

     参考代码如下：

         1、简单实现版本，该版本只支持基础类型

package com.xmm.webserver.service.impl;

import java.lang.reflect.Method;
import java.util.List;
import java.util.Map;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.TypeReference;
import com.xmm.module.utils.SpdEsbQueryParam;
import com.xmm.web.share.interfaces.SpdEsbForwardService;
import com.xmm.webserver.base.GenericService;
import com.xmm.webserver.util.SpringUtil;

@Service("spdEsbForwardService")
public class SpdEsbForwardServiceImpl extends GenericService implements SpdEsbForwardService {
    Logger logger = LoggerFactory.getLogger(this.getClass());
    
    /**
     * 转发方法
     * @param params 封装好的请求数据(json格式)
     * **********属性说明：
     * *************targetName          请求类全路径
     * *************methodName          请求方法
     * *************queryParamsList     请求参数
     * *************returnType          返回类型全路径
     */
    @SuppressWarnings({ "rawtypes", "unchecked", "unused" })
    public Object spdEsbForward(String params) {
        try {
            Map<String, String> paramMap = JSON.parseObject(params, new TypeReference<Map<String, String>>() {}); 
            //获取调用类全路径
            String targetName = paramMap.get("targetName");
            //获取调用方法名
            String methodName = paramMap.get("methodName");
            //获取返回数据类型
            String returnType = paramMap.get("returnType");
            //获取查询请求参数
            String queryParams = paramMap.get("queryParamsList");   
            //将请求类型转换为list
            List<SpdEsbQueryParam> list = JSON.parseObject(queryParams, new TypeReference<List<SpdEsbQueryParam>>() {});
            
            // 调用方法的请求数据类型集合
            Class classNum[] = new Class[list.size()]; 
            // 调用方法的请求数据值集合
            Object objectNum[] = new Object[list.size()]; 
            int i = 0;
            for (SpdEsbQueryParam spdEsbQueryParam : list) {
                //获取请求数据类型
                Class paramCalss = Class.forName(spdEsbQueryParam.getPueryParamType());
                //获取请求数据值
                String paramValue=spdEsbQueryParam.getPueryParamValue().toString();
                
                classNum[i] = paramCalss;
                objectNum[i] = JSON.parseObject(paramValue, paramCalss);
                i++;
            }
            
            // 实例化调用类
            Object obj = SpringUtil.getBean(Class.forName(targetName));
            // 装载方法
            Method method = obj.getClass().getMethod(methodName, classNum);
            // 调用方法
            Object object =  method.invoke(obj, objectNum);
            return object;
        } catch (Exception e) {
            logger.error("",e);
        }
        return null;
    }
}

 

     请求参数：

{
    "methodName": "queryRouteInfoList",//请求方法
    "targetName": "com.xmm.web.share.interfaces.RouteInfoService",//请求完整路劲
    "queryParamsList": [  //查询参数集合
        {
            "pueryParamValue": {  // 查询参数值
                "flag": true,
                "pageSize": 20,
                "pageNum": 1,
                "routeName": "路由"
            },
            "pueryParamName": "query", //参数名称
            "pueryParamType": "com.xmm.web.share.query.RouteInfoQuery" //查询参数类型
        }
    ],
    "returnType": "com.xmm.module.commons.SingleResult<RouteInfoDTO>"  // 返回只类型
}

 

        2、复杂类型，该类型支持枚举、集合、类中包含集合.....数据类型，其他有没有不支持的有带验证

package com.xmm.webserver.service.impl;

import java.lang.reflect.Method;
import java.lang.reflect.ParameterizedType;
import java.lang.reflect.Type;
import java.util.List;
import java.util.Map;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.TypeReference;
import com.xmm.module.utils.SpdEsbQueryParam;
import com.xmm.web.share.interfaces.SpdEsbForwardService;
import com.xmm.webserver.base.GenericService;
import com.xmm.webserver.util.SpringUtil;

@Service("spdEsbForwardService")
public class SpdEsbForwardServiceImpl extends GenericService implements SpdEsbForwardService {
    Logger logger = LoggerFactory.getLogger(this.getClass());
    
    /**
     * 转发方法
     * @param params 封装好的请求数据(json格式)
     * **********属性说明：
     * *************targetName          请求类全路径
     * *************methodName          请求方法
     * *************queryParamsList     请求参数
     * *************returnType          返回类型全路径
     */
    @SuppressWarnings({ "rawtypes", "unused", "unchecked" })
    public String spdEsbForward(String params) {
        try {
            Map<String, String> paramMap = JSON.parseObject(params, new TypeReference<Map<String, String>>() {}); 
            //获取调用类全路径
            String targetName = paramMap.get("targetName");
            //获取调用方法名
            String methodName = paramMap.get("methodName");
            //获取返回数据类型
            String returnType = paramMap.get("returnType");
            //获取查询请求参数
            String queryParams = paramMap.get("queryParamsList");   
            //将请求类型转换为list
            List<SpdEsbQueryParam> list = JSON.parseObject(queryParams, new TypeReference<List<SpdEsbQueryParam>>() {});
            
            int length = list.size();
            // 调用方法的请求数据类型集合
            Class classNum[] = new Class[length]; 
            // 调用方法的请求数据值
            String classValue[] = new String[length];
            // 调用方法的请求数据值集合
            Object objectNum[] = new Object[length]; 
            
            for (int i=0; i < length; i++) {
                SpdEsbQueryParam spdEsbQueryParam = list.get(i);
                //获取请求数据类型
                classNum[i] = Class.forName(spdEsbQueryParam.getPueryParamType());
                //获取请求数据值
                classValue[i] = spdEsbQueryParam.getPueryParamValue().toString();
            }
            
            // 实例化调用类
            Object obj = SpringUtil.getBean(Class.forName(targetName));
            // 装载方法
            Method method = Class.forName(targetName).getMethod(methodName,classNum);
            // 获取参数，可能是多个，所以是数组
            Type[] types = method.getGenericParameterTypes();   
            for (int i=0; i < length; i++) {
                Type queryType = types[i];
                
                // 判断此类型是否是Type对象的数组
                if (!(queryType instanceof ParameterizedType)){
                    //获取对象
                    Class paramCalss = Class.forName(queryType.getTypeName());
                    //判断对象是否是枚举
                    if(paramCalss.isEnum()){
                        objectNum[i] = tresolveEnumValue(classValue[i], paramCalss); 
                    }else{
                        objectNum[i] = JSON.parseObject(classValue[i],queryType);
                    }
                } else {
                    objectNum[i] = JSON.parseObject(classValue[i],queryType);
                }
            }
            
            // 调用方法
            Object object =  method.invoke(obj, objectNum);
            return JSON.toJSONString(object);
        } catch (Exception e) {
            logger.error("",e);
        }
        return null;
    }
    
    private <T> T tresolveEnumValue(String value, Class<T> type) {  
        for (T constant : type.getEnumConstants()){  
            if (constant.toString().equalsIgnoreCase(value)) {  
                return constant;  
            }  
        }     
        return null;  
    }
}

   

    请求参数1-带集合：

{
    "methodName": "enumberOut",
    "targetName": "com.xmm.web.share.interfaces.EnumberService",
    "queryParamsList": [
        {
            "pueryParamValue": {
                "modifyBy": "admin",
                "batchNo": "120598",
                "notOutQuantity": 96,
                "outQuantity": 4
            },
            "pueryParamName": "enumber",
            "pueryParamType": "com.xmm.web.share.dto.EnumberDto"
        },
        {
            "pueryParamValue": [
                {
                    "eCode": "201705160006162"
                },
                {
                    "eCode": "20170000006163"
                },
                {
                    "eCode": "2017000006164"
                },
                {
                    "eCode": "2017516006165"
                }
            ],
            "pueryParamName": "enumberListDetail",
            "pueryParamType": "java.util.List"
        },
        {
            "pueryParamValue": {
                "agent": true,
                "userName": "admin",
                "accountId": "4607"
            },
            "pueryParamName": "user",
            "pueryParamType": "com.xmm.web.share.dto.UserDTO"
        },
        {
            "pueryParamValue": {
                "batchNo": "120598",
                "flag": true,
                "outQuantity": 4,
                "pageSize": 20,
                "remark": "你妹",
                "pageNum": 1
            },
            "pueryParamName": "query",
            "pueryParamType": "com.xmm.web.share.query.EnumberQuery"
        }
    ],
    "returnType": "com.xmm.module.commons.Result"
}

    请求参数2-带枚举：

{
    "methodName": "createNewAccount",
    "targetName": "com.xmm.share.interfaces.AccountManagerService",
    "queryParamsList": [
        {
            "pueryParamValue": "11010512",
            "pueryParamName": "agentId",
            "pueryParamType": "java.lang.Integer"
        },
        {
            "pueryParamValue": "AGENT",
            "pueryParamName": "AGENT",
            "pueryParamType": "com.xmm.module.enums.ACCOUNT_TYPE"
        }
    ],
    "returnType": "com.xmm.share.dto.AccountDto"
}