![[Alam aeki] Guida illustrata alla modellazione di un dominio con Event Sourci...](https://cdn.slidesharecdn.com/ss_thumbnails/alamaeki-140615030507-phpapp01-thumbnail.jpg?width=560&fit=bounds)
More Related Content
What's hot (20)
Similar to Akka.net & Actor Model (20)
Akka.net & Actor Model
- 1. DEV012 - AKKA.NET Multithreading & Distributed Programming Made Easy STEFANO DEL FURIA IIS ROSSELLI STOA DELFURIA@GMAIL.COM @STENODELFO WPC2017 1
- 2. #DOTNETDAY2018 2 Enthusiastic adopter of C# and .NET since 2001 Computer Science Teacher @ IIS-Rosselli Founder of EduDotNet.It community Software Architect @ STOA Technical writer Drummer WPC2017 2
- 3. Multithreading Actor Model & AKKA.Net Actor & Messages ActorSystem Resilienza Persistenza Delivery Remoting Scale Up/Scale Out Testing Anti-Pattern Varie ed eventuali WPC2017 3
- 4. WPC2017 4 Olivetti Elea 9003/02(1960) 33 KW 20 KB ram 20 MB Nastro magnetico No OS, No Schermo 3 Attivit contemporanee Bibbiena (AR) www.elea9003.it
- 5. WPC2017 5
- 6. WPC2017 6
- 7. WPC2017 7
- 8. Ti studi a cosa serve il Multithread Avere una UI reattiva Incrementare le prestazioni Operazioni concorrenti CPU (Core) Input / Output WPC2017 8
- 9. e quali siano i relativi pattern !!! Fire & Forget Polling Wait for Completion Completion Notification WPC2017 9
- 10. 10/50 Perch辿 poi arriva un cliente Presse n. 153 Robot n. 1303 Stazioni di verniciatura n. 8
- 11. che lo vuole distribuito e pure reattivo !!!
- 12. Un giorno andr嘆 a vivere in Teoria perch辿 in Teoria va tutto bene WPC2017 12
- 13. Ma invece scopri che in Pratica La programmazione Multithread 竪 difficile Scrivere codice 竪 MOLTO complicato Il tempo di progettazione delle applicazioni aumenta I pattern paralleli sono difficili da implementare WPC2017 13
- 14. ed in pi湛 !!! LOverhead pu嘆 ridurre le prestazioni Troppe potenziali problematiche Races, deadlocks, livelocks, lock convoys, cache coherency overheads, lost event notifications, broken serializability, priority inversion WPC2017 14
- 15. Lassa Gi WPC2017 15 (Modo di dire perugino: las-sa-g狸) Invito a rinunciare a svolgere unattivit a causa della sua impossibilit di realizzazione Es: 束Ci provo con quella ragazza ? 損 束Lassa Gi 損
- 16. WPC2017 16
- 17. WPC2017 17
- 18. WPC2017 18
- 20. WPC2017 20
- 21. Actor Model studiare tu devi !!! WPC2017 21
- 22. Actor Model Evita che i thread collidano sui dati Utilizza dei task leggeri Scambio di messaggi in maniera asincrona WPC2017 22
- 23. Actor Model 1973 Carl Hewitt definisce lActor model un modello concettuale Ha a che fare con la computazione concorrente Definisce regole generali per come debbano interagire i componenti di un sistema e pi湛 sistemi tra di loro. Origine in Erlang WPC2017 23
- 24. Actor Model Semplifica la realizzazione di sistemi: Scalabili Concorrenti Elevate prestazioni Bassa latenza WPC2017 24
- 25. Ambiti applicativi Applicazioni transazionali (Finanziarie, social media, telecom) Batch (Divisione del carico di lavoro tra pi湛 Actor) Microservices (REST, GraphQL, System integration) Comunicazioni (Chat, notifiche Real time) Gioco (Multiplayer) Elaborazione numerica (Business intelligence, data mining) IoT (Ingestion del flusso di dati) WPC2017 25
- 26. AKKA.NET Unimplementazione in .NET dellActor Model Alte prestazioni (3.3M messaggi al secondo) Molto leggera (ogni Actor occupa 400byte) Akka TestKit Akka Persistence Akka Logger WPC2017 26 Akka DI Akka Remote Akka Cluster
- 27. Cos竪 un Actor Tutto 竪 un Actor lazy-by-design Compiti piccoli e ben definiti Unit computazionale primitiva Ogni istanza ha un indirizzo (reference) Possibilit di esecuzione locale o distribuita Comunica con altri Actor via messaggi asincroni WPC2017 27
- 28. Le 3 cose che pu嘆 fare un Actor Ricevere ed elaborare un messaggio Creare altri Actor Inviare messaggi agli altri Actor (compreso se stesso) WPC2017 28
- 29. Come 竪 fatto un Actor Mailbox in ingresso Comportamento Stato Strategia di Supervisione Gerarchia di figli Processa sempre un messaggio alla volta WPC2017 29
- 30. Gli Actor condividono i thread WPC2017 30
- 31. Actor & Messaggi WPC2017 31
- 32. Cos竪 un Messaggio Classe POCO Le istanze dei messaggi dovrebbero essere immutabili WPC2017 32
- 33. Gerarchia degli Actor (system context) WPC2017 33
- 34. Actor 101 Definizione dei ReceiveActor Logica di comportamento nel costruttore Definizione dei UntypedActor Logica di comportamento nel metodo OnReceive() Creazione dellActorSystem Creazione degli Actor Contenuto di un messaggio Utilizzo di Props WPC2017 34
- 35. Actor 101 Invio di messaggi ad un Actor Tell() Forward() Terminare un Actor Stop() (Termina lActor immediatamente) PoisonPill() (Termina lActor dopo lelaborazione del messaggio corrente) WPC2017 35
- 36. DEMO 1-2: Akka.NET for dummies WPC2017 36
- 37. ActorSystem Centro di controllo del sistema di Actor Evitare la creazione di pi湛 Actor System Oggetti pesanti Gestione pi湛 complessa Implementare un proprio ActorSystem Singleton Configurazione di default WPC2017 37
- 39. Configurazione HOCON (Human-Optimized Config Object Notation) un formato di configurazione estensibile Configura tutto (logging, networking, serialization, etc) Utilizzabile anche mediante App.config Web.config WPC2017 39
- 40. Logging (Log su file ? sul serio ?? .. nel 2017 ???) Utilizzare il meccanismo di Akka.Net Facile da implementare Evitare log sincrono Disabilitare la modalit Debug in produzione WPC2017 40
- 41. Actor Reference, Path e Address WPC2017 41
- 42. Actor Reference, Path e Address WPC2017 42
- 43. Indirizzo univoco e globale WPC2017 43
- 44. Ricapitolando Implementare un Actor System gerarchico Evitare gerarchie FLAT con Actor tutti creati allo stesso livello Implementare delle classi base per messaggi, logging, supervisione, ecc. WPC2017 44
- 47. WPC2017 47
- 48. WPC2017 48 Ciclo di vita di un Actor
- 49. Supervisione Resume LActor viene mantenuto e lo stato viene preservato Restart LActor viene ricreato e lo stato viene cancellato Stop LActor viene terminato Escalate LActor inoltra il problema al livello superiore e successivamente termina se stesso WPC2017 49
- 53. BackOff Supervisor Certe volte il fallimento di un Actor dipende da una risorsa esterna a cui si deve dare il tempo di ripartire Riavvio ritardato Strategia esponenziale (3, 6, 12, 24, ) WPC2017 53
- 55. Persistenza Memorizzazione su di uno storage Event Source Snapshot Reidrata lo stato dellActor Dopo un crash Per qualsiasi ragione WPC2017 55
- 56. Persistenza In-memory + files locali Microsoft SQL Server Azure tables PostgreSql Cassandra WPC2017 56 MySql MongoDB Redis Sqlite Oracle
- 58. Message Delivery Non viene garantita la consegna del messaggio Usa politica At Most Once Alternative At Least Once Exactly Once WPC2017 58
- 59. WPC2017 59
- 62. Remoting Il componente pi湛 importante di AKKA.NET Implementa un ActorSystem tra pi湛 processi distribuiti in rete WPC2017 62
- 63. Remoting Peer-to-peer Location transparency Remote addressing , messaging, deployment Multiple network transports (in verit solo TCP) Attenzione !!! I messaggi vengono serializzati Attenzione alla dimensione del payload WPC2017 63
- 66. Scale UP Router Round Robin Broadcast Random Consistent Hashing (Cluster) Smallest Mailbox WPC2017 66
- 68. Scale OUT Clustering Pi湛 nodi di un ActorSystem agiscono come fosse un unico nodo Alta disponibilit Alte prestazioni WPC2017 68
- 70. Testing Akka.TestKit.* NUnit XUnit VsTest TestActorSystem lActor System utilizzato da TestKit e viene ricreato ogni volta che si esegue un test TestActor il mittente implicito di tutti i messaggi che verrano inviati agli attori WPC2017 70
- 71. WPC2017 71
- 72. Cosa si pu嘆 testare ExpectMsg ExpectNoMsg Within AwaitAssert TestActorRef TestProbe WPC2017 72
- 74. Anti-Pattern Request / Respnse Async / Await Akka.Interfaced (0.5.x) https://github.com/SaladLab/Akka.Interfaced WPC2017 74
- 76. Ed altro ancora Event-stream Networking Finite-State-Machine Circuit Breaker Scheduler WPC2017 76
- 77. Riferimenti WPC2017 Demo https://github.com/delfuria/WPC2017-AKKA.NET Akka .NET http://getakka.net/ Akka Bootcamp https://github.com/petabridge/akka- bootcamp Gitter https://gitter.im/akkadotnet/akka.net WPC2017 77