解决生产问题的万能接口（Java编译器API的使用）

文章目录

  • 前言
  • Tool和ToolProvider
  • 编译器工具：JavaCompiler
  • 文件管理
    • 文件：FileObject
    • 文件管理器：JavaFileManager
  • 诊断监听器：Diagnostic
  • Demo：allPowerfulInterface
    • 具体实现
    • 测试
  • 结语

前言

当生产环境出现问题时，经常需要走一个很繁琐的上线流程进行部署，然后再解决问题，于是我想写一个万能接口来避免这个流程，这个接口的思想是：

  • 将写好逻辑的Java源程序上传到指定的线上HTTP接口
  • 线上编译并运行上传的源代码

这实际上就是Java编译器API的使用，本文就带着大家来学习和实现一下，本文实现的Demo具有以下特点：

  • 实现了MyBatis万能查询接口
  • 实现了与Spring框架的完美融合，丝滑在上传源代码中使用IOC中的Bean

Tool和ToolProvider

Tool是所有可以从程序中调用的工具的公共接口，这些工具通常是命令行程序，例如编译器等。该接口的run方法使用给定的I/O通道和参数运行该工具。返回0表示成功，返回非0表示错误。生成的任何诊断信息将以某种未指定的格式写入输出流或错误流。

/**
*in:如果为空则使用标准输入
*out:如果为空则使用标准输出
*err:如果为空则使用标准错误
*arguments:该工具运行时需要的参数
*/
int	run(InputStream in, OutputStream out, OutputStream err, String... arguments)

ToolProvider是一个工具提供类，用于提供一些实现了Tool接口的工具：

static DocumentationTool getSystemDocumentationTool()
static JavaCompiler	getSystemJavaCompiler()

编译器工具：JavaCompiler

JavaCompiler是用于从代码中调用 Java 编译器的工具。该工具依赖于以下两个服务：

  • 文件管理器：编译器工具有一个相关联的标准文件管理器，可以通过调用 getStandardFileManager 方法获取，文件管理器有以下两方面的作用：
    • 解决自定义编译任务如何的读取和写入文件的问题
    • 可以在多个自定义编译任务之间共享，以此减少扫描和读取文件的开销
  • 诊断监听器：在编译过程中，编译器可能会生成诊断信息（例如错误消息）。如果提供了诊断监听器，这些诊断信息将会提供给监听器。如果未提供监听器，则诊断信息将以未指定的格式进行格式化，并写入默认输出流。即使提供了诊断监听器，某些诊断信息可能也不适合放在一个诊断对象中，而会被写入默认输出。

该接口提供以下方法：

/**
*diagnosticListener：用于非致命诊断的诊断侦听器，如果为空，则使用编译器的默认方法来报告诊断
*locale：格式化诊断时要应用的语言环境；Null表示默认区域设置。
*charset：用于解码字节的字符集，如果为空，则使用平台默认值。
*/
StandardJavaFileManager getStandardFileManager(DiagnosticListener<? super JavaFileObject> diagnosticListener, Locale locale, Charset charset);

/**
*out：一个Writer用于编译器的额外输出，如果为零则默认为标准错误流
*fileManager：文件管理器，如果为空则默认使用编译器的标准管理器
*diagnosticListener：诊断侦听器；如果为空，则使用编译器的默认方法来报告诊断
*options：编译器选项
*classes：注解处理要处理的类名，空表示没有类名
*compilationUnits：要编译的编译单元，null表示没有编译单元
*/
JavaCompiler.CompilationTask getTask(Writer out, JavaFileManager fileManager, DiagnosticListener<? super JavaFileObject> diagnosticListener, Iterable<String> options, Iterable<String> classes, Iterable<? extends JavaFileObject> compilationUnits)

其中getTask方法可以建立一个CompilationTask 编译任务，该任务接口继承了Callabel接口，并提供了以下方法设置一个注解处理器：

void setProcessors(Iterable<? extends Processor> processors)

文件管理

文件：FileObject
«interface»
FileObject
«interface»
JavaFileObject
«class»
ForwardingFileObject
«class»
ForwardingJavaFileObject
«class»
SimpleJavaFileObject

