• 刚来公司就接了一个不发版直接改代码的需求

    前言

    前几天突然接到一个技术需求，想要做一个功能。前端有一个表单，在页面上可以直接写 java 代码，写完后就能保存到数据库，并且这个代码实时生效。这岂非是不用发版就可以随时改代码了吗？而且有bug也不怕，随时改。

    适用场景：代码逻辑需要经常变动的业务。

    核心思想

    • 页面改动 java 代码字符串
    • java 代码字符串编译成 class
    • 动态加载到 jvm

    实现重点

    JDK 提供了一个工具包 javax.tools 让使用者可以用简易的 API 进行编译。

    这些工具包的使用步骤：

    1. 获取一个 javax.tools.JavaCompiler 实例。
    2. 基于 Java 文件对象初始化一个编译任务 CompilationTask 实例。
    3. 因为JVM 里面的 Class 是基于 ClassLoader 隔离的，所以编译成功之后可以通过自定义的类加载器加载对应的类实例
    4. 使用反射 API 进行实例化和后续的调用。

    1. 代码编译

    这一步需要将 java 文件编译成 class，其实平常的开发过程中，我们的代码编译都是由 IDEA、Maven 等工具完成。

    内置的 SimpleJavaFileObject 是面向源码文件的，而我们的是源码字符串，所以需要实现 JavaFileObject 接口自定义一个 JavaFileObject。

    1. public class CharSequenceJavaFileObject extends SimpleJavaFileObject {
    2.  
    3.     public static final String CLASS_EXTENSION = ".class";
    4.  
    5.     public static final String JAVA_EXTENSION = ".java";
    6.  
    7.     private static URI fromClassName(String className) {
    8.         try {
    9.             return new URI(className);
    10.         } catch (URISyntaxException e) {
    11.             throw new IllegalArgumentException(className, e);
    12.         }
    13.     }
    14.  
    15.     private ByteArrayOutputStream byteCode;
    16.     private final CharSequence sourceCode;
    17.  
    18.     public CharSequenceJavaFileObject(String className, CharSequence sourceCode) {
    19.         super(fromClassName(className + JAVA_EXTENSION), Kind.SOURCE);
    20.         this.sourceCode = sourceCode;
    21.     }
    22.  
    23.     public CharSequenceJavaFileObject(String fullClassName, Kind kind) {
    24.         super(fromClassName(fullClassName), kind);
    25.         this.sourceCode = null;
    26.     }
    27.  
    28.     public CharSequenceJavaFileObject(URI uri, Kind kind) {
    29.         super(uri, kind);
    30.         this.sourceCode = null;
    31.     }
    32.  
    33.     @Override
    34.     public CharSequence getCharContent(boolean ignoreEncodingErrors) throws IOException {
    35.         return sourceCode;
    36.     }
    37.  
    38.     @Override
    39.     public InputStream openInputStream() {
    40.         return new ByteArrayInputStream(getByteCode());
    41.     }
    42.  
    43.     // 注意这个方法是编译结果回调的OutputStream，回调成功后就能通过下面的getByteCode()方法获取目标类编译后的字节码字节数组
    44.     @Override
    45.     public OutputStream openOutputStream() {
    46.         return byteCode = new ByteArrayOutputStream();
    47.     }
    48.  
    49.     public byte[] getByteCode() {
    50.         return byteCode.toByteArray();
    51.     }
    52. }
    53. 复制代码

    如果编译成功之后，直接通过 CharSequenceJavaFileObject#getByteCode()方法即可获取目标类编译后的字节码对应的字节数组（二进制内容）

    2. 实现 ClassLoader

    因为JVM 里面的 Class 是基于 ClassLoader 隔离的，所以编译成功之后得通过自定义的类加载器加载对应的类实例，否则是加载不了的，因为同一个类只会加载一次。

    主要关注 findClass 方法

    1. public class JdkDynamicCompileClassLoader extends ClassLoader {
    2.  
    3.     public static final String CLASS_EXTENSION = ".class";
    4.  
    5.     private final static Map<String, JavaFileObject> javaFileObjectMap = new ConcurrentHashMap<>();
    6.  
    7.     public JdkDynamicCompileClassLoader(ClassLoader parentClassLoader) {
    8.         super(parentClassLoader);
    9.     }
    10.  
    11.  
    12.     @Override
    13.     protected Class<?> findClass(String name) throws ClassNotFoundException {
    14.         JavaFileObject javaFileObject = javaFileObjectMap.get(name);
    15.         if (null != javaFileObject) {
    16.             CharSequenceJavaFileObject charSequenceJavaFileObject = (CharSequenceJavaFileObject) javaFileObject;
    17.             byte[] byteCode = charSequenceJavaFileObject.getByteCode();
    18.             return defineClass(name, byteCode, 0, byteCode.length);
    19.         }
    20.         return super.findClass(name);
    21.     }
    22.  
    23.     @Override
    24.     public InputStream getResourceAsStream(String name) {
    25.         if (name.endsWith(CLASS_EXTENSION)) {
    26.             String qualifiedClassName = name.substring(0, name.length() - CLASS_EXTENSION.length()).replace('/', '.');
    27.             CharSequenceJavaFileObject javaFileObject = (CharSequenceJavaFileObject) javaFileObjectMap.get(qualifiedClassName);
    28.             if (null != javaFileObject && null != javaFileObject.getByteCode()) {
    29.                 return new ByteArrayInputStream(javaFileObject.getByteCode());
    30.             }
    31.         }
    32.         return super.getResourceAsStream(name);
    33.     }
    34.  
    35.     /**
    36.      * 暂时存放编译的源文件对象,key为全类名的别名（非URI模式）,如club.throwable.compile.HelloService
    37.      */
    38.     void addJavaFileObject(String qualifiedClassName, JavaFileObject javaFileObject) {
    39.         javaFileObjectMap.put(qualifiedClassName, javaFileObject);
    40.     }
    41.  
    42.     Collection<JavaFileObject> listJavaFileObject() {
    43.         return Collections.unmodifiableCollection(javaFileObjectMap.values());
    44.     }
    45. }
    46. 复制代码

    3. 封装了上面的 ClassLoader 和 JavaFileObject

    1. public class JdkDynamicCompileJavaFileManager extends ForwardingJavaFileManager<JavaFileManager> {
    2.  
    3.     private final JdkDynamicCompileClassLoader classLoader;
    4.     private final Map<URI, JavaFileObject> javaFileObjectMap = new ConcurrentHashMap<>();
    5.  
    6.     public JdkDynamicCompileJavaFileManager(JavaFileManager fileManager, JdkDynamicCompileClassLoader classLoader) {
    7.         super(fileManager);
    8.         this.classLoader = classLoader;
    9.     }
    10.  
    11.     private static URI fromLocation(Location location, String packageName, String relativeName) {
    12.         try {
    13.             return new URI(location.getName() + '/' + packageName + '/' + relativeName);
    14.         } catch (URISyntaxException e) {
    15.             throw new IllegalArgumentException(e);
    16.         }
    17.     }
    18.  
    19.     @Override
    20.     public FileObject getFileForInput(Location location, String packageName, String relativeName) throws IOException {
    21.         JavaFileObject javaFileObject = javaFileObjectMap.get(fromLocation(location, packageName, relativeName));
    22.         if (null != javaFileObject) {
    23.             return javaFileObject;
    24.         }
    25.         return super.getFileForInput(location, packageName, relativeName);
    26.     }
    27.  
    28.     /**
    29.      * 这里是编译器返回的同(源)Java文件对象,替换为CharSequenceJavaFileObject实现
    30.      */
    31.     @Override
    32.     public JavaFileObject getJavaFileForOutput(Location location, String className, JavaFileObject.Kind kind, FileObject sibling) throws IOException {
    33.         JavaFileObject javaFileObject = new CharSequenceJavaFileObject(className, kind);
    34.         classLoader.addJavaFileObject(className, javaFileObject);
    35.         return javaFileObject;
    36.     }
    37.  
    38.     /**
    39.      * 这里覆盖原来的类加载器
    40.      */
    41.     @Override
    42.     public ClassLoader getClassLoader(Location location) {
    43.         return classLoader;
    44.     }
    45.  
    46.     @Override
    47.     public String inferBinaryName(Location location, JavaFileObject file) {
    48.         if (file instanceof CharSequenceJavaFileObject) {
    49.             return file.getName();
    50.         }
    51.         return super.inferBinaryName(location, file);
    52.     }
    53.  
    54.     @Override
    55.     public Iterable<JavaFileObject> list(Location location, String packageName, Set<JavaFileObject.Kind> kinds, boolean recurse) throws IOException {
    56.         Iterable<JavaFileObject> superResult = super.list(location, packageName, kinds, recurse);
    57.         List<JavaFileObject> result = new ArrayList<>();
    58.         // 这里要区分编译的Location以及编译的Kind
    59.         if (location == StandardLocation.CLASS_PATH && kinds.contains(JavaFileObject.Kind.CLASS)) {
    60.             // .class文件以及classPath下
    61.             for (JavaFileObject file : javaFileObjectMap.values()) {
    62.                 if (file.getKind() == JavaFileObject.Kind.CLASS && file.getName().startsWith(packageName)) {
    63.                     result.add(file);
    64.                 }
    65.             }
    66.             // 这里需要额外添加类加载器加载的所有Java文件对象
    67.             result.addAll(classLoader.listJavaFileObject());
    68.         } else if (location == StandardLocation.SOURCE_PATH && kinds.contains(JavaFileObject.Kind.SOURCE)) {
    69.             // .java文件以及编译路径下
    70.             for (JavaFileObject file : javaFileObjectMap.values()) {
    71.                 if (file.getKind() == JavaFileObject.Kind.SOURCE && file.getName().startsWith(packageName)) {
    72.                     result.add(file);
    73.                 }
    74.             }
    75.         }
    76.         for (JavaFileObject javaFileObject : superResult) {
    77.             result.add(javaFileObject);
    78.         }
    79.         return result;
    80.     }
    81.  
    82.     /**
    83.      * 自定义方法,用于添加和缓存待编译的源文件对象
    84.      */
    85.     public void addJavaFileObject(Location location, String packageName, String relativeName, JavaFileObject javaFileObject) {
    86.         javaFileObjectMap.put(fromLocation(location, packageName, relativeName), javaFileObject);
    87.     }
    88. }
    89. 复制代码

    4. 使用 JavaCompiler 编译并反射生成实例对象

    1. public final class JdkCompiler {
    2.  
    3.     static DiagnosticCollector<JavaFileObject> DIAGNOSTIC_COLLECTOR = new DiagnosticCollector<>();
    4.  
    5.     @SuppressWarnings("unchecked")
    6.     public static <T> T compile(String packageName,
    7.                                 String className,
    8.                                 String sourceCode) throws Exception {
    9.         // 获取系统编译器实例
    10.         JavaCompiler compiler = ToolProvider.getSystemJavaCompiler();
    11.         // 设置编译参数
    12.         List<String> options = new ArrayList<>();
    13.         options.add("-source");
    14.         options.add("1.8");
    15.         options.add("-target");
    16.         options.add("1.8");
    17.         // 获取标准的Java文件管理器实例
    18.         StandardJavaFileManager manager = compiler.getStandardFileManager(DIAGNOSTIC_COLLECTOR, null, null);
    19.         // 初始化自定义类加载器
    20.         JdkDynamicCompileClassLoader classLoader = new JdkDynamicCompileClassLoader(Thread.currentThread().getContextClassLoader());
    21.  
    22.         // 初始化自定义Java文件管理器实例
    23.         JdkDynamicCompileJavaFileManager fileManager = new JdkDynamicCompileJavaFileManager(manager, classLoader);
    24.         String qualifiedName = packageName + "." + className;
    25.         // 构建Java源文件实例
    26.         CharSequenceJavaFileObject javaFileObject = new CharSequenceJavaFileObject(className, sourceCode);
    27.         // 添加Java源文件实例到自定义Java文件管理器实例中
    28.         fileManager.addJavaFileObject(
    29.                 StandardLocation.SOURCE_PATH,
    30.                 packageName,
    31.                 className + CharSequenceJavaFileObject.JAVA_EXTENSION,
    32.                 javaFileObject
    33.         );
    34.         // 初始化一个编译任务实例
    35.         JavaCompiler.CompilationTask compilationTask = compiler.getTask(
    36.                 null,
    37.                 fileManager,
    38.                 DIAGNOSTIC_COLLECTOR,
    39.                 options,
    40.                 null,
    41.                 Collections.singletonList(javaFileObject)
    42.         );
    43.         Boolean result = compilationTask.call();
    44.         System.out.println(String.format("编译[%s]结果:%s", qualifiedName, result));
    45.         Class<?> klass = classLoader.loadClass(qualifiedName);
    46.         return (T) klass.getDeclaredConstructor().newInstance();
    47.     }
    48. }
    49. 复制代码

    完成上面工具的搭建之后。我们可以接入数据库的操作了。数据库层面省略，只展示 service 层

    service 层：

    1. public class JavaService {
    2.  
    3.     public Object saveAndGetObject(String packageName,String className,String javaContent) throws Exception {
    4.         Object object = JdkCompiler.compile(packageName, className, javaContent);
    5.         return object;
    6.     }
    7.  
    8. }
    9. 复制代码

    测试：

    1. public class TestService {
    2.  
    3.     public static void main(String[] args) throws Exception {
    4.         test();
    5.     }
    6.  
    7.     static String content="package cn.mmc;\n" +
    8.             "\n" +
    9.             "public class SayHello {\n" +
    10.             "    \n" +
    11.             "    public void say(){\n" +
    12.             "        System.out.println(\"11111111111\");\n" +
    13.             "    }\n" +
    14.             "}";
    15.  
    16.     static String content2="package cn.mmc;\n" +
    17.             "\n" +
    18.             "public class SayHello {\n" +
    19.             "    \n" +
    20.             "    public void say(){\n" +
    21.             "        System.out.println(\"22222222222222\");\n" +
    22.             "    }\n" +
    23.             "}";
    24.  
    25.     public static void test() throws Exception {
    26.         JavaService javaService = new JavaService();
    27.         Object sayHello = javaService.saveAndGetObject("cn.mmc", "SayHello", content);
    28.         sayHello.getClass().getMethod("say").invoke(sayHello);
    29.  
    30.         Object sayHello2 = javaService.saveAndGetObject("cn.mmc", "SayHello", content2);
    31.         sayHello2.getClass().getMethod("say").invoke(sayHello2);
    32.     }
    33. }
    34. 复制代码

    我们在启动应用时，更换了代码文件内存，然后直接反射调用对象的方法。执行结果：

    可以看到，新的代码已经生效！！！

    注意，直接开放修改代码虽然方便，但是一定要做好安全防护

  • 相关阅读:
    SpringBoot 拦截器
    十大排序详解
    【语义分割】语义分割概念及算法介绍
    光谱数据处理：1.特征波长优选的不同方法与Python实现
    SpringBoot中公共字段的自动填充
    InputMan12.0J、VB.net、imTime
    总结Rabbitmq的六种模式
    创新案例分享 | 建设高校科研管理信息系统，助力提升信息化实际效能
    Word控件Spire.Doc 【文本】教程(18) ；如何在C#中获取word文档中的文本
    如何在 Vue.js 中使用 Axios
  • 原文地址：https://blog.csdn.net/m0_73311735/article/details/126522602