动态发布接口

动态发布接口

HTTP接口分为REST和SOAP2种方式，文中都涉及到，包含从动态生成文件到编译class再到装载到spring容器和ws.Endpoint中。

REST风格

方案：

1.提供java文件模板

2.读取文件内容

3.查库修改生成java文件

4.通过JDK中的javax.tools.JavaCompiler动态编译成class

5.通过继承java.net.URLClassLoader动态加载class文件到内存

6.通过获取spring的ApplicationContext手动把mapping注册到RequestMappingHandlerMapping中完成动态发布

过程：

1.模板文件根据业务自行配置(涉及公司机密，忽略)

2.读取文件内容，生成java文件，编译class，加载class，发布接口

        //动态创建接口        @Override        public Boolean createGenerate(String serviceName,Long interfaceId,String structrue) {                try {                        //首字母大写                        serviceName = StringUtils.firstCharUpper(serviceName);                        //目录路径                        Path directoryPath = Paths.get(outDirectory);                        // 如果目录不存在                        if (!Files.exists(directoryPath)) {                            //创建目录                            Files.createDirectories(directoryPath);                        }                        String controllerJava = serviceName + "Controller.java";                        String autoJavaFile = outDirectory + controllerJava;                        //文件路径                        Path filePath = Paths.get(autoJavaFile);                        if (!Files.exists(filePath)) {                            //创建文件                            Files.createFile(filePath);                        } else {                                logger.error("动态创建接口错误,文件已存在:"+autoJavaFile);                                return false;                        }                        // 读取模板文件流                        String javaFile = directory + "RestTemplateController.java";                        String content = FileUtils.readFile(javaFile);                        //替换文件                        content = replaceJava(content, serviceName, interfaceId,structrue);                        //写入文件                        Files.write(filePath, content.getBytes(charsetName));                        String fullName = packageName + serviceName + "Controller";                        //动态编译class                        JavaStringCompiler compiler = new JavaStringCompiler();                        Map results = compiler.compile(controllerJava, content);                        //加载class                        Class clzMul = compiler.loadClass(fullName, results);                        //获取spring的applicationContext                        ApplicationContext applicationContext = SpringContextHelper.getApplicationContext();                        //注册接口到注册中心                        MappingRegulator.controlCenter(clzMul, applicationContext, create);                } catch (Exception e) {                        logger.error("动态创建接口错误",e);                        return false;                }                return true;        }                /**        * controlCenter(运行时RequestMappingHandlerMapping中添加、删除、修改Mapping接口)            * @param   Class 希望加载的类Class            * @param  ApplicationContext spring上下文         * @param  type 1新增 2修改 3删除         * @throws Exception          * @throws IllegalAccessException         * @Exception 异常对象            * @since  CodingExample　Ver(编码范例查看) 1.1        * @author jiaxiaoxian         */        public static void controlCenter(Class controllerClass,ApplicationContext  Context,Integer type) throws IllegalAccessException, Exception{                //获取RequestMappingHandlerMapping                 RequestMappingHandlerMapping requestMappingHandlerMapping=(RequestMappingHandlerMapping) Context.getBean("requestMappingHandlerMapping");                Method getMappingForMethod =ReflectionUtils.findMethod(RequestMappingHandlerMapping.class, "getMappingForMethod",Method.class,Class.class);                //设置私有属性为可见                getMappingForMethod.setAccessible(true);                //获取类中的方法                Method[] method_arr = controllerClass.getMethods();                for (Method method : method_arr) {                        //判断方法上是否有注解RequestMapping                        if (method.getAnnotation(RequestMapping.class) != null) {                                //获取到类的RequestMappingInfo                                 RequestMappingInfo mappingInfo = (RequestMappingInfo) getMappingForMethod.invoke(requestMappingHandlerMapping, method,controllerClass);                                if(type == 1){                                        //注册                                        registerMapping(requestMappingHandlerMapping, mappingInfo, controllerClass, method);                                }else if(type == 2){                                        //取消注册                                        unRegisterMapping(requestMappingHandlerMapping, mappingInfo);                                        registerMapping(requestMappingHandlerMapping, mappingInfo, controllerClass, method);                                }else if(type == 3){                                        unRegisterMapping(requestMappingHandlerMapping, mappingInfo);                                }                                                        }                }        }                /**         *         * registerMapping(注册mapping到spring容器中)            * @param   requestMappingHandlerMapping            * @Exception 异常对象            * @since  CodingExample　Ver(编码范例查看) 1.1        * @author jiaxiaoxian         */        public static void registerMapping(RequestMappingHandlerMapping requestMappingHandlerMapping,RequestMappingInfo mappingInfo, Class controllerClass, Method method) throws Exception, IllegalAccessException{                requestMappingHandlerMapping.registerMapping(mappingInfo, controllerClass.newInstance(),method);        }                /**         *         * unRegisterMapping(spring容器中删除mapping)            * @param   requestMappingHandlerMapping            * @Exception 异常对象            * @since  CodingExample　Ver(编码范例查看) 1.1        * @author jiaxiaoxian         */        public static void unRegisterMapping(RequestMappingHandlerMapping requestMappingHandlerMapping,RequestMappingInfo mappingInfo) throws Exception, IllegalAccessException{                requestMappingHandlerMapping.unregisterMapping(mappingInfo);        }