FileObject用于表示Java编程语言中的文件，这些文件包括：

  • JavaFileObject.Kind.CLASS：字节码文件
  • JavaFileObject.Kind.SOURCE：源文件
  • JavaFileObject.Kind.HTML：HTML
  • JavaFileObject.Kind.OTHER：除此之外的其他文件

它有两个子实现，其中：

  • ForwardingFileObject<F extends FileObject>：是一个FileObject的包装类，可以将调用转发给指定的文件对象。
  • JavaFileObject：Java源文件和Java字节码文件的抽象。

文件管理器：JavaFileManager
«interface»
JavaFileManager
«class»
ForwardingJavaFileManager
«interface»
StandardJavaFileManager

JavaFileManager是用于操作 Java 编程语言中文件的文件管理器。在构建新的 JavaFileObjects 时，文件管理器必须确定创建它们的位置。例如，如果文件管理器管理文件系统上的常规文件，它很可能会有一个当前/工作目录作为创建或查找文件的默认位置。可以向文件管理器提供一些提示，以确定创建文件的位置，但任何文件管理器都可能选择忽略这些提示。它有以下两个实现类：

  • ForwardingJavaFileManager<M extends JavaFileManager>：文件管理器的包装类，可以将调用转发给指定的文件管理器。
  • StandardJavaFileManager：基于 java.io.File 和 java.nio.file.Path 的文件管理器。

诊断监听器：Diagnostic

和诊断监听器有关的类如下，它们简单易懂，在此不再赘述。
«interface»
Diagnostic
«interface»
DiagnosticListener
«final class»
DiagnosticCollector

Demo：allPowerfulInterface

通过以下四个类就可以实现该功能了，具体代码放到下边了。

在这里插入图片描述

具体实现

  • AllPowerfulController.java：请求入口
@Slf4j
@RestController
@RequestMapping("/manual/allPowerful")
@RequiredArgsConstructor
public class AllPowerfulController {

    private final CompileLoadAndRun compileLoadAndRun;

    @PostMapping("/go")
    public CommonRespDTO test(@RequestParam("sourceFile") MultipartFile sourceFile) throws IOException {
        return compileLoadAndRun.go(sourceFile.getBytes());
    }

}
  • CompileLoadAndRun.java：负责编译、加载并运行上传的源文件
@Slf4j
@Component
@RequiredArgsConstructor
public class CompileLoadAndRun {

    private final ApplicationContext applicationContext;
    private static final String CLASS_PATH = "./target/classes/generated";
    //换成你自己的
    private static final String CLASS_NAME = "xxx.allPowerfulInterface.handler.AllPowerFulHandler";

    public CommonRespDTO go(byte[] sourceCode) {
        //获取编译器和文件管理器
        JavaCompiler javaCompiler = ToolProvider.getSystemJavaCompiler();
        StandardJavaFileManager fileManager = javaCompiler.getStandardFileManager(null, null, StandardCharsets.UTF_8);
        //创建编译任务，将编译后的类放到类路径下
        JavaCompiler.CompilationTask task = javaCompiler.getTask(
                null,
                fileManager,
                null,
                List.of("-d", CLASS_PATH),
                null,
                List.of(new MemoryJavaFileObject(CLASS_NAME, sourceCode)));
        Boolean success = task.call();
        //编译成功后执行
        if (success) {
            try {
                //加载类
                File classPath = new File(CLASS_PATH);
                URLClassLoader classLoader = URLClassLoader.newInstance(new URL[]{classPath.toURI().toURL()});
                Class<?> clazz = Class.forName(CLASS_NAME, true, classLoader);
                //构建对象，通过构造函数构造，构造函数参数要从Spring容器中获取
                ArrayList<Class<?>> constructorParamClass = new ArrayList<>();
                ArrayList<Object> constructorParamObj = new ArrayList<>();
                for (Field field : clazz.getDeclaredFields()) {
                    constructorParamClass.add(field.getType());
                    constructorParamObj.add(applicationContext.getBean(field.getType()));
                }
                //获取构造函数并构造对象
                Constructor<?> constructor = clazz.getConstructor(constructorParamClass.toArray(new Class[]{}));
                Object target = constructor.newInstance(constructorParamObj.toArray(new Object[]{}));
                //获取并执行方法
                Method method = clazz.getDeclaredMethod("handle");
                method.invoke(target);
            } catch (MalformedURLException | ClassNotFoundException | InvocationTargetException |
                     NoSuchMethodException | IllegalAccessException | InstantiationException e) {
                log.error("执行失败", e);
                return CommonRespDTO.error(1, "执行失败");
            }
            return CommonRespDTO.success("执行成功");
        } else {
            return CommonRespDTO.error(1, "编译失败");
        }
    }

