Akka - Uma plataforma para o desenvolvimento de sistemas concorrentes e distribuídos para a JVM

Apresentação sobre programação de sistemas concorrentes usando Akka, em Java e Scala, apresentada na QConSP 2011.

Ementa:


Conheça Akka, uma plataforma para o JVM para desenvolvimento de sistemas concorrentes e/ou distribuídos através do paradigma de Atores.

Descreveremos o paradigma de atores, suas vantagens e desvantagens, e mostraremos exemplos da API em Java e em Scala, com execução local e distribuída, memória transacional e tolerância a falhas.

1. Uma plataforma para o desenvolvimento de sistemas concorrentes e distribuídos para a JVM

2. Akka Uma plataforma para o desenvolvimento de sistemas concorrentes e distribuídos para a JVM Daniel Capó Sobral Consultor pela Tecnisys Programador e Sysadmin Ex-committer FreeBSD Aficionado por Scala

3. Akka Uma plataforma para o desenvolvimento de sistemas concorrentes e distribuídos para a JVM Conheça Akka , uma plataforma para o JVM para desenvolvimento de sistemas concorrentes e/ou distribuídos através do paradigma de Atores . Descreveremos o paradigma de atores, suas vantagens e desvantagens, e mostraremos exemplos da API em Java e em Scala, com execução local e distribuída, memória transacional e tolerância a falhas.

4. Conteúdo

5. O que é Akka ?

6. Uma cadeia de montanhas?

7. Uma cadeia de montanhas? “ Akka ” é uma cadeia de montanhas na Suécia

8. Um componente do Typesafe Stack ?

9. Um componente do Typesafe Stack ? A Typesafe foi fundada em 2011 pelos criadores da linguagem de programação Scala e do middleware Akka . O Typesafe Stack contém Scala, Akka e ferramentas de desenvolvimento, tudo open source . A Typesafe Subscription provê suporte comercial.

10. Uma solução de:

11. Uma solução de:

12. Uma solução de:

13. Uma solução de:

14. Concorrência

15. Atores

16. Objetos vs Atores

17. Objetos vs Atores

18. Objetos vs Atores

19. Objetos vs Atores

20. Objetos vs Atores

21. Objetos vs Atores

22. Fatos sobre Atores

23. Definindo um Ator - Java public class SampleUntypedActor extends UntypedActor { public void onReceive (Object message) throws Exception { if ( message instanceof String ) EventHandler.info( this , String.format ( "Received String message: %s" , message )); else throw new IllegalArgumentException ( "Unknown message: " + message); } }

24. Criando um Ator - Java import static akka.actor.Actors .*; ActorRef myActor = actorOf ( SampleUntypedActor.class ); myActor.start (); // Construtor com parâmetros ActorRef actor = actorOf ( new UntypedActorFactory () { public UntypedActor create () { return new MyUntypedActor ( " service:name " , 5 ); } }).start();

25. ActorRef vs Actor

26. Ciclo de Vida

27. Enviando uma mensagem

28. Futuros interface Future<T> { void await (); boolean isCompleted (); boolean isExpired (); long timeoutInNanos (); Option <T> result (); Option < Throwable > exception (); Future<T> onComplete (Procedure<Future<T>> procedure); }

29. Usando Futuros - Java Future future = actorRef.sendRequestReplyFuture ( " Hello " , getContext (), 1000 ); future.await (); if ( future.isCompleted ()) { Option resultOption = future.result (); if ( resultOption.isDefined ()) { Object result = resultOption.get (); ... } ... // whatever }

30. Respondendo ao Remetente - Java public void onReceive (Object message) throws Exception { if ( message instanceof String ) { String msg = ( String ) message ; if ( msg.equals ( "Hello" ) && getContext (). getSenderFuture (). isDefined ()) { // Reply to original sender of message using the channel getContext ().channel(). sendOneWay ( msg + " from " + getContext (). getUuid ()); } } }

31. Respondendo Mensagem - Java public void onReceive (Object message) throws Exception { if ( message instanceof String ) { String msg = ( String ) message ; if ( msg.equals ( " Hello " )) { if ( getContext (). replySafe ( msg + " from " + getContext (). getUuid ())) ... // success else ... // handle failure } } }

32. Parando um Ator - Java actor.stop ();

33. Akka em Scala

34. Akka em Scala

35. Typed Actors

36. Agentes

37. Agentes - Scala

38. STM

39. STM - Java final Ref<Integer> ref = new Ref<Integer>( ); public int counter () { return new Atomic < Integer >() { public Integer atomically () { int inc = ref.get () + 1 ; ref.set ( inc ); return inc ; } }.execute(); }

40. Dataflow

41. Dataflow - Scala

42. Escalabilidade

43. Atores Remotos - Java // server code class HelloWorldActor extends UntypedActor { public void onReceive ( Object msg ) { getContext (). replySafe ( msg + " World" ); } } remote ().start( " localhost " , 9999). register ( " hello-service " , actorOf ( HelloWorldActor.class )); // client code ActorRef actor = remote (). actorFor ( " hello-service " , " localhost " , 9999); Object res = actor.sendRequestReply ( " Hello " );

44. Atores Remotos

45. Tolerância à Falhas

46. Tolerância à Falhas

47. Só isso?

48. Só isso?

49. Só isso? Crédito: Palestra Above the Clouds : Introducing Akka Jonas Bonér

50. Mais informações...

51. Contato