Skip to content

Latest commit

 

History

History
105 lines (78 loc) · 4.66 KB

README.md

File metadata and controls

105 lines (78 loc) · 4.66 KB
Raw

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

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

中间件使用

增强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/ 成功界面如下；可以开启/关闭验证了！{功能还在完善} 微信公众号：bugstack虫洞栈 & 任务列表

7. 其他

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