From f2b9ae222aa6371575c9fec0ee88b03f9d3c94e2 Mon Sep 17 00:00:00 2001 From: tjq Date: Mon, 2 Jan 2023 11:21:49 +0800 Subject: [PATCH] feat: optimize akka remote impl --- .../main/java/tech/powerjob/remote/akka/AkkaCSInitializer.java | 2 +- .../main/java/tech/powerjob/remote/akka/AkkaTransporter.java | 3 +++ 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaCSInitializer.java b/powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaCSInitializer.java index d3350dfe..0565c22e 100644 --- a/powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaCSInitializer.java +++ b/powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaCSInitializer.java @@ -66,7 +66,7 @@ public class AkkaCSInitializer implements CSInitializer { @Override public void bindHandlers(List actorInfos) { - + // TODO: 考虑如何优雅绑定(实在不行就暴力绑定到一个 actor 上,反正可以切协议) } @Override diff --git a/powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaTransporter.java b/powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaTransporter.java index 96d0fd8b..3c1c0c6a 100644 --- a/powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaTransporter.java +++ b/powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaTransporter.java @@ -40,6 +40,9 @@ public class AkkaTransporter implements Transporter { private static final Map SERVER_PATH_MAP = Maps.newHashMap(); private static final Map WORKER_PATH_MAP = Maps.newHashMap(); + /* + HandlerLocation#fullPath -> actorName + */ static { SERVER_PATH_MAP.put("", "");