    private static class MemoryJavaFileObject extends SimpleJavaFileObject {

        private final CharSequence sourceCode;

        public MemoryJavaFileObject(String className, byte[] sourceCode) {
            super(URI.create("string:///" + className.replace('.', '/') + Kind.SOURCE.extension), Kind.SOURCE);
            this.sourceCode = new String(sourceCode, StandardCharsets.UTF_8);
        }

        @Override
        public CharSequence getCharContent(boolean ignoreEncodingErrors) {
            return sourceCode;
        }

    }

}
  • IHandler.java：用来约束上传源文件的行为，上传的源文件必须实现该接口
public interface IHandler {

    void handle();
}
  • AllPowerFulManager.java：封装Mapper并实现查询结果的转换
@Slf4j
@Service
@RequiredArgsConstructor
public class AllPowerFulManager {

    private final AllPowerFulMapper allPowerFulMapper;

    public void insert(String table, String fields, String values) {
        allPowerFulMapper.insert(table, fields, values);
    }

    public void delete(String table, String condition) {
        allPowerFulMapper.delete(table, condition);
    }

    public void update(String table, String fieldValues, String condition) {
        allPowerFulMapper.update(table, fieldValues, condition);
    }

    public <T> List<T> select(String table, String fields, String condition, Class<T> clazz) {
        ArrayList<T> result = new ArrayList<>();
        List<Map<String, Object>> unMappedList = allPowerFulMapper.select(table, fields, condition);
        for (Map<String, Object> unMappedMap : unMappedList) {
            try {
                T target = clazz.getConstructor().newInstance();
                for (String key : unMappedMap.keySet()) {
                    String fieldName = this.toCamelCase(key);
                    try {
                        Field field = clazz.getDeclaredField(fieldName);
                        field.setAccessible(true);
                        if (field.getType() == Byte.class) {
                            field.set(target, Byte.valueOf(unMappedMap.get(key).toString()));
                        } else if (field.getType() == byte.class) {
                            field.set(target, Byte.parseByte(unMappedMap.get(key).toString()));
                        } else if (field.getType() == Integer.class) {
                            field.set(target, Integer.valueOf(unMappedMap.get(key).toString()));
                        } else if (field.getType() == int.class) {
                            field.set(target, Integer.parseInt(unMappedMap.get(key).toString()));
                        } else if (field.getType() == Long.class) {
                            field.set(target, Long.valueOf(unMappedMap.get(key).toString()));
                        } else if (field.getType() == long.class) {
                            field.set(target, Long.parseLong(unMappedMap.get(key).toString()));
                        } else if (field.getType() == Float.class) {
                            field.set(target, Float.valueOf(unMappedMap.get(key).toString()));
                        } else if (field.getType() == float.class) {
                            field.set(target, Float.parseFloat(unMappedMap.get(key).toString()));
                        } else if (field.getType() == Double.class) {
                            field.set(target, Double.valueOf(unMappedMap.get(key).toString()));
                        } else if (field.getType() == double.class) {
                            field.set(target, Double.parseDouble(unMappedMap.get(key).toString()));
                        } else {
                            field.set(target, unMappedMap.get(key));
                        }
                    } catch (NoSuchFieldException e) {
                        log.error("字段不存在", e);
                    }
                }
                result.add(target);
            } catch (InstantiationException | IllegalAccessException | InvocationTargetException |
                     NoSuchMethodException e) {
                log.error("实例化失败", e);
            }
        }
        return result;
    }

