Welt der Welt HazelCast Karte mit Zuhörer

Question

Mit Hazelcast, stelle ich mir ein gängiges Szenario vor, dass Verbraucher über den aktuellen Zustand der Welt (was gerade in der Karte ist) wissen wollen und dann Updates mit nichts dazwischen verloren.

Stellen Sie sich ein Szenario vor, in dem eine Hazelcast-Karte eine Vielzahl von Daten enthält, die ein Verbraucher (möglicherweise über Rx) den aktuellen Status und dann etwaige Aktualisierungen vom Zuhörer streamen möchte.

Die API schlägt vor, dass wir einen Listener für Updates hinzufügen und die Map als normale ConcurrentMap behandeln. Während ich jedoch die Map aufzählen möchte, können Updates über den Listener kommen, so dass die korrekte Reihenfolge der Elemente schwierig ist.

Wir könnten eine Sperre zwischen dem Map Enumerator und dem Listener teilen, aber das scheint ein bisschen ein Code-Geruch.

Also meine Frage im Allgemeinen ist, wenn wir das SoTW und dann Updates streamen möchten, wie können wir das tun? Ist etwas in Hazelcast eingebaut, das uns helfen kann?

Danke für die Hilfe

Answer 1

Zunächst einmal, und ich denke, es ist nur unglücklicherweise erklärt, hat eine Karte keine Ordnung!

Die zweite Sache, eine Hazelcast-Karte ist eine nicht-Snapshotting, nicht-persistente Datenstruktur. Wie bei einer ConcurrentHashMap werden Änderungen an der Datenstruktur im Iterator und umgekehrt dargestellt.

Ereignisse auf der anderen Seite sind ein vollständig unabhängiges System, insbesondere da Ereignisse asynchron geliefert werden. Es kann also vorkommen, dass die Ereignisse tatsächlich eintreffen, bevor Sie den Iterator auf das gleiche Element oder die andere Runde vorgerückt haben.

Wenn Sie eine bessere Garantie benötigen, iterieren Sie zuerst, fügen Sie den Listener hinzu und übernehmen Sie die Änderungen (Sie müssen in einer zweiten Iteration ein Delta machen) zwischen dem Start des ersten Laufs und Ereignissen, die Sie möglicherweise verpasst haben. Keine wirklich nette Art, damit umzugehen, aber ich glaube nicht, dass es einen anderen Weg gibt.