CQRS+ES勉強会＃１

イベントソーシング・CQRS勉強会 #1 - イベントソーシングやってみた報告会
https://sekiban.connpass.com/event/343929/

にて使用した資料です
スライド内で使われているコードはGithubにて公開されています。
https://github.com/HalsekiRaika/cqrs-es-playground

Transcript

1. RustでCQRS+ESを勉強 してみた話 イベントソーシング・CQRS勉強会 #1 榊崎リシェラ
2. ・矢原一樹 a.k.a 榊崎リシェラ ・X: @RechellaTek ・フリーランス ・Rust / Java ・CQRS+ESを学び始めて１年ぐらい Profile
3. §1. CQRS+ESを実践するにあたって失敗したこと §2. Rustで段階的にCQRS+ESの実装をしてみる §3. まとめ 本日の話題
4. §1. CQRS+ESを実践するにあたって失敗したこと
5. CQRS+ESの出会い ActivityPubというプロトコルを利用したSNSの開発中、大量のレポジトリ が出来上がってCRUD操作がかなり辛くなった。リポジトリの他に案はな いのかと調べているとCQRS+ESに行き着いた 概念は非常にシンプルで、Scalaのサンプルを動かしたりしているうちに 理解が進んだが… §1. CQRS+ESを実践するにあたって失敗したこと
6. CQRS+ES、仕組みは理解できたけど どうやって実装すればいいのか全く分からない…
7. Xで投稿すると… DynamoDBやCosmosDB等を使った方法 アクターモデルを使った方法 CDC+Outboxを使った方法 etc… §1. CQRS+ESを実践するにあたって失敗したこと
8. アクターモデルを使った方法が良さそう
9. なんやかんやあって失敗… アクターモデルを使ったライブラリを再現しようとした → 何を血迷ったのか既存のライブラリ（例えばAkka）を完全再現しよ うとして本筋から外れて勝手に爆発 なんで踏みとどまらなかったんや… CQRS+ESの知識を深めるよりも先にモデルを導入しようとした → 集約のルールやコマンド、イベントがめちゃくちゃになって プロジェクトを爆破 §1. CQRS+ESを実践するにあたって失敗したこと
10. §1. CQRS+ESを実践するにあたって失敗したこと 総じて… 全体的な知識不足 CQRS+ESを実現するために必要な技術 を考えてから実装するべきだった
11. §2. Rustで段階的にCQRS+ESの実装をしてみる 書き込みのロジック編（CQRS+ES）
12. 一旦愚直にコードに起こしてみる
13. https://github.com/HalsekiRaika/cqrs-es-playground 最初の一歩 fn(&Entity, Command) -> Result<Event, Rejection> を意識してuser.handle(input)でイベントを生成して、 user.apply(event)でイベントをデータに適用している 様々な場所で挙げられている通り、イベントのリプレイ が出てくると、リクエスト毎にデータがリプレイされる ことになるためパフォーマンスがかなり悪くなる。 §2. Rustで段階的にCQRS+ESの実装をしてみる
14. https://github.com/HalsekiRaika/cqrs-es-playground User集約に全てがハードコードされている handleは集約の不変参照を使って、コマンドを イベントに変換している applyで始めて可変参照を使って、イベントから データを変更している Command Entity Event handle apply 不変 可変 EventStore §2. Rustで段階的にCQRS+ESの実装をしてみる
15. §2. Rustで段階的にCQRS+ESの実装をしてみる 汎化 大分見通しが良くなった https://github.com/HalsekiRaika/cqrs-es-playground
16. §2. Rustで段階的にCQRS+ESの実装をしてみる Command Entity Event handle apply 不変 可変 EventStore https://github.com/HalsekiRaika/cqrs-es-playground
17. §2. Rustで段階的にCQRS+ESの実装をしてみる 処理が終わると データは解放されてしまう 見逃せない問題 「リクエスト毎にイベントをリプレイして 最新の状態を作り上げてしまう」 ＿人人人人人人人人人＿ ＞ CRUDよりひどい ＜ ￣Y^Y^Y^Y^Y^Y^Y^Y^Y^￣ https://github.com/HalsekiRaika/cqrs-es-playground
18. §2. Rustで段階的にCQRS+ESの実装をしてみる 状態 Actor 「A」 Actor 「…」 MailBox 伏線回収
19. §2. Rustで段階的にCQRS+ESの実装をしてみる 軽量プロセスの導入 https://github.com/HalsekiRaika/cqrs-es-playground
20. §2. Rustで段階的にCQRS+ESの実装をしてみる 軽量プロセスの導入 Receptor::handle(&self, Command) を使うことでコマンドを送信してイベント が貰えるようになった。 Receptor::apply(&self, Event) でイベントを送信して内部状態を更新する ことができるようになった。 Receptor::entrust(&self, Command) でコマンドを送信してそのまま内部状態を 更新することができるようになった。 これだけ特殊でコマンドを送る処理だけし か止まらない。 https://github.com/HalsekiRaika/cqrs-es-playground
21. §3. まとめ
22. §3. まとめ • 失敗点から手法を見出すことができた • アクターモデルを参考にした軽量プロセスによるリプレイ の削減を思いついた
23. ご清聴ありがとうございました！！！