简单计划任务框架 sdb-schedule
发布于 4 年前 作者 shudingbo 3285 次浏览 最后一次编辑是 3 年前 来自 分享

简洁计划任务框架

add.jpg

安装

Using npm:

$ npm install sdb-schedule

To run the tests:

$ node test.js

描述

本模块是一个简洁的计划任务框架模块(基于**node-schedule**)。 你只需要简单的配置,就可以获得功能强大的计划任务控制功能。此模块提供了下列功能:

  • 使用 Cron 格式 灵活的配置计划任务
  • 可以在执行中,动态控制计划任务的开/关/更新
  • 任务的配置脚本可以放在系统任意位置。

APP(UI)

现在我们实现了一个APP sdb-schedule-ui,用于管理schedule( 只支持 redis drv ),你可以在这里下载 download.

  • 基于 Eletron 实现

更新记录

1.0.8

  • 实现功能 #4,可以单独编辑Job的配置

1.0.6

修复 #1

1.0.5

修复 使用RedisDrv时,Job启动计时记录不正确的问题。

1.0.4

实现 Redisdrv(redis 配置文件管理模块),使用node-redis

1.0.3

重构代码,独立配置文件管理为单独的模块。现在能够更容易支持多个类型的配置文件管理。例如 使用 File/Redis/sql Server 存储管理计划任务的配置文件。

  • 增加 文件类型(FileDrv.js) 配置文件管理模块。

配置 及 配置 管理

配置文件

配置文件采用json格式,定义了每个计划任务,结构大致如下:

{
	"schedules":{
		"enableRoom":{
			"cron":"*/5 * * * * *",
			"fun":"./sc/enableRoom.js",
			"switch":true
		},
		"disableRoom":{
			"cron":"*/5 * * * * *",
			"fun":"./sc/disableRoom.js",
			"switch":false
		}
	}
}

所有的工作任务在schedules域进行定义,每一个任务都有一个json对象定义,必须包含下面3个域(cron,fun和switch)。

  • cron , 定义任务的 cron 格式的字符串。
  • fun , 是一个nodejs函数模块,在计划任务触发时调用。
  • switch, 开关,告诉 sdb-schedules 是开还是关。

The cron format consists of:

*    *    *    *    *    *
┬    ┬    ┬    ┬    ┬    ┬
│    │    │    │    │    |
│    │    │    │    │    └ day of week (0 - 7) (0 or 7 is Sun)
│    │    │    │    └───── month (1 - 12)
│    │    │    └────────── day of month (1 - 31)
│    │    └─────────────── hour (0 - 23)
│    └──────────────────── minute (0 - 59)
└───────────────────────── second (0 - 59, OPTIONAL)

Unsupported Cron Features

Currently, W (nearest weekday), L (last day of month/week), and # (nth weekday of the month) are not supported. Most other features supported by popular cron implementations should work just fine.

cron-parser is used to parse crontab instructions.

配置文件管理

自1.0.3版本起,配置文件管理作为了单独的模块,现在缺省提供了 文件类配置文件管理模块(FileDrv),您可以根据需求扩展配置文件管理模块,例如使用redis 管理配置模块。 我们可以在创建sdb-schedule时通过传入参数,指定使用的配置管理模块:

var app = sc({ 
				'cfg_drv':'filedrv.js',
				'cfg_opt':{
					'cfgFile':"./config.json"
				}
			});
  • cfg_drv,指定使用的配置文件管理模块;
  • cfg_opt,指定配置文件管理模块的参数,会在构造配置文件管理模块式,作为参数传入。

FileDrv ( File Configuration Manager Module)

Using file manager the configuration.

cfg_opt:

  • cfgFile,Config file path;

RedisDrv ( Redis Configuration Manager Module)

Using Redis manager the configuration.

cfg_opt:

  • host, redis server’s host;
  • port, redis server’s port;
  • keyPre, redis key’s pre;
  • checkInterval, check config interval, mill sec;

API

I am schedule framework, have two part:Frame and JobPlugin.

  • Frame, admin the Job Plugin.
  • Job Plugin, Implement the schedule Job work.

Work flow like this:

  1. var sc = require("sdb-schedule"); Require module sdb-schedules.
  2. var app = sc( { 'cfg_drv':'filedrv.js','cfg_opt':{} }); Construct sc object and give her ths config file path.
  3. app.run(); Call run() start work.
  4. app.stop(); Stop work.

Frame

Run

Run all job that switch is true.
No parames.

stop

Stop all job. No parames.

updateJob

updateJob(name,scCfg )

  • name, Job’s name, string.
  • scCfg, Job’s cfg.
    {
    	"corn":<* * * * * * *>,
        "fun":"",
        "switch":true|false
    }

Update Job,

  • If cron or fun has change,and the job is running,then restart job.
  • If job not run,only change the config.
  • If job not exist, add new job,but can’t run it ,you must manual run it( call runJob );

runJob

runJob(name)

  • name, Job’s name, string.

stopJob

stopJob(name)

  • name, Job’s name, string.

getConfig

getConfig(name)

  • name, Job’s name, string.
  • return, json’s format object.

JobPlugin

Job Plugin,是一个单独的node模块,直接作为函数导出,必须包含三个参数: module.exports = function(sc,job,isStop){}

  • sc, sdb-schedule 对象实例,你可以通过它调用 提供的相关函数;
  • job, json对象,当前任务的相关信息;
  • isStop, boolean类型,true 表示是任务停止启动的回调;false 表示是任务运行的回调.
  • return 'msg string’, 字符串,函数可以返回一个字符串,用于标记任务执行的具体情况。 如果使用了 RedisDrv 配置管理器R,这个消息将会被记录到redis,您可以通过查询redis,检测任务具体的执行信息。

下面是一个完整的例子,例子说明了下列特色:

  • 动态改变任务属性
  • 自己停止自己
module.exports = function(sc,job,isStop){
	if( isStop === true ){
		return stop( sc,job );
	}else{
		return run( sc,job );
	}
};

var g_cnt = 0;
function run( sc,job)
{
    console.log( 'run ' + 20002222 );
	g_cnt++;
	console.log( job['name'] + "  " + g_cnt +" : " + job['cron'] );
	if( g_cnt > 10 ){
		sc.stopJob( job['name'] );  // example stop this job
	}
	if( g_cnt > 3 ){
		sc.updateJob( job['name'], {
			"cron":"*/2 * * * * *",
			"fun":"./sc/enableRoom.js",
			"switch":true
		});
	}

    return 'Run OK';
}

function stop(sc,job)
{
	console.log( 'stop ' + 20002222 );
    return;
}

Copyright and license

Copyright 2016+ shudingbo

Licensed under the [MIT License].

2 回复

更新记录, 1.0.4 配置文件管理独立为单独的模块:可以通过 文件,redis等对配置进行管理。

我都准备好代码准备提问,看到了你的帖子,还是把我的问题贴出来:

var schedule = require(‘node-schedule’); var r = new schedule.RecurrenceRule(); r.second = [5,10,20,30,40,50,59]; var l = schedule.scheduleJob(r, function(){ doschedule(); }); function doschedule(){ var rule = new schedule.RecurrenceRule();
rule.second = [10,20,30,40,50,59]; var k = schedule.scheduleJob(rule, function(){ //疑问一:这儿settimeout 无效,怎样实现延时 }); setTimeout(function() { k.cancel(); //疑问二:如何指定取消某一个计划。上一个计划60秒还没执行完,我需要取消。 }, 60000); }

先看看你的项目,我的疑问二应该能得到解决,关于我这儿代码里 node延时的方法没找到合适的。

回到顶部