180729-Quick-Task 动态脚本支持框架之任务动态加载

文章目录
  1. Quick-Task 动态脚本支持框架之任务动态加载
    1. I. 任务动态加载
      1. 1. 任务监听的从0到1
        1. a. 数据库存储方式
        2. b. 文件存储方式
        3. c. 缓存存储方式
      2. 2. 任务监听的实现
    2. II. 其他
      1. 0. 相关
      2. 1. 一灰灰Blog: https://liuyueyi.github.io/hexblog
      3. 2. 声明
      4. 3. 扫描关注

Quick-Task 动态脚本支持框架之任务动态加载

前面几篇博文分别介绍了整个项目的基本架构,使用说明,以及整体框架的设计与实现初稿,接下来则进入更细节的实现篇,将整个工程中核心实现捞出来,从为什么这么设计到最终的实现给予说明

相关系列博文:

I. 任务动态加载

这个动态脚本调度框架,最大的一个功能点就是支持热加载了,何为热加载?

简单来说就是在程序不宕机的情况下,可以往里面添加新的任务,删除旧的任务,更新已有的任务等等,就好比飞机在天上飞的时候给它加油,就这么高端的操作(😊)

为了支持热加载,首先面临的问题就是如何判断有任务的新增/删除/修改?

1. 任务监听的从0到1

要实现任务变更的监听,自然而然想到的一个方案就是起一个线程,不断的轮询,基本的逻辑无非是判断是否有任务的变更发生而已,也因此关注点就落在了如何判断任务是否有变更了

最简单粗暴直观的方法,就是记录之前的所有的任务,然后每次轮询时判断当前的所有任务与之前的所有任务是否有区别

再落到具体的实现上,则与任务的具体存储有关系了。很容易想到了几种任务存储方式有

  • 文件
  • 数据库 (如mysql)
  • 缓存 (如redis)

a. 数据库存储方式

这种方法比较好想到,同时也好实现,所有的任务都直接存在DB的某张表中;只需要保证表中包含以下几个字段即可

  • task: 具体的任务脚本逻辑
  • state: 任务的状态(表示运行,暂停等)
  • update: 任务的更新时间

基于上面的三个属性,判断的逻辑就清晰了

  • 起一个check线程,不断的扫表,获取所有的任务
  • 将当前获取的任务与上一次获取的任务进行对比
  • 根据比对的结果,封装任务更新事件,抛给下游处理

当然在db的场景下,还有一个更简单的方式,借助mysql的dbevent事件来处理任务的变更

  • 首先开启mysql的dbevent事件,即db中记录的新增删除变更都会抛出一个消息
  • 监听dbevent,以此封装任务的更新事件,丢给下一层进行处理即可

说明:

从个人的角度出发,在实际的应用场景中,基于DB的存储方案是比较合适的,然而我并没有去做这一个,因为相比于文件的方式,有点重量级了; 而我自己的实际项目中,文件方式已经足够解决我的需求了

b. 文件存储方式

这个可以说是最先想到,也是最容易实现的一种方式了。我的所有任务都放在指定的目录下,然后监听这个目录下所有文件的变动即可

QuickTask项目中,默认的实现方式,就是基于文件存储的动态任务监听,好处是简单,实现简单,理解简单,用起来也简单

c. 缓存存储方式

无非是拿缓存做db存储的思路,也没有啥其他的讲究,当然我并没有想过真的去拿缓存来实现,感觉这种实现方式有点非主流,当然也没有什么明显的优势

2. 任务监听的实现

上面是基本上把我如何实现动态任务监听的想法都写出来了,接下来就是具体的实现了,采用本地文件来存储具体的任务脚本,那么任务变化监听,就转换为了目录下文件变动的监听了

到了这一步,具体的实现方案就出来了,要实现文件变动监听,jdk7就提供了WatchService,当然还有大名鼎鼎的 commons-io,两个都可以实现,下面贴出commons-io的实现方式

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
69
70
71
@Slf4j
public class TaskChangeWatcher {
private static final String SCRIPT_TYPE = ".groovy";

public static boolean registerWatcher(File file) {
try {
long period = TimeUnit.SECONDS.toMillis(1);

// 使用commons-io的文件观察器,实现文件动态变动的监听
FileAlterationObserver observer =
new FileAlterationObserver(file, FileFilterUtils.and(FileFilterUtils.fileFileFilter()));

observer.addListener(new TaskChangeListener());
FileAlterationMonitor monitor = new FileAlterationMonitor(period, observer);
monitor.start();

return true;
} catch (Exception e) {
log.error("register watcher for script task change error! file: {} e:{}", file.getAbsolutePath(), e);
return false;
}
}

static final class TaskChangeListener extends FileAlterationListenerAdaptor {
private boolean ignore(File file) {
return !file.getName().endsWith(SCRIPT_TYPE);
}

private void addTask(File file) {
ITask script = ScriptLoadUtil.loadScript(file);
if (script == null) {
return;
}

// 更新context中缓存,并启动任务
ScriptTaskDecorate task = new ScriptTaskDecorate(script);
TaskContainer.registerTask(file.getAbsolutePath(), task);
}

@Override
public void onFileCreate(File file) {
if (ignore(file)) {
return;
}
addTask(file);
// 在线程池中执行task
log.info("add task : {}", file.getAbsolutePath());
}

@Override
public void onFileChange(File file) {
if (ignore(file)) {
return;
}
addTask(file);
// 在线程池中执行task
log.info("task changed : {}", file.getName());
}

@Override
public void onFileDelete(File file) {
if (ignore(file)) {
return;
}

// 文件删除,表示需要卸载旧的task
TaskContainer.removeTask(file.getAbsolutePath());
log.info("task delete: {}", file.getName());
}
}
}

上面的实现,核心就是注册目录变动的监听,当出现文件的变化时,判断是否为groovy脚本,然后加载任务,并丢给任务容器进行调度执行

对于文件变动的监听的具体方案和讲解,如有疑问可以参考我之前的一篇博文:

II. 其他

0. 相关

博文:

项目:

1. 一灰灰Bloghttps://liuyueyi.github.io/hexblog

一灰灰的个人博客,记录所有学习和工作中的博文,欢迎大家前去逛逛

2. 声明

尽信书则不如,已上内容,纯属一家之言,因个人能力有限,难免有疏漏和错误之处,如发现bug或者有更好的建议,欢迎批评指正,不吝感激

3. 扫描关注

一灰灰blog

QrCode

知识星球

goals

评论

Your browser is out-of-date!

Update your browser to view this website correctly. Update my browser now

×