PowerJob源码学习

最新推荐文章于 2025-03-09 17:00:33 发布

12334567890

最新推荐文章于 2025-03-09 17:00:33 发布

阅读量729

点赞数

分类专栏： java 文章标签：学习服务器 java

本文链接：https://blog.csdn.net/github_39083395/article/details/128645902

版权

本文深入分析了PowerJob的服务端启动类Initializer和客户端启动类PowerJobWorker，讲解了其初始化过程，包括日志上报、健康上报等。介绍了scheduleAtFixedRate和scheduleWithFixedDelay的区别，并探讨了客户端与服务端的Akka服务交互，如TaskTrackerActor、ProcessorTrackerActor和WorkerActor的角色与功能。此外，还提到了服务端Vert服务和日志模块的实现细节，如Actor消息模式、重试工具类及Google Cache的使用。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

*******************************PowerJob学习*********************************************************
服务端启动类：tech.powerjob.server.core.handler.impl.Initializer：
知识点：
@Component
@ConditionalOnExpression("'${execution.env}'!='test'") + @PostConstruct 程序启动后会初始化加载这个注释下的方法

客户端启动类：tech.powerjob.worker.PowerJobWorker ：
知识点：实现了InitializingBean类的afterPropertiesSet()方法
初始化包括了【日志上报，健康上报，客户端发送http请求获取appName是否可用】。

上报方式：
workerRuntime.getExecutorManager().getCoreExecutor().scheduleAtFixedRate(new WorkerHealthReporter(workerRuntime), 0, config.getHealthReportInterval(), TimeUnit.SECONDS);
workerRuntime.getExecutorManager().getCoreExecutor().scheduleWithFixedDelay(omsLogHandler.logSubmitter, 0, 5, TimeUnit.SECONDS);

scheduleAtFixedRate：执行任务开始计时，不算是否执行完，间隔一定时间，执行下一次。
scheduleWithFixedDelay：执行完上一次任务，间隔一定时间，执行下一次。
四个参数说明：（
command：执行线程
initialDelay：初始化延时
period：两次开始执行最小间隔时间
unit：计时单位
）

客户端akka服务：
1：[【TaskTrackerActor】worker 上报 task 执行情况，服务端调度任务请求（一次任务处理的入口），WorkerMapTaskRequest
ProcessorTracker 定时向 TaskTracker 上报健康状态，服务器要求任务实例停止执行请求，
服务器查询实例运行状态、需要返回详细的运行数据
.match(ProcessorReportTaskStatusReq.class, this::onReceiveProcessorReportTaskStatusReq)
.match(ServerScheduleJobReq.class, this::onReceiveServerScheduleJobReq)
调度中心分发任务请求 .match(ProcessorMapTaskRequest.class, this::onReceiveProcessorMapTaskRequest)
.match(ProcessorTrackerStatusReportReq.class, this::onReceiveProcessorTrackerStatusReportReq)
.match(ServerStopInstanceReq.class, this::onReceiveServerStopInstanceReq)
.match(ServerQueryInstanceStatusReq.class, this::onReceiveServerQueryInstanceStatusReq)
2：【ProcessorTrackerActor】 TaskTracker 派发 task 进行执行，TaskTracker 停止 ProcessorTracker，释放相关资源

最低0.47元/天解锁文章