作者: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 的教程。
git clone https://github.com/KFCFans/PowerJob.git
application-daily.properties
来修改并使用。需要修改的地方为数据库配置:spring.datasource.core.jdbc-url
spring.datasource.core.username
spring.datasource.core.password
spring.data.mongodb.uri
以获取完全版体验。OhMyApplication
启动调度服务器,观察启动日志,查看是否启动成功~启动成功后,访问 http://127.0.0.1:7700/ ,如果能顺利出现 Web 界面,则说明调度服务器启动成功!powerjob-agent-test
和控制台密码(用于进入控制台),注册示例应用(当然你也可以注册其他的 appName,只是别忘记在示例程序中同步修改~)
进入示例工程(powerjob-worker-samples),修改配置文件连接 powerjob-server 并编写自己的处理器代码。
修改 powerjob-worker-samples 的启动配置类 OhMySchedulerConfig
,将 appName
修改为刚刚在控制台注册的名称。
编写自己的处理器:在示例工程中新建一个类,继承你想要使用的处理器(各个处理器的介绍可见官方文档[2]),这里为了简单演示,选择使用单机处理器 BasicProcessor
,以下代码示例演示了在线日志功能的使用。
@Slf4j
@Component
public class StandaloneProcessorDemo implements BasicProcessor {
@Override
public ProcessResult process(TaskContext context) throws Exception {
OmsLogger omsLogger = context.getOmsLogger();
omsLogger.info("start process,context is {}.", context);
System.out.println("jobParams is " + context.getJobParams());
return new ProcessResult(true, "process successfully~");
}
}
启动示例程序,即直接运行主类 SampleApplication
,观察控制台输出信息,判断是否启动成功。
调度服务器与示例工程都启动完毕后,再次前往 Web 页面( http://127.0.0.1:7700/ ),进行任务的配置与运行。
TaskContext
对象的 jobParams 属性)(进行一次处理器开发就能理解了)由执行类型(单机、广播和 MapReduce)、处理器类型和处理器参数组成,后两项相互关联。
com.github.kfcfans.oms.processors.demo.MapReduceProcessorDemo
)18#com.github.kfcfans.oms.container.DemoProcessor
)用来标明允许执行任务的机器状态,避开那些摇摇欲坠的机器,0 代表无任何限制。
192.168.1.1:27777,192.168.1.2:27777
选择任务执行失败后报警通知的对象,需要事先录入。
基础的教程到这里也就结束了~更多功能示例可见官方文档[2],工作流、MapReduce、容器等高级特性等你来探索!
本章详细介绍了 PowerJob 的快速入门,根据本文能够快速搭建起本地开发/测试环境。下一章节,我将会对 PowerJob 整体的架构做一个介绍,为后面的技术剖析做准备。
那我们下期再见喽~
“常在河边走,哪有不湿鞋”,然而,这句话在茶卡盐湖却属于奢望。
稍有不慎,隐秘的盐窟便对你敞开怀抱,瞬间将你吞噬~
盐湖如此,人生亦是如此。
难免不幸时,也要对着美好的明天微笑~
[1]
《讲解开源项目》: https://github.com/HelloGitHub-Team/Article
[2]
官方文档: https://www.yuque.com/powerjob/guidence
[3]
在线生成网站: https://cron.qqe2.com/