Machen Akka Nachrichten einzigartige/von einigem Attribute versioniert

Question

Ich habe den folgenden Anwendungsfall:

Ein Schauspieler Daten aus einer externen Quelle verbraucht, die aus key:value Paaren bestehen. Dann werden sie an einen Schauspieler übergeben, der einige Aktionen an key und die letzte value durchführen muss, wobei die älteren übersprungen werden. Grundsätzlich versuche ich die Mailbox in "Unterthemen" mit einer Kapazität von 1 zu teilen. Ist so etwas überhaupt mit Akka möglich? Wenn nicht, welche Alternativen sollte ich berücksichtigen?

Answer 1

Ich denke, was Sie brauchen, ist eine Priorität Postfach, wo die neueren Nachrichten höhere Priorität haben. Sehen Sie sich die Standardimplementierung PriorityMailbox an.

Es könnte wie folgt aussehen (basierend auf dem Beispiel aus der Dokumentation):

import akka.dispatch.PriorityGenerator 
import akka.dispatch.UnboundedStablePriorityMailbox 
import com.typesafe.config.Config 

type Version = // Long, Date, Timestamp, smth else - must be ordered 
case class MyMessage(key: String, value: String, version: Version) 

class MyPrioMailbox(settings: ActorSystem.Settings, config: Config) 
    extends UnboundedStablePriorityMailbox(
    // Create a new PriorityGenerator, lower prio means more important 
    PriorityGenerator { 
     case MyMessage(_, _, version) => versionToInt(version) 

     // PoisonPill when no other left 
     case PoisonPill => 1 // or Int.MaxValue - 2 

     // We default to 1, which is in between high and low 
     case otherwise  => 0 // or Int.MaxValue - 1 
    }) 

Hier versionToInt sollten einige Int Wert zurück, der niedriger ist nach neueren Versionen von Nachrichten (höhere Priorität), sagen wir in 2 - Inf Angebot.

Anschließend können Sie die höchste Version verfolgen, die in Ihrem Akteur verarbeitet wurde, und alle anderen Nachrichten löschen, die älter als diese Version sind. Verwenden Sie entweder become oder nur einen var in Ihrem Schauspieler dafür.

Es ist erwähnenswert, dass die Reihenfolge der gesendeten Nachrichten von Akka garantiert wird, aber letztendlich hängt es vom Sender ab, in welcher Reihenfolge sie gesendet werden und von den Verzögerungen dazwischen, was sich darauf auswirken würde, welche Nachrichten verarbeitet werden.