fuzhengwei / schedule-spring-boot-starter

增强SpringBoot Schedule，开发中间件以zookeeper为注册中心扩展为分布式任务调度系统，接入方式接单易用，目前实现功能如下； 多机器部署任务 统一控制中心启停 宕机灾备，自动启动执行 实时检测任务执行信息：部署数量、任务总量、成功次数、失败次数、执行耗时等

schedule-spring-boot-starter 分布式任务中间件

微信公众号：bugstack虫洞栈 | 沉淀、分享、成长，让自己和他人都能有所收获！

• 博客：https://bugstack.cn
• 详细文档(含视频)
• 分布式任务DcsSchedule中间件，Github地址：https://github.com/fuzhengwei/schedule-spring-boot-starter
• 分布式任务DcsSchedule控制台，Github地址：https://github.com/fuzhengwei/itstack-middleware-control
• 分布式任务DcsSchedule案例工程，Github地址：https://github.com/fuzhengwei/itstack-demo-springboot-helloworld
• 欢迎⭐Star和使用，你用剑🗡、我用刀🔪，好的代码都很*😏，望你不吝出招💨！

中间件使用

增强SpringBoot Schedule，开发中间件以zookeeper为注册中心扩展为分布式任务调度系统，接入方式接单易用，目前实现功能如下；

• 多机器部署任务
• 统一控制中心启停
• 宕机灾备，自动启动执行
• 实时检测任务执行信息：部署数量、任务总量、成功次数、失败次数、执行耗时等

1. 版本记录

	版本	发布日期	备注
1	1.0.0-RELEASE	2019-12-07	基本功能实现；任务接入、分布式启停
2	1.0.1-RELEASE	2019-12-07	上传测试版本
3	1.0.2-RELEASE	2019-12-07	关于zk监听执行起停没有判断节点是否存在修复

2. 环境准备

1. jdk1.8

2. StringBoot 2.x

3. 配置中心zookeeper 3.4.14 {准备好zookeeper服务，如果windows调试可以从这里下载：https://www-eu.apache.org/dist/zookeeper}

4. 下载后解压，在bin同级路径创建文件夹data、logs

5. 修改conf/zoo.cfg，修改配置如下；

   dataDir=D:\\Program Files\\apache-zookeeper-3.4.14\\data
   dataLogDir=D:\\Program Files\\apache-zookeeper-3.4.14\\logs

6. 打包部署控制平台

7. 下载地址：https://github.com/fuzhengwei/itstack-middleware-control.git

8. 部署访问：http://localhost:7397

3. 配置POM

<dependency>
    <groupId>org.itstack.middleware</groupId>
    <artifactId>schedule-spring-boot-starter</artifactId>
    <version>1.0.0-RELEASE</version>
</dependency>

4. 引入分布式任务DcsSchedule

1. 与SpringBoot的Sceduling非常像，他的注解是；@EnableScheduling，尽可能降低使用难度
2. 这个注解主要方便给我们自己的中间件一个入口，也是😏扒拉源码发现的可以这么干{我一直说好的代码都很*气}

@SpringBootApplication
@EnableDcsScheduling
public class HelloWorldApplication {

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

}

5. 在任务方法上添加注解

1. 这个注解也和SpringBoot的Schedule很像，但是多了desc描述和启停初始化控制
2. cron：执行计划
3. desc：任务描述
4. autoStartup：默认启动状态
5. 如果你的任务需要参数可以通过引入service去调用获取等方式都可以

@Component("demoTaskThree")
public class DemoTaskThree {
	
    @DcsScheduled(cron = "0 0 9,13 * * *", desc = "03定时任务执行测试：taskMethod01", autoStartup = false)
    public void taskMethod01() {
        System.out.println("03定时任务执行测试：taskMethod01");
    }

    @DcsScheduled(cron = "0 0/30 8-10 * * *", desc = "03定时任务执行测试：taskMethod02", autoStartup = false)
    public void taskMethod02() {
        System.out.println("03定时任务执行测试：taskMethod02");
    }

}

6. 启动验证

1. 启动SpringBoot工程即可，autoStartup = true的会自动启动任务(任务是多线程并行执行的)
2. 启动控制平台：itstack-middleware-control，访问：http://localhost:7397/ 成功界面如下；可以开启/关闭验证了！{功能还在完善}

7. 其他

如果在使用的过程中遇到什么问题，欢迎联系我，微信号：monkeycode！

schedule-spring-boot-starter's Issues

工程编译异常与建议

1.schedule-spring-boot-starter编译异常：
Failed to execute goal org.apache.maven.plugins:maven-gpg-plugin:1.5:sign (sign-artifacts) on project schedule-spring-boot-starter: Exit code: 1 -> [Help 1]
解决方案：https://blog.csdn.net/huoxue_2012/article/details/77102395

2.schedule-spring-boot-starter 冒似不能发布到maven仓库，并且pom引用不了。

3.建议新增一个demo工程，让用户更快的跑步来。

以上问题也有可能是我的环境原因哈

ThreadPoolTaskScheduler 初始化

@bean("itstack-middlware-schedule-taskScheduler")
public TaskScheduler taskScheduler() {
ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
taskScheduler.setPoolSize(Constants.Global.schedulePoolSize);
taskScheduler.setRemoveOnCancelPolicy(true);
taskScheduler.setThreadNamePrefix("ItStackMiddlewareScheduleThreadPool-");
return taskScheduler;
}

你好，这边需要执行 taskScheduler.initialize 进行初始化吧， 要不然内部的ExecutorService executor是null