LagomでAkka Streamsを使ってWebSocketによるサービスを実装してみる - たけぞう瀕死ブログ
Lagomを試してみるシリーズ第6回です。今回はAkka Streamsを使ったストリーミングを試してみました。 まずは簡単な例としてレスポンスをストリームで返すサービスを定義してみます。Responseの型にAkka StreamsのSourceを指定している以外は通常のサービスと変わりません。 ServiceCall<Integer, String, Source<String, ?>> tick(); @Override default Descriptor descriptor() { return named("helloservice").with( pathCall("/tick/:interval", tick()) ).withAutoAcl(true); } 実装は以下のような感じになります。このサービスはリクエストされたメッセージをintervalで指定された間隔で繰
Reactive DDD with Akka
Don't miss: ddd-leaven-akka-v2 - runnable sample e-commerce application built from Akka-DDD artifacts described in this series. When comparing traditional and DDD/CQRS architectures (see my previous article) I said that the goal of DDD model is to decompose complex business domain into manageable pieces taking into account scalability and consistency requirements. What it means is that by bringing
akkameetup で「Malba」の発表しました！！
どうもご無沙汰しておりますbuster84です。今回akkameetupに参加させていただいて、発表しました。運営のドワンゴさんどうもありがとうございました。そのときの資料が以下です。 Job queue in b2b with Akka from Yasuki Okumura toggetterまとめ せっかくなので、いくつかtwitter経由でも質問もいただいていたので、それに答えていきたいと思います。 pullでpollingって、akka使っていいことあったのかな？ Queueを操作しないといけないので、そこの部分でLockせずにデータ操作が行えて、きれいに書けるのはakka使ってよかったと思います。後、Playを業務で使っているのでworkerをakkaのActorで書くのが当たり前だったので自然とakkaを使いました。Pollingに関しましては、Push通知をWorkerに対
akka-persistenceのプラグインをつくろう
akka-persistence.md akka-persistenceのプラグインをつくろう 僕はおくみん @okumin 参考 Persistence — Akka Documentation Akka persistence is 何 Actorの内部状態をストレージへ保存するもの 保存方法はJournalとSnapshotの二種類 Journalは更新イベントを1つずつ発生した順番に保存する MySQLのバイナリログやRedisのAppend Only Fileようなイメージ 更新イベントを最初から最後まで順番に適用していけば、元の状態が復元できる Snapshotはその時点でのActorの状態を直接保存する mysqldumpやRedisのRDB snapshotのようなイメージ ある時点tまでのデータはSnapshotから、残りのデータはJournalから取り出すことでリカバリ
1
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
Akka 2.x roadmap
akka stream and playframework
GitHub - buster84/Malba: Job Queue
GitHub - rkuhn/asynctest: Minimalistic JUnit-style framework for testing asynchronous components
Ray Roestenburg | Code: Unit testing Akka Actors with the TestKit