こんにちは、CA ProFit-X の松村です。 私たちのプロダクトでは広告配信のシステムにAkkaを使っていて、アプリケーションはAWS/Docker環境に配備して運用しています。今回はAkkaのCluster Shardingという拡張を使って、主にAWS環境を想定した簡単なリアルタイム集計システム(即時集計系)をつくってみたのでその内容をご紹介します。 下ではAkka Cluster Shardingについて簡単に説明した後、試作した即時集計系の実装・永続化と配備について説明します。その後、ワークロードとノード数を増減させた実験とその結果について説明します。 Akka Cluster Sharding について Akka ClusterはGossip Protocolとφ Accrual Failure Detectorという手法に基づいた非中央集権的なノード群構築を行うAkka拡張
こんにちは! Smalgo の阿川です。 先日、Spray, Akka, Scala といった技術のノウハウを共有しましょう、という趣旨の社内勉強会で発表する機会がありましたので、そのスライドを公開します。 スライド Actor と Future 僕は Scala 歴はこの時点で 2 ヶ月ほどで scala.concurrent.Future を使ったプログラミングの経験も浅いものでしたので、Akka の Actor と Future の使い分けにはかなり悩みました。最初は全て Actor で実装しようとしていたのですが、そのためにはアクターモデルそのものや Typed Actor など、学習しなければならない要素が多すぎると判断して、最終的にスライドにある方針に落ち着きました。 この方針に決めてからは設計で悩むことも減りサクサクと実装が進みましたので、これからはじめて Akka を触って
Akka, Finagle and Storm are 3 new open source frameworks for distributed parallel and concurrent programming. They all run on the JVM and work well with Java and Scala. They are very useful for many common problems: Real-time analytics Complex website with different input and outputs Finance Multiplayer games Big data Akka, Finagle and Storm are all very elegant solutions optimized for different p
About Us News, articles, code snippets and more by the hakkers in the Akka community. Links: Akka Home Akka Docs I’ve seen a question pop up a number of times on the Akka Mailing List that looks something like: “How do you tell Akka to shut down the ActorSystem when everything’s finished?” It turns out that there’s no magical flag for this, no configuration setting, no special callback you can reg
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
処理を実行中です
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く