Running a 2400 Akka Nodes Cluster on Google Compute Engine | @lightbend
We’re so excited that Google gave us 3000 cores to test a large Akka cluster on Google Compute Engine (GCE), which is an infrastructure-as-a-service that lets you run your large-scale computing workloads on Linux virtual machines hosted on Google's infrastructure. Google views Akka as a powerful tool for exploring the limits of GCE to run Akka/Java applications, so we were honored to  participate
akka-stream を始ã‚ã‚‹ã¨ãã«è¦šãˆã¦ãŠããŸã„ã“ã¨
akka-stream 特有ã®å˜èªžã‚„概念を分ã‹ã‚Šã‚„ã™ã説明ã—ã¾ã™ã€‚
最新DDDアーã‚テクãƒãƒ£ã¨Akkaã§ã®å®Ÿè£…ヒントã«ã¤ã„ã¦
DDD+CQRS+Event Sourcingã¨Akkaã§ã®å®Ÿè£…ヒントを解説。
CQRS+ESã‚’Akka Persistenceを使ã£ã¦å®Ÿè£…ã—ã¦ã¿ã‚‹ã€‚
1. CQRS+EventSourcingã‚’Akka Persistence を使ã£ã¦å®Ÿè£…ã—ã¦ã¿ã‚‹ã€‚〜コツã¨ãƒãƒžã‚Šãƒã‚¤ãƒ³ ト〜 2016/03/16 Reactive Messaging Patternsプレèªæ›¸ä¼š - CQRSã€ESã®åŸºæœ¬ã‚’å¦ã¶ - Satoshi Matsushita 2. 自己紹介 • Satoshi Matsushita @satoshi_m8a • Scala, Akka, DDD, フãƒãƒ³ãƒˆã‚¨ãƒ³ãƒ‰, コンピュータビジョン, æ©Ÿæ¢°å¦ ç¿’ • ã‚²ãƒ’ãƒ«ãƒ³æ ªå¼ä¼šç¤¾ Python, Go, Erlang, Scala, OCaml, TypeScript 「Gehirn Infrastructure Services〠セã‚ãƒ¥ãƒªãƒ†ã‚£è¨ºæ– â€¢ ECã®ã‚·ã‚¹ãƒ†ãƒ ã‚’Akka Persistenceを使ã£ã¦é–‹ç™ºã—ã¦ã„ãŸã€‚ 3. Akka + DDD æ°—é‹ã®é«˜ã¾ã‚Š(1) • Scal
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 Streams ã¦ã‚™å†å®Ÿè£…ã—ãŸã‚‰100å€é€Ÿããªã£ãŸè©± #ScalaMatsuri
3. Copyright © 2016 TIS Inc. All rights reserved. 今日話ã™ã“㨠Akka Streams を使ã£ã¦ãƒãƒƒãƒã®å‡¦ç†é€Ÿåº¦ã‚’100å€ã«ã—ãŸäº‹ä¾‹
アクターã®è«¸åˆƒã®å‰£ï¼šéžåŒæœŸã®ãƒ¡ãƒƒã‚»ãƒ¼ã‚¸ãƒ‘ッシングã¨çŠ¶æ…‹éš”離対障害モデルã€ãã—ã¦ãれを克æœã™ã‚‹Akka Streamã®å¯èƒ½æ€§ - TanUkkiiã®ãƒ–ãƒã‚°
Scalaã®ã‚¢ã‚¯ã‚¿ãƒ¼ãƒ©ã‚¤ãƒ–ラリã§ã‚ã‚‹Akkaã§ã¯ä»Šã¾ã§HTTPãŒIOパッケージã§ã‚µãƒãƒ¼ãƒˆã•ã‚Œã¦ãã¾ã›ã‚“ã§ã—ãŸã€‚HTTPã®ã‚µãƒãƒ¼ãƒˆã¯Akka Streamã®é–‹ç™ºã¨ã¨ã‚‚ã«ãªã•ã‚ŒãŸã®ã§ã™ã€‚ãªãœã‚¢ã‚¯ã‚¿ãƒ¼ãƒ¢ãƒ‡ãƒ«ã¨HTTPã‚’ã™ãçµ±åˆã›ãšã«Streamã®ç™»å ´ã‚’å¾…ã¤ã“ã¨ã«ãªã£ãŸã®ã‹ï¼Ÿã“ã®ç–‘å•ã«ç”ãˆã‚‹ã“ã¨ã¯ã‚¢ã‚¯ã‚¿ãƒ¼ã®å•é¡Œã‚’考ãˆã‚‹ã‚ˆã„é¡Œæã§ã™ã€‚ Sprayã®é©æ–°ã¨ãã®é™ç•Œ Sprayã¯Akkaã®ã‚¢ã‚¯ã‚¿ãƒ¼ãƒ¢ãƒ‡ãƒ«ã¨HTTPã‚’çµ±åˆã—ã¦æˆåŠŸã—ãŸãƒ•ãƒ¬ãƒ¼ãƒ ワークã§ã™ã€‚Sprayã¯JVMベースã®ãƒ•ãƒ¬ãƒ¼ãƒ ワークã®ä¸ã§æœ€é«˜ã®ãƒ‘フォーマンスを誇りã¾ã—ãŸã€‚Sprayã¯ServletãŒã‚‚ã¤ãŒã‚¹ãƒ¬ãƒƒãƒ‰ã®é«˜é€Ÿæ€§ã¨ã€NodeJSãŒã‚‚ã¤ã‚¤ãƒ™ãƒ³ãƒˆãƒ«ãƒ¼ãƒ—ã«ã‚ˆã‚‹å¤§é‡ã®ãƒªã‚¯ã‚¨ã‚¹ãƒˆã‚’効率的ã«æŒãã“ã¨ã®ç‰¹æ€§ã®ä¸¡ç«‹ã‚’ã€ã‚¢ã‚¯ã‚¿ãƒ¼ã«ã‚ˆã£ã¦å¯èƒ½ã«ã—ãŸã®ã§ã™ã€‚ ã¨ã“ã‚ãŒSprayã¯ã‚¢ã‚¯ã‚¿ãƒ¼ãƒ¢ãƒ‡ãƒ«ãªã‚‰ã§ã¯ã®å•é¡Œã¨ã‚‚戦ã†ã“ã¨ã«ãªã‚Šã¾ã™ã€‚Reactive Manife
Akkaã®åˆ†æ•£ã•ã‚ŒãŸã‚¢ã‚¯ã‚¿ãƒ¼é–“ã§DBを使ã‚ãšã«ãƒ‡ãƒ¼ã‚¿ã‚’共有ã™ã‚‹æ–¹æ³• - Qiita
本記事㯠TIS Engineer Advent Calendar 2015 23日目ã®è¨˜äº‹ã§ã™ã€‚ ã¯ã˜ã‚ã« Akka ã§åˆ†æ•£ã‚·ã‚¹ãƒ†ãƒ を構築ã—ãŸã¨ãã«ã€åˆ†æ•£ã•ã‚ŒãŸè¤‡æ•°ã®ã‚¢ã‚¯ã‚¿ãƒ¼é–“ã§å¸¸ã«æ›´æ–°ã•ã‚Œã‚‹ãƒ‡ãƒ¼ã‚¿ã‚’共有ã™ã‚‹ã“ã¨ã‚’考ãˆã¾ã™ã€‚DBを使ã‚ãšã«ã‚„ã‚ã†ã¨ã™ã‚‹ã¨ã€å…±æœ‰ãƒ‡ãƒ¼ã‚¿ã‚’管ç†ã™ã‚‹ãŸã‚ã®ã‚¢ã‚¯ã‚¿ãƒ¼ã‚’1ã¤ä½œã£ã¦ãŠãã€å¸¸ã«ãã®ã‚¢ã‚¯ã‚¿ãƒ¼ã«ãƒ‡ãƒ¼ã‚¿ã®å–å¾—ã¨æ›´æ–°ã‚’ä¾é ¼ã™ã‚‹ã¨ã„ã†æ–¹æ³•ãŒæ€ã„ã¤ãã¾ã™ã€‚ã—ã‹ã—ã€ã“ã®æ–¹æ³•ã§ã¯ãƒ‡ãƒ¼ã‚¿ã‚’共有ã™ã‚‹ãŸã‚ã®ã‚¢ã‚¯ã‚¿ãƒ¼ãŒå˜ä¸€éšœå®³ç‚¹ã«ãªã£ã¦ã—ã¾ã†ã¨ã„ã†ã“ã¨ã¨ã€ãã®éƒ¨åˆ†ã®ã‚¹ã‚±ãƒ¼ãƒ©ãƒ“リティを確ä¿ã§ããªã„ã¨ã„ã†å•é¡ŒãŒã‚ã‚Šã¾ã™ã€‚ è€éšœå®³æ€§ã¨ã‚¹ã‚±ãƒ¼ãƒ©ãƒ“リティを確ä¿ã—ãŸã¾ã¾ã€Akkaã®ã‚¢ã‚¯ã‚¿ãƒ¼é–“ã§ãƒ‡ãƒ¼ã‚¿ã‚’共有ã™ã‚‹ã«ã¯ã©ã†ã™ã‚Œã°è‰¯ã„ã®ã§ã—ょã†ã‹ï¼Ÿã“ã†ã„ã†ã‚±ãƒ¼ã‚¹ã§ã¯ Akka ã® Distributed Data ã¨ã„ã†ãƒ¢ã‚¸ãƒ¥ãƒ¼ãƒ«ãŒä½¿ãˆã¾ã™ã€‚Distributed Data を使ã†ã¨ã€DBを使ã‚ãšã«
Developing an Akka Edge6
Developing an Akka Edgeã¨ã„ã†Akkaã®å…¥é–€æ›¸ã‚’èªã‚“ã§å‹‰å¼·ã—ã¦ã„ã¾ã™ã€‚ è¦ç´„ã—ã¦ç¤¾å†…勉強会ã§ç™ºè¡¨ã—ãŸæ™‚ã®ã‚¹ãƒ©ã‚¤ãƒ‰ã‚’手直ã—ã—ãŸã‚‚ã®ã§ã™Read less
怒涛ã®Akka: Actorç·¨ - KZKY memo
Akka Scala Docã®Actorsを大体èªã‚“ã§å™›ã¿ç •ã„ãŸã®ã§ãã®ãƒ¡ãƒ¢ï¼Ž Actors 怒涛ã®Akka: Actors - KZKY memo Typed Actors 怒涛ã®Akka: Typed Actors - KZKY memo Fault Tolerance 怒涛ã®Akka: Fault Tolerance - KZKY memo Dispatchers 怒涛ã®Akka: Dispatchers - KZKY memo Mailboxes 怒涛ã®Akka: Mailboxes - KZKY memo Routing 怒涛ã®Akka: Routing - KZKY memo FSM 怒涛ã®Akka: FSM - KZKY memo Persistence 2.3.9ã§ã¯ã¾ã Experimentalã®ã‚ˆã†ãªã®ã§ã‚„らãªã„． Testing Actor Systems 怒涛ã®Akk
Don't use Actors for concurrency
Don't use actors for concurrency. Instead, use actors for state and use futures for concurrency. A common practice I've seen in scala code is to use actors for concurrency. This is encouraged by Akka and a lot of writing about Scala, the documentation of which is highly actor-centric. I assert that this is a bad practice and should be considered an antipattern most of the time it is used. Actors s
ランã‚ング
ランã‚ング
ランã‚ング
リリースã€éšœå®³æƒ…å ±ãªã©ã®ã‚µãƒ¼ãƒ“スã®ãŠçŸ¥ã‚‰ã›
最新ã®äººæ°—エントリーã®é…ä¿¡
j次ã®ãƒ–ックマーク
kå‰ã®ãƒ–ックマーク
lã‚ã¨ã§èªã‚€
eコメント一覧を開ã
oページを開ã
How Akka Works: 'At Least Once' Message Delivery | @lightbend
History of Falcon, the way to production release
Implementing DMM API Gateway in Akka Streams and HTTP
Akka Clusterã®è€éšœå®³è¨è¨ˆ
Finite state machines with Akka | Codurance
Persistence Query • Akka Documentation
https://downloads.typesafe.com/website/casestudies/images/typesafe-community-story-dwango.pdf
http://www.smartjava.org/content/visualizing-back-pressure-and-reactive-streams-akka-streams-statsd-grafana-and-influxdb/
compmoc blog: Primes computation : From home made akka actors based solution to akka-stream
{{#tags}}- {{label}}
{{/tags}}