.class工具类测试

HelloWorld.java

@@ -0,0 +1 @@
+public class HelloWorld { public static void main(String[] args) { System.out.println("Hello, world!"); } }

cloud-etl-common/pom.xml

@@ -28,6 +28,12 @@
             <groupId>com.muyu</groupId>
             <artifactId>cloud-common-security</artifactId>
         </dependency>
+        <dependency>
+            <groupId>com.aliyun.oss</groupId>
+            <artifactId>aliyun-sdk-oss</artifactId>
+            <version>3.17.4</version>
+            <scope>compile</scope>
+        </dependency>
 
         <dependency>
             <groupId>com.aliyun.oss</groupId>

cloud-etl-common/src/main/java/com/muyu/utils/OssUpload.java

@@ -1,11 +1,9 @@
 package com.muyu.utils;
 
+
 import com.aliyun.oss.OSS;
-
 import com.aliyun.oss.OSSClientBuilder;
-
 import com.aliyun.oss.model.PutObjectRequest;
-
 import com.muyu.common.core.domain.Result;
 
 import java.io.ByteArrayInputStream;

cloud-etl-server/pom.xml

@@ -43,7 +43,12 @@
             <artifactId>spring-boot-starter-actuator</artifactId>
         </dependency>
 
+<<<<<<< HEAD
+
+<!--        //创建测试工程，引入依赖-->
+=======
         <!--        //创建测试工程，引入依赖-->
+>>>>>>> 6153133e0ae6ba8fbc2d841bc887a2893fd758a4
         <dependency>
             <groupId>com.aliyun.oss</groupId>
             <artifactId>aliyun-sdk-oss</artifactId>
@@ -55,7 +60,10 @@
             <artifactId>jaxb-api</artifactId>
             <version>2.3.1</version>
         </dependency>
+<<<<<<< HEAD
+=======
 
+>>>>>>> 6153133e0ae6ba8fbc2d841bc887a2893fd758a4
         <dependency>
             <groupId>javax.activation</groupId>
             <artifactId>activation</artifactId>
@@ -113,6 +121,11 @@
             <artifactId>junit</artifactId>
         </dependency>
 
+<<<<<<< HEAD
+
+
+=======
+>>>>>>> 6153133e0ae6ba8fbc2d841bc887a2893fd758a4
         <!--        &lt;!&ndash;         XllJob定时任务 &ndash;&gt;-->
         <!--        <dependency>-->
         <!--            <groupId>com.muyu</groupId>-->

cloud-etl-server/src/main/java/com/muyu/controller/EngIneController.java

