非同期処理の基本とアクターモデルが解決する課題とは
はじめまして、マーベリック株式会社のリチャード 伊真岡です。この連載では非同期処理に役立つアクターモデルを学ぶため、JavaとScalaから使えるOSSであり、アクターモデルの実装を提供するAkkaを紹介します。連載の前半では非同期処理とActorの基礎的な部分を、後半では非同期処理から分散システムへと話を進めていきます。分散システムは現代のシステム構築において重要性を増しているので、Akkaが非同期処理のツールから始まって、どんな分散システムのアーキテクチャーのパターンを可能にしてくれるのかを紹介したいと思います。連載の第一回である今回は非同期処理の現状や歴史をおさらいし、そしてアクターモデルによって非同期処理の中でも、どういった問題が解決されるのかお話します。 非同期処理とは 現代のアプリケーション開発では非同期処理を扱う機会が数多くあるといえるでしょう。非同期処理[1]とは、処理を開
Scalaz 8 IO vs Akka (typed) actors vs Monix (part 1)
There’s a couple of hot development areas in the Scala ecosystem, and the competition between the various side-effect wrappers is one of the most interesting. We have the bifunctor IO from Scalaz 8 (which is now a standalone project, ZIO), we have cats-effect and its IO, which is a simpler version of Monix’s Task, and finally we have the good old Akka actors. Some people say that the IO/Task wrapp
Akka HTTPの仕組みを理解する - LINE ENGINEERING
初めまして、Ads Platform開発チームの岡田（@ocadaruma）です。 この記事はLINE Advent Calendar 2017の17日目の記事です。 今回、個人的に以前から気になっていたAkka HTTPの内部構造について、この機会に調べましたので紹介いたします。 Akka HTTPとは Akka HTTPは、Lightbend社によって開発されている、Scala/Java用のHTTP toolkitです。 現在はメンテナンスが終了したsprayの後継と位置付けられており、特徴的なRouting DSLをsprayから受け継いでいます。 また、Play Frameworkは2.6系より、Akka HTTPをデフォルトのバックエンドとして採用しています。 調査のきっかけ Routing DSLを始めとしたAkka HTTPのAPIは、シンプルかつ高いComposabilit
Akka実践バイブル アクターモデルによる並行・分散システムの実現 | 翔泳社
並行プログラミングからクラスタリング、 そしてリアクティブシステムへ！ 昨今、ムーアの法則は終焉したとも言われ、かつてのコンピュータの性能向上に期待するアーキテクチャでは、増加を続けるトラフィックに対処することが難しくなりました。 並行プログラミングやクラスタ構成によるスケーリングへの理解が開発者・アーキテクトに求められています。 本書は並列・分散処理フレームワークAkkaの解説書『Akka in Action』の日本語版です。本書では、制御が難しい並行・分散システムをAkkaによって安全に構築する方法を学ぶことができます。 アクターモデルなどの基本概念やAkkaの基本的な機能といった全体像から、akka-httpとakka-streamを用いたストリーム処理に基づくハイパフォーマンスなRESTサービスを構築する方法、Akkaのクラスタリングを用いて障害からの回復力を持つスケーラブルなシス
blog/hapens-before-rule-in-akka.md at master · TanUkkii007/blog
アクターのロケーション透過性は、アクターがどのサーバー、どのCPUコア、どのスレッド上で実行されようが同じ挙動になることを保証する。これはプログラマがアクターの実行環境を意識しなくていいという点ですばらしい。この性質により僕のような並列プログラミングや分散システムにそんなに詳しくない開発者でも安全に並列分散システムのコードを書くことができている。 アクターが並列プログラミングを簡単にするもう１つの特性はカプセル化である。アクターは内部にミュータブルな状態をもつことができ、それを安全に更新することができる。つまりvarを使うことができる。ここでもプログラマは並列環境で実行されていることを意識する必要はない。アクターの強いカプセル化は内部状態を外からのアクセスから守ってくれる。 もしプログラマが並列環境を意識しなくてはいけなかったら、このアクター内のvarは@volatile宣言がされてなけれ
ChatWorkのリアクティブシステム導入事例から学ぶActor設計プラクティス
Actorの設計プラクティスに関して簡単にまとめた資料です
Running an Akka Cluster with Docker Containers · Adventures in HttpContext
A reserved Jekyll theme that places the utmost gravity on content with a hidden drawer. Made by @mdo. Running an Akka Cluster with Docker Containers Mar 23 2014 Update! You can now use SBT-Docker with SBT-Native Packager for a better sbt/docker experience. Here’s the new approach with an updated GitHub repo. We recently upgraded our vagrant environments to use docker. One of our projects relies on
Instant Messaging at LinkedIn: Scaling to Hundreds of Thousands of Persistent Connections on One Machine
Instant Messaging at LinkedIn: Scaling to Hundreds of Thousands of Persistent Connections on One Machine Coauthor: Cliff Snyder We recently introduced Instant Messaging on LinkedIn, complete with typing indicators and read receipts. To make this happen, we needed a way to push data from the server to mobile and web clients over persistent connections instead of the traditional request-response par
akka-stream を始めるときに覚えておきたいこと
akka-stream 特有の単語や概念を分かりやすく説明します。
マイクロサービスとDDDをGo言語とScala+Akkaで比較したらEventSourcingの話にもなって面白かったまとめ - yoskhdia’s diary
Reactive Messaging Patterns読書会のなかで、「マイクロサービスとAkkaとGo」な面白い話題が出たので代表でまとめる試みエントリです。（結構、色々な話題に飛んでいるので難度高い。） まとめ方としては、会話ログを転記して、最後にまとめる形をとっています。また、議論と私の考えが混ざらないように所感は分けておきます。 ddd-cqrs-es.connpass.com TL;DR 要素技術（どんな言語使うとか、どんなアーキテクチャにするとか）の前に、組織やプロダクトの性格を考えて戦略を決めましょう。 そして、その中で最適と思われる戦術をとれるような要素技術を採用しましょう。 Akka良いよ。 ログ（一部抜粋） Slackからの引用のためテキストベースです。 事の始まりは、荒木さん（以下、 @applideveloper ）の発言でした。 （この記事絡みですね。 集合知で各
最新DDDアーキテクチャとAkkaでの実装ヒントについて
DDD+CQRS+Event SourcingとAkkaでの実装ヒントを解説。
3ヶ月間Scalaと付き 合って感じた事 ……という発表を想定していたのですが
本題のタイトルは『何故「可変な状態を持たないものにAkkaのActorを使うのはアンチパターン」なのか』です。
Zen of Akka
This document contains the slides from a talk given by Konrad Malawski on the "Tao/Zen of Programming" using Akka. Some of the key points discussed include: - Actors are meant to work together and each actor should focus on a single responsibility. Having only one actor limits its capabilities. - Actors should be structured in a hierarchy with parent-child relationships to allow for supervision. A
アクターの諸刃の剣：非同期のメッセージパッシングと状態隔離対障害モデル、そしてそれを克服するAkka Streamの可能性 - TanUkkiiのブログ
ScalaのアクターライブラリであるAkkaでは今までHTTPがIOパッケージでサポートされてきませんでした。HTTPのサポートはAkka Streamの開発とともになされたのです。なぜアクターモデルとHTTPをすぐ統合せずにStreamの登場を待つことになったのか？この疑問に答えることはアクターの問題を考えるよい題材です。 Sprayの革新とその限界 SprayはAkkaのアクターモデルとHTTPを統合して成功したフレームワークです。SprayはJVMベースのフレームワークの中で最高のパフォーマンスを誇りました。SprayはServletがもつがスレッドの高速性と、NodeJSがもつイベントループによる大量のリクエストを効率的に捌くことの特性の両立を、アクターによって可能にしたのです。 ところがSprayはアクターモデルならではの問題とも戦うことになります。Reactive Manife
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
Using Akka Cluster for a payment service
Akka Clusterの耐障害設計
Reactive TCP Client Using Akka Framework
CQRS+ESをAkka Persistenceを使って実装してみる。
Akka stream
Efficient data transfer through zero copy
