本文适合有 JAVA 基础知识的人群
作者:HelloGitHub-Salieri
HelloGitHub 推出的《讲解开源项目》[1]系列。
项目地址:
https://github.com/KFCFans/PowerJob
PowerJob 的设计目标为企业级的分布式任务调度平台,即成为公司内部的调度中间件。整个公司统一部署调度中心 powerjob-server,旗下所有业务线应用只需要依赖 'powerjob-worker' 即可接入获取任务调度与分布式计算能力。
因此,PowerJob 由调度服务器(powerjob-server)和执行器(powerjob-worker)两部分组成,powerjob-server 负责提供 Web 服务和完成任务的调度,powerjob-worker 则负责执行用户所编写的任务代码,同时提供分布式计算能力。
以下为在本地开发环境快速搭建并试用 PowerJob 的教程。
1 . 创建数据库(不需要建表,只需要创建数据库)powerjob-daily
2 . 修改配置文件,配置文件的说明官方文档[2]写的非常详细,此处不再赘述。由于是在本地 IDE 搭建测试环境,因此我们选择使用开发环境的配置文件 Application-daily.properties 来修改并使用。需要修改的地方为数据库配置:
3 . 完成配置文件的修改后,可以直接通过启动类 OhMyApplication 启动调度服务器,观察启动日志,查看是否启动成功~启动成功后,访问 http://127.0.0.1:7700/ ,如果能顺利出现 Web 界面,则说明调度服务器启动成功!
4 . 注册应用:点击主页应用注册按钮,填入 powerjob-agent-test 和控制台密码(用于进入控制台),注册示例应用(当然你也可以注册其他的 appName,只是别忘记在示例程序中同步修改~)
进入示例工程(powerjob-worker-samples),修改配置文件连接 powerjob-server 并编写自己的处理器代码。
1 . 修改 powerjob-worker-samples 的启动配置类 OhMySchedulerConfig,将 appName 修改为刚刚在控制台注册的名称。
2 . 编写自己的处理器:在示例工程中新建一个类,继承你想要使用的处理器(各个处理器的介绍可见官方文档[3]),这里为了简单演示,选择使用单机处理器 BasicProcessor ,以下代码示例演示了在线日志功能的使用。
3 . 启动示例程序,即直接运行主类 SampleApplication,观察控制台输出信息,判断是否启动成功。
调度服务器与示例工程都启动完毕后,再次前往 Web 页面( http://127.0.0.1:7700/ ),进行任务的配置与运行。
1 . 在首页输入框输入配置的应用名称,成功操作后会正式进入前端管理界面。
2 . 点击任务管理 -> 新建任务(右上角),开始创建任务。
3 . 完成任务创建后,即可在控制台看到刚才创建的任务,如果觉得等待调度太过于漫长,可以直接点击运行按钮,立即运行本任务。
4 . 前往任务示例边栏,查看任务的运行状态和在线日志
由执行类型(单机、广播和 MapReduce)、处理器类型和处理器参数组成,后两项相互关联。
用来标明允许执行任务的机器状态,避开那些摇摇欲坠的机器,0 代表无任何限制。
选择任务执行失败后报警通知的对象,需要事先录入。
基础的教程到这里也就结束了~更多功能示例可见官方文档[5],工作流、MapReduce、容器等高级特性等你来探索!
本章详细介绍了 PowerJob 的快速入门,根据本文能够快速搭建起本地开发/测试环境。下一章节,我将会对PowerJob 整体的架构做一个介绍,为后面的技术剖析做准备。
那我们下期再见喽~
“常在河边走,哪有不湿鞋”,然而,这句话在茶卡盐湖却属于奢望。
稍有不慎,隐秘的盐窟便对你敞开怀抱,瞬间将你吞噬~
盐湖如此,人生亦是如此。
难免不幸时,也要对着美好的明天微笑~
[1]《讲解开源项目》: https://github.com/HelloGitHub-Team/Article
[2] 官方文档: https://www.yuque.com/ohmyscheduler/guidence/bdvp1u#4DTFD
[3] 官方文档: https://www.yuque.com/ohmyscheduler/guidence/hczm7m
[4] 在线生成网站: https://cron.qqe2.com/
[5] 官方文档: https://www.yuque.com/ohmyscheduler/guidence/ysug77