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: add remote akka impl

Browse Source
This commit is contained in:
tjq 2022-12-31 16:40:33 +08:00
parent c6d90be839
commit 31d2283f99
3 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaCSInitializer.java
View File

@ -50,7 +50,7 @@ public class AkkaCSInitializer implements CSInitializer {
Config akkaFinalConfig = ConfigFactory.parseMap(overrideConfig).withFallback(akkaBasicConfig);
// 启动时绑定当前的 actorSystemName
String actorSystemName = AkkaConstant.fetchActorSystemName(config.getServerType(), false);
String actorSystemName = AkkaConstant.fetchActorSystemName(config.getServerType(), true);
this.actorSystem = ActorSystem.create(actorSystemName, akkaFinalConfig);
// 处理系统中产生的异常情况

6
powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaConstant.java
View File

@ -20,13 +20,13 @@ public class AkkaConstant {
/**
* 获取 actorSystem 名称
* @param serverType 当前服务器类型，powerjob-server 为 server，powerjob-worker 为 worker
* @param reversed 是否反向输出，默认输出当前服务器对应的 actorSystemName，reversed = true 后倒置为目标服务器的 actorSystemName
* @param mine 是否输出当前服务器对应的 actorSystemName，mine = false 后倒置为目标服务器的 actorSystemName
* @return actorSystemName
*/
public static String fetchActorSystemName(ServerType serverType, boolean reversed) {
public static String fetchActorSystemName(ServerType serverType, boolean mine) {
boolean outputServer = serverType == ServerType.SERVER;
if (reversed) {
if (!mine) {
outputServer = !outputServer;
}

2
powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaTransporter.java
View File

@ -48,7 +48,7 @@ public class AkkaTransporter implements Transporter {
public AkkaTransporter(ServerType serverType, ActorSystem actorSystem) {
this.actorSystem = actorSystem;
this.serverType = serverType;
this.targetActorSystemName = AkkaConstant.fetchActorSystemName(serverType, true);
this.targetActorSystemName = AkkaConstant.fetchActorSystemName(serverType, false);
}
@Override