は、アッカ・メッセージがユニーク/いくつかの属性

Question

でバージョン管理、私は次のユースケースを持っていることを確認します：

俳優がkey:valueペアで構成され、いくつかの外部ソースからのデータを消費します。その後、彼らはkeyと最新のvalueでいくつかのアクションを実行する必要がある俳優に渡され、古いものをスキップします。基本的に私はメールボックスを1の容量の "サブトピック"に分割しようとしています。 Akkaでそのようなことは可能ですか？そうでない場合、私はどのような選択肢を検討すべきですか？

Answer 1

私はあなたが必要と思うのは、より新しいメッセージが優先される優先メールボックスです。 PriorityMailboxのデフォルトの実装を見てください。

それは（ドキュメントの例に基づいて）このようなものになります。

ここ versionToInt

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 
    }) 

メッセージ（優先順位が高い）の新しいバージョンの低い一部のInt値を返す必要がありますが、2 - Infで言います範囲。

その後、あなたの俳優で処理された最高のバージョンを追跡し、そのバージョンより古い他のすべてのメッセージをドロップすることができます。あなたの俳優にはbecomeまたはvarを使用してください。

送信されたメッセージの順序はAkkaによって保証されますが、最終的に送信者と送信者の間で遅延が発生し、処理されるメッセージに影響します。