Akka HTTP の Graceful な Shutdown の方法 または私は如何にして OSS のコードを読んでいるか - astamuse Lab
どうもみなさまおはこんばんちわー。アプリケーションエンジニアの池田 (@yukung) です。3 度目の登場になります。 2020 年始まりましたね！時が経つのは早いもので私も入社してはや 1 年が経ちましたが、最近はエンジニアだけに限らず、様々な分野で専門を持つ方々が弊社に入社してきてくださっていて、そんな方々の自己紹介を聞くたびに、世の中には知らない世界がまだまだたくさんあるなぁ、と思う刺激的な毎日です。 2020 年の心配事は、オリンピックによる混雑ですねぇ。あまりに混雑するようなら、どうせなら期間中はリモートワークで切り抜けようかな、とか密かに思っています。（弊社には宮崎からリモートワークで働いてるエンジニアもいます） lab.astamuse.co.jp Akka HTTP はいいぞ さて、今回は何を書こうかと考えた時に、前々回、前回と技術的なことを書いていなかったことを思い出し
ChatWorkのリアクティブシステム導入事例から学ぶActor設計プラクティス
Actorの設計プラクティスに関して簡単にまとめた資料です
最新DDDアーキテクチャとAkkaでの実装ヒントについて
DDD+CQRS+Event SourcingとAkkaでの実装ヒントを解説。
プログラミング言語のパラダイムシフトーScalaから見る関数型と並列性時代の幕開けー
[DI05] Azure Event Hubs と Azure Stream Analytics で、”今を処理”するde:code 2017
テストしないで大丈夫? AkkaのActorを単体テストする - Qiita
はじめに この記事では、AkkaのActorを用いたプログラムの単体テスト方法について簡単に説明します。 Actorをテストするのは通常のオブジェクトをテストするよりも下記の理由により困難です。 タイミング メッセージは非同期に送信されるので、単体テストでいつ検査を実行したらよいかを知ることは難しいことです。 非同期 Actorは並列のスレッドで実行されます。これはシングルスレッドで実行されるプログラムよりも検査するのが難しいです。 ステートレス Actorは内部の状態を隠蔽しています。通常この内部状態に直接アクセスすることはできないので、単体テストが困難になります。 強調と結合 複数のActorと結合して実行されます。これをテストするにはActor間のメッセージのやりとりを盗み聞きする必要があります。 この面倒なテストを、Akka-TestKitを使うことによって軽減します。 Akka-
Akka Cluster Shardingで即時集計系をつくる | Scala Tech Blog
こんにちは、CA ProFit-X の松村です。 私たちのプロダクトでは広告配信のシステムにAkkaを使っていて、アプリケーションはAWS/Docker環境に配備して運用しています。今回はAkkaのCluster Shardingという拡張を使って、主にAWS環境を想定した簡単なリアルタイム集計システム(即時集計系)をつくってみたのでその内容をご紹介します。 下ではAkka Cluster Shardingについて簡単に説明した後、試作した即時集計系の実装・永続化と配備について説明します。その後、ワークロードとノード数を増減させた実験とその結果について説明します。 Akka Cluster Sharding について Akka ClusterはGossip Protocolとφ Accrual Failure Detectorという手法に基づいた非中央集権的なノード群構築を行うAkka拡張
【Akka】Akka Streamsがめっちゃ便利すぎて脳汁が出た話し | Scala Tech Blog
こんにちは！Smalgoの來田です。 注意：タイトルは過激ですが内容至って普通なチュートリアル記事です。 仕事でWorkerを作った時に使ってみてめっちゃ便利だと思ったのでAkka Streamsについて書きたいと思います！ まだまだ中の実装の深いところまで追えてるわけじゃないので間違っていたら教えてください。 Akka Streamsとは Reactive Streams（ノンブロッキングでback pressureな非同期ストリーム処理の標準仕様）のAkka実装 Back Pressureとは 非同期なストリーム処理の場合下記の問題が起きる Publisher側の処理が早い場合Subscriber側のバッファーが溢れてしまう Subscriberに遠慮してPublisher側の処理を抑えた場合は無駄が多くなってしまう それをSubscriberが自分が処理できる量をPublisherに
Reactive Design Patterns in Akka using Java 8 | @lightbend
With the recent release of Java 8 we’ve been very excited to show how to use the new language features when building Reactive applications. I previously detailed how to use Java 8 with the Play Framework and this is a follow-up post introducing Akka with Java 8. Akka is a toolkit and runtime for building highly concurrent, distributed, and fault tolerant event-driven applications on the JVM. It us
並行処理初心者のためのAkka入門
Concurrent programing explanation for akka beginers. 並行処理初心者のためのAkka入門 akka meetup 2014/09/28(日) http://connpass.com/event/8622/ このイベントの導入説明のために書かれました。 内容には、並行処理、アクターモデル、Akkaの機能の説明となっています。
Testing Fiber Implementations in JVM
I have always been interested in concurrent programming through the use of threads. This inclination did not originate from a need to exploit the parallelism at the hardware level for performance reasons, but rather due to the fact that I believe it establishes a model of reasoning about your code that provides a more convenient and natural way for encapsulating concurrency in the overall program
Akkaを使って回復力のあるソフトウェアを作る
あなたのアプリケーションの一部を正常な形から歪めてしまうような故障の毎日起きる例には、一時的に利用できないデータベース・サーバー、素晴らしい新製品を誰もが使おうとして起きる負荷スパイク、どうにかそのサブルーチンまですり抜けて、それを窒息させる不正なユーザー入力などがあります。このような状況からの回復は、できるだけ早く正常なサービスを回復するために、理想的には自動的であるべきです。 この文脈における回復力は、障害は隔離されなければならないことを意味します。避けられるなら、障害が発生したコンポーネントは、他のコンポーネントをダウンしてはなりません。サービスレベルは下がり、恐らくある機能は一時的に利用できませんが、しかしアプリの残りの部分は尚動きます。一旦火事が広がることを阻止できたら、それを消さなくてはいけません。障害のあるコンポーネントは再スタートさせるか、ファイルオーバーによりバックアップ
Akkaで簡単分散プログラミング - in a Stream
今回は，Scalaで手軽に本格的な分散プログラミングができる，Akkaについて紹介したいと思います． Akkaは現在Scalaと一緒の形でTypesafe社によって配布されています． Scalaに標準で用意されているActor機能よりも高機能なものになっています． シンプルなコード・設定ファイルで実際にどのようにプログラムが書けるかを， 見てみたいと思います． サーバ側のソースコードは次のようになります． 《 server.scala 》 import akka.actor.Actor class EchoActor extends Actor { protected def receive = { case x => self.reply(x) } } 5行: Actorトレイトのreceiveメソッドを実装します．これがクライアントからのメッセージを受け取る部分となります． 6行: ク
Akka dispatchers waiting for ever
Recently, I've been developing different examples using Akka; for instance a playtool P2P model. For the evaluation, benchmarking, and understanding better, I tried to run the example using different types of dispatchers that Akka introduces. The issue that I've been facing is that specifically using BalancingDispatcher with a thread-pool-executor (which by default should be for this type of dispa
Java Champion Jonas Bonér Explains the Akka Framework
Jonas Bonér is a husband, dad, programmer, teacher, speaker, author and Java Champion. He is the CTO of Typesafe,which was founded in 2011 by the creators of the Scala programming language and Akka middleware, and is an active contributor to the Open Source community. Most notably, he created the Akka Project, the AspectWerkz Aspect-Oriented Programming (AOP) framework, is a committer to the Terra
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
Akka docs on your Kindle!
Erlang Style
CQRS+ESをAkka Persistenceを使って実装してみる。
Efficient data transfer through zero copy
Typed Actors — Akka Documentation
Akkaのsingle-thread:dispatcherは本当にシングルスレッド? - めも（コメント可）