問題タブ [akka-persistence]

これは akka 永続性をローカル データベースとして使用することをお勧めしますか? サーバーにアクセスできない場合に備えてデータをローカルに保存する必要があり、私のアプリは akka の上に構築されているため、akka-persistence を使用するのが最も簡単な方法のように思えます。

データは、平均で 10 秒あたり約 1 レコードの割合で埋められます。それでも、akka-persistence が少し異なる目的のために設計されていることを考えると、それは誤用のように思えます。知っておくべき問題はありますか?

Akka Persistence と永続アクターの適用可能性について混乱していますが、永続アクターを使用する必要があるのはいつですか?

特定のショッピング アプリケーションのカート モジュールを例にとると、すべてのユーザーのカート セッションは、それぞれ固有の persistenceId を持つ永続的なアクターになりますか?

実際のアプリケーションでのユーザビリティは? クエリ側は永続アクターの状態をどのように処理しますか? 永続的なアクターが実際のアプリケーションで役に立たないのはいつですか?

状態の保存またはメッセージの保存は同じことですか? そうじゃない？それぞれを使用する必要がある場合、違いは何ですか?

誰かが私にいくつかの例を教えてもらえますか?

私は現在、Play-Scala フレームワークと akka アクターを使用して、データベースでの CRUD アクションが発生したときに電子メールを送信するアプリケーションを開発しています。サーバーの再起動時に問題が発生しました。

Play フレームワークの再起動時または akka スケジューラーの永続化時に akka スケジューラーをリロードし、アプリの再起動時にスケジューラーを実行する方法。たとえば、これは私のコードです。

Akka (バージョン 2.4.0) Persistency と Cassandra プラグイン (バージョン 0.6、 https://github.com/krasserm/akka-persistence-cassandra ) を使用して障害から回復するアプリを作成しようとしました。イベントは何の問題もなく cassandra に保存されていますが、1 つを強制終了してアクターしようとしたため、スーパーバイザーがそれを再起動しましたが、イベントは によって受信されませんreceiveRecover。

問題はプラグイン自体にあるようです。cassandra の代わりに共有 LevelDB を使用しているかのように、回復ステップでイベントが受信されています。

私の永続的なアクターの実装は次のとおりです。

上記のどちらの場合でも、コードは変更されません。誰もこの問題を見たことがありますか?

例として説明

他のコマンドを受け入れる前に、どうすればアクターの状態を初期化できますか?

私にはしつこい俳優がいます。初めて起動するとき (データベースが空)、初期データを保持します。しかし、期待どおりに状態が更新されません。最初のメッセージが処理された後にのみ更新されます。状態の更新後にアクターにメッセージの処理を開始させるにはどうすればよいですか?

アクターコード

テストコード

出力

完全なコード