問題タブ [akka-persistence]

akka イベントを json にシリアル化する必要があります。「 Scalaで使用するJSONライブラリは? 」に基づいて、いくつかのライブラリを試しました。シリアライザーはすべての具体的なイベントを認識しないため、ケース クラスとケース オブジェクトで構成されるイベントは、リフレクションを使用してシリアル化する必要があります。json4sが私の要件に最も合っているようです。

json4s を使用する際の問題は、どの実装が使用されていても、オブジェクトの逆シリアル化によって異なるインスタンスが生成されることです。ケース オブジェクトにパターン マッチングを多用しているため、既存のコードがすべて壊れてしまいます。

私の質問は、ケース オブジェクトを保存するときに、scala および akka の永続性で使用できる JSON ライブラリはどれですか?

リフレクションを介してケース オブジェクトの逆シリアル化を正しく処理するライブラリは 1 つでもありますか? - または、誰かが良い回避策を持っていますか?

akkaの永続性を理解し、使用しようとしています。私はこの EventSourcing の世界に不慣れです。

いくつかのアイテムをリストするために ActorRef を取得しようとしていますが、この「アクター名が一意ではありません」というエラーが発生しています。だから私はこのactorSelectionメソッドを使おうとしています。

問題は、パスを要求することです。それはどのパスですか？PlayFramework の Akka.system() を使用している場合、正しいパスを使用していることを確認するにはどうすればよいですか?

現在のコード:

以下の簡単な例を使用して、 Akka 2.4 の新機能PersistentFSM( http://doc.akka.io/docs/akka/2.4.0/scala/persistence.html#Persistent_FSM )をテストしようとしています。

この例では、5 つのランダムな整数を生成し、シーケンスに追加します。私がやりたいことは、データを永続化し、アプリケーションの次の実行時に既存の一連の数字に追加し続けることです。現在のドキュメントPersistentFSMは少し不足しており、これを機能させる明確な方法はありません。何か案は？

TestFSM.scala:

参照.conf:

私の状態が潜在的に非常に大きい (RAM に収まらないとしましょう) いくつかのエンティティのリストであるサービスを実装しようとして、akka 永続化で遊んでいます。ユーザーがすべてのエンティティのすべての履歴を利用できるようにしたいとします。akkaの永続性でそれを行うことはできますか?

現在、私のアクターの状態はそのようになっています。

ご覧のとおり、プロセスのマップはメモリに保存されるため、プロセスの数が多くなると、アプリケーションがメモリ不足になる可能性があります。

私はAkkaを使用し、askメソッドを使用してメッセージを送信していました

しかし、そのアクターを に置き換えようとするとPersistentActor with AtLeastOnceDeliveryLike、フューチャーは完全ではなく、タイムアウトで落ちてしまいます。

ask メソッドで Akka Persistent Actor を使用することは可能ですか?

Akka + Scala を使用して、CQRS + イベント ソーシングを使用してバックエンドを設計しています。成長している状態を処理する方法がわかりません。たとえば、ユーザーのリストが増えていきます。私の理解では、各ユーザーは UserCreated イベントの後に作成され、そのようなイベントは PersistentActor によって再生され、ユーザーはコレクションに保存されます。何かのようなもの：

明らかに、そのような状態は最終的にこのアクターがメモリに保持するには大きくなりすぎるため、何か間違ったことをしていると思います。

このサンプル プロジェクトを見つけました。各ユーザーを異なるアクターが保持し、必要に応じて (イベント履歴から) ロードする必要があるようです。

これを行う正しい方法は何ですか？どうもありがとう。