    private String toCamelCase(String str) {
        if (str == null || str.isEmpty()) {
            return str;
        }
        StringBuilder result = new StringBuilder();
        boolean upperCase = false;
        for (int i = 0; i < str.length(); i++) {
            char c = str.charAt(i);
            if (c == '_') {
                upperCase = true;
            } else {
                if (upperCase) {
                    result.append(Character.toUpperCase(c));
                    upperCase = false;
                } else {
                    result.append(Character.toLowerCase(c));
                }
            }
        }
        return result.toString();
    }
}
  • AllPowerFulMapper.java：MyBatis万能接口：
@Mapper
public interface AllPowerFulMapper {

    @Insert("INSERT INTO ${table}(${fields}) VALUES(${values})")
    void insert(@Param("table") String table, @Param("fields") String fields, @Param("values") String values);

    @Delete("DELETE FROM ${table} WHERE ${condition}")
    void delete(@Param("table") String table, @Param("condition") String condition);

    @Update("UPDATE ${table} SET ${fieldValues} WHERE ${condition}")
    void update(@Param("table") String table, @Param("fieldValues") String fieldValues, @Param("condition") String condition);

    @Select("SELECT ${fields} FROM ${table} WHERE ${condition}")
    List<Map<String, Object>> select(@Param("table") String table, @Param("fields") String fields, @Param("condition") String condition);

}

测试

我们实现一个类：

@Component
@RequiredArgsConstructor
public class AllPowerFulHandler implements IHandler {

    private final AllPowerFulManager allPowerFulManager;

    public void handle() {
        List<SkuEntity> skuList = allPowerFulManager.select("t_sku", "*", "1=1 limit 10", SkuEntity.class);
        System.out.println(JSON.toJSONString(skuList));
    }

}

在这里插入图片描述
然后使用IDEA的.http文件（manual.http）测试一下：

### 万能接口
POST http://localhost:8089/manual/allPowerful/go
Content-Type: multipart/form-data; boundary=WebAppBoundary

--WebAppBoundary
Content-Disposition: form-data; name="sourceFile";filename="AllPowerFulHandler.java";
Content-Type: application/json

< ./AllPowerFulHandler.java
--WebAppBoundary--

结果非常的完美。

结语

注意，该工具具有严重的安全隐患，请谨慎使用。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：/a/700584.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

安全智能预警软件有人试图窃取会立即发出高分贝警报已解锁VIP功能

安全智能预警软件有人试图窃取会立即发出高分贝警报已解锁VIP功能

一款手机安全智能预警软件&#xff0c;无论是网吧还是餐馆小聚&#xff0c;您的手机都能得到贴心的守护&#xff0c;一旦有人试图窃取&#xff0c;应用会立即发出高分贝警报&#xff0c;确保您在公交、地铁、商场等拥挤环境中依然能牢牢掌控手机。&#xff08;解锁专业版&#…
阅读更多...
Qt——窗口

Qt——窗口

目录 概述 菜单栏 创建菜单栏 创建子菜单 添加分割线 添加图标 工具栏 创建工具栏 设置初始位置和停靠位置 设置浮动属性 设置移动属性 状态栏 创建状态栏 显示实时消息 添加控件 浮动窗口 创建浮动窗口 对话框 创建对话框 对话框的分类 Qt 内置对话框 …
阅读更多...
FreeRTOS学习笔记-基于stm32（14）内存管理

FreeRTOS学习笔记-基于stm32（14）内存管理

一、FreeRTOS 内存管理简介 FreeRTOS有两种方法来创建任务&#xff0c;队列&#xff0c;信号量等&#xff0c;一种动态一种静态。静态方法需要手动定义任务堆栈。使用动态内存管理的时候 FreeRTOS 内核在创建任务、队列、信号量的时候会动态的申请 RAM。 我们在移植FreeRTOS时可…
阅读更多...
由于人工智能，他们的语言更容易理解

由于人工智能，他们的语言更容易理解

密歇根大学、墨西哥国家天体物理研究所和光学与电子研究所的研究人员正在使用人工智能模型来破译狗的语言。 在国际会议上提出的新研究展示了先进的人工智能 模型如何帮助人类了解动物。 密歇根大学人工智能实验室主任 Rada Mihalcea 强调了这项研究的重要性&#xff1a;对于…
阅读更多...
Javaweb03-Servlet技术1(Servlet,ServletConfig,ServletContext)

