Akka HTTPからAkka Streamへのつなぎ込みとGraphDSLで単純なリバースプロクシを構築 - Qiita
スコープ Web屋さん向け。また、やや実践寄りかも、と思います。 Akka HTTPからAkka Streamへのつなぎ込み GraphDSLを用いて、簡単なフローグラフの構築 とりあえず書いてみた 調査とかトライアンドエラーがけっこう苦労した libraryDependencies ++= { val akkaV = "2.4.3" Seq( "com.typesafe.akka" %% "akka-stream" % akkaV, "com.typesafe.akka" %% "akka-http-experimental" % akkaV ) } package mananan.eval.akka.stream import akka.actor.ActorSystem import akka.http.scaladsl._ import akka.http.scaladsl.mod
Scalaで並行処理#4 – AkkaのFault Tolerance(耐障害性） | DevelopersIO
Supervisorによる耐障害性 Akkaでのエラーや障害に対する対処は「let it crash」というアプローチをとっています。 この考え方は障害は発生しうるものという前提に基づき、障害が発生したらプロセスを適切に再スタートさせるという考え方です。 そのためにAkkaではSupervisorとよばれるものがActorを管理し、監視対象のActorに障害が発生した際、 プロセスを再スタートさせ、プロセスを生かし続けます。こうしてAkkaは耐障害性を確保しています。 Supervisorが行う再スタート方法 AkkaのSupervisorは二種類の再スタート方法を持っています。 1.One-For-One 管理対象のうちいずれかのプロセスがクラッシュしたら、その対象のコンポーネントのみを再スタートさせます。 2.All-For-One Supervisorも含む、管理対象のうちいずれかの
Scala での簡単な RemoteActor - なんとなくな Developer のメモ
Scala の Actor 用 API では、リモートプロセスを含むプロセス間通信を実現するための API が用意されているので、今回はこれを試してみる事にする。 RemoteActor の使い方 RemoteActor を実現するには、scala.actors.Actor オブジェクトのメソッドに加え、scala.actors.remote.RemoteActor オブジェクトの各種メソッドを使う事になる。 基本的に、actor や receive メソッドに以下のような RemoteActor 用のメソッドを組み合わせればよい。 alive メソッドで待ち受けるポート番号を指定 register メソッドで RemoteActor 対象の Actor にシンボルを付ける select メソッドで呼び出す RemoteActor を特定する とりあえず、簡単な RemoteActor の
1
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
処理を実行中です
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
HTTP server using akka-http and akka-streams
Akka Actor入門 - case class HatenaDiary(id: String = ”seratch2”)
