添加任务执行的基类和本地bean类型的java任务的解析类

byit-myth-core/myth-executor-core/src/main/java/Mains.java

-public class Mains {
-}

byit-myth-core/myth-executor-core/src/main/java/com/byit/job/enums/IEnum.java

+package com.byit.job.enums;
+
+/**
+ * @program: byit-myth-job->IEnum
+ * @description: 所有的枚举类均继承此接口
+ * @author: huangfu
+ * @date: 2019/11/13 15:46
+ **/
+public interface IEnum {
+    /**
+     * 返码值
+     * @return
+     */
+    int getCode();
+
+    /**
+     * 返回执行信息
+     * @return
+     */
+    String getMsg();
+}

byit-myth-core/myth-executor-core/src/main/java/com/byit/job/enums/JobResultEnum.java

+package com.byit.job.enums;
+
+/**
+ * 任务执行接执行的结果码值
+ * @author huangfu
+ */
+public enum JobResultEnum implements IEnum {
+    SUCCESS(200,"任务执行成功"),
+    FAIL(500,"任务执行失败"),
+    FAIL_TIMEOUT(502,"超时错误");
+    private int code;
+    private String msg;
+
+    JobResultEnum() {
+    }
+
+    JobResultEnum(int code, String msg) {
+        this.code = code;
+        this.msg = msg;
+    }
+
+
+    @Override
+    public int getCode() {
+        return this.code;
+    }
+
+    @Override
+    public String getMsg() {
+        return this.msg;
+    }
+}
\ No newline at end of file

byit-myth-core/myth-executor-core/src/main/java/com/byit/job/handler/BaseJobHandler.java

+package com.byit.job.handler;
+
+import com.byit.job.handler.interfaces.IJobHandler;
+import com.byit.job.model.ReturnResult;
+
+/**
+ * @program: byit-myth-job->AbsIJobHandler
+ * @description: TODO
+ * @author: huangfu
+ * @date: 2019/11/13 16:06
+ **/
+public abstract class BaseJobHandler implements IJobHandler {
+
+    @Override
+    public void init(String param) {
+
+    }
+
+    @Override
+    public void destroy(String param) {
+
+    }
+}

byit-myth-core/myth-executor-core/src/main/java/com/byit/job/handler/annotation/JobHandler.java

+package com.byit.job.handler.annotation;
+
+import java.lang.annotation.*;
+
+/**
+ * 主要应用在本地java任务上
+ */
+@Target({ElementType.TYPE})
+@Retention(RetentionPolicy.RUNTIME)
+@Documented
+public @interface JobHandler {
+
+    String value();
+
+}

byit-myth-core/myth-executor-core/src/main/java/com/byit/job/handler/impl/GlueJobHandler.java

+package com.byit.job.handler.impl;
+
+import com.byit.job.handler.BaseJobHandler;
+import com.byit.job.handler.interfaces.IJobHandler;
+import com.byit.job.model.ReturnResult;
+
+/**
+ * @program: byit-myth-job->GlueJobHandler
+ * @description: 任务节点处理程序
+ * @author: huangfu
+ * @date: 2019/11/13 16:23
+ **/
+public class GlueJobHandler extends BaseJobHandler {
+    /**
+     * 任务实例
+     */
+    private IJobHandler jobHandler;
+    /**
+     * 作业更新时间
+     */
+    private long glueUpdateTime;
+
+    public GlueJobHandler(IJobHandler jobHandler, long glueUpdateTime) {
+
+        this.jobHandler = jobHandler;
+        this.glueUpdateTime = glueUpdateTime;
+    }
+
+    /**
+     * 回调任务节点
+     * @param param
+     * @return
+     * @throws Exception
+     */
+    @Override
+    public ReturnResult<String> execute(String param) throws Exception {
+        return jobHandler.execute(param);
+    }
+}

byit-myth-core/myth-executor-core/src/main/java/com/byit/job/handler/interfaces/IJobHandler.java

