MCP Client To Server 구현 by RemoteActor

Author: psmon

McpServer/Program.cs

@@ -16,7 +16,12 @@
     .WithStdioServerTransport()
     .WithToolsFromAssembly();
 
-builder.Services.AddSingleton<ActorService>();
+//var serverMode = args.Contains("--serverMode"); // 실행 인자에서 serverMode 설정
+
+var clientMode = args.Contains("--clientMode"); // 실행 인자에서 clientMode 설정
+
+builder.Services.AddSingleton<ActorService>(provider => new ActorService(!clientMode));
+
 builder.Services.AddHostedService<ActorServiceInitializer>();
 
 await builder.Build().RunAsync();

McpServer/Properties/launchSettings.json

@@ -0,0 +1,8 @@
+{
+  "profiles": {
+    "McpServer": {
+      "commandName": "Project",
+      "commandLineArgs": "--serverMode"
+    }
+  }
+}

McpServer/Service/ActorService.cs

@@ -1,4 +1,6 @@
 using Akka.Actor;
+using Akka.Configuration;
+
 using McpServer.Actor;
 using McpServer.Actor.Model;
 
@@ -14,23 +16,57 @@ public class ActorService
 
     public IActorRef HistoryActor { get; set; }
 
-    public ActorService()
+    public ActorService(bool serverMode)
     {
-        actorSystem = ActorSystem.Create("MyActorSystem");
-        
-        SearchActor = actorSystem.ActorOf<SearchActor>("search-actor");
-        RecordActor = actorSystem.ActorOf<RecordActor>("record-actor");
-        HistoryActor = actorSystem.ActorOf<HistoryActor>("history-actor");
-        
-        RecordActor.Tell(new SetHistoryActorCommand()
+        Console.WriteLine($"ActorService initialized in {(serverMode ? "Server" : "Client")} mode.");
+
+        // HOCON 설정
+        var config = ConfigurationFactory.ParseString($@"
+            akka {{
+                actor {{
+                    provider = ""Akka.Remote.RemoteActorRefProvider, Akka.Remote""
+                }}
+                remote {{
+                    dot-netty.tcp {{
+                        hostname = ""127.0.0.1""
+                        port = {(serverMode ? 5500 : 0)} // 서버 모드일 때만 포트 5500 사용
+                    }}
+                }}
+            }}
+        ");
+
+        actorSystem = ActorSystem.Create("MyActorSystem", config);
+
+        if (serverMode)
         {
-            HistoryActor = HistoryActor
-        });
-        
-        SearchActor.Tell(new SetHistoryActorCommand()
+            // 서버 모드일 때만 특정 액터를 초기화
+            SearchActor = actorSystem.ActorOf<SearchActor>("search-actor");
+            RecordActor = actorSystem.ActorOf<RecordActor>("record-actor");
+            HistoryActor = actorSystem.ActorOf<HistoryActor>("history-actor");
+
+            RecordActor.Tell(new SetHistoryActorCommand()
+            {
+                HistoryActor = HistoryActor
+            });
+
+            SearchActor.Tell(new SetHistoryActorCommand()
+            {
+                HistoryActor = HistoryActor
+            });
+        }
+        else
         {
-            HistoryActor = HistoryActor
-        });
+            // 클라이언트 모드일 때 원격 액터 참조
+            var remoteAddress = "akka.tcp://MyActorSystem@127.0.0.1:5500";
+            SearchActor = actorSystem.ActorSelection($"{remoteAddress}/user/search-actor")
+                .ResolveOne(TimeSpan.FromSeconds(3)).Result;
+
+            RecordActor = actorSystem.ActorSelection($"{remoteAddress}/user/record-actor")
+                .ResolveOne(TimeSpan.FromSeconds(3)).Result;
+
+            HistoryActor = actorSystem.ActorSelection($"{remoteAddress}/user/history-actor")
+                .ResolveOne(TimeSpan.FromSeconds(3)).Result;
+        }
     }
 
 }