高并发，多子系统 配置化，任务入库定时处理设计思想

 

 

对任何子系统请求进行先入库，用同一格式保存（具体业务数据数据库用一个字段保存json串 1），然后定时任务去用反射执行/java工具类获取示例（3）（实现异步处理）

 

结合gateWay思想：不同的参数查询配置表中对应配置的服务类，获取服务类对应的服务实例，调用不同的服务

结合高并发请求入库思想：所有请求同一格式保存入庫（请求业务类型，请求参数json保存一个字段中，请求号，请求状态。。。。），定时任务扫描：根据请求类型

查到配置表中对应是json转化实体类，查到对应的处理服务类，然后用参数对象传入服务对象正常调用

 

 任务发起后通过状态标志流转，有异常就改对应状态

 

1,json解析成Java类对象

SanxaingTYZDCrdtAplyRequest feideeLoanApplyRequest = JSONObject.parseObject(loanApplyRequest.getLoanInfo(),SanxaingTYZDCrdtAplyRequest.class);

 

2，获取名字对应的类-------------用于读取配置中的字符转化成类，由此类结合1解析json成类对象

 public Class getInsureCheckBean(InsureApplyRequest insureApplyRequest) {

        String bankType = insureApplyRequest.getBankType();

        String insureChannel = insureApplyRequest.getInsureChannel();

        BankConf bankConf = bankConfMapper.query(insureApplyRequest.getBankType(), insureApplyRequest.getInsureChannel());

        if (bankConf==null){

            LOGGER.error(CodeEnum.CODE_0027.getMsg() + ":" + bankType);

            return null;

        }

        String insureParamClass = bankConf.getInsureParamClass();

        if (insureParamClass==null){

            LOGGER.error("没有配置投保请求参数bean:{},{}", bankType, insureChannel);

            return null;

        }

        try {

            return Class.forName(insureParamClass);

        } catch (ClassNotFoundException e) {

            LOGGER.error("请检查银行类型["+bankType+","+insureChannel+"]的投保请求bean配置",e);

            return null;

        }

    }

 

 

 

3，获取数据中配置的字符串对应的实例----------处理多态，根据不同的参数获取具体的实现类对象。或某一对象   

 

 

结合gateWay思想：不同的参数查询配置表中对应配置的服务类，获取服务类对应的服务实例，调用不同的服务(实现服务配置化分流)

结合高并发请求入库思想：所有请求同一格式保存入庫（请求业务类型，请求参数json保存一个字段中，请求号，请求状态。。。。），定时任务扫描：根据请求类型

查到配置表中对应是json转化实体类，查到对应的处理服务类，然后用参数对象传入服务对象正常调用

 

应用：

AbstractFacadeExchange facadeInstance = facadeInstanceFactory.getFacadeInstance(request.getBankCode());

ApiResponse response = facadeInstance.send(facadeSendRequest);

 

 

FacadeInstanceFactory：

    public AbstractFacadeExchange getFacadeInstance(String bankType) {

        Map<String, String> facadeExchange = facadeInstanceConfig.getFacadeExchange();

        Set<String> strings = facadeExchange.keySet();

        for (String key : strings) {

            if (bankType != null && bankType.equals(key)) {

                String instanceName = facadeExchange.get(key);

                return (AbstractFacadeExchange) AppContextAware.getObject(instanceName);

            }

        }

        LOGGER.error(CodeEnum.CODE_0027.getMsg() + ":" + bankType);

        return null;

    }

 

 

@Service

public class AppContextAware implements ApplicationContextAware {

 

    private static ApplicationContext applicationContext;

 

    @Override

    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {

        this.applicationContext = applicationContext;

    }

 

    public static <T> T getObject(String id) {

        return (T)applicationContext.getBean(id);

    }

 

    public static ApplicationContext getApplicationContext() {

        return applicationContext;

    }

}

 

 

 

参看：

http://yuhuiblog69586958738152683856.iteye.com/admin/blogs/2428696