third_codes/PowerJob
1
0
Fork 1
mirror of https://github.com/PowerJob/PowerJob.git synced 2025-07-17 00:00:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: optimize server monitor event

Browse Source
This commit is contained in:
tjq 2022-09-12 21:52:26 +08:00
parent fd562d8ea0
commit 5b223d23ad
4 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
powerjob-server/powerjob-server-core/src/main/java/tech/powerjob/server/core/handler/AbWorkerRequestHandler.java
View File

@ -4,6 +4,7 @@ import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.exception.ExceptionUtils; import org.apache.commons.lang3.exception.ExceptionUtils;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.core.env.Environment; import org.springframework.core.env.Environment;
import tech.powerjob.common.enums.InstanceStatus;
import tech.powerjob.common.request.*; import tech.powerjob.common.request.*;
import tech.powerjob.common.response.AskResponse; import tech.powerjob.common.response.AskResponse;
import tech.powerjob.common.serialize.JsonUtils; import tech.powerjob.common.serialize.JsonUtils;
@ -76,7 +77,7 @@ public abstract class AbWorkerRequestHandler implements IWorkerRequestHandler {
.setJobId(req.getJobId()) .setJobId(req.getJobId())
.setInstanceId(req.getInstanceId()) .setInstanceId(req.getInstanceId())
.setWfInstanceId(req.getWfInstanceId()) .setWfInstanceId(req.getWfInstanceId())
.setInstanceStatus(req.getInstanceStatus()) .setInstanceStatus(InstanceStatus.of(req.getInstanceStatus()))
.setDelayMs(startMs - req.getReportTime()) .setDelayMs(startMs - req.getReportTime())
.setServerProcessStatus(TtReportInstanceStatusEvent.Status.SUCCESS); .setServerProcessStatus(TtReportInstanceStatusEvent.Status.SUCCESS);
try { try {

2
powerjob-server/powerjob-server-core/src/main/java/tech/powerjob/server/core/handler/impl/WorkerRequestAkkaHandler.java
View File

@ -24,7 +24,7 @@ public class WorkerRequestAkkaHandler extends AbstractActor {
public static Props defaultProps(){ public static Props defaultProps(){
return Props.create(WorkerRequestAkkaHandler.class) return Props.create(WorkerRequestAkkaHandler.class)
.withDispatcher("akka.worker-request-actor-dispatcher") .withDispatcher("akka.w-r-c-d")
.withRouter( .withRouter(
new RoundRobinPool(Runtime.getRuntime().availableProcessors() * 4) new RoundRobinPool(Runtime.getRuntime().availableProcessors() * 4)
.withResizer(new DefaultResizer( .withResizer(new DefaultResizer(

3
powerjob-server/powerjob-server-monitor/src/tech/powerjob/server/monitor/events/w2s/TtReportInstanceStatusEvent.java
View File

@ -2,6 +2,7 @@ package tech.powerjob.server.monitor.events.w2s;
import lombok.Setter; import lombok.Setter;
import lombok.experimental.Accessors; import lombok.experimental.Accessors;
import tech.powerjob.common.enums.InstanceStatus;
import tech.powerjob.server.common.SJ; import tech.powerjob.server.common.SJ;
import tech.powerjob.server.monitor.Event; import tech.powerjob.server.monitor.Event;
@ -21,7 +22,7 @@ public class TtReportInstanceStatusEvent implements Event {
private Long wfInstanceId; private Long wfInstanceId;
private int instanceStatus; private InstanceStatus instanceStatus;
private Long delayMs; private Long delayMs;

3
powerjob-server/powerjob-server-starter/src/main/resources/oms-server.akka.conf
View File

@ -25,7 +25,8 @@ akka {
} }
} }
worker-request-actor-dispatcher { # worker-request-core-dispatcher
w-r-c-d {
# Dispatcher is the name of the event-based dispatcher # Dispatcher is the name of the event-based dispatcher
type = Dispatcher type = Dispatcher
# What kind of ExecutionService to use # What kind of ExecutionService to use