Erstellen von Akteur pro Domain-Objekt

Question

Ich habe versucht, einen Router mit einem ConsistentHashingPool zu verwenden, um Akteure zu erstellen, um Nachrichten auf der Grundlage einer Objekt-ID zu konsumieren, die in diesem einfachen Fall eine eindeutige Zeichenfolge ist.

Ich möchte einen Akteur pro Domain-Aggregat und das schien wie eine wirklich einfache Art, es zu tun.

Aber das Hashing scheint seltsame Dinge zu tun und Nachrichten an Akteure zu senden, die bereits aus einem anderen Hash-Mapping-Wert hervorgegangen sind.

ActorSystem.ActorOf(
    Props.Create(() => new MyAggergateActor()).WithRouter(
     new ConsistentHashingPool(10) 
     .WithHashMapping(o => (o as MyEvent)?.MyAggregateUniqueId ?? string.Empty) 
     .WithResizer(new DefaultResizer(1, int.MaxValue))), 
    "myAggregateRouter"); 

Auch Werte aus den nrOfInstances scheint zwicken auch Dinge zu brechen, vielleicht die Hash Sinn funktioniert nur über den Satz von Anfang Instanzen und keine neuen Akteure hervorgebracht werden? Ich dachte der Resizer sollte mir hier helfen?

Bitte verzeihen Sie jede Naivität, ich habe gerade erst mit Akka begonnen.

Answer 1

Der Schlüssel hier ist zu verstehen, was Router wirklich tun. Konsistentes Hashing bedeutet, dass die gegebenen Bereiche aller möglichen konsistenten Hash-Werte, jeder der Akteure in dem Pool des Routers verantwortlich ist für die Handhabung von Bereich der Hashes von der gesamten Bandbreite der Möglichkeiten.

Zum Beispiel: Wenn Ihr konsistenter Hashwert einer der Werte aus dem möglichen Bereich von 1-100 sein kann, wird ein konsistenter Hash-Router mit einem Pool von 10 Akteuren Nachrichten mit Hashes von 1-10 an den ersten Akteur delegieren. 20 zu der zweiten und so weiter ... Sobald Sie die Größe des Pools ändern, werden diese Hash-Bereiche für jeden Akteur im Pool angepasst. In diesem Fall wird nach der Änderung der Größe des Pools auf 20 Akteure nun der erste Bereich ausgewählt Serve reicht von 1-5, Sekunde 6-10 etc.

Wenn Sie Schauspieler im laufenden Betrieb erstellen und Nachrichten an sie basierend auf einer Entitäts-ID weiterleiten möchten, glaube ich, dass die Sache, die Sie suchen, ist Akka.Cluster.Sharding .