Colaboração em tempo real com Clojure

(1)

Colaboração em tempo real

com Clojure

QCon - São Paulo, 2016

Leonardo Borges @leonardo_borges www.atlassian.com

(2)

Sobre

‣ Líder de equipe / Desenvolvedor Clojure na Atlassian

‣ Fundador do Grupo de Usuários Clojure de Sydney

‣ Autor do livro Clojure Reactive

(3)

Colaboração

co.la.bo.ra.ção

1 Ato de colaborar; cooperação; ajuda. 2 Trabalho feito pelos colaboradores. 3 Conjunto dos colaboradores. 4 Inform Reunião de duas ou mais pessoas

(4)

(5)

(6)

Operational Transformation 101

lá QQCon São Paulo!

user server

(7)

Operational Transformation 101

user server

(ins 0 “O”)

lá QQCon São Paulo! lá QQCon São Paulo!

(8)

Operational Transformation 101

user server

(del 3) (ins 0 “O”)

(9)

Operational Transformation 101

user server

(del 3) (ins 0 “O”)

Olá QQCon São Paulo! lá QCon São Paulo!

(10)

Operational Transformation 101

user server

OláQQCon São Paulo! Olá QCon São Paulo! (del 3)

(ins 0 “O”)

(11)

Operational Transformation 101

user server

(del 3) (ins 0 “O”)

(12)

Operational Transformation 101

user server

Olá QCon São Paulo! Olá QCon São Paulo!

(del 3) (ins 0 “O”)

(13)

user user user user user web server state

(14)

user user user user user web server state user user user user web server web server load balancer

(15)

user user user user user DB user user user user web server load balancer

(16)

Para onde encaminhamos as requisições?

(17)

Como os servidores falam um com o outro?

(18)

O que acontece quando um dos servidores cai ou entra no

(19)

Que tipo de garantias de entrega são necessárias?

(20)

Que tipo de garantias de ordenação são necessárias?

(21)

Que tipo de garantias de ordenação são necessárias?

(22)

(23)

Vert.x

-SockJS

-Clustering

(24)

Vert.x

-SockJS

-Clustering

(25)

Vert.x

-SockJS

-Clustering

(26)

(27)

Actors

-State

-Location Transparency

-“At least once” delivery semantics -Ordering guarantees

(28)

Actors

-State

-“At least once” delivery semantics -Ordering guarantees

(29)

Actors

-State

-Garantias de entrega “At least once” e garantia de ordem

(30)

Akka and Pulsar

-Usar Akka desde Clojure é tedioso

-Clustering (in Pulsar) -JVM only

(31)

Akka and Pulsar (Quasar)

-Usar Akka desde Clojure é tedioso -Clustering (in Pulsar)

-JVM only -Fairness

(32)

-JVM only

-Fairness

(33)

-JVM only -Fairness

(34)

user web server state entity

Fairness

(35)

user user

web server entity state entity

Fairness

user

(36)

(37)

Sumário das opções

Entrega Ordem Fairness End-to-End

Vert.x

Akka / Pulsar

Distributed core.async (custom code)

(38)

(39)

(40)

Multiplexer

(41)

Multiplexer

Multiplexer endpoint duplex

(42)

Multiplexer

Multiplexer endpoint

web server state duplex

channel

duplex channel

(43)

Multiplexer

endpoint

web server state

web server state duplex channel duplex channel duplex channel duplex channel

(44)

web server state

Multiplexer

endpoint

web server state

web server state duplex channel duplex channel duplex channel duplex channel

(45)

Multiplexer

user load

balancer

web server state Multiplex

(46)

Multiplexer

user load

balancer

(47)

Multiplexer

user load

balancer

(48)

Multiplexer

user load

balancer

(49)

Multiplexer

user load

balancer

(50)

Multiplexer

user load

balancer

(51)

Aleph cluster

-Client and Server network programming

-Built on Netty and therefore asynchronous -Hazelcast for group membership

(52)

Aleph cluster

-Client and Server network programming -Desenvolvido com Netty (async #FTW)

(53)

Aleph cluster

-Client and Server network programming -Desenvolvido com Netty (async #FTW) -Hazelcast for group membership

(54)

Aleph cluster + multiplexer

-Distributed, end-to-end core.async channels

-Message delivery and ordering guarantees -Fault tolerance

-Fairness

(55)

Aleph cluster + multiplexer

-Distributed, end-to-end core.async channels -Message delivery and ordering guarantees -Fault tolerance

-Fairness

(56)

Isso parece bastante trabalho.

Por que não usar Erlang/Akka

(57)

Stack

OT

diff, materialise, etc…

Networking

multiplexer,

(58)

Stack

OT

diff, materialise, etc…

Networking

multiplexer,

aleph, hazelcast, etc…

(59)

Clojurescript

-Compila código Clojure para Javascript

(60)

(ns hello.core

#?(:clj (:import (org.joda.time DateTime)))) (defn now [] #?(:clj (DateTime/now) :cljs (js/Date.now))) (defn tomorrow [] (+ (now) 86400000))

Clojurescript

Cljc

(61)

(ns hello.core

(:import (org.joda.time DateTime))) (defn now [] (DateTime/now)) (defn tomorrow [] (+ (now) 86400000)) (ns hello.core) (defn now [] (js/Date.now)) (defn tomorrow [] (+ (now) 86400000))

Clojurescript

Clj

Cljs

(62)

(63)

Async

-core.async implementa CSP (Communicating Sequential Processes) -Funciona tanto na JVM como no browser

(64)

core.async

(defn fetch-person [id]

(go (to-person (<! (fetch-resource url))))) (defn fetch-friends [id]

(go (map to-person (<! (fetch-resource url))))) (defn aggregate-person [id]

(go (let [person (<! (fetch-person id))

friends (<! (fetch-friends id))]

(65)

Programação funcional

-Funções puras

-First-class e higher-order functions -Programação declarativa

(66)

Clojure

-Imutabilidade por padrão

-Polimorfismo via records, protocols e multimethods -Extensibilidade via macros

-Ciclo de desenvolvimento extremamente curto dada a

(67)

Conclusão

-Clojurescript está mais que pronto para produção -Programação funcional e Clojure oferecem claros

benefícios para o desenvolvimento de software concorrente -core.async é uma ferramenta poderosa e flexível para

programação assíncrona

-por que não dar Clojure e programação funcional uma chance no seu próximo projeto?

(68)

References

Akka Pulsar Vert.x Aleph Jupiter OT algorithm

Consistent Hashing Ring CRDTs in Riak akka.io bit.ly/actors-pulsar vertx.io/ aleph.io/ bit.ly/jupiterOT bit.ly/HashingRing bit.ly/CRDTRiak

(69)

Obrigado!

Perguntas? Leonardo Borges @leonardo_borges www.atlassian.com www.leonardoborges.com