Akkaによるスレッドの使い方
•Thread •join •Runnable/Callable •Lock •synchronized •Atomic variables •volatile •ThreadLocal •DynamicVariable •ConcurrentHashMap •ConcurrentLinkedQueue •ForkJoin •ThreadPool •Executor/ExecutorService •ExecutionContext •Future •Thread intereference •Memory Consistency error •Dead lock •Live lock •Starvation •InterruptedException •Scheduling
CRDT (Conflict-free Replicated Data Type)を15分で説明してみる - Qiita
CRDTについて勉強したので纏めてみました。15分くらいでざっとわかったつもりになれる感じで纏めてみたつもりです。 全体スライド Slideshareのスライドが埋め込めなかったので、↓からアクセスしてくださいm(-_-)m 下記はスライドの講演の書き下しのようになっているので、スライドだけ見るんじゃなくて、スライドを見ながら文章を読み進めたい方向けです。 CRDTとは 今回は、CRDTというデータ構造について紹介します。CRDTはそもそも2011年にSSS(Stabilization, Safety, and Security of Distributed Systems)という国際会議で、INRIA(フランス国立情報学自動制御研究所)のMarc Shapiro博士によって発表された、比較的新しいモノです。 CRDTは"Conflict-free Replicated Data Type
ChatWorkのリアクティブシステム導入事例から学ぶActor設計プラクティス
Actorの設計プラクティスに関して簡単にまとめた資料です
Configuration • Akka HTTP
Just like any other Akka module, Akka HTTP is configured via Typesafe Config. Usually this means that you provide an application.conf which contains all the application-specific settings that differ from the default ones provided by the reference configuration files from the individual Akka modules. These are the relevant default configuration values for the Akka HTTP modules. akka-http-core copys
Akka-chan's Survival Guide for the Streaming World
Reactive Streams are a cross-company initiative first ignited by Lightbend in 2013, soon to be joined by RxJava and other implementations focused on solving a very similar problem: asynchronous non-blocking stream processing, with guaranteed over-flow protection. Fast forward to 2016 and now these interfaces are part of JSR-266 and proposed for JDK9. In this talk we'll first disambiguate what the
Akka Cluster and Auto-scaling
Akka Cluster allows distributing actors across multiple JVMs with no single point of failure. The document discusses challenges faced with unreachable members and journal lifecycles when operating an Akka Cluster application at scale for 10 months. For unreachables, triggering a scale-in to mark nodes as down and automating restarts addressed the issue. Journals stored in Redis required cleanup to
Akka-PersistenceのserializerとしてKryoを使う - Qiita
とりあえず使えるようにする Akka-PersistenceでKryoをとりあえず使えるようにする設定については以前書いた。 Akka-Persistenceコトハジメ#serializerとしてkryoを使う serializer選択について Akka-PersistenceのPersistentActor#persistで永続化するメッセージはserializeしてから永続化している。 その際に使用できるSerializerを公式が提示している。 External Akka Serializers 以下のページでもserializer選択は大事だと強調しており、こちらではGoogle Protobuf/Apache Thrift/Apache Avroが提示されている。 Picking the right serialization format Protobufは何となく使うのがめん
Akka と Amazon ECS で構築するワーカー基盤：1万件のメッセージを処理させてみた | DevelopersIO
この記事は Scala Advent Calendar 2016 - Qiita19日目の記事です。私は普段、クラスメソッド株式会社でサーバーサイドエンジニアとして働いています。業務のかたわら、「ScalaとAWSを使ってなにができるか」ということを主なテーマにブログを執筆しています：和田祐介 ｜ Developers.IO 今回は、AkkaとAmazon ECSを触ってみたいと思い、実際にワーカーを構築して処理させてみましたので記録を残します。 なにがしたいか ScalaおよびJavaの並列分散処理フレームワークである Akka におけるアプリ実行環境として、Amazon ECSが選択できることを示します。また、ECSのTask数（コンテナ数）によって処理性能がどう変わるか、ひとつの例を出します。どちらも、単純に使ってみたかったというのが動機です。ただ、Akkaは分散環境で動作することを
actors do not compose
Steven Shaw @steshaw Akka Actors may not be what you want http://t.co/rIrtdYzd3s by @noelwelsh. In short, actors do not compose. 2013-03-05 09:15:16 Tony Morris @dibblego @etorreborre @steshaw @noelwelsh Actors are a concurrency primitive, not a solution. They do not compose. See @pchiusano blog too. 2013-03-05 11:51:15
ActorでCircuitBreakerを実装してみた話 - Qiita
実装してみる理由 ReactiveSystemやMicroservices等の文脈で登場するCircuitBreakerについて以前調べた。 [Akka]CircuitBreakerはどう動くのか - Qiita AkkaのCircuitBreakerとNetflixのHystrixの違い - Qiita CircuitBreakerは内部にClose, Open, Half-Openの3つの状態を持ち、さらに非同期処理の実行とその監視という2つの責務を持つ。 状態の管理と責務の分割にはActorが適しているんじゃないかと思ったのがきっかけ。 リポジトリはここ。 petitviolet/supervisor Actor同士のsuperviseしている状態に似ている(と感じた)のでsupervisorという名前にしてある。 気分が乗ったのでMavenCentralにも公開している。 使い方
AkkaのCircuitBreakerとNetflixのHystrixの違い - Qiita
この記事はなに？ マイクロサービス等の文脈で登場するCircuitBreaker。 Scalaで使えるものの代表(要出典)として以下の2つを比較する。 Circuit Breaker - Akka Documentation シンプルだが単機能 Netflix/Hystrix 高機能 ちなみに個人的な好みはAkkaの方。 Scalaから使いやすいのと導入が簡単。 CircuitBreakerってどんなもの？ 以前書いたので貼っておきます。 [Akka]CircuitBreakerはどう動くのか - Qiita 公式サンプルがある。 ちなみに独自のサンプル実装はここ。 akka.pattern.CircuitBreakerに状態遷移の条件に当たるもの(maxFailures, callTimeout, resetTimeout)を渡してインスタンス化する。 そしてCircuitBreaker
[Akka]CircuitBreakerはどう動くのか - Qiita
CircuitBreakerとは 原典にあたるのはMartin Fowler氏のpostになるはず。 リモートへのリクエストが失敗した時にうまいこと障害が伝搬しないようにするためのデザイン。 昨今のMicroserviceアーキテクチャな文脈だと考えやすい。 特定のサービスがダウンしてしまった時に、 それに依存するサービスが引きずられてダウンしてしまわないようにするもの。 Reactiveなシステムを作る上で欠かせない存在になりそう。 CircuitBreakerの状態 監視対象とするサービスの状態に応じてClose, Open, Half-Openの3つをとる。 それぞれの状態の意味はおおざっぱに以下。 Close 正常に動作していて、対象サービスにリクエストを送る状態 Open 対象サービスに異常があり、リクエストを送らない状態 Half-Open そろそろ直ったかな、とちょっとリクエ
![[Akka]CircuitBreakerはどう動くのか - Qiita](https://cdn-ak-scissors.b.st-hatena.com/image/square/ff588dd60dd95b35587bf09cd2dcd7b7137099df/height=288;version=1;width=512/https%3A%2F%2Fqiita-user-contents.imgix.net%2Fhttps%253A%252F%252Fcdn.qiita.com%252Fassets%252Fpublic%252Farticle-ogp-background-412672c5f0600ab9a64263b751f1bc81.png%3Fixlib%3Drb-4.0.0%26w%3D1200%26mark64%3DaHR0cHM6Ly9xaWl0YS11c2VyLWNvbnRlbnRzLmltZ2l4Lm5ldC9-dGV4dD9peGxpYj1yYi00LjAuMCZ3PTk3MiZoPTM3OCZ0eHQ9JTVCQWtrYSU1RENpcmN1aXRCcmVha2VyJUUzJTgxJUFGJUUzJTgxJUE5JUUzJTgxJTg2JUU1JThCJTk1JUUzJTgxJThGJUUzJTgxJUFFJUUzJTgxJThCJnR4dC1hbGlnbj1sZWZ0JTJDdG9wJnR4dC1jb2xvcj0lMjMyMTIxMjEmdHh0LWZvbnQ9SGlyYWdpbm8lMjBTYW5zJTIwVzYmdHh0LXNpemU9NTYmcz1lNjQyNWQ4OTI3M2FhMDA5NjIxODBjZWVkOGFlYTBjNA%26mark-x%3D142%26mark-y%3D57%26blend64%3DaHR0cHM6Ly9xaWl0YS11c2VyLWNvbnRlbnRzLmltZ2l4Lm5ldC9-dGV4dD9peGxpYj1yYi00LjAuMCZoPTc2Jnc9NzcwJnR4dD0lNDBwZXRpdHZpb2xldCZ0eHQtY29sb3I9JTIzMjEyMTIxJnR4dC1mb250PUhpcmFnaW5vJTIwU2FucyUyMFc2JnR4dC1zaXplPTM2JnR4dC1hbGlnbj1sZWZ0JTJDdG9wJnM9ZDYxZmRkYWMzZmExMGFlYTQ5NmMzOWIwMjIxMmZjMDg%26blend-x%3D142%26blend-y%3D486%26blend-mode%3Dnormal%26s%3D83dfef35784f27d5dc9e3d4b7e35d2fc)
Akka HTTP 10.0.0 "X" Released! | Akka
Dear hakkers, Today, we are proud and happy to announce the immediate availability of the fully stable version of Akka HTTP – 10.0.0, charmingly code named “X” by @jonas on gitter! Please note that while the version number changed significantly, the actual surface APIs did not by much. The akka-http-core module was already stable back in Akka 2.4, so it remained binary compatible, and the sources
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
Introduction to Akka HTTP
Scala Days Copenhagen - 8 Akka anti-patterns you'd better be aware of
Core Server API • Akka HTTP
Akka http
Implementing DMM API Gateway in Akka Streams and HTTP
Reactive Microservices with Scala and Akka
Akka Streams adapter — Eventuate