Javaweb03-Servlet技术1(Servlet,ServletConfig,ServletContext)

Servlet技术(Servlet,ServletConfig,ServletContext) 1.Servlet的概述 Servlet是运行在Web服务器端的Java应用程序&#xff0c;它使用Java语言编写。与Java程序的区别是&#xff0c;Servlet 对象主要封装了对HTTP请求的处理&#xff0c;并且它的运行需要Servlet容器(Tomcat)的…
阅读更多...
【五】Linux软件仓库Yum源--SSH远程控制--SCP远程传输

【五】Linux软件仓库Yum源--SSH远程控制--SCP远程传输

RPM&#xff08;红帽软件包管理器&#xff09; RPM建立统一的数据库文件&#xff0c;记录软件信息并分析依赖关系。目前RPM的优势已经被公众所认可&#xff0c;使用范围也已不局限在红帽系统中了。常见RPM命令如下&#xff1a; 安装软件 rpm -ivh file…
阅读更多...
BitSet位图进行去重海量数据

BitSet位图进行去重海量数据

问题 怎么在40亿个整数中找到唯一重复的数字? 1.Set的不可重复性 if(set.contains(x))System.out.println("重复的数字是"x);else{set.add(x);}但是&#xff0c;contains()方法消耗的时间&#xff0c;消耗的空间很大&#xff0c;毕竟有约40亿的数据&#xff0c;所…
阅读更多...
Vue--》打造细腻颗粒感 —— 细分组件颗粒图

Vue--》打造细腻颗粒感 —— 细分组件颗粒图

写文背景&#xff1a;当涉及到前端开发时&#xff0c;我们经常会发现自己在不同的组件中复用相似的逻辑&#xff0c;在过去我们可能会通过混入、高阶组件或者全局组件等方式来实现代码的复用&#xff1b;或者一个组件逻辑太多&#xff0c;写出了超多的响应式ref数据和五花八门的…
阅读更多...
[大模型]LLaMA3-8B-Instruct langchain 接入

[大模型]LLaMA3-8B-Instruct langchain 接入

环境准备 在 Autodl 平台中租赁一个 3090 等 24G 显存的显卡机器&#xff0c;如下图所示镜像选择 PyTorch-->2.1.0-->3.10(ubuntu22.04)-->12.1 接下来打开刚刚租用服务器的 JupyterLab&#xff0c;并且打开其中的终端开始环境配置、模型下载和运行演示。 pip 换…
阅读更多...
华为鲲鹏应用开发基础：鲲鹏处理器及关键硬件特性介绍（二）

华为鲲鹏应用开发基础：鲲鹏处理器及关键硬件特性介绍（二）

1. 鲲鹏简介 1.1 鲲鹏处理器简介 鲲鹏处理器是华为自研的基于ARMv8指令集开发的数据中心级处理器 1.2 基于鲲鹏主板的多样化计算产品 1.3 基于鲲鹏920的华为TaiShan（泰山） 200服务器 1.3.1 TaiShan 2280服务器内部视图 1.3.2 TaiShan 2280服务器物理结构 1.3.3 TaiShan 2280服…
阅读更多...
【Java】解决Java报错：IOException during File Operations

【Java】解决Java报错：IOException during File Operations

文章目录 引言一、IOException的定义与概述1. 什么是IOException&#xff1f;2. IOException的常见触发场景3. 示例代码 二、解决方案1. 检查文件是否存在2. 使用try-with-resources语句3. 捕获和处理IOException4. 使用NIO进行文件操作 三、最佳实践1. 检查文件状态2. 使用try…
阅读更多...
缓冲区的奥秘：解析数据交错的魔法

缓冲区的奥秘：解析数据交错的魔法

目录 一、理解缓存区的好处 &#xff08;一&#xff09;直观性的理解 &#xff08;二&#xff09;缓存区的好处 二、经典案例分析体会 &#xff08;一&#xff09;文件读写流&#xff08;File I/O Buffering&#xff09; BufferedOutputStream 和 BufferedWriter 可以加快…
阅读更多...
四川古力未来科技抖音小店打造品质生活，可靠之选引领潮流

