# dynamic-schedule
**Repository Path**: mmj-luozhou/dynamic-schedule
## Basic Information
- **Project Name**: dynamic-schedule
- **Description**: 轻量级的动态定时调度器
- **Primary Language**: Java
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No
## Statistics
- **Stars**: 1
- **Forks**: 0
- **Created**: 2019-10-15
- **Last Updated**: 2020-12-19
## Categories & Tags
**Categories**: Uncategorized
**Tags**: None
## README
# dynamic-schedule
[](https://github.com/kinglaw1204/dynamic-schedule)
## 介绍
dynamic-schedule是一款轻量级调度框架，它主要解决传统调度框架不支持动态定时任务的问题，通过dynamic-schedule你可以解决如下场景的问题：
- 需要以不同时间差进行调用任务，比如接口调用回调，为了保证最大限度通知，可以调用多次，假设对方系统不可用，可以以不同的时间差调用，给对方已恢复时间，同时保证业务处理逻辑不丢失。
- 异步延时处理任务
## 快速开始
### 普通模式
**1.下载代码**
```
git clone https://github.com/kinglaw1204/dynamic-schedule.git
```
**2.安装依赖**
```
mvn install
```
**3.添加依赖**
```
top.luozhou
dynamic-schedule-core
1.0.0-SNAPSHOT
```
**4.初始化配置**
在项目启动时只需执行下面语句即可：
```java
new ScheduleConfig().init();
```
比如springboot中：
```java
public static void main(String[] args) {
new ScheduleConfig().init();
new SpringApplication(Test.class).run(args);
}
```
启动成功即可
**5.定义job**
```java
@Slf4j
public class PersistenceTestJob extends AbstractJob {
@Override
public void run() {
log.info("我执行啦{}",getStatus());
log.info("获取数据实体{}",getBody());
setStatus(JobStatus.COMPLETED.getStatus());
}
@Override
public boolean equals(Object o) {
return super.equals(o);
}
@Override
public int hashCode() {
return super.hashCode();
}
}
```
上述代码中，`run`方法中是实现自己的业务逻辑，`hashCode`方法和`equals`重写，在持久化模式必须，直接复制就好，普通模式可以忽略。
`getBody()`可以获取job中传入的实体数据，获取后可以完成业务操作。
`setStatus(JobStatus.COMPLETED)`表示操作完成，设置完成状态，调度策略不会执行下一个策略,如果还需要继续调度，不设置状态即可。
**6.定义策略（非必须，可以用内置策略）**
```java
public class MultiTimesStragegy implements IStrategy {
/**
* 设置执行时间间隔，单位是毫秒，比如间隔是一秒，执行三次，数组设置元素为 [1000,2000,3000] */
private long[] times;
private int pos;
public MultiTimesStragegy(long[] times) {
this.times = times;
}
public MultiTimesStragegy() {
}
@Override
public Long doGetNextSecond() {
if (null == times || times.length<=0){
log.error("执行策略时间为空，请设置执行策略时间！");
return -1L;
}
while (pos < times.length) {
return times[pos++];
}
return -1L;
}
@Override
public Long doGetCurrentSecond() {
if (times == null){
times =new long[1];
}
return times[pos];
}
```
实现策略接口即可，重写`doGetCurrentSecond`和`doGetNextSecond`方法即可，上述是内置的多间隔策略实现代码。
**6.添加job**
```java
/**获取一个job添加器worker*/
Iworker worker = DefaultWorker.getWorker();
/**构造一个job*/
AbstractJob job = new PersistenceTestJob();
job.setBody(new Teacher("小粥老师"));
/**给job设置调度策略，这里是内置的默认多级时间调度策略，单位是毫秒，可以自定义实现，这里的意思是
调度3次，第一次1秒，第二次2秒，第三次3秒*/
job.setStrategy(new MultiTimesStragegy(new long[]{1000,2000,3000}));
/**把job添加给woker*/
worker.addJob(job);
```
### 持久化模式
持久化模式流程和普通模式差别不大，只需多两个步骤：
**1.创建sqllite数据库，初始化脚本，脚本内容在代码db目录下**
**2.初始化配置设置持久化模式，配置数据库url**
```java
ScheduleConfig config = new ScheduleConfig();
config.setPersistence(true);
config.setJdbcUrl("jdbc:sqlite:/xxxxx/dynamic-schedule.sqlite");
config.init();
```
## 架构设计
## TODOLIST
* [x] [支持自定义扩展调度策略](#)
* [x] [支持多倍时间差多次调度](#)
* [x] [支持定时任务持久化](#)
* [x] [支持重启自动执行未完成任务](#)
## 联系作者
- [kinglaw1204@gmail.com](mailto:kinglaw1204@gmail.com)