diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/OhMyApplication.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/OhMyApplication.java index 9b944bf7..e1063978 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/OhMyApplication.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/OhMyApplication.java @@ -1,8 +1,8 @@ package com.github.kfcfans.powerjob.server; import com.github.kfcfans.powerjob.server.common.utils.PropertyUtils; -import com.github.kfcfans.powerjob.server.transport.starter.AkkaStarter; -import com.github.kfcfans.powerjob.server.transport.starter.VertXStarter; +import com.github.kfcfans.powerjob.server.remote.transport.starter.AkkaStarter; +import com.github.kfcfans.powerjob.server.remote.transport.starter.VertXStarter; import lombok.extern.slf4j.Slf4j; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/handler/inner/FriendRequestHandler.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/server/FriendRequestHandler.java similarity index 83% rename from powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/handler/inner/FriendRequestHandler.java rename to powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/server/FriendRequestHandler.java index ea4ba19d..2c246c1b 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/handler/inner/FriendRequestHandler.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/server/FriendRequestHandler.java @@ -1,14 +1,14 @@ -package com.github.kfcfans.powerjob.server.handler.inner; +package com.github.kfcfans.powerjob.server.remote.server; import akka.actor.AbstractActor; import com.alibaba.fastjson.JSONObject; -import com.github.kfcfans.powerjob.common.model.WorkerInfo; +import com.github.kfcfans.powerjob.server.remote.worker.cluster.WorkerInfo; import com.github.kfcfans.powerjob.common.response.AskResponse; import com.github.kfcfans.powerjob.server.common.utils.SpringUtils; -import com.github.kfcfans.powerjob.server.service.ha.WorkerManagerService; -import com.github.kfcfans.powerjob.server.handler.inner.requests.FriendQueryWorkerClusterStatusReq; -import com.github.kfcfans.powerjob.server.handler.inner.requests.Ping; -import com.github.kfcfans.powerjob.server.handler.inner.requests.RemoteProcessReq; +import com.github.kfcfans.powerjob.server.remote.server.request.FriendQueryWorkerClusterStatusReq; +import com.github.kfcfans.powerjob.server.remote.server.request.Ping; +import com.github.kfcfans.powerjob.server.remote.server.request.RemoteProcessReq; +import com.github.kfcfans.powerjob.server.remote.worker.cluster.WorkerClusterManagerService; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.exception.ExceptionUtils; import org.springframework.util.ReflectionUtils; @@ -45,7 +45,7 @@ public class FriendRequestHandler extends AbstractActor { * 处理查询Worker节点的请求 */ private void onReceiveFriendQueryWorkerClusterStatusReq(FriendQueryWorkerClusterStatusReq req) { - Map workerInfo = WorkerManagerService.getActiveWorkerInfo(req.getAppId()); + Map workerInfo = WorkerClusterManagerService.getActiveWorkerInfo(req.getAppId()); AskResponse askResponse = AskResponse.succeed(workerInfo); getSender().tell(askResponse, getSelf()); } diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/ha/DefaultServerElectionService.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/server/election/DefaultServerElectionService.java similarity index 95% rename from powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/ha/DefaultServerElectionService.java rename to powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/server/election/DefaultServerElectionService.java index 6f52ac25..716ba850 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/ha/DefaultServerElectionService.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/server/election/DefaultServerElectionService.java @@ -1,4 +1,4 @@ -package com.github.kfcfans.powerjob.server.service.ha; +package com.github.kfcfans.powerjob.server.remote.server.election; import akka.actor.ActorSelection; import akka.pattern.Patterns; @@ -7,11 +7,11 @@ import com.github.kfcfans.powerjob.common.Protocol; import com.github.kfcfans.powerjob.common.response.AskResponse; import com.github.kfcfans.powerjob.server.extension.LockService; import com.github.kfcfans.powerjob.server.extension.ServerElectionService; -import com.github.kfcfans.powerjob.server.handler.inner.requests.Ping; +import com.github.kfcfans.powerjob.server.remote.server.request.Ping; import com.github.kfcfans.powerjob.server.persistence.core.model.AppInfoDO; import com.github.kfcfans.powerjob.server.persistence.core.repository.AppInfoRepository; -import com.github.kfcfans.powerjob.server.transport.TransportService; -import com.github.kfcfans.powerjob.server.transport.starter.AkkaStarter; +import com.github.kfcfans.powerjob.server.remote.transport.TransportService; +import com.github.kfcfans.powerjob.server.remote.transport.starter.AkkaStarter; import com.google.common.collect.Sets; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/common/redirect/DesignateServer.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/server/redirector/DesignateServer.java similarity index 90% rename from powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/common/redirect/DesignateServer.java rename to powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/server/redirector/DesignateServer.java index 7954b7e6..4f69d8fa 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/common/redirect/DesignateServer.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/server/redirector/DesignateServer.java @@ -1,4 +1,4 @@ -package com.github.kfcfans.powerjob.server.common.redirect; +package com.github.kfcfans.powerjob.server.remote.server.redirector; import java.lang.annotation.ElementType; import java.lang.annotation.Retention; diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/common/redirect/DesignateServerAspect.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/server/redirector/DesignateServerAspect.java similarity index 94% rename from powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/common/redirect/DesignateServerAspect.java rename to powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/server/redirector/DesignateServerAspect.java index 5202862d..d4d789f3 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/common/redirect/DesignateServerAspect.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/server/redirector/DesignateServerAspect.java @@ -1,12 +1,12 @@ -package com.github.kfcfans.powerjob.server.common.redirect; +package com.github.kfcfans.powerjob.server.remote.server.redirector; import akka.pattern.Patterns; import com.alibaba.fastjson.JSONObject; import com.github.kfcfans.powerjob.common.PowerJobException; import com.github.kfcfans.powerjob.common.RemoteConstant; import com.github.kfcfans.powerjob.common.response.AskResponse; -import com.github.kfcfans.powerjob.server.transport.starter.AkkaStarter; -import com.github.kfcfans.powerjob.server.handler.inner.requests.RemoteProcessReq; +import com.github.kfcfans.powerjob.server.remote.server.request.RemoteProcessReq; +import com.github.kfcfans.powerjob.server.remote.transport.starter.AkkaStarter; import com.github.kfcfans.powerjob.server.persistence.core.model.AppInfoDO; import com.github.kfcfans.powerjob.server.persistence.core.repository.AppInfoRepository; import lombok.extern.slf4j.Slf4j; diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/handler/inner/requests/FriendQueryWorkerClusterStatusReq.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/server/request/FriendQueryWorkerClusterStatusReq.java similarity index 84% rename from powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/handler/inner/requests/FriendQueryWorkerClusterStatusReq.java rename to powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/server/request/FriendQueryWorkerClusterStatusReq.java index af772858..eb77d230 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/handler/inner/requests/FriendQueryWorkerClusterStatusReq.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/server/request/FriendQueryWorkerClusterStatusReq.java @@ -1,4 +1,4 @@ -package com.github.kfcfans.powerjob.server.handler.inner.requests; +package com.github.kfcfans.powerjob.server.remote.server.request; import com.github.kfcfans.powerjob.common.OmsSerializable; import lombok.AllArgsConstructor; diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/handler/inner/requests/Ping.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/server/request/Ping.java similarity index 78% rename from powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/handler/inner/requests/Ping.java rename to powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/server/request/Ping.java index 62010c7a..df6d02af 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/handler/inner/requests/Ping.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/server/request/Ping.java @@ -1,4 +1,4 @@ -package com.github.kfcfans.powerjob.server.handler.inner.requests; +package com.github.kfcfans.powerjob.server.remote.server.request; import com.github.kfcfans.powerjob.common.OmsSerializable; import lombok.Data; diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/handler/inner/requests/RemoteProcessReq.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/server/request/RemoteProcessReq.java similarity index 86% rename from powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/handler/inner/requests/RemoteProcessReq.java rename to powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/server/request/RemoteProcessReq.java index ccd264be..022dff34 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/handler/inner/requests/RemoteProcessReq.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/server/request/RemoteProcessReq.java @@ -1,4 +1,4 @@ -package com.github.kfcfans.powerjob.server.handler.inner.requests; +package com.github.kfcfans.powerjob.server.remote.server.request; import com.github.kfcfans.powerjob.common.OmsSerializable; import lombok.Getter; diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/transport/TransportService.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/transport/TransportService.java similarity index 96% rename from powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/transport/TransportService.java rename to powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/transport/TransportService.java index 14ffdc53..53c764e5 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/transport/TransportService.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/transport/TransportService.java @@ -1,4 +1,4 @@ -package com.github.kfcfans.powerjob.server.transport; +package com.github.kfcfans.powerjob.server.remote.transport; import com.github.kfcfans.powerjob.common.OmsSerializable; import com.github.kfcfans.powerjob.common.Protocol; diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/transport/Transporter.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/transport/Transporter.java similarity index 88% rename from powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/transport/Transporter.java rename to powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/transport/Transporter.java index 4dedc78c..debb6bc2 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/transport/Transporter.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/transport/Transporter.java @@ -1,4 +1,4 @@ -package com.github.kfcfans.powerjob.server.transport; +package com.github.kfcfans.powerjob.server.remote.transport; import com.github.kfcfans.powerjob.common.OmsSerializable; import com.github.kfcfans.powerjob.common.Protocol; diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/transport/impl/AkkaTransporter.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/transport/impl/AkkaTransporter.java similarity index 86% rename from powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/transport/impl/AkkaTransporter.java rename to powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/transport/impl/AkkaTransporter.java index 71f8ec39..977ac379 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/transport/impl/AkkaTransporter.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/transport/impl/AkkaTransporter.java @@ -1,4 +1,4 @@ -package com.github.kfcfans.powerjob.server.transport.impl; +package com.github.kfcfans.powerjob.server.remote.transport.impl; import akka.actor.ActorSelection; import akka.pattern.Patterns; @@ -6,8 +6,8 @@ import com.github.kfcfans.powerjob.common.OmsSerializable; import com.github.kfcfans.powerjob.common.Protocol; import com.github.kfcfans.powerjob.common.RemoteConstant; import com.github.kfcfans.powerjob.common.response.AskResponse; -import com.github.kfcfans.powerjob.server.transport.Transporter; -import com.github.kfcfans.powerjob.server.transport.starter.AkkaStarter; +import com.github.kfcfans.powerjob.server.remote.transport.Transporter; +import com.github.kfcfans.powerjob.server.remote.transport.starter.AkkaStarter; import org.springframework.stereotype.Service; import java.time.Duration; diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/transport/impl/HttpTransporter.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/transport/impl/HttpTransporter.java similarity index 92% rename from powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/transport/impl/HttpTransporter.java rename to powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/transport/impl/HttpTransporter.java index 38de6f6c..3e57fc46 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/transport/impl/HttpTransporter.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/transport/impl/HttpTransporter.java @@ -1,12 +1,12 @@ -package com.github.kfcfans.powerjob.server.transport.impl; +package com.github.kfcfans.powerjob.server.remote.transport.impl; import com.github.kfcfans.powerjob.common.OmsSerializable; import com.github.kfcfans.powerjob.common.Protocol; import com.github.kfcfans.powerjob.common.RemoteConstant; import com.github.kfcfans.powerjob.common.response.AskResponse; import com.github.kfcfans.powerjob.common.utils.NetUtils; -import com.github.kfcfans.powerjob.server.transport.Transporter; -import com.github.kfcfans.powerjob.server.transport.starter.VertXStarter; +import com.github.kfcfans.powerjob.server.remote.transport.Transporter; +import com.github.kfcfans.powerjob.server.remote.transport.starter.VertXStarter; import io.vertx.core.Future; import io.vertx.core.Vertx; import io.vertx.core.buffer.Buffer; diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/transport/starter/AkkaStarter.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/transport/starter/AkkaStarter.java similarity index 95% rename from powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/transport/starter/AkkaStarter.java rename to powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/transport/starter/AkkaStarter.java index d8a39177..03a4c695 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/transport/starter/AkkaStarter.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/transport/starter/AkkaStarter.java @@ -1,4 +1,4 @@ -package com.github.kfcfans.powerjob.server.transport.starter; +package com.github.kfcfans.powerjob.server.remote.transport.starter; import akka.actor.ActorSelection; import akka.actor.ActorSystem; @@ -12,8 +12,8 @@ import com.github.kfcfans.powerjob.common.response.AskResponse; import com.github.kfcfans.powerjob.common.utils.NetUtils; import com.github.kfcfans.powerjob.server.common.PowerJobServerConfigKey; import com.github.kfcfans.powerjob.server.common.utils.PropertyUtils; -import com.github.kfcfans.powerjob.server.handler.inner.FriendRequestHandler; -import com.github.kfcfans.powerjob.server.handler.outer.WorkerRequestAkkaHandler; +import com.github.kfcfans.powerjob.server.remote.server.FriendRequestHandler; +import com.github.kfcfans.powerjob.server.remote.worker.handler.impl.WorkerRequestAkkaHandler; import com.google.common.base.Stopwatch; import com.google.common.collect.Maps; import com.typesafe.config.Config; diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/transport/starter/VertXStarter.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/transport/starter/VertXStarter.java similarity index 90% rename from powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/transport/starter/VertXStarter.java rename to powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/transport/starter/VertXStarter.java index 9cd6e9d3..1d70ebda 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/transport/starter/VertXStarter.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/transport/starter/VertXStarter.java @@ -1,10 +1,10 @@ -package com.github.kfcfans.powerjob.server.transport.starter; +package com.github.kfcfans.powerjob.server.remote.transport.starter; import com.github.kfcfans.powerjob.common.OmsConstant; import com.github.kfcfans.powerjob.common.utils.NetUtils; import com.github.kfcfans.powerjob.server.common.PowerJobServerConfigKey; import com.github.kfcfans.powerjob.server.common.utils.PropertyUtils; -import com.github.kfcfans.powerjob.server.handler.outer.WorkerRequestHttpHandler; +import com.github.kfcfans.powerjob.server.remote.worker.handler.impl.WorkerRequestHttpHandler; import com.google.common.base.Stopwatch; import io.vertx.core.Vertx; import lombok.Getter; diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/ha/ClusterStatusHolder.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/worker/cluster/ClusterStatusHolder.java similarity index 98% rename from powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/ha/ClusterStatusHolder.java rename to powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/worker/cluster/ClusterStatusHolder.java index 0a448f74..6d185488 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/ha/ClusterStatusHolder.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/worker/cluster/ClusterStatusHolder.java @@ -1,9 +1,8 @@ -package com.github.kfcfans.powerjob.server.service.ha; +package com.github.kfcfans.powerjob.server.remote.worker.cluster; import com.alibaba.fastjson.JSON; import com.github.kfcfans.powerjob.common.model.DeployedContainerInfo; import com.github.kfcfans.powerjob.common.model.SystemMetrics; -import com.github.kfcfans.powerjob.common.model.WorkerInfo; import com.github.kfcfans.powerjob.common.request.WorkerHeartbeat; import com.google.common.collect.Lists; import com.google.common.collect.Maps; diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/ha/WorkerManagerService.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/worker/cluster/WorkerClusterManagerService.java similarity index 96% rename from powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/ha/WorkerManagerService.java rename to powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/worker/cluster/WorkerClusterManagerService.java index 5a2877a5..ea2687c7 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/ha/WorkerManagerService.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/worker/cluster/WorkerClusterManagerService.java @@ -1,7 +1,6 @@ -package com.github.kfcfans.powerjob.server.service.ha; +package com.github.kfcfans.powerjob.server.remote.worker.cluster; import com.github.kfcfans.powerjob.common.model.DeployedContainerInfo; -import com.github.kfcfans.powerjob.common.model.WorkerInfo; import com.github.kfcfans.powerjob.common.request.WorkerHeartbeat; import com.google.common.collect.Maps; import com.google.common.collect.Sets; @@ -16,7 +15,7 @@ import java.util.*; * @since 2020/4/5 */ @Slf4j -public class WorkerManagerService { +public class WorkerClusterManagerService { // 存储Worker健康信息,appId -> ClusterStatusHolder private static final Map appId2ClusterStatus = Maps.newConcurrentMap(); diff --git a/powerjob-common/src/main/java/com/github/kfcfans/powerjob/common/model/WorkerInfo.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/worker/cluster/WorkerInfo.java similarity index 80% rename from powerjob-common/src/main/java/com/github/kfcfans/powerjob/common/model/WorkerInfo.java rename to powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/worker/cluster/WorkerInfo.java index 4aaba661..7d4b069c 100644 --- a/powerjob-common/src/main/java/com/github/kfcfans/powerjob/common/model/WorkerInfo.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/worker/cluster/WorkerInfo.java @@ -1,5 +1,7 @@ -package com.github.kfcfans.powerjob.common.model; +package com.github.kfcfans.powerjob.server.remote.worker.cluster; +import com.github.kfcfans.powerjob.common.model.DeployedContainerInfo; +import com.github.kfcfans.powerjob.common.model.SystemMetrics; import com.github.kfcfans.powerjob.common.request.WorkerHeartbeat; import lombok.Data; diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/handler/outer/WorkerRequestHandler.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/worker/handler/WorkerRequestHandler.java similarity index 91% rename from powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/handler/outer/WorkerRequestHandler.java rename to powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/worker/handler/WorkerRequestHandler.java index f5f6ea01..8d836d96 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/handler/outer/WorkerRequestHandler.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/worker/handler/WorkerRequestHandler.java @@ -1,7 +1,7 @@ -package com.github.kfcfans.powerjob.server.handler.outer; +package com.github.kfcfans.powerjob.server.remote.worker.handler; import com.github.kfcfans.powerjob.common.InstanceStatus; -import com.github.kfcfans.powerjob.common.model.WorkerInfo; +import com.github.kfcfans.powerjob.server.remote.worker.cluster.WorkerInfo; import com.github.kfcfans.powerjob.common.request.*; import com.github.kfcfans.powerjob.common.response.AskResponse; import com.github.kfcfans.powerjob.common.utils.JsonUtils; @@ -13,7 +13,7 @@ import com.github.kfcfans.powerjob.server.persistence.core.model.JobInfoDO; import com.github.kfcfans.powerjob.server.persistence.core.repository.ContainerInfoRepository; import com.github.kfcfans.powerjob.server.persistence.core.repository.JobInfoRepository; import com.github.kfcfans.powerjob.server.service.InstanceLogService; -import com.github.kfcfans.powerjob.server.service.ha.WorkerManagerService; +import com.github.kfcfans.powerjob.server.remote.worker.cluster.WorkerClusterManagerService; import com.github.kfcfans.powerjob.server.service.instance.InstanceManager; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.BeanUtils; @@ -51,7 +51,7 @@ public class WorkerRequestHandler { * @param heartbeat 心跳包 */ public void onReceiveWorkerHeartbeat(WorkerHeartbeat heartbeat) { - WorkerManagerService.updateStatus(heartbeat); + WorkerClusterManagerService.updateStatus(heartbeat); } /** @@ -123,7 +123,7 @@ public class WorkerRequestHandler { if (!jobInfo.getAppId().equals(appId)) { askResponse = AskResponse.failed("Permission Denied!"); }else { - List sortedAvailableWorker = WorkerManagerService.getAvailableWorkers(appId, jobInfo.getMinCpuCores(), jobInfo.getMinMemorySpace(), jobInfo.getMinDiskSpace()) + List sortedAvailableWorker = WorkerClusterManagerService.getAvailableWorkers(appId, jobInfo.getMinCpuCores(), jobInfo.getMinMemorySpace(), jobInfo.getMinDiskSpace()) .stream().map(WorkerInfo::getAddress).collect(Collectors.toList()); askResponse = AskResponse.succeed(sortedAvailableWorker); } diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/handler/outer/WorkerRequestAkkaHandler.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/worker/handler/impl/WorkerRequestAkkaHandler.java similarity index 92% rename from powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/handler/outer/WorkerRequestAkkaHandler.java rename to powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/worker/handler/impl/WorkerRequestAkkaHandler.java index 00ebef8f..af5fd39f 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/handler/outer/WorkerRequestAkkaHandler.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/worker/handler/impl/WorkerRequestAkkaHandler.java @@ -1,4 +1,4 @@ -package com.github.kfcfans.powerjob.server.handler.outer; +package com.github.kfcfans.powerjob.server.remote.worker.handler.impl; import akka.actor.AbstractActor; import com.github.kfcfans.powerjob.common.request.*; @@ -7,7 +7,7 @@ import lombok.extern.slf4j.Slf4j; import java.util.Optional; -import static com.github.kfcfans.powerjob.server.handler.outer.WorkerRequestHandler.getWorkerRequestHandler; +import static com.github.kfcfans.powerjob.server.remote.worker.handler.WorkerRequestHandler.getWorkerRequestHandler; /** * 处理 Worker 请求 diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/handler/outer/WorkerRequestHttpHandler.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/worker/handler/impl/WorkerRequestHttpHandler.java similarity index 94% rename from powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/handler/outer/WorkerRequestHttpHandler.java rename to powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/worker/handler/impl/WorkerRequestHttpHandler.java index ccb6ad6e..83f7de23 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/handler/outer/WorkerRequestHttpHandler.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/remote/worker/handler/impl/WorkerRequestHttpHandler.java @@ -1,4 +1,4 @@ -package com.github.kfcfans.powerjob.server.handler.outer; +package com.github.kfcfans.powerjob.server.remote.worker.handler.impl; import com.github.kfcfans.powerjob.common.OmsConstant; import com.github.kfcfans.powerjob.common.ProtocolConstant; @@ -21,7 +21,7 @@ import org.apache.commons.lang3.exception.ExceptionUtils; import java.util.Properties; -import static com.github.kfcfans.powerjob.server.handler.outer.WorkerRequestHandler.getWorkerRequestHandler; +import static com.github.kfcfans.powerjob.server.remote.worker.handler.WorkerRequestHandler.getWorkerRequestHandler; /** * WorkerRequestHandler diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/ContainerService.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/ContainerService.java index 7ba8cbd3..84f20ca0 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/ContainerService.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/ContainerService.java @@ -10,14 +10,14 @@ import com.github.kfcfans.powerjob.common.utils.CommonUtils; import com.github.kfcfans.powerjob.common.utils.JsonUtils; import com.github.kfcfans.powerjob.common.utils.NetUtils; import com.github.kfcfans.powerjob.common.utils.SegmentLock; -import com.github.kfcfans.powerjob.server.transport.starter.AkkaStarter; +import com.github.kfcfans.powerjob.server.remote.transport.starter.AkkaStarter; import com.github.kfcfans.powerjob.server.common.constans.ContainerSourceType; import com.github.kfcfans.powerjob.server.common.constans.SwitchableStatus; import com.github.kfcfans.powerjob.server.common.utils.OmsFileUtils; import com.github.kfcfans.powerjob.server.persistence.core.model.ContainerInfoDO; import com.github.kfcfans.powerjob.server.persistence.core.repository.ContainerInfoRepository; import com.github.kfcfans.powerjob.server.persistence.mongodb.GridFsManager; -import com.github.kfcfans.powerjob.server.service.ha.WorkerManagerService; +import com.github.kfcfans.powerjob.server.remote.worker.cluster.WorkerClusterManagerService; import com.github.kfcfans.powerjob.server.extension.LockService; import com.github.kfcfans.powerjob.server.web.request.SaveContainerInfoRequest; import com.google.common.collect.ArrayListMultimap; @@ -125,7 +125,7 @@ public class ContainerService { } ServerDestroyContainerRequest destroyRequest = new ServerDestroyContainerRequest(container.getId()); - WorkerManagerService.getActiveWorkerInfo(container.getAppId()).keySet().forEach(akkaAddress -> { + WorkerClusterManagerService.getActiveWorkerInfo(container.getAppId()).keySet().forEach(akkaAddress -> { ActorSelection workerActor = AkkaStarter.getWorkerActor(akkaAddress); workerActor.tell(destroyRequest, null); }); @@ -247,7 +247,7 @@ public class ContainerService { containerInfoRepository.saveAndFlush(container); // 开始部署(需要分批进行) - Set workerAddressList = WorkerManagerService.getActiveWorkerInfo(container.getAppId()).keySet(); + Set workerAddressList = WorkerClusterManagerService.getActiveWorkerInfo(container.getAppId()).keySet(); if (workerAddressList.isEmpty()) { remote.sendText("SYSTEM: there is no worker available now, deploy failed!"); return; @@ -284,9 +284,9 @@ public class ContainerService { * @return 拼接好的可阅读字符串 */ public String fetchDeployedInfo(Long appId, Long containerId) { - List infoList = WorkerManagerService.getDeployedContainerInfos(appId, containerId); + List infoList = WorkerClusterManagerService.getDeployedContainerInfos(appId, containerId); - Set aliveWorkers = WorkerManagerService.getActiveWorkerInfo(appId).keySet(); + Set aliveWorkers = WorkerClusterManagerService.getActiveWorkerInfo(appId).keySet(); Set deployedList = Sets.newLinkedHashSet(); List unDeployedList = Lists.newLinkedList(); diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/DispatchService.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/DispatchService.java index 8c24b544..a33e2982 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/DispatchService.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/DispatchService.java @@ -1,16 +1,16 @@ package com.github.kfcfans.powerjob.server.service; import com.github.kfcfans.powerjob.common.*; -import com.github.kfcfans.powerjob.common.model.WorkerInfo; +import com.github.kfcfans.powerjob.server.remote.worker.cluster.WorkerInfo; import com.github.kfcfans.powerjob.common.request.ServerScheduleJobReq; import com.github.kfcfans.powerjob.server.persistence.core.model.InstanceInfoDO; import com.github.kfcfans.powerjob.server.persistence.core.model.JobInfoDO; import com.github.kfcfans.powerjob.server.persistence.core.repository.InstanceInfoRepository; -import com.github.kfcfans.powerjob.server.service.ha.WorkerManagerService; +import com.github.kfcfans.powerjob.server.remote.worker.cluster.WorkerClusterManagerService; import com.github.kfcfans.powerjob.server.service.instance.InstanceManager; import com.github.kfcfans.powerjob.server.service.instance.InstanceMetadataService; import com.github.kfcfans.powerjob.server.service.lock.local.UseSegmentLock; -import com.github.kfcfans.powerjob.server.transport.TransportService; +import com.github.kfcfans.powerjob.server.remote.transport.TransportService; import com.google.common.base.Splitter; import com.google.common.collect.Lists; import com.google.common.collect.Sets; @@ -107,7 +107,7 @@ public class DispatchService { } // 获取当前所有可用的Worker - List allAvailableWorker = WorkerManagerService.getSortedAvailableWorkers(jobInfo.getAppId(), jobInfo.getMinCpuCores(), jobInfo.getMinMemorySpace(), jobInfo.getMinDiskSpace()); + List allAvailableWorker = WorkerClusterManagerService.getSortedAvailableWorkers(jobInfo.getAppId(), jobInfo.getMinCpuCores(), jobInfo.getMinMemorySpace(), jobInfo.getMinDiskSpace()); allAvailableWorker.removeIf(worker -> { // 空,则全部不过滤 @@ -120,7 +120,7 @@ public class DispatchService { }); if (CollectionUtils.isEmpty(allAvailableWorker)) { - String clusterStatusDescription = WorkerManagerService.getWorkerClusterStatusDescription(jobInfo.getAppId()); + String clusterStatusDescription = WorkerClusterManagerService.getWorkerClusterStatusDescription(jobInfo.getAppId()); log.warn("[Dispatcher-{}|{}] cancel dispatch job due to no worker available, clusterStatus is {}.", jobId, instanceId, clusterStatusDescription); instanceInfoRepository.update4TriggerFailed(instanceId, FAILED.getV(), currentRunningTimes, current, current, RemoteConstant.EMPTY_ADDRESS, SystemInstanceResult.NO_WORKER_AVAILABLE, dbInstanceParams, now); diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/InstanceLogService.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/InstanceLogService.java index 18fde5c4..36f964c7 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/InstanceLogService.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/InstanceLogService.java @@ -7,7 +7,7 @@ import com.github.kfcfans.powerjob.common.model.InstanceLogContent; import com.github.kfcfans.powerjob.common.utils.CommonUtils; import com.github.kfcfans.powerjob.common.utils.NetUtils; import com.github.kfcfans.powerjob.common.utils.SegmentLock; -import com.github.kfcfans.powerjob.server.common.redirect.DesignateServer; +import com.github.kfcfans.powerjob.server.remote.server.redirector.DesignateServer; import com.github.kfcfans.powerjob.server.common.utils.OmsFileUtils; import com.github.kfcfans.powerjob.server.persistence.StringPage; import com.github.kfcfans.powerjob.server.persistence.core.model.JobInfoDO; diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/JobService.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/JobService.java index 290f87fc..eed840c8 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/JobService.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/JobService.java @@ -8,7 +8,7 @@ import com.github.kfcfans.powerjob.common.request.http.SaveJobInfoRequest; import com.github.kfcfans.powerjob.common.response.JobInfoDTO; import com.github.kfcfans.powerjob.server.common.SJ; import com.github.kfcfans.powerjob.server.common.constans.SwitchableStatus; -import com.github.kfcfans.powerjob.server.common.redirect.DesignateServer; +import com.github.kfcfans.powerjob.server.remote.server.redirector.DesignateServer; import com.github.kfcfans.powerjob.server.common.utils.CronExpression; import com.github.kfcfans.powerjob.server.common.utils.QueryConvertUtils; import com.github.kfcfans.powerjob.server.persistence.core.model.InstanceInfoDO; diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/instance/InstanceService.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/instance/InstanceService.java index 660f3b6f..bad1d98c 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/instance/InstanceService.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/instance/InstanceService.java @@ -2,13 +2,13 @@ package com.github.kfcfans.powerjob.server.service.instance; import com.github.kfcfans.powerjob.common.*; import com.github.kfcfans.powerjob.common.model.InstanceDetail; -import com.github.kfcfans.powerjob.common.model.WorkerInfo; +import com.github.kfcfans.powerjob.server.remote.worker.cluster.WorkerInfo; import com.github.kfcfans.powerjob.common.request.ServerQueryInstanceStatusReq; import com.github.kfcfans.powerjob.common.request.ServerStopInstanceReq; import com.github.kfcfans.powerjob.common.response.AskResponse; import com.github.kfcfans.powerjob.common.response.InstanceInfoDTO; import com.github.kfcfans.powerjob.server.common.constans.InstanceType; -import com.github.kfcfans.powerjob.server.common.redirect.DesignateServer; +import com.github.kfcfans.powerjob.server.remote.server.redirector.DesignateServer; import com.github.kfcfans.powerjob.server.common.utils.QueryConvertUtils; import com.github.kfcfans.powerjob.server.common.utils.timewheel.TimerFuture; import com.github.kfcfans.powerjob.server.persistence.core.model.InstanceInfoDO; @@ -16,9 +16,9 @@ import com.github.kfcfans.powerjob.server.persistence.core.model.JobInfoDO; import com.github.kfcfans.powerjob.server.persistence.core.repository.InstanceInfoRepository; import com.github.kfcfans.powerjob.server.persistence.core.repository.JobInfoRepository; import com.github.kfcfans.powerjob.server.service.DispatchService; -import com.github.kfcfans.powerjob.server.service.ha.WorkerManagerService; +import com.github.kfcfans.powerjob.server.remote.worker.cluster.WorkerClusterManagerService; import com.github.kfcfans.powerjob.server.service.id.IdGenerateService; -import com.github.kfcfans.powerjob.server.transport.TransportService; +import com.github.kfcfans.powerjob.server.remote.transport.TransportService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Service; @@ -115,7 +115,7 @@ public class InstanceService { 不可靠通知停止 TaskTracker 假如没有成功关闭,之后 TaskTracker 会再次 reportStatus,按照流程,instanceLog 会被更新为 RUNNING,开发者可以再次手动关闭 */ - Optional workerInfoOpt = WorkerManagerService.getWorkerInfo(instanceInfo.getAppId(), instanceInfo.getTaskTrackerAddress()); + Optional workerInfoOpt = WorkerClusterManagerService.getWorkerInfo(instanceInfo.getAppId(), instanceInfo.getTaskTrackerAddress()); if (workerInfoOpt.isPresent()) { ServerStopInstanceReq req = new ServerStopInstanceReq(instanceId); WorkerInfo workerInfo = workerInfoOpt.get(); @@ -252,7 +252,7 @@ public class InstanceService { return detail; } - Optional workerInfoOpt = WorkerManagerService.getWorkerInfo(instanceInfoDO.getAppId(), instanceInfoDO.getTaskTrackerAddress()); + Optional workerInfoOpt = WorkerClusterManagerService.getWorkerInfo(instanceInfoDO.getAppId(), instanceInfoDO.getTaskTrackerAddress()); if (workerInfoOpt.isPresent()) { WorkerInfo workerInfo = workerInfoOpt.get(); ServerQueryInstanceStatusReq req = new ServerQueryInstanceStatusReq(instanceId); diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/timing/CleanService.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/timing/CleanService.java index 60bbcdfb..c7654aeb 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/timing/CleanService.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/timing/CleanService.java @@ -6,7 +6,7 @@ import com.github.kfcfans.powerjob.server.common.utils.OmsFileUtils; import com.github.kfcfans.powerjob.server.persistence.core.repository.InstanceInfoRepository; import com.github.kfcfans.powerjob.server.persistence.core.repository.WorkflowInstanceInfoRepository; import com.github.kfcfans.powerjob.server.persistence.mongodb.GridFsManager; -import com.github.kfcfans.powerjob.server.service.ha.WorkerManagerService; +import com.github.kfcfans.powerjob.server.remote.worker.cluster.WorkerClusterManagerService; import com.github.kfcfans.powerjob.server.extension.LockService; import com.google.common.annotations.VisibleForTesting; import com.google.common.base.Stopwatch; @@ -62,7 +62,7 @@ public class CleanService { public void timingClean() { // 释放本地缓存 - WorkerManagerService.cleanUp(); + WorkerClusterManagerService.cleanUp(); // 释放磁盘空间 cleanLocal(OmsFileUtils.genLogDirPath(), instanceInfoRetentionDay); diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/timing/InstanceStatusCheckService.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/timing/InstanceStatusCheckService.java index 785d0cff..6de92f91 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/timing/InstanceStatusCheckService.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/timing/InstanceStatusCheckService.java @@ -5,7 +5,7 @@ import com.github.kfcfans.powerjob.common.SystemInstanceResult; import com.github.kfcfans.powerjob.common.TimeExpressionType; import com.github.kfcfans.powerjob.common.WorkflowInstanceStatus; import com.github.kfcfans.powerjob.server.common.constans.SwitchableStatus; -import com.github.kfcfans.powerjob.server.transport.starter.AkkaStarter; +import com.github.kfcfans.powerjob.server.remote.transport.starter.AkkaStarter; import com.github.kfcfans.powerjob.server.persistence.core.model.*; import com.github.kfcfans.powerjob.server.persistence.core.repository.*; import com.github.kfcfans.powerjob.server.service.DispatchService; diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/timing/schedule/OmsScheduleService.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/timing/schedule/OmsScheduleService.java index 2f59b9bf..b0e25727 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/timing/schedule/OmsScheduleService.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/timing/schedule/OmsScheduleService.java @@ -2,7 +2,7 @@ package com.github.kfcfans.powerjob.server.service.timing.schedule; import com.github.kfcfans.powerjob.common.InstanceStatus; import com.github.kfcfans.powerjob.common.TimeExpressionType; -import com.github.kfcfans.powerjob.server.transport.starter.AkkaStarter; +import com.github.kfcfans.powerjob.server.remote.transport.starter.AkkaStarter; import com.github.kfcfans.powerjob.server.common.constans.SwitchableStatus; import com.github.kfcfans.powerjob.server.common.utils.CronExpression; import com.github.kfcfans.powerjob.server.persistence.core.model.AppInfoDO; @@ -14,7 +14,7 @@ import com.github.kfcfans.powerjob.server.persistence.core.repository.JobInfoRep import com.github.kfcfans.powerjob.server.persistence.core.repository.WorkflowInfoRepository; import com.github.kfcfans.powerjob.server.service.DispatchService; import com.github.kfcfans.powerjob.server.service.JobService; -import com.github.kfcfans.powerjob.server.service.ha.WorkerManagerService; +import com.github.kfcfans.powerjob.server.remote.worker.cluster.WorkerClusterManagerService; import com.github.kfcfans.powerjob.server.service.instance.InstanceService; import com.github.kfcfans.powerjob.server.service.instance.InstanceTimeWheelService; import com.github.kfcfans.powerjob.server.service.workflow.WorkflowInstanceManager; @@ -84,7 +84,7 @@ public class OmsScheduleService { } List allAppIds = allAppInfos.stream().map(AppInfoDO::getId).collect(Collectors.toList()); // 清理不需要维护的数据 - WorkerManagerService.clean(allAppIds); + WorkerClusterManagerService.clean(allAppIds); // 调度 CRON 表达式 JOB try { diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/workflow/WorkflowService.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/workflow/WorkflowService.java index 71bda99d..9195b87e 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/workflow/WorkflowService.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/workflow/WorkflowService.java @@ -7,7 +7,7 @@ import com.github.kfcfans.powerjob.common.request.http.SaveWorkflowRequest; import com.github.kfcfans.powerjob.common.response.WorkflowInfoDTO; import com.github.kfcfans.powerjob.server.common.SJ; import com.github.kfcfans.powerjob.server.common.constans.SwitchableStatus; -import com.github.kfcfans.powerjob.server.common.redirect.DesignateServer; +import com.github.kfcfans.powerjob.server.remote.server.redirector.DesignateServer; import com.github.kfcfans.powerjob.server.common.utils.CronExpression; import com.github.kfcfans.powerjob.server.common.utils.WorkflowDAGUtils; import com.github.kfcfans.powerjob.server.persistence.core.model.WorkflowInfoDO; diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/web/controller/ContainerController.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/web/controller/ContainerController.java index c6b24d92..b3cca57c 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/web/controller/ContainerController.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/web/controller/ContainerController.java @@ -2,7 +2,7 @@ package com.github.kfcfans.powerjob.server.web.controller; import com.github.kfcfans.powerjob.common.OmsConstant; import com.github.kfcfans.powerjob.common.response.ResultDTO; -import com.github.kfcfans.powerjob.server.transport.starter.AkkaStarter; +import com.github.kfcfans.powerjob.server.remote.transport.starter.AkkaStarter; import com.github.kfcfans.powerjob.server.common.constans.ContainerSourceType; import com.github.kfcfans.powerjob.server.common.constans.SwitchableStatus; import com.github.kfcfans.powerjob.server.common.utils.ContainerTemplateGenerator; diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/web/controller/ServerController.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/web/controller/ServerController.java index ee883a14..57d46d3b 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/web/controller/ServerController.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/web/controller/ServerController.java @@ -8,8 +8,8 @@ import com.github.kfcfans.powerjob.common.utils.NetUtils; import com.github.kfcfans.powerjob.server.extension.ServerElectionService; import com.github.kfcfans.powerjob.server.persistence.core.model.AppInfoDO; import com.github.kfcfans.powerjob.server.persistence.core.repository.AppInfoRepository; -import com.github.kfcfans.powerjob.server.service.ha.WorkerManagerService; -import com.github.kfcfans.powerjob.server.transport.TransportService; +import com.github.kfcfans.powerjob.server.remote.worker.cluster.WorkerClusterManagerService; +import com.github.kfcfans.powerjob.server.remote.transport.TransportService; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestParam; @@ -56,9 +56,9 @@ public class ServerController { res.put("communicationSystemInfo", transportService.getProtocol2Transporter()); res.put("serverTime", CommonUtils.formatTime(System.currentTimeMillis())); res.put("serverTimeZone", TimeZone.getDefault().getDisplayName()); - res.put("appIds", WorkerManagerService.getAppId2ClusterStatus().keySet()); + res.put("appIds", WorkerClusterManagerService.getAppId2ClusterStatus().keySet()); if (debug) { - res.put("appId2ClusterInfo", JSON.parseObject(JSON.toJSONString(WorkerManagerService.getAppId2ClusterStatus()))); + res.put("appId2ClusterInfo", JSON.parseObject(JSON.toJSONString(WorkerClusterManagerService.getAppId2ClusterStatus()))); } return ResultDTO.success(res); diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/web/controller/SystemInfoController.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/web/controller/SystemInfoController.java index d2fcb1b4..f11cbffb 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/web/controller/SystemInfoController.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/web/controller/SystemInfoController.java @@ -5,12 +5,12 @@ import akka.pattern.Patterns; import com.github.kfcfans.powerjob.common.InstanceStatus; import com.github.kfcfans.powerjob.common.OmsConstant; import com.github.kfcfans.powerjob.common.RemoteConstant; -import com.github.kfcfans.powerjob.common.model.WorkerInfo; +import com.github.kfcfans.powerjob.server.remote.worker.cluster.WorkerInfo; import com.github.kfcfans.powerjob.common.response.AskResponse; import com.github.kfcfans.powerjob.common.response.ResultDTO; import com.github.kfcfans.powerjob.common.utils.JsonUtils; -import com.github.kfcfans.powerjob.server.transport.starter.AkkaStarter; -import com.github.kfcfans.powerjob.server.handler.inner.requests.FriendQueryWorkerClusterStatusReq; +import com.github.kfcfans.powerjob.server.remote.transport.starter.AkkaStarter; +import com.github.kfcfans.powerjob.server.remote.server.request.FriendQueryWorkerClusterStatusReq; import com.github.kfcfans.powerjob.server.common.constans.SwitchableStatus; import com.github.kfcfans.powerjob.server.persistence.core.model.AppInfoDO; import com.github.kfcfans.powerjob.server.persistence.core.repository.AppInfoRepository; diff --git a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/web/response/WorkerStatusVO.java b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/web/response/WorkerStatusVO.java index 31232f78..a1e75b78 100644 --- a/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/web/response/WorkerStatusVO.java +++ b/powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/web/response/WorkerStatusVO.java @@ -1,7 +1,7 @@ package com.github.kfcfans.powerjob.server.web.response; import com.github.kfcfans.powerjob.common.model.SystemMetrics; -import com.github.kfcfans.powerjob.common.model.WorkerInfo; +import com.github.kfcfans.powerjob.server.remote.worker.cluster.WorkerInfo; import lombok.Data; import lombok.NoArgsConstructor;