Akkaイベントバスチュートリアル

Question

akkaでイベントバスを使用する方法に関する良いチュートリアル/説明はありますか？ Akkaのドキュメントを読んだことがありますが、イベントバスの使い方を理解するのが難しいと感じています

Answer 1

良いチュートリアルがあるかどうかわかりませんが、イベントストリームを使用すると役に立つ可能性があります。しかし、高いレベルでは、イベントストリームは、アプリが持つpub/subタイプの要件を満たすための優れたメカニズムです。たとえば、システムのユーザーの残高を更新するユースケースがあるとします。残高には頻繁にアクセスするため、パフォーマンスを向上させるために残高をキャッシュすることに決めました。天びんが更新されると、ユーザーが天びんでスレッショルドを越えているかどうかを確認して確認し、そうであれば電子メールで通知します。重量が重くてユーザーの応答が遅くなるため、キャッシュのドロップまたはバランスのしきい値のチェックのいずれかをメインの残高更新コールに直接関連付ける必要はありません。この例では、AccountCacherとLowBalanceChecker役者を

//Message and event classes 
case class UpdateAccountBalance(userId:Long, amount:Long) 
case class BalanceUpdated(userId:Long) 

//Actor that performs account updates 
class AccountManager extends Actor{ 
    val dao = new AccountManagerDao 

    def receive = { 
    case UpdateAccountBalance(userId, amount) => 
     val res = for(result <- dao.updateBalance(userId, amount)) yield{ 
     context.system.eventStream.publish(BalanceUpdated(userId)) 
     result     
     } 

     sender ! res 
    } 
} 

//Actor that manages a cache of account balance data 
class AccountCacher extends Actor{ 
    val cache = new AccountCache 

    override def preStart = { 
    context.system.eventStream.subscribe(context.self, classOf[BalanceUpdated]) 
    } 

    def receive = { 
    case BalanceUpdated(userId) => 
     cache.remove(userId) 
    } 
} 

//Actor that checks balance after an update to warn of low balance 
class LowBalanceChecker extends Actor{ 
    val dao = new LowBalanceDao 

    override def preStart = { 
    context.system.eventStream.subscribe(context.self, classOf[BalanceUpdated]) 
    } 

    def receive = { 
    case BalanceUpdated(userId) => 
     for{ 
     balance <- dao.getBalance(userId) 
     theshold <- dao.getBalanceThreshold(userId) 
     if (balance < threshold) 
     }{ 
     sendBalanceEmail(userId, balance) 
     } 
    } 
} 

を両方BalanceUpdatedイベントのクラス型でeventStreamにサブスクライブ：あなたはそうのような要件の特定のセットをモデル化することができます。このイベントがストリームに公開されたイベントの場合、これらのアクターインスタンスの両方で受信されます。次に、AccountManagerでは、残高更新が成功すると、ユーザーのためにBalanceUpdatedイベントが発生します。これが並行して行われると、そのメッセージはAccountCacherとLowBalanceCheckerの両方のメールボックスに配信され、キャッシュとのバランスが落ち、アカウントのしきい値がチェックされ、電子メールが送信される可能性があります。

さて、あなただけのこれらの他の2人の俳優と直接通信するAccountManagerに直接tell (!)電話を入れている可能性がありますが、一つはそれがあまりにも密接残高更新のこれら二つの「副作用」をカップリングされる可能性があります主張することができ、それらのこと詳細の種類は必ずしもAccountManagerに属するとは限りません。純粋に副作用（コア・ビジネス・フロー自体の一部ではない）として発生する必要がある追加のもの（検査、更新など）が発生する可能性がある条件がある場合、イベント・ストリームは良い方法かもしれません募集されているイベントとそのイベントに反応する必要のある人物を切り離すことができます。

Answer 2

ActorSystemごとに存在するEventBusがあります。このEventBusはEvent Streamと呼ばれ、system.eventStreamを呼び出して取得できます。

ActorSystemはlogging、Dead LettersおよびCluster Eventsを含む多くのものに対してイベントストリームを使用します。

独自のパブリッシュ/サブスクライブ要件にイベントストリームを使用することもできます。たとえば、イベントストリームはテスト中に役立ちます。特定のイベント（ログイベントなど）については、Test KitのtestActorをイベントストリームに登録してください。expectとすることができます。これは何かが起こったときに別のアクタにメッセージを送信しない場合でもテストでイベントを期待する必要がある場合に特に便利です。

イベントストリームは1つのActorSystem内でのみ動作することに注意してください。ストリームに公開されているリモーティングイベントを使用している場合は、デフォルトではリモートシステムには行きません（自分でサポートを追加することもできます）。

イベントストリームを使用しない場合は、理論的には別のEventBusを作成することができます。

イベントバス用のより良いドキュメントは、Akka 2.2のために働いていますので、this ticketが完了したら再びチェックしてください。