akka.net永続性を使用して、いくつかのメッセージタイプをSQL Serverデータベースに格納しました。そしてそのビジネスシナリオでは、それは機能します。他のケースでは、私はちょうどC#.netを使用してメッセージを非直列化し、akka.netなしのメッセージプロパティを見たいと思っていました。どうすればそれが可能でしょうか?C#を使用してakka.net永続性メッセージをデシリアライズする
0
A
答えて
0
設定済みのSQLジャーナルを使用すると、すべてのイベントデータは、イベントソースに使用されるテーブルのPayload
列(SQLServerではデフォルトでdbo.EventJournal
)にシリアル化されたバイナリとして格納されます。今後、選択したデータベースがその形式をサポートする場合、この形式をバイナリ形式からJSON形式に変更する可能性があります。
使用するシリアライザに応じて、ペイロード列の内容を単純にデシリアライズするだけで元のイベントを取得できます。 デフォルトのシリアライザは使用しないでください。既に行っている場合は、v1.2の時点ではJSON.NETです。最も顕著なの(機能をタグ付けすることによって使用される)イベントとの合計順序のようなものを記述したイベントジャーナルテーブルキャリーメタデータの
byte[] payload = ...; // get bytes from Payload column
var settings = new JsonSerializerSettings {PreserveReferencesHandling = PreserveReferencesHandling.Objects};
using (var stream = new MemoryStream(payload))
using (var reader = new StreamReader(stream))
{
var domainEvent = JsonConvert.DeserializeObject(reader.ReadToEnd(), settings);
}
その他のフィールドは、永続ID:あなたは、単に保存オブジェクト参照(PreserveReferencesHandling.Objects)とJsonConvert
を使用して、それをデシリアライズすることができます特定のイベント(単一のアクターのコンテキスト内で単調に増加している)のシーケンス番号とを含むことができる。
関連する問題
- 1. Akka.netの永続性(テキスト)
- 2. akka.net永続アクタをテストするには
- 3. Akka.NETの永続性は、IActorRefを含むメッセージの再生をどのように処理しますか?
- 4. Postmanを使用してREST永続性エンドポイントをテストする
- 5. 例外を使用してJPA永続性を設定するEntityManagerの永続性プロバイダーがありません
- 6. AMQPを使用してMessageStoreを使用しないSpring統合アグリゲータのメッセージ永続性?
- 7. 未処理のメッセージのAkka永続性
- 8. メッセージ・サイクル後の値の永続性
- 9. メッセージの永続性 - Redis pub/sub
- 10. ajaxを使用して永続性を持つjqueryのオーダーリスト
- 11. System.Reactiveを使用してメッセージをデシリアライズする
- 12. spring-rabbitmqを使用して永続的なメッセージをマークする方法は?
- 13. C#の - デシリアライズSOAPメッセージ
- 14. Akka永続性:ジャーナル内の「古い」メッセージを削除する
- 15. 永続性からメッセージを削除する方法Hivemqブローカー
- 16. レイクタスクを使用する際に永続性を維持する
- 17. Akka.Net(C#)クラスタ内のすべてのアクタにメッセージを公開
- 18. 永続性ファイルを使用してOracleデータベースを生成するhibernate
- 19. MS SQLサーバを使用するHornetQ永続性
- 20. Javaメッセージングとキューイングシステムで永続性を使用する場合
- 21. EhCacheディスクの永続性 - 任意のオブジェクトを永続化する
- 22. プラグインの永続性を使用して、Javaでreflexionを使用してロードする
- 23. オブジェクト永続性モデルを使用してC#でdynamodb tablenameを動的に変更する方法
- 24. JavaScriptは永続化メカニズムとしてカスタム属性を使用します
- 25. スプライトキットを使用したレベルのメニューの永続性
- 26. EclipseLinkとUCanAccessを使用した永続性のエラー
- 27. SparkJava(jetty 9.4.x)を使用したMongoベースのセッション永続性
- 28. レルムObjective-Cを使用してデータを永続化する方法は?
- 29. 複数の要素を持つXMLファイルをデシリアライズする属性 - 属性はC#。ネット4を使用して
- 30. C#でGoogle TransliterationをデシリアライズするNewtonsoft.Jsonを使用して
イベントをSQL Serverにシリアル化するために使用したシリアライザはどれですか? – Horusiath
私は今までにakka.netに付属しているデフォルトのシリアライズを使用しました –