动态发布接口

发布时间:2020-08-22 00:04:17 作者:jiazhipeng12
来源:网络 阅读:3788

动态发布接口

    HTTP接口分为RESTSOAP2种方式,文中都涉及到,包含从动态生成文件到编译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<String, byte[]> 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<String, byte[]> 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 


推荐阅读:
  1. el-form-renderer 1.12.1 发布:支持设置动态 options
  2. 使用Grpc+maven定义接口、发布服务、调用服务

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

动态 生成 接口

上一篇:Centos 7 设置tomcat开机自启动

下一篇:基于tomcat的连接数与线程池详解

相关阅读

您好,登录后才能下订单哦!

密码登录
登录注册
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》