クイックスタートガイド — Akka Documentation
ストリームã¯åŸºæœ¬çš„ã«ã¯ã‚½ãƒ¼ã‚¹ã‹ã‚‰å§‹ã¾ã‚Šã¾ã™ã€‚Akka Stream を始ã‚ã‚‹å ´åˆã‚‚然りã§ã™ã€‚ã—ã‹ã—ã¾ãšã¯ã€ã‚¹ãƒˆãƒªãƒ¼ãƒŸãƒ³ã‚°ã®ãŸã‚ã«å¿…è¦ãªã‚‚ã®ã‚’インãƒãƒ¼ãƒˆã—ã¦ã¿ã¾ã—ょã†ã€‚
Akka実践ãƒã‚¤ãƒ–ルをゆã£ãã‚Šèªã¿è§£ã - Qiita
今回ã®ãŠé¡Œ 『Akka実践ãƒã‚¤ãƒ–ルã€ã§ã™ã€‚ éˆå™¨ãƒ¬ãƒ™ãƒ«ã®é‡åŽšã•ã‚’æŒã¤ã“ã®æœ¬ã‚’ã€ã‚¿ã‚¤ãƒˆãƒ«ã®é€šã‚Šã‚†ã£ãã‚Šã¨èªã¿è§£ã„ã¦ã„ããŸã„ã¨æ€ã„ã¾ã™ã€‚ 普段ã¯Akkaã©ã“ã‚ã‹Scalaã™ã‚‰ä½¿ã‚ãªã„ã®ã§ã©ã“ã¾ã§æ£ç¢ºã«æ›¸ã‘ã‚‹ã‹ã‚ã‹ã‚‰ãªã„ã‘ã©ã€ 隔週ãらã„ã®ãƒšãƒ¼ã‚¹ã§èªã¿è§£ã„ã¦ã„ããŸã„ã§ã™ã€‚ 今後ã®äºˆå®š ç¬¬ï¼‘ç« ã€€Akkaã®ç´¹ä»‹ ç¬¬ï¼’ç« ã€€æœ€å°ã®Akkaアプリケーション ç¬¬ï¼“ç« ã€€ã‚¢ã‚¯ã‚¿ãƒ¼ã«ã‚ˆã‚‹ãƒ†ã‚¹ãƒˆé§†å‹•é–‹ç™º ç¬¬ï¼”ç« ã€€è€éšœå®³æ€§ ç¬¬ï¼•ç« ã€€Future ç¬¬ï¼–ç« ã€€Akkaã«ã‚ˆã‚‹ã¯ã˜ã‚ã¦ã®åˆ†æ•£ã‚¢ãƒ—リケーション ç¬¬ï¼—ç« ã€€è¨å®šã¨ãƒã‚®ãƒ³ã‚°ã¨ãƒ‡ãƒ—ãƒã‚¤ ç¬¬ï¼˜ç« ã€€ã‚¢ã‚¯ã‚¿ãƒ¼ã®æ§‹é€ パターン ç¬¬ï¼™ç« ã€€ãƒ¡ãƒƒã‚»ãƒ¼ã‚¸ã®ãƒ«ãƒ¼ãƒ†ã‚£ãƒ³ã‚° 第１ï¼ç« 　メッセージãƒãƒ£ãƒãƒ« ç¬¬ï¼‘ï¼‘ç« ã€€æœ‰é™çŠ¶æ…‹ãƒžã‚·ãƒ³ã¨ã‚¨ãƒ¼ã‚¸ã‚§ãƒ³ãƒˆ ç¬¬ï¼‘ï¼’ç« ã€€ã‚¹ãƒˆãƒªãƒ¼ãƒŸãƒ³ã‚° ç¬¬ï¼‘ï¼“ç« ã€€ã‚·ã‚¹ãƒ†ãƒ çµ±åˆ ç¬¬ï¼‘ï¼”ç« ã€€ã‚¯ãƒ©ã‚¹ã‚¿ãƒªãƒ³ã‚° ç¬¬ï¼‘ï¼•ç« ã€€ã‚¢ã‚¯ã‚¿ãƒ¼ã®æ°¸ç¶šåŒ– ç¬¬ï¼‘ï¼–ç« ã€€ãƒ‘ãƒ•ã‚©ãƒ¼ãƒžãƒ³ã‚¹Tips ç¬¬ï¼‘ï¼—ç« ã€€Akk
メニーコア時代ã®ãƒ‘ラダイム　リアクティブシステムを知ã‚ã†
第9回目ã¨ãªã‚‹ä»Šå›žã¯ã€Akkaã®æ‹¡å¼µæ©Ÿèƒ½Akka HTTPを用ã„ã¦Web APIを作æˆã™ã‚‹æ–¹æ³•ã‚’紹介ã—ã¾ã™ã€‚
Akka-Streamã§éžåŒæœŸä¸¦åˆ—å‡¦ç† - Qiita
çµæ§‹å‰ã‹ã‚‰ã‚ˆã 「大è¦æ¨¡ãƒ‡ãƒ¼ã‚¿å‡¦ç†æ¥å‹™çµŒé¨“者 優é‡ã€ ãªã‚“ã¦ã„ã†è¨˜äº‹ã€åºƒå‘Šãªã©ã‚’ã¡ã‚‰ã»ã‚‰è¦‹ã‹ã‘ã‚‹æ°—ãŒã—ã¦ã€ã„ã‚ã„ã‚ã‚°ã‚°ã£ã¦ã¿ãŸã¨ã“ã‚ã€è¡æ’ƒçš„ãªè¨˜äº‹ã‚’発見。 ãƒãƒƒãƒã‚’ Akka Streams ã§å†å®Ÿè£…ã—ãŸã‚‰100å€é€Ÿããªã£ãŸè©± #ScalaMatsuri プãƒã‚¸ã‚§ã‚¯ãƒˆä»•æ§˜ã¨ãƒ©ã‚¤ãƒ–ラリã¨ã®ç›¸æ€§ã¨ã‹ã‚‚ã‚ã‚‹ã ã‚ã†ã‹ã‚‰ã€ä½•ã§ã‚‚ã‹ã‚“ã§ã‚‚Akka-Stream使ãˆã°æ—©ããªã‚‹ã€ã¨ã„ã†å•é¡Œã§ã‚‚ãªã„ã§ã—ょã†ãŒã€ãã†ã¯è¨€ã£ã¦ã‚‚ã€ã“ã†ã„ã£ãŸåŠ¹çŽ‡æ”¹å–„事例を実ç¾ã•ã›ã‚‰ã‚ŒãŸã‚‰ã€ã‚¨ãƒ³ã‚¸ãƒ‹ã‚¢å†¥åˆ©ã«ã¤ãã‚‹ã§ã—ょã†ã€‚ 上記ã®ãƒªãƒ³ã‚¯ã§ã¯Akka-Stream以外ã«ã‚‚ã€DBã«ã‚¢ã‚¯ã‚»ã‚¹ã™ã‚‹ãŸã‚ã®Slick使ã£ãŸã‚Šã€å˜ç´”ã«ã‚µãƒ¼ãƒã®å®Ÿãƒ¡ãƒ¢ãƒªä¸Šã’ã‚‹ã“ã¨ã§ã€ç·åˆçš„ã«295å€ã®åŠ¹çŽ‡ã‚¢ãƒƒãƒ—を実ç¾ã—ã¦ã„るよã†ã§ã™ã€‚ Slickã®å‹‰å¼·ã¯æ¬¡å›žã«å›žã™ã¨ã—ã¦ã€ä»Šå›žã¯Akka-Streamã®ä½¿ã„æ–¹ã¨ã€CPUマルãƒã‚³ã‚¢ã‚’使ã£ãŸéžåŒæœŸå‡¦ç†ã‚’本家サイトç‰çœºã‚ãª
Akka Streams を使ã£ã¦ç°¡å˜ãªé›†è¨ˆã‚’行ㆠStream を構築ã—ã¦ã¿ã‚‹ - Qiita
Akka Streams ã£ã¦? Akka Streams 㯠Reactive Streams（ノンブãƒãƒƒã‚ングã§back pressureãªéžåŒæœŸã‚¹ãƒˆãƒªãƒ¼ãƒ 処ç†ã®æ¨™æº–仕様）ã®Akka実装。 ã¤ã¾ã‚‹ã¨ã“ã‚ã€Back-pressure ã«ã‚ˆã£ã¦Subscriberå´ã¯å—ã‘ãã‚Œãªã„仕事をå—ã‘ãšã€Subscriberå´ã§ã©ã®ãらã„仕事をå—ã‘ã‚‹ã“ã¨ãŒã§ãã‚‹ã‹Publisherå´ã«é€šçŸ¥ã™ã‚‹æ–¹å¼ã‚’ã¨ã‚‹ã“ã¨ã§ã€åŠ¹çŽ‡ã‚ˆã処ç†ã‚’è¡Œã†ã“ã¨ãŒã§ãるよã†ã«ã™ã‚‹ã‚‚ã®ã§ã™ã€‚ ã¾ãŸã€Akka Streams を実装ã™ã‚‹æ™‚ã«ã¯æ§‹æˆã®é …ã§ç¤ºã™ã‚ˆã†ãªãƒ•ãƒãƒ¼ãƒãƒ£ãƒ¼ãƒˆã‚’記載ã™ã‚‹ã“ã¨ãŒå¤šãã€ã‚³ãƒ¼ãƒ‰ã®èªã¿æ‰‹ã«ã¨ã£ã¦ã‚‚ã€ã‚ã‹ã‚Šã‚„ã™ã処ç†å†…容をä¼ãˆã‚‹ã“ã¨ãŒã§ãã¾ã™ã€‚ Akka Streamsã®åŸºæœ¬ã«é–¢ã—ã¦ã¯ä¸‹è¨˜ã‚’å‚考ã«ã•ã›ã¦ã„ãŸã ãã¾ã—ãŸã€‚ Akka Stream ã«ã¤ã„ã¦ã®åŸºç¤Žæ¦‚念 Akka Document 今回やã£ã¦ã¿ã‚‹ã“㨠今
Akka Streams ã«ã¤ã„ã¦ã®åŸºç¤Žæ¦‚念 - Qiita
Akka Streams ãŒ2.4以é™ã‹ã‚‰experimentalを外ã—ã¦ã€æ£å¼ç‰ˆã‚’リリースã—ã¾ã—ãŸã€‚ä¸åº¦ä¼šç¤¾ã§3æ—¥ã®HackerDaysã‚’æ©Ÿã«ã€Akka Streams を勉強ã—ã¯ã˜ã‚ã¾ã—ãŸã€‚ ã“ã®è¨˜äº‹ã§ã¯ã€AkkaStreamã®å…¬å¼ãƒ‰ã‚ュメントを抜粋ã—ã€ç¿»è¨³ã—ãªãŒã‚‰ã€AkkaStreamã®åŸºç¤Žæ¦‚念を説明ã—ã¾ã™ã€‚ Akka Streams ã£ã¦ãªã« 背景 今ã®Internet上ã€æˆ‘々ã¯è†¨å¤§ãªãƒ‡ãƒ¼ã‚¿ã‚’消費ã—ã¦ã„る。ãã®å¤§é‡ã®ãƒ‡ãƒ¼ã‚¿ã‚’人々ã¯ãƒ“ッグデータã¨å‘¼ã‚“ã§ã„ã‚‹w。 ã‚‚ã†æ˜”ã¿ãŸã„ã«ãƒ‡ãƒ¼ã‚¿ã‚’全部ダウンãƒãƒ¼ãƒ‰ã—ã¦å‡¦ç†ã€å‡¦ç†å®Œäº†ã—ã¦ã‚¢ãƒƒãƒ—ãƒãƒ¼ãƒ‰çš„ãªå‡¦ç†ã¯æ™‚間掛ã‹ã‚Šã™ãŽã€ãã‚‚ãも一å°ã®ã‚µãƒ¼ãƒã«ä¿å˜ã—ãã‚Œãªã„データã¯å‡¦ç†ã§ããªã„ã®ã§ã€Streamã¿ãŸã„ãªæµã‚Œã¨ã—ã¦ã®å‡¦ç†ãŒå¿…è¦ã«ãªã£ã¦ã„る。 AkkaãŒä½¿ã†Actorモデルもãã®ä¸€ä¾‹ã€ãƒ‡ãƒ¼ã‚¿ã‚’分割ã—ã€ãƒ¡ãƒƒã‚»ãƒ¼ã‚¸ã¨ã—ã¦Actorã«é€ã‚‹ã€Actorã¯åªã€…æµ
Preparing for distributed system failures using akka #ScalaMatsuri
This document discusses architectural safety measures for distributed systems using Akka. It begins by introducing Akka and how it can be used to implement timeouts, circuit breakers, bulkheads and other patterns for handling failures in distributed systems. It then covers specific Akka features like actors, supervisors and clustering that provide tools for building resilient distributed architect
分散システムã«ã¤ã„ã¦èªžã‚‹ã¨ãã«æˆ‘々ã®èªžã‚‹ã“㨠― 分散システムã«ã¾ã¤ã‚ã‚‹é‡è¦ãªæ¦‚念ã«ã¤ã„㦠| POSTD
分散システムã«ã¤ã„ã¦ã¯ã€ã‚‚ã†éšåˆ†ã¨å‰ã‹ã‚‰å¦ã³ãŸã„ã¨æ€ã£ã¦ã„ã¾ã—ãŸã€‚ãŸã ã€ãã‚Œã¯ä¸€åº¦é¦–ã‚’çªã£è¾¼ã‚“ã ら最後ã€ã‚´ãƒ¼ãƒ«ã®ãªã„è¿·è·¯ã«è¿·ã„込むよã†ãªã‚‚ã®ãªã®ã§ã™ã€‚ã©ã“ã¾ã§ã‚‚続ã„ã¦ã„るウサギã®ç©´ã®ã‚ˆã†ãªã‚‚ã®ã§ã™ã€‚分散システムã«é–¢ã™ã‚‹æ–‡çŒ®ã¯æ˜Ÿã®æ•°ã»ã©å˜åœ¨ã—ã¾ã™ã€‚様々ãªå¤§å¦ã‹ã‚‰ãŸãã•ã‚“ã®è«–æ–‡ãŒç™ºè¡¨ã•ã‚Œã¦ã„ã‚‹ã°ã‹ã‚Šã§ãªãã€è†¨å¤§ãªæ•°ã®æ›¸ç±ã‚‚ã‚ã‚‹ã®ã§ã™ã€‚ç§ã®ã‚ˆã†ãªå…¨ãã®åˆå¿ƒè€…ã«ã¯ã€ã©ã®è«–文をèªã‚“ã らã„ã„ã®ã‹ã€ã©ã®æ›¸ç±ã‚’è²·ã£ãŸã‚‰ã„ã„ã®ã‹ã€è¦‹å½“ã‚‚ã¤ãã¾ã›ã‚“。 ãã‚“ãªã¨ãã€ä¸€éƒ¨ã®ãƒ–ãƒã‚¬ãƒ¼ãŒã€ 分散システムエンジニア （ãã‚ŒãŒã©ã†ã„ã†æ„味ã§ã‚れ）ã«ãªã‚‹ãªã‚‰çŸ¥ã£ã¦ãŠãã¹ãè«–æ–‡ã¨ã„ã†ã‚‚ã®ã‚’推奨ã—ã¦ã„ã‚‹ã®ã‚’見ã¤ã‘ã¾ã—ãŸã€‚ãã®ä¸€éƒ¨ã‚’紹介ã—ã¾ã—ょã†ã€‚ FLP , Zab , Time, Clocks and the Ordering of Events in a Distributed Systems , Viewstamped
Manning: Akka in Action
Akka in Action is a comprehensive tutorial on building message-oriented systems using Akka. The book takes a hands-on approach, where each new concept is followed by an example that shows you how it works, how to implement the code, and how to (unit) test it. about the technology Akka makes it relatively easy to build applications in the cloud or on devices with many cores that efficiently use the
Akka-Streams in Production
2. 自己紹介 • ä¼šç¤¾ï¼šæ ªå¼ä¼šç¤¾ã‚µã‚¤ãƒãƒ¼ã‚¨ãƒ¼ã‚¸ã‚§ãƒ³ãƒˆ • åå‰ï¼šä¾†ç”°ä¸€å®£ • 仕事：アドテクスタジオ->Smalgo->サーãƒã‚µ イドエンジニア • 言語：Java(5å¹´), Scala(1å¹´åŠ), 他細々㨠2
Concurrency and Fault Tolerance Made Easy: An Akka Tutorial with Examples | Toptal®
Concurrency and Fault Tolerance Made Easy: An Akka Tutorial With Examples Writing concurrent programs is hard. Having to deal with threads, locks, race conditions, and so on is highly error-prone and can lead to code that is difficult to read, test, and maintain. This post provides an introductory guide to the Scala-based Akka framework, showing (with code samples) how Akka facilitates and simplif
Futures patterns • Akka Documentation
Dependency The Akka dependencies are available from Akka’s library repository. To access them there, you need to configure the URL for this repository. sbtresolvers += "Akka library repository".at("https://repo.akka.io/maven") Maven<project> ... <repositories> <repository> <id>akka-repository</id> <name>Akka library repository</name> <url>https://repo.akka.io/maven</url> </repository> </repositori
怒涛ã®Akka: Actors - KZKY memo
Actor API extends Actorã—ãŸã¨ãã«ä½¿ãˆã‚‹ APIã®èª¬æ˜Ž context.actorOfã§child actorã¤ãã‚‹ start/stopã®hook etc. Actor Lifecycle 図を見る ç™»å ´äººç‰© ActorPath ActorSelection pathã®è¡¨ç¾ actor refã®åå‰è§£æ±º ActorRef incarnationã®è¡¨ç¾ pathã‚’æŒã¤ uidã‚’æŒã¤ Actor Incarnation pathã«æ‰€å±ž uidã‚’æŒã¤ mailboxã‚’æŒã¤ ä¾å˜é–¢ä¿‚ Actorã®æ§‹æˆè¦ç´ ã®ä¾å˜é–¢ä¿‚ Actor -> context=ActorContext -> self = ActorRef -> path=ActorPath Lifecycle Monitoring aka DeathWatch ã‚ã‚‹Actorã®å供をwatch対象ã«ã™ã‚‹ import
Akka Memo - tkawachi Blog
Scala 2.10 ã‹ã‚‰ä»˜ã„ã¦ãã‚‹ Akka ã® Actor ã«ã¤ã„ã¦ã®ãŠå‹‰å¼·ãƒ¡ãƒ¢ã€‚ 全然ã¾ã¨ã¾ã£ã¦ã„ãªã„ãŒæ™’ã—ã¦ãŠã。 概念 Actor akka.actor.Actor。 メッセージをå—ã‘ã¦å‡¦ç†ã‚’ã™ã‚‹äººã€‚ Mailbox Actorã¸ã®ãƒ¡ãƒƒã‚»ãƒ¼ã‚¸ãŒæºœã¾ã‚‹ã¨ã“ã‚。 Supervision Actoré–“ã®ä¾å˜é–¢ä¿‚ã®ã“ã¨ã€‚ Actorインスタンスã¯ãƒ„ãƒªãƒ¼æ§‹é€ ã«ãªã£ã¦ã„る。 親㌠supervisor ã¨ãªã‚‹ã€‚ Actor ãŒå¤±æ•—ã—ãŸã‚‰ã©ã†ã™ã‚‹ã‹ã¯ supervisor ã® actor ãŒåˆ¶å¾¡ã™ã‚‹ã€‚ 親 actor ㌠shutdown ã—ãŸã‚‰ã€ãã®åã©ã‚‚ã¯å…¨ã¦ shutdown ã™ã‚‹ã€‚ タスクã®ã¾ã¨ã¾ã‚Šæ¯Žã«ã‚µãƒ–ツリーを形æˆã™ã‚‹ã‚ˆã†ã«ã™ã‚‹ã¨è‰¯ã„らã—ã„。 Actor Path Actorインスタンスã«ã¯ãƒ„ãƒªãƒ¼æ§‹é€ ä¸Šã®ä½ç½®ã‚’表ã™æ–‡å—列ãŒã¤ã„ã¦ãŠã‚Šã€ã“れを actor path ã¨å‘¼ã¶ã€‚ /, /
ã€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ã«
Akka and JDBC to Services - NoisyCode
I started mapping out this post over a month ago after I saw another question about how to handle blocking database calls on the Akka mailing list. I’ve been working towards most of what follows over the last year and after discussing the basics with a few others in the Vancouver Polyglot community with some additional prompting from Saem, I finally put this together (project link for the lazy). T
Developing an Akka Edge4-5
2. ã“ã®æœ¬ã«ã¤ã„㦠Developing an Akka Edge (è‘—)Thomas Lockney, Raymond Tay Akkaåˆå¿ƒè€…å‘ã‘ã®æ´‹æ›¸ å…¨191ページ・10ç« ã›ã£ã‹ãèªã‚“ã§ã‚‹ã®ã§è¦ç´„ã—ã¾ã—㟠※自分ã§èª¿ã¹ãŸäº‹ã‚„ã€è€ƒãˆãŸä¾‹ã‚‚載ã›ãŸã®ã§ã‚¹ãƒ©ã‚¤ãƒ‰ã«æ£ã—ããªã„ã“ã¨ãŒæ›¸ã„ã¦ã‚ã‚‹å¯èƒ½æ€§ãŒã‚ã‚Šã¾ã™â€»
リリースã€éšœå®³æƒ…å ±ãªã©ã®ã‚µãƒ¼ãƒ“スã®ãŠçŸ¥ã‚‰ã›
最新ã®äººæ°—エントリーã®é…ä¿¡
j次ã®ãƒ–ックマーク
kå‰ã®ãƒ–ックマーク
lã‚ã¨ã§èªã‚€
eコメント一覧を開ã
oページを開ã
Scala Documentation — Akka Documentation
Akkaã§åˆ†æ•£ã‚·ã‚¹ãƒ†ãƒ 入門
GitHub - akka-js/akka.js: Akka, for Scala.js
{{#tags}}- {{label}}
{{/tags}}