1.6.8-SNAPSHOT 修改Compiler为javassist

Author: qq254963746

lts-core/src/main/java/com/github/ltsopensource/core/compiler/AbstractCompiler.java

@@ -50,5 +50,41 @@ public Class<?> compile(String code) {
 
     protected abstract Class<?> doCompile(String name, String source) throws Throwable;
 
+    public static void main(String[] args) {
+        String code = "package com.github.ltsopensource.core.support.bean;\n" +
+                "import com.github.ltsopensource.core.support.bean.BeanCopier;\n" +
+                "import com.github.ltsopensource.queue.domain.JobPo;\n" +
+                "public class JobPo2JobPoBeanCopier1 implements BeanCopier<JobPo,JobPo> {\n" +
+                "public void copyProps(JobPo source, JobPo target){\n" +
+                "target.setJobId(source.getJobId());\n" +
+                "target.setJobType(source.getJobType());\n" +
+                "target.setPriority(source.getPriority());\n" +
+                "target.setTaskId(source.getTaskId());\n" +
+                "target.setRealTaskId(source.getRealTaskId());\n" +
+                "target.setGmtCreated(source.getGmtCreated());\n" +
+                "target.setGmtModified(source.getGmtModified());\n" +
+                "target.setSubmitNodeGroup(source.getSubmitNodeGroup());\n" +
+                "target.setTaskTrackerNodeGroup(source.getTaskTrackerNodeGroup());\n" +
+                "com.github.ltsopensource.core.support.bean.PropConverter<JobPo, java.util.Map<java.lang.String, java.lang.String>> extParamsConverter = (com.github.ltsopensource.core.support.bean.PropConverter<JobPo, java.util.Map<java.lang.String, java.lang.String>> )com.github.ltsopensource.core.support.bean.BeanCopierFactory.getConverter(1,\"extParams\");\n" +
+                "target.setExtParams((java.util.Map<java.lang.String, java.lang.String>)extParamsConverter.convert(source));\n" +
+                "com.github.ltsopensource.core.support.bean.PropConverter<JobPo, java.util.Map<java.lang.String, java.lang.String>> internalExtParamsConverter = (com.github.ltsopensource.core.support.bean.PropConverter<JobPo, java.util.Map<java.lang.String, java.lang.String>> )com.github.ltsopensource.core.support.bean.BeanCopierFactory.getConverter(1,\"internalExtParams\");\n" +
+                "target.setInternalExtParams((java.util.Map<java.lang.String, java.lang.String>)internalExtParamsConverter.convert(source));\n" +
+                "target.setTaskTrackerIdentity(source.getTaskTrackerIdentity());\n" +
+                "target.setNeedFeedback(source.isNeedFeedback());\n" +
+                "target.setCronExpression(source.getCronExpression());\n" +
+                "target.setTriggerTime(source.getTriggerTime());\n" +
+                "target.setRetryTimes(source.getRetryTimes());\n" +
+                "target.setMaxRetryTimes(source.getMaxRetryTimes());\n" +
+                "target.setRepeatCount(source.getRepeatCount());\n" +
+                "target.setRepeatedCount(source.getRepeatedCount());\n" +
+                "target.setRepeatInterval(source.getRepeatInterval());\n" +
+                "target.setRelyOnPrevCycle(source.getRelyOnPrevCycle());\n" +
+                "target.setLastGenerateTriggerTime(source.getLastGenerateTriggerTime());\n" +
+                "}}";
+
+        Compiler compiler = new JavassistCompiler();
+        compiler.compile(code);
+
+    }
 }
 

lts-core/src/main/java/com/github/ltsopensource/core/compiler/JdkCompiler.java

@@ -4,6 +4,7 @@
 
 import javax.tools.*;
 import java.io.*;
+import java.lang.reflect.Method;
 import java.net.URI;
 import java.net.URISyntaxException;
 import java.net.URL;
@@ -17,7 +18,7 @@ public class JdkCompiler extends AbstractCompiler {
     public static final String CLASS_EXTENSION = ".class";
     public static final String JAVA_EXTENSION = ".java";
 
-    private final JavaCompiler compiler = ToolProvider.getSystemJavaCompiler();
+    private JavaCompiler compiler = ToolProvider.getSystemJavaCompiler();
 
     private final DiagnosticCollector<JavaFileObject> diagnosticCollector = new DiagnosticCollector<JavaFileObject>();
 
@@ -28,7 +29,15 @@ public class JdkCompiler extends AbstractCompiler {
     private volatile List<String> options;
 
     public JdkCompiler() {
-
+        if (compiler == null) {
+            try {
+                Class<?> javacTool = Class.forName("com.sun.tools.javac.api.JavacTool");
+                Method create = javacTool.getMethod("create");
+                compiler = (JavaCompiler) create.invoke(null);
+            } catch (Exception e) {
+                throw new AssertionError(e);
+            }
+        }
         options = new ArrayList<String>();
 //        options.add("-target");
 //        options.add("1.6");

lts-core/src/main/java/com/github/ltsopensource/core/constant/Constants.java

@@ -69,7 +69,7 @@ public interface Constants {
     String PROCESSOR_THREAD = "job.processor.thread";
     int DEFAULT_PROCESSOR_THREAD = 32 + AVAILABLE_PROCESSOR * 5;
 
-    int LATCH_TIMEOUT_MILLIS = 10 * 60 * 1000;      // 10分钟
+    int LATCH_TIMEOUT_MILLIS =  60 * 1000;      // 60s
 
     // 任务最多重试次数
     String JOB_MAX_RETRY_TIMES = "job.max.retry.times";

lts-core/src/main/java/com/github/ltsopensource/core/support/bean/BeanCopierFactory.java

@@ -5,7 +5,7 @@
 import com.github.ltsopensource.core.commons.utils.ClassHelper;
 import com.github.ltsopensource.core.commons.utils.ReflectionUtils;
 import com.github.ltsopensource.core.compiler.Compiler;
-import com.github.ltsopensource.core.compiler.JavassistCompiler;
+import com.github.ltsopensource.core.compiler.JdkCompiler;
 import com.github.ltsopensource.core.exception.LtsRuntimeException;
 import com.github.ltsopensource.core.logger.Logger;
 import com.github.ltsopensource.core.logger.LoggerFactory;
@@ -26,7 +26,7 @@ public final class BeanCopierFactory {
 
     private static final Logger LOGGER = LoggerFactory.getLogger(BeanCopierFactory.class);
 
-    private static Compiler COMPILER = new JavassistCompiler();
+    private static Compiler COMPILER = new JdkCompiler();
     private static final AtomicInteger SEQ = new AtomicInteger(0);
     private static final ConcurrentMap<Integer, Map<String, PropConverter<?, ?>>> SEQ_PROP_CVT_MAP = new ConcurrentHashMap<Integer, Map<String, PropConverter<?, ?>>>();
 

lts-example/src/main/resources/application.properties

@@ -18,7 +18,6 @@ lts.tasktracker.registry-address=zookeeper://127.0.0.1:2181
 lts.tasktracker.node-group=test_trade_TaskTracker
 lts.tasktracker.dispatch-runner.enable=true
 lts.tasktracker.dispatch-runner.shard-value=taskId
-lts.tasktracker.dispatch-runner.scanner-packages=com.github.ltsopensource.example
 
 lts.monitor.cluster-name=test_cluster
 lts.monitor.registry-address=zookeeper://127.0.0.1:2181