动态发布接口

动态发布接口

创新互联专注为客户提供全方位的互联网综合服务，包含不限于网站建设、成都网站制作、哈密网络推广、微信小程序开发、哈密网络营销、哈密企业策划、哈密品牌公关、搜索引擎seo、人物专访、企业宣传片、企业代运营等，从售前售中售后，我们都将竭诚为您服务，您的肯定，是我们最大的嘉奖；创新互联为所有大学生创业者提供哈密建站搭建服务，24小时服务热线：18982081108，官方网址：www.cdcxhl.com

    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 

新闻名称：动态发布接口
新闻来源：http://cdiso.cn/article/pjcdog.html