c# - 如何在部署在不同群集节点上的两个相同参与者之间保持状态？ (akka.net)

如果我具有如下所示的设置，那么说我将有3个节点加入集群，并且我使用了循环池。

var worker = cluster.ActorOf(Props.Create<Worker>().WithRouter(
                 new ClusterRouterPool(
                     new RoundRobinPool(5),
                     new ClusterRouterPoolSettings(30, true, 1))), "worker");

“工作者”只记得它已经处理了多少条消息，如下所示

public class Worker : TypedActor, IHandle<int> {
readonly List<int> processed;

public Worker()
{
    processed = new List<int>();
}

public void Handle(int message)
{
    System.Threading.Thread.Sleep(new Random().Next(1000, 2000));
    processed.Add(message);
    Console.WriteLine("WORKER ({0}) [{1}:{2}], processed: {3}", message, Context.Self.Path, Cluster.Get(Context.System).SelfUniqueAddress.Address.Port, processed.Count);
}

无论如何，是否需要在不同群集节点上的不同参与者之间同步“已处理列表”？这是akka.net.cluster.sharding最终会做的事情吗？还是我在做完全没有意义的事情？

最佳答案

通常，您的问题似乎与JVM akka eventuate和ddata插件提供的问题最接近。在每种情况下，当参与者在同一条数据上进行操作时，一般的副作用是最终的一致性-由于您的状态是“在多台计算机上工作的许多参与者之间共享的”状态，因此在特定时间点的实际状态可能会模糊视您采取哪种演员的观点而异。

目前，您还没有听说过.NET平台上有任何成品可以投入生产的选项，但是Akka.DistributedData（目前正在开发中）将允许您完成任务。这是CRDTs的Akka实现。

CRDT将为您提供访问最终一致的数据类型的权限，这些数据类型可以在整个应用程序的总体状态简洁的情况下，通过分布式集群中的不同节点进行复制。在这种情况下，您可以将processed列表替换为GSet，这将允许您以分布式方式将元素附加到一个数据集。

如果您不想等待，冒险或自行构建CRDT，则可以使用Riak之类的第三方解决方案。

PS：Akka.Cluster.Sharding具有不同的目的，即即使在节点数发生变化时，也可以自动在群集上自动平均分配参与者，以便在当前群集范围中仅存在一个特定参与者的实例。

关于c# - 如何在部署在不同群集节点上的两个相同参与者之间保持状态？ (akka.net)，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/33603157/