结果：

可以正常发布spring接口，动态生成文件注入mapping到spring接口中。

SOAP风格

方案：

1.提供java文件模板

2.读取文件内容

3.查库修改生成java文件

4.通过JDK中的javax.tools.JavaCompiler动态编译成class

5.通过继承java.net.URLClassLoader动态加载class文件到内存

6.通过javax.xml.ws.Endpoint的publish动态发布接口

过程：

1.模板文件根据业务自行配置(涉及公司机密，忽略)

2.读取文件内容，生成java文件，编译class，加载class，通过Endpoint发布接口

        @Override        public Boolean createGenerate(String serviceName, Long interfaceId, String structrue) {                try {                        serviceName = StringUtils.firstCharUpper(serviceName);                        Path directoryPath = Paths.get(outDirectory);                        // 如果文件不存在                        if (!Files.exists(directoryPath)) {                                Files.createDirectories(directoryPath);                        }                        String controllerJava = serviceName + "Controller.java";                        String autoJavaFile = outDirectory + controllerJava;                        Path filePath = Paths.get(autoJavaFile);                        if (!Files.exists(filePath)) {                                Files.createFile(filePath);                        } else {                                logger.error("动态创建接口错误ws,文件已存在:" + autoJavaFile);                                return false;                        }                        String wsJavaFile = directory + "JwsTemplateController.java";                        String content = FileUtils.readFile(wsJavaFile);                        content = replaceJava(content, serviceName, interfaceId, structrue);                        Files.write(filePath, content.getBytes(charsetName));                        String fullName = packageName + serviceName + "Controller";                        JavaStringCompiler compiler = new JavaStringCompiler();                        Map results = compiler.compile(controllerJava, content);                        Class clzMul = compiler.loadClass(fullName, results);                        publish(clzMul, serviceName);                } catch (Exception e) {                        logger.error("动态创建接口错误ws", e);                        return false;                }                return true;        }        //动态发布接口        private void publish(Class clzMul, String serviceName) throws Exception {                serviceName = firstCharLower(serviceName);                Endpoint endpoint = Endpoint.create(clzMul.newInstance());                endpoint.publish(wsDomain + serviceName);                //redisUtil.set(serviceName, endpoint);                endpointMap.put(serviceName, endpoint);        }

结果：

可以正常发布SOAP接口，动态生成文件发布SOAP接口。

后面附件会上传动态生成需要的工具类,需要的小伙伴可以下载,记得好评！

author:贾小仙

time:2018/9/5