leaf-jobs

一个简单的任务调度中心

• rpc模块 netty
• quartz-support模块 quartz集群模式
• console模块 springboot控制台
• jobs-starter模块 服务端需要依赖
• test模块 spi的test模块

数据库脚本

• leaf-jobs/db/customer.sql
• leaf-jobs/db/tables_mysql_innodb.sql

服务端配置

可参考test模块

依赖

    <dependency>
        <groupId>com.leaf.jobs</groupId>
        <artifactId>jobs-spring-boot-starter</artifactId>
        <version>0.0.1-SNAPSHOT</version>
    </dependency>

支持springboot autoconfig

@SpringBootApplication
@JobsScanner(basePackages = "com.leaf.jobs")
public class SpiApplication {

    public static void main(String[] args) {
        SpringApplication.run(SpiApplication.class, args);
    }
}

public interface HelloService {

    String sayHello(String name);

    String sayHello2(String name, String age);
}

@JobsProvider(group = "rjb")
@Slf4j
public class HelloServiceImpl implements HelloService {

    @Override
    public String sayHello(String name) {
        log.info("hi service" + name);
        return "ss: " + name;
    }

    @Override
    public String sayHello2(String name, String age) {
        log.info("hi service" + name);
        return "ss: " + name + age;
    }
}

    leaf:
        jobs:
          registerAddress: 172.16.2.203:2181
          systemName: rjb
          port: 9000
          script: true //支持推送shell脚本等执行

调度中心控制台

启动 com.leaf.jobs.JobsApplication 即可

后续

• 日志回显优化
• 脚本 groovy 执行
• 子任务