四川古力未来科技抖音小店打造品质生活，可靠之选引领潮流

在当今数字化快速发展的时代&#xff0c;电商平台如雨后春笋般涌现&#xff0c;抖音小店作为其中的佼佼者&#xff0c;凭借其独特的短视频电商模式&#xff0c;迅速吸引了大批年轻消费者的目光。而在众多的抖音小店中&#xff0c;四川古力未来科技抖音小店凭借其卓越的品质和专…
阅读更多...
数字时代网络安全即服务的兴起

数字时代网络安全即服务的兴起

在日益数字化的世界里&#xff0c;威胁形势不断演变&#xff0c;网络攻击变得越来越复杂和频繁。当组织努力保护敏感数据并保持运营完整性时&#xff0c;传统的网络安全措施往往不够。 这为更具动态性和可扩展性的解决方案铺平了道路&#xff1a;网络安全即服务 (CSaaS)。网络…
阅读更多...
数据结构---排序算法

数据结构---排序算法

个人介绍 hello hello~ &#xff0c;这里是 code袁~&#x1f496;&#x1f496; &#xff0c;欢迎大家点赞&#x1f973;&#x1f973;关注&#x1f4a5;&#x1f4a5;收藏&#x1f339;&#x1f339;&#x1f339; &#x1f981;作者简介&#xff1a;一名喜欢分享和记录学习的…
阅读更多...
【短剧看剧系统之投流版】短剧看剧系统功能更新，前端uniapp搭建开发

【短剧看剧系统之投流版】短剧看剧系统功能更新，前端uniapp搭建开发

目录 一、常规款短剧系统和投流版的区别&#xff1f; 二、后端体系 1.管理端&#xff1a; 2.代理投流端 三、功能区别 总结&#xff1a; 前言&#xff1a; 短剧看剧系统目前在抖音端是比较热门的&#xff0c;最重要的功能就是可以接入第三方cps&#xff0c;包含类目报白…
阅读更多...
如何将JPG/PNG位图免费快速一键转换成SVG格式的矢量图

如何将JPG/PNG位图免费快速一键转换成SVG格式的矢量图

环境&#xff1a; JPG/PNG位图 问题描述&#xff1a; 如何将JPG/PNG位图快速一键转换成SVG格式的矢量图 解决方案&#xff1a; 是一个人工智能驱动的图片转换工具&#xff0c;可以帮助用户将」JPG/PNG位图快速转换成SVG格式的矢量图&#xff0c;方便设计人员对图片进行二次…
阅读更多...
AIGC提示词---如何写提示词？

AIGC提示词---如何写提示词？

你真的了解你的AI助手吗&#xff1f; 想象一下&#xff0c;你和别人使用相同的AI工具&#xff0c;但为何他的工作效率总是高出一截&#xff1f;秘诀可能就藏在那些看似简单的提示词里。精准的提示词是解锁AI潜能的关键&#xff0c;它们能让AI更好地理解你的需求&#xff0c;从…
阅读更多...
【AI大模型】Transformers大模型库（八）：大模型微调之LoraConfig

【AI大模型】Transformers大模型库（八）：大模型微调之LoraConfig

目录 一、引言 二、LoraConfig配置参数 2.1 概述 2.2 LoraConfig参数说明 2.3 代码示例 三、总结 一、引言 这里的Transformers指的是huggingface开发的大模型库&#xff0c;为huggingface上数以万计的预训练大模型提供预测、训练等服务。 &#x1f917; Transformers …
阅读更多...
Spring中事务的隔离级别和传播机制

Spring中事务的隔离级别和传播机制

上一篇博客中讲解了关于事务的两种使用方式包括Transactional的详解。 Transactional 注解当中的三个常⻅属性: 1. rollbackFor: 异常回滚属性. 指定能够触发事务回滚的异常类型. 可以指定多个异常类型 2. Isolation: 事务的隔离级别. 默认值为 Isolation.DEFAULT 3. propagat…
阅读更多...
最新文章

Copyright @ 2022~2023