@@ -217,7 +217,7 @@ public class EngIneController extends BaseController {
     }
 
     /**
-     * 通过id查询版本version信息
+     * 通过id查询版本version信息  传入id    和   versionId
      */
     @GetMapping("/findVersionById/{id}")
     public Result findVersionById(@PathVariable("id") Long id) {

cloud-etl-server/src/main/java/com/muyu/input/Demo.java

@@ -1,3 +1,4 @@
+//<<<<<<< HEAD
 //package com.muyu.input;
 //
 //import com.aliyun.oss.ClientException;
@@ -7,14 +8,12 @@
 //import com.aliyun.oss.OSSException;
 //import com.aliyun.oss.model.PutObjectRequest;
 //import com.aliyun.oss.model.PutObjectResult;
-//
 //import java.io.FileInputStream;
 //import java.io.InputStream;
 //
 //public class Demo {
 //
 //    public static void main(String[] args) throws Exception {
-//
 //        // Endpoint以华东1（杭州）为例，其它Region请按实际情况填写。
 //        String endpoint = "https://oss-cn-shanghai.aliyuncs.com";
 //        // 从环境变量中获取访问凭证。运行本代码示例之前，请确保已设置环境变量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。
@@ -22,10 +21,10 @@
 //        // 填写Bucket名称，例如examplebucket。
 //        String bucketName = "011811";
 //        // 填写Object完整路径，完整路径中不能包含Bucket名称，例如exampledir/exampleobject.txt。
-//        String objectName = "cloud-etl-engine\\cloud-etl-engine\\cloud-etl-server\\target\\cloud-engine.jar";
+//        String objectName = "localpath\\examplefile.txt";
 //        // 填写本地文件的完整路径，例如D:\\localpath\\examplefile.txt。
 //        // 如果未指定本地路径，则默认从示例程序所属项目对应本地路径中上传文件流。
-//        String filePath = "D:\\cloud-etl-engine\\cloud-etl-engine\\cloud-etl-server\\target\\cloud-engine.jar";
+//        String filePath= "C:\\Users\\qdm\\Desktop\\Project\\CLOUD-ETL-UI-ENGINE\\cloud-etl-engine\\cloud-etl-server\\target\\";
 //
 //        // 创建OSSClient实例。
 //        OSS ossClient = new OSSClientBuilder().build(endpoint, credentialsProvider);
@@ -54,8 +53,67 @@
 //            }
 //        }
 //    }
-//
-//    public static void main1(String[] args) {
-//        System.out.println("你好世界");
-//    }
 //}
+//=======
+////package com.muyu.input;
+////
+////import com.aliyun.oss.ClientException;
+////import com.aliyun.oss.OSS;
+////import com.aliyun.oss.common.auth.*;
+////import com.aliyun.oss.OSSClientBuilder;
+////import com.aliyun.oss.OSSException;
+////import com.aliyun.oss.model.PutObjectRequest;
+////import com.aliyun.oss.model.PutObjectResult;
+////
+////import java.io.FileInputStream;
+////import java.io.InputStream;
+////
+////public class Demo {
+////
+////    public static void main(String[] args) throws Exception {
+////
+////        // Endpoint以华东1（杭州）为例，其它Region请按实际情况填写。
+////        String endpoint = "https://oss-cn-shanghai.aliyuncs.com";
+////        // 从环境变量中获取访问凭证。运行本代码示例之前，请确保已设置环境变量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。
+////        EnvironmentVariableCredentialsProvider credentialsProvider = CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();
+////        // 填写Bucket名称，例如examplebucket。
+////        String bucketName = "011811";
+////        // 填写Object完整路径，完整路径中不能包含Bucket名称，例如exampledir/exampleobject.txt。
+////        String objectName = "cloud-etl-engine\\cloud-etl-engine\\cloud-etl-server\\target\\cloud-engine.jar";
+////        // 填写本地文件的完整路径，例如D:\\localpath\\examplefile.txt。
+////        // 如果未指定本地路径，则默认从示例程序所属项目对应本地路径中上传文件流。
+////        String filePath = "D:\\cloud-etl-engine\\cloud-etl-engine\\cloud-etl-server\\target\\cloud-engine.jar";
+////
+////        // 创建OSSClient实例。
+////        OSS ossClient = new OSSClientBuilder().build(endpoint, credentialsProvider);
+////
+////        try {
+////            InputStream inputStream = new FileInputStream(filePath);
+////            // 创建PutObjectRequest对象。
+////            PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, objectName, inputStream);
+////            // 创建PutObject请求。
+////            PutObjectResult result = ossClient.putObject(putObjectRequest);
+////        } catch (OSSException oe) {
+////            System.out.println("Caught an OSSException, which means your request made it to OSS, "
+////                    + "but was rejected with an error response for some reason.");
+////            System.out.println("Error Message:" + oe.getErrorMessage());
+////            System.out.println("Error Code:" + oe.getErrorCode());
+////            System.out.println("Request ID:" + oe.getRequestId());
+////            System.out.println("Host ID:" + oe.getHostId());
+////        } catch (ClientException ce) {
+////            System.out.println("Caught an ClientException, which means the client encountered "
+////                    + "a serious internal problem while trying to communicate with OSS, "
+////                    + "such as not being able to access the network.");
+////            System.out.println("Error Message:" + ce.getMessage());
+////        } finally {
+////            if (ossClient != null) {
+////                ossClient.shutdown();
+////            }
+////        }
+////    }
+////
+////    public static void main1(String[] args) {
+////        System.out.println("你好世界");
+////    }
+////}
+//>>>>>>> 6153133e0ae6ba8fbc2d841bc887a2893fd758a4

cloud-etl-server/src/main/java/com/muyu/javacomplier/JavaCompilerDemo.java

@@ -0,0 +1,53 @@
+package com.muyu.javacomplier;
+
+import lombok.extern.log4j.Log4j2;
+
+import javax.tools.*;
+import java.io.FileWriter;
+import java.io.IOException;
+import java.util.Arrays;
+@Log4j2
+public class JavaCompilerDemo {
+
+    public static void main(String[] args) {
+        String sourceCode = "public class HelloWorld { public static void main(String[] args) { System.out.println(\"Hello, world!\"); } }";
+        String fileName = "HelloWorld.java";
+        try {
+            // 将源代码写入文件
+            writeToFile(fileName, sourceCode);
+
+            // 获取Java编译器实例
+            JavaCompiler compiler = ToolProvider.getSystemJavaCompiler();
+
+            // 设置编译参数
+            DiagnosticCollector<JavaFileObject> diagnostics = new DiagnosticCollector<>();
+            StandardJavaFileManager fileManager = compiler.getStandardFileManager(diagnostics, null, null);
+            Iterable<? extends JavaFileObject> compilationUnits = fileManager.getJavaFileObjectsFromStrings(Arrays.asList(fileName));
+
+            // 执行编译
+            JavaCompiler.CompilationTask task = compiler.getTask(null, fileManager, diagnostics, null, null, compilationUnits);
+            log.info("数据是:{}"+task);
+            boolean success = task.call();
+
+            // 处理编译结果
+            if (success) {
+                System.out.println("编译成功");
+            } else {
+                System.out.println("编译失败");
+                diagnostics.getDiagnostics().forEach(d -> System.out.format("Line %d, Column %d: %s%n", d.getLineNumber(), d.getColumnNumber(), d.getMessage(null)));
+            }
+
+            // 释放资源
+            fileManager.close();
+
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+
+    private static void writeToFile(String fileName, String sourceCode) throws IOException {
+        try (FileWriter writer = new FileWriter(fileName)) {
+            writer.write(sourceCode);
+        }
+    }
+}

cloud-etl-server/src/main/java/com/muyu/javacomplier/JavaStringCompiler.java

@@ -0,0 +1,70 @@
+package com.itranswarp.compiler;
+
+import java.io.IOException;
+import java.util.Arrays;
+import java.util.Map;
+
+import javax.tools.JavaCompiler;
+import javax.tools.JavaFileObject;
+import javax.tools.StandardJavaFileManager;
+import javax.tools.ToolProvider;
+import javax.tools.JavaCompiler.CompilationTask;
+
+/**
+ * In-memory compile Java source code as String.
+ * 
+ * @author michael
+ */
+public class JavaStringCompiler {
+
+	JavaCompiler compiler;
+	StandardJavaFileManager stdManager;
+
+	public JavaStringCompiler() {
+		this.compiler = ToolProvider.getSystemJavaCompiler();
+		this.stdManager = compiler.getStandardFileManager(null, null, null);
+	}
+
+	/**
+	 * Compile a Java source file in memory.
+	 * 
+	 * @param fileName
+	 *            Java file name, e.g. "Test.java"
+	 * @param source
+	 *            The source code as String.
+	 * @return The compiled results as Map that contains class name as key,
+	 *         class binary as value.
+	 * @throws IOException
+	 *             If compile error.
+	 */
+	public Map<String, byte[]> compile(String fileName, String source) throws IOException {
+		try (MemoryJavaFileManager manager = new MemoryJavaFileManager(stdManager)) {
+			JavaFileObject javaFileObject = manager.makeStringSource(fileName, source);
+			CompilationTask task = compiler.getTask(null, manager, null, null, null, Arrays.asList(javaFileObject));
+			Boolean result = task.call();
+			if (result == null || !result.booleanValue()) {
+				throw new RuntimeException("Compilation failed.");
+			}
+			return manager.getClassBytes();
+		}
+	}
+
+	/**
+	 * Load class from compiled classes.
+	 * 
+	 * @param name
+	 *            Full class name.
+	 * @param classBytes
+	 *            Compiled results as a Map.
+	 * @return The Class instance.
+	 * @throws ClassNotFoundException
+	 *             If class not found.
+	 * @throws IOException
+	 *             If load error.
+	 */
+	public Class<?> loadClass(String name, Map<String, byte[]> classBytes) throws ClassNotFoundException, IOException {
+		try (MemoryClassLoader classLoader = new MemoryClassLoader(classBytes)) {
+			return classLoader.loadClass(name);
+		}
+	}
+}

cloud-etl-server/src/main/java/com/muyu/javacomplier/MemoryClassLoader.java

@@ -0,0 +1,33 @@
+package com.muyu.javacomplier;
+
+import java.net.URL;
+import java.net.URLClassLoader;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * Load class from byte[] which is compiled in memory.
+ *
+ * @author michael
+ */
+class MemoryClassLoader extends URLClassLoader {
+
+	// class name to class bytes:
+	Map<String, byte[]> classBytes = new HashMap<String, byte[]>();
+
+	public MemoryClassLoader(Map<String, byte[]> classBytes) {
+		super(new URL[0], MemoryClassLoader.class.getClassLoader());
+		this.classBytes.putAll(classBytes);
+	}
+
+	@Override
+	protected Class<?> findClass(String name) throws ClassNotFoundException {
+		byte[] buf = classBytes.get(name);
+		if (buf == null) {
+			return super.findClass(name);
+		}
+		classBytes.remove(name);
+		return defineClass(name, buf, 0, buf.length);
+	}
+
+}

cloud-etl-server/src/main/java/com/muyu/javacomplier/MemoryJavaFileManager.java

@@ -0,0 +1,96 @@
+package com.itranswarp.compiler;
+
+import java.io.ByteArrayOutputStream;
+import java.io.FilterOutputStream;
+import java.io.IOException;
+import java.io.OutputStream;
+import java.net.URI;
+import java.nio.CharBuffer;
+import java.util.HashMap;
+import java.util.Map;
+
+import javax.tools.FileObject;
+import javax.tools.ForwardingJavaFileManager;
+import javax.tools.JavaFileManager;
+import javax.tools.JavaFileObject;
+import javax.tools.JavaFileObject.Kind;
+import javax.tools.SimpleJavaFileObject;
+
+/**
+ * In-memory java file manager.
+ * 
+ * @author michael
+ */
+class MemoryJavaFileManager extends ForwardingJavaFileManager<JavaFileManager> {
+
+	// compiled classes in bytes:
+	final Map<String, byte[]> classBytes = new HashMap<String, byte[]>();
+
+	MemoryJavaFileManager(JavaFileManager fileManager) {
+		super(fileManager);
+	}
+
+	public Map<String, byte[]> getClassBytes() {
+		return new HashMap<String, byte[]>(this.classBytes);
+	}
+
+	@Override
+	public void flush() throws IOException {
+	}
+
+	@Override
+	public void close() throws IOException {
+		classBytes.clear();
+	}
+
+	@Override
+	public JavaFileObject getJavaFileForOutput(JavaFileManager.Location location, String className, Kind kind,
+			FileObject sibling) throws IOException {
+		if (kind == Kind.CLASS) {
+			return new MemoryOutputJavaFileObject(className);
+		} else {
+			return super.getJavaFileForOutput(location, className, kind, sibling);
+		}
+	}
+
+	JavaFileObject makeStringSource(String name, String code) {
+		return new MemoryInputJavaFileObject(name, code);
+	}
+
+	static class MemoryInputJavaFileObject extends SimpleJavaFileObject {
+
+		final String code;
+
+		MemoryInputJavaFileObject(String name, String code) {
+			super(URI.create("string:///" + name), Kind.SOURCE);
+			this.code = code;
+		}
+
+		@Override
+		public CharBuffer getCharContent(boolean ignoreEncodingErrors) {
+			return CharBuffer.wrap(code);
+		}
+	}
+
+	class MemoryOutputJavaFileObject extends SimpleJavaFileObject {
+		final String name;
+
+		MemoryOutputJavaFileObject(String name) {
+			super(URI.create("string:///" + name), Kind.CLASS);
+			this.name = name;
+		}
+
+		@Override
+		public OutputStream openOutputStream() {
+			return new FilterOutputStream(new ByteArrayOutputStream()) {
+				@Override
+				public void close() throws IOException {
+					out.close();
+					ByteArrayOutputStream bos = (ByteArrayOutputStream) out;
+					classBytes.put(name, bos.toByteArray());
+				}
+			};
+		}
+
+	}
+}

cloud-etl-server/src/main/java/com/muyu/javacomplier/OssDownload.java

@@ -0,0 +1,48 @@
+package com.muyu.cloud.rule.utils.upload;
+
+import com.aliyun.oss.OSSClient;
+import com.aliyun.oss.model.GetObjectRequest;
+import com.aliyun.oss.model.ObjectMetadata;
+import com.muyu.common.core.domain.Result;
+
+import java.io.File;
+
+
+public class OssDownload {
+
+    // 阿里云 endpoint
+    private static final String endpoint = "oss-cn-wulanchabu.aliyuncs.com";
+    // 阿里云 accessKeyId
+    private static final String accessKeyId = "LTAI5t8mk6aWqDq5w6WA49et";
+    // 阿里云 accessKeySecret　　
+    private static final String accessKeySecret = "SuLwzfEOruGOs1RSCq4vA1Bcf1849R";
+    // bucket
+    private static final String bucketName = "oss-1209";
+    // OSS文件路径
+    private static final String filePath = "build/rule/version/";
+
+    public static Result<Object> streamingDownload(String fileName) {
+        String source = null;
+        // 创建 OSSClient 实例
+        OSSClient ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret);
+        // 判断 bucket 是否存在
+        Boolean flag_bucket = ossClient.doesBucketExist(bucketName);
+        if (!flag_bucket) {
+            System.out.println("bucket不存在");
+            return Result.error("bucket不存在");
+        }
+        String objectName = fileName + ".java";
+        Boolean flag_file = ossClient.doesObjectExist(bucketName, filePath+objectName);
+        if (!flag_file) {
+            System.out.println("预下载文件不存在");
+            return Result.error("预下载文件不存在");
+        }
+        // 本地文件下载路径
+        String localPath = "home/"+objectName;
+        ObjectMetadata object = ossClient.getObject(new GetObjectRequest(bucketName, filePath + objectName), new File(localPath));
+        System.out.println(object);
+        ossClient.shutdown();
+        return Result.success(source);
+    }
+
+}