Akka.Net ClusterClientReceptionist多节点故障

Question

我试图创建一个示例，创建一个能够处理订单和发送订单的客户端的集群。

为此，我使用ClusterClientReceptionist和ClusterClient在客户端和集群网络之间进行通信。

群集节点的代码：

namespace ClusterNode 
{ 
    class Program 
    { 
     static void Main(string[] args) 
     { 
      bool isFirst = false; 
      using (var mutex = new Mutex(false, "5D14E338-616C-4637-93E7-E59D152DC005", out isFirst)) 
      { 
       using (var system = ActorSystem.Create(nameof(Order), CreateConfig(isFirst))) 
       { 
        var receptionistConfig = ClusterClientReceptionist.DefaultConfig(); 
        system.Settings.InjectTopLevelFallback(receptionistConfig); 

        ClusterRouterPoolSettings settings = new ClusterRouterPoolSettings(int.MaxValue, 1, true); 
        ClusterRouterPool pool = new ClusterRouterPool(new Akka.Routing.RoundRobinPool(1), settings); 

        var aref = system.ActorOf(pool.Props(Props.Create<OrderProcessor>()), nameof(OrderProcessor)); 

        var receptionist = ClusterClientReceptionist.Get(system); 
        receptionist.RegisterService(aref); 

        system.WhenTerminated.Wait(); 
       } 
      } 
     } 

     private static Config CreateConfig(bool isFirst) 
     { 
      var configString = "akka { actor.provider = \"Akka.Cluster.ClusterActorRefProvider, Akka.Cluster\"\n"; 

      var port = (isFirst) ? 8082 : 0; 

      configString += "remote { helios.tcp { hostname = localhost, port = " + port + " } }\n"; 
      configString += "cluster {\n seed-nodes = [\"akka.tcp://" + nameof(Order) + "@localhost:8082\"] \n"; 
      configString += "}\n"; 
      configString += "}"; 
      var config = ConfigurationFactory.ParseString(configString); 
      return config; 
     } 
    } 
} 

客户端代码：

namespace Client 
{ 
    class Program 
    { 
     static void Main(string[] args) 
     { 
      using (var system = ActorSystem.Create(nameof(Client), CreateConfig())) 
      { 
       system.Settings.InjectTopLevelFallback(ClusterClientReceptionist.DefaultConfig()); 
       var client = system.ActorOf(ClusterClient.Props(ClusterClientSettings.Create(system))); 

       bool quit = false; 
       while (!quit) 
       { 
        var str = Console.ReadLine(); 

        if (string.Equals(str, "QUIT", StringComparison.InvariantCultureIgnoreCase)) 
        { 
         quit = true; 
         continue; 
        } 

        Order order = new Order() { Msg = str }; 

        var respTask = client.Ask<Response>(new ClusterClient.Send("/user/OrderProcessor", order)); 
        respTask.Wait(); 

        Console.WriteLine(respTask.Result.ResponseMsg); 
       } 
       system.Terminate(); 
       system.WhenTerminated.Wait(); 
      } 
     } 

     private static Config CreateConfig() 
     { 
      var configString = "akka { actor.provider = \"Akka.Remote.RemoteActorRefProvider, Akka.Remote\"\n"; 
      configString += "remote { helios.tcp { hostname = localhost, port = 0 } }\n"; 
      configString += "cluster {\n seed-nodes = [\"akka.tcp://" + nameof(Order) + "@localhost:8082\"], "; 
      configString += " client { initial-contacts : [ \"akka.tcp://" + nameof(Order) + "@localhost:8082/system/receptionist\" ] }"; 
      configString += " }\n"; 
      configString += "}"; 
      var config = ConfigurationFactory.ParseString(configString); 
      return config; 
     } 
    } 
} 

在i创建一个群集节点和一个客户端的样品工作。 如果我尝试创建多个群集节点，它们相互连接，然后直接dissasociate和群集崩溃。

如果我评论两个folling行集群的工作，但机制接待员/客户端不起作用。

var receptionist = ClusterClientReceptionist.Get(system); 
receptionist.RegisterService(aref);    

他们的配置是否丢失？

Answer 1

今天我只是有同样的问题，并设法通过改变线序列化，而不是默认的Json来解决它。

我不得不从的NuGet在配置添加Akka.Serialization.Wire和更新序列化绑定，你可以看到这在Cluster Tools Example