基于agenda的Nodejs定时任务管理框架搭建 |
您所在的位置：网站首页 › nodejs定时执行文件 › 基于agenda的Nodejs定时任务管理框架搭建 |
|
0、背景
在大型项目中，定时任务的应用场景越来越广。一般来说，按照微服务的思想，我们会将定时任务单独部署一套服务，核心的业务接口独立到另一个服务中，从而降低相互之间的耦合程度。在需要使用定时任务时，只需要由定时任务微服务定时向核心业务服务发起异步接口调用。 基于NodeJS来搭建这样一套定时任务的话，我们可以使用现有比较成熟的第三方框架来快速搭建，开发人员只需要关注定时任务的实现逻辑即可。 1、agenda 在github搜索nodejs schedule的话会有很多类库，比如node-schedule，agenda，node-cron等。之所以选择agenda的话主要由两个原因：1、agenda接口简单，还可使用人类可读的cron表达式；2、agenda提供了完整的Restful API接口，以及可统计查看操作的UI界面。 这样的话，我们只要在代码中提前定义好定时任务处理逻辑，然后就可以在界面在新增或者移除定时任务安排，而无需重新上线。 下面我们就开始从头搭建基于agenda的定时任务。 2、基础环境准备 MongoDB：agenda需要使用MongoDB来存储定时任务数据。建议大家使用docker进行一建安装，操作简单，删除也方便。只需要docker中搜索mongo，选择安装默认推荐的官方版即可。agenda：定时任务管理框架，文档参考：https://github.com/agenda/agendaagendash：基于agenda的UI管理界面，文档参考：https://github.com/agenda/agendashexpress：用于配合agendash启动WEB服务nirvana-logger：非必选，nodejs日志输出框架，文档参考：https://www.npmjs.com/package/nirvana-logger 3、样例代码 1 // 框架引入 2 var express = require('express'); 3 var app = express(); 4 5 var Agenda = require('agenda'); 6 var Agendash = require('agendash'); 7 var L = require('nirvana-logger')('agenda') 8 9 // agenda初始化，并连接MongoDB 10 var agenda = new Agenda({db: {address: 'mongodb://localhost:32768/agenda'}}); 11 12 // 定义一个测试任务 13 agenda.define('testJob', function (job, done) { 14 try { 15 L('hello',job.attrs.data, new Date()) 16 done() 17 }catch (err) { 18 done(new Error(err)) 19 } 20 }) 21 22 // agenda框架启动 23 agenda.on('ready', function () { 24 L("====>>>agenda启动成功 |
今日新闻 |
推荐新闻 |
| CopyRight 2018-2019 办公设备维修网 版权所有 豫ICP备15022753号-3 |