+package com.byit.job.handler.interfaces;
+
+import com.byit.job.model.ReturnResult;
+
+/**
+ * @program: byit-myth-job->IJobHandler
+ * @description: 所有执行器的执行类的基类，即所有类型的执行器都是此接口的实现类
+ * @author: huangfu
+ * @date: 2019/11/13 15:31
+ **/
+public interface IJobHandler {
+    /**
+     * 所有的任务执行程序必须回调此方法执行
+     * @param param
+     * @return
+     * @throws Exception
+     */
+    ReturnResult<String> execute(String param) throws Exception;
+
+    /**
+     * 初始化时调用
+     * @param param
+     */
+    void init(String param);
+
+    /**
+     * 销毁时调用
+     * @param param
+     */
+    void destroy(String param);
+}

byit-myth-core/myth-executor-core/src/main/java/com/byit/job/model/ReturnResult.java

+package com.byit.job.model;
+
+import com.byit.job.enums.JobResultEnum;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.io.Serializable;
+
+/**
+ * @program: byit-myth-job->ReturnResult
+ * @description: 服务调用的返回结果
+ * @author: huangfu
+ * @date: 2019/11/13 15:39
+ **/
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class ReturnResult<T> implements Serializable {
+    public static final long serialVersionUID = 1573630876693L;
+    public static final ReturnResult SUCCESS = new ReturnResult(null);
+    public static final ReturnResult FAIL = new ReturnResult(JobResultEnum.FAIL.getCode(),JobResultEnum.FAIL.getMsg());
+    public static final ReturnResult FAIL_TIMEOUT = new ReturnResult(JobResultEnum.FAIL_TIMEOUT.getCode(),JobResultEnum.FAIL_TIMEOUT.getMsg());
+    private int code;
+    private String msg;
+    private T content;
+
+    /**
+     * 默认就是错误
+     * @param code
+     * @param msg
+     */
+    public ReturnResult(int code, String msg) {
+        this.code = code;
+        this.msg = msg;
+    }
+
+    /**
+     * 默认就是成功
+     * @param content
+     */
+    public ReturnResult(T content) {
+        this.code = JobResultEnum.SUCCESS.getCode();
+        this.content = content;
+    }
+}

byit-myth-executor/myth-executor-api/pom.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>byit-myth-executor</artifactId>
+        <groupId>myth-job</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>myth-job</groupId>
+    <artifactId>myth-executor-api</artifactId>
+
+
+</project>
\ No newline at end of file

byit-myth-executor/myth-executor-api/src/main/java/com/byit/api/JavaBeanExecutor.java

+package com.byit.api;
+
+import com.byit.job.model.ReturnResult;
+
+/**
+ * @program: byit-myth-job->JavaBeanExcutor
+ * @description: API外部调用接口
+ * @author: huangfu
+ * @date: 2019/11/13 16:52
+ **/
+public interface JavaBeanExecutor {
+    /**
+     * 执行接口
+     * @param param
+     * @return
+     */
+    ReturnResult<String> execute(String param);
+}

byit-myth-executor/myth-executor-client/pom.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>byit-myth-executor</artifactId>
+        <groupId>myth-job</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>myth-job</groupId>
+    <artifactId>myth-executor-client</artifactId>
+
+
+</project>
\ No newline at end of file

byit-myth-executor/myth-job-server/pom.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>byit-myth-executor</artifactId>
+        <groupId>myth-job</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>myth-job</groupId>
+    <artifactId>myth-job-server</artifactId>
+
+
+</project>
\ No newline at end of file

byit-myth-executor/pom.xml

@@ -10,12 +10,28 @@
     <modelVersion>4.0.0</modelVersion>
 
     <artifactId>byit-myth-executor</artifactId>
+    <packaging>pom</packaging>
+    <modules>
+        <module>myth-executor-api</module>
+        <module>myth-executor-client</module>
+        <module>myth-job-server</module>
+    </modules>
 
 
     <dependencies>
         <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter</artifactId>
+        </dependency>
+        <dependency>
             <groupId>org.projectlombok</groupId>
             <artifactId>lombok</artifactId>
         </dependency>
+        <!--执行器核心控制-->
+        <dependency>
+            <groupId>myth-job</groupId>
+            <artifactId>myth-executor-core</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
     </dependencies>
 </project>
\ No newline at end of file