springboot实现动态定时任务（客户端维持心跳）

准备：

1.启动类里面使用@EnableScheduling 注解开启功能

2.定时任务工具类

@Async
public class ScheduleUtil {

    private static ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler();
    private static Map<String, ScheduledFuture<?>> scheduledFutureMap = new HashMap<>();

    static {
        threadPoolTaskScheduler.initialize();
        System.out.println("定时任务线程池启动");
    }

    /**
     * 启动
     *
     * @param scheduleTask 定时任务
     * @param corn         执行时间表达式
     */
    public static boolean start(ScheduleTask scheduleTask, String corn) {
        System.out.println("启动定时任务线程 taskId " + scheduleTask.getId());
        ScheduledFuture<?> scheduledFuture = threadPoolTaskScheduler
                .schedule(scheduleTask, new CronTrigger(corn));
        scheduledFutureMap.put(scheduleTask.getId(), scheduledFuture);
        return true;
    }

    /**
     * 取消
     *
     * @param scheduleTask 定时任务
     */
    public static boolean cancel(ScheduleTask scheduleTask) {
        System.out.println("关闭定时任务线程 taskId " + scheduleTask.getId());
        ScheduledFuture<?> scheduledFuture = scheduledFutureMap.get(scheduleTask.getId());
        if (scheduledFuture != null && !scheduledFuture.isCancelled()) {
            scheduledFuture.cancel(false);
        }
        scheduledFutureMap.remove(scheduleTask.getId());
        return true;
    }

    /**
     * 取消通过guid
     *
     */
    public static boolean byGuidCancel(String guid){
        System.out.println("关闭定时任务线程 taskId " + guid);
        ScheduledFuture<?> scheduledFuture = scheduledFutureMap.get(guid);
        if (scheduledFuture != null && !scheduledFuture.isCancelled()) {
            scheduledFuture.cancel(false);
        }
        return true;
    }


    /**
     * 修改
     *
     * @param scheduleTask 定时任务
     * @param corn         执行时间表达式
     */
    public static boolean reset(ScheduleTask scheduleTask, String corn) {
        //先取消定时任务
        cancel(scheduleTask);
        //然后启动新的定时任务
        start(scheduleTask, corn);
        return true;
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68

3.定时任务实体类：

@Data
@AllArgsConstructor
@NoArgsConstructor
public class ScheduleTask implements Runnable {
    

    private String id;
    private String guid;
    private TaskService service;


    @Override
    public void run() {
        service.work(id); //这里也可以增加参数
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

4：根据业务逻辑创建实际定时任务服务：

public interface TaskService {

    /**
     * 发送心跳包
     * @param guid
     */
    void work(String guid);//这里也可以增加参数，与上方对应
}
1
2
3
4
5
6
7
8

public class TaskServiceImpl implements TaskService {
@Resource
private RestTemplate restTemplate;


    @Override
    public void work(String guid) {
   //书写字节的业务逻辑
    }
}
1
2
3
4
5
6
7
8
9
10

调用：

ScheduleUtil.start(new ScheduleTask(WxTokenUtil.guid, taskService, WxTokenUtil.guid), "0 */1 * * * ?");

1
2