Démystifier le réactif et l'orchestration de services avec Vert.x, Kubernetes et Kotlin

Transcript

1. Démystifier le réactif et l'orchestration de services avec Vert.x, Kubernetes et Kotlin
2. Julien Ponge Maitre de Conférences “Delegated consultant to Red Hat” on Vert.x Eclipse Golo + extensive F/OSS background ! https://julien.ponge.org/ " @jponge # @jponge  https://www.mixcloud.com/hclcast/
3. “No to average expertise on any of these technologies” ! " (or async)
4. Kotlin? (1 slide to be an expert)
5. data class Person(val name: String, val age: Int) fun String.yo() { println("$this -> Yo!") } fun wrap(block: () -> Unit) { println("{{{") block() println("}}}") } fun main(args: Array<String>) { wrap { val phil = Person(name="Philippe", age=45) println(phil) phil.name.yo() } }
6. data class Person(val name: String, val age: Int) fun String.yo() { println("$this -> Yo!") } fun wrap(block: () -> Unit) { println("{{{") block() println("}}}") } fun main(args: Array<String>) { wrap { val phil = Person(name="Philippe", age=45) println(phil) phil.name.yo() } }
7. data class Person(val name: String, val age: Int) fun String.yo() { println("$this -> Yo!") } fun wrap(block: () -> Unit) { println("{{{") block() println("}}}") } fun main(args: Array<String>) { wrap { val phil = Person(name="Philippe", age=45) println(phil) phil.name.yo() } }
8. data class Person(val name: String, val age: Int) fun String.yo() { println("$this -> Yo!") } fun wrap(block: () -> Unit) { println("{{{") block() println("}}}") } fun main(args: Array<String>) { wrap { val phil = Person(name="Philippe", age=45) println(phil) phil.name.yo() } } {{{ Person(name=Philippe, age=45) Philippe -> Yo! }}}
9. Reactive? (because resources are scarce)
11. Application
12. Reactive systems Reactive streams Reactive programming Reactive “Responding to stimuli” Manifesto, Actor, Messages Resilience, Elasticity, Scalability, Asynchronous, non-blocking Data flow Back-pressure Non-blocking Data flow Events, Observable Spreadsheets Akka, Vert.x Akka Streams, RxJava, Reactor, Vert.x Reactor, Reactive Spring, RxJava, Vert.x
13. while (isRunning) { String line = bufferedReader.readLine(); switch (line.substring(0, 4)) { case "ECHO": bufferedWriter.write(line); break // ... // other cases ( ...) // ... default: bufferedWriter.write("UNKW Unknown command"); } }
14. x 1000 = %
15. Virtual machines, Containers, etc
17. Vert.x? (async all the things!)
18. Eclipse Vert.x Open source project started in 2012 Eclipse / Apache licensing A toolkit for building reactive applications for the JVM 7K ⋆ on ' Built on top of ! https://vertx.io " @vertx_project
19. ( ) ( Http server verticle Database client verticle  Event Bus + ) “Details for user 1234?” “{data}” 4 instances 1 instance
20. Events Thread Event Loop
21.  Verticles ( ( ( public class SomeVerticle extends AbstractVerticle { @Override public void start() throws Exception { } @Override public void stop() throws Exception { } } class SomeVerticle : AbstractVerticle() { override fun start() { } override fun stop() { } } exports.vertxStart = function() { } exports.vertxStop = function() { }
22. (demo) Hello Kotlin + Vert.x
24. Async is hard (callback hell is just one facet)
25. Kotlin coroutines Looks “like” sequential operations async/await, Go-style channels
27. RxJava2 + Kotlin extensions Declarative data flows over event sources Operators transforming data + event streams
28. fun main(args: Array<String>) { val rand = Random() val o1 = Observable .fromCallable(rand ::nextInt) .repeat() .take(500, TimeUnit.MILLISECONDS) .filter { it > 0 } .filter { it % 2 == 0 } .map { "[${it}]" } val o2 = Observable.fromIterable(1 ..Long.MAX_VALUE) Observables .zip(o1, o2) { n, id -> "${id} -> ${n}" } .subscribeBy( onNext = logger ::info, onError = { logger.error("Oh?") }, onComplete = { logger.info("Done!") } ) } “id -> [n]” zip()
29. Kubernetes? (orchestrating containers for you)
30. https://cloud.google.com/kubernetes-engine/kubernetes-comic
32. https://cloud.google.com/kubernetes-engine/kubernetes-comic
33. https://cloud.google.com/kubernetes-engine/kubernetes-comic
34. Pod Pod Pod Pod Pod Pod Pod Pod Node Node Master(s)
35. Same host Same network Same namespace Same volumes Same secrets Pod Container Container Container
36. Container Container Container Pod replicas & scaling Readiness probes Liveness probes Restart policy Rolling upgrades (…)
37. Using Kubernetes (minikube is your friend)
38. ⚙ Temperatures services Aggregate Alarm
39. Vert.x callbacks Coroutines, liveness RxKotlin Discovery RxKotlin, SockJS event bus bridge, VueJS, MongoDB
40. (demo) Kubernetes (minikube) https://github.com/jponge/demo-vertx-kotlin-rxjava2-kubernetes
41. Outro (how was the nap?)
42. Unified end-to-end reactive model + ecosystem (not just APIs…) For all kinds of distributed applications (even the small-scale ones) Flexible toolkit, not a framework (your needs, your call)
43. https: //youtu.be/ZkWsilpiSqw - Applications réactives avec Eclipse Vert.x . Building Reactive Microservices in Java https: //goo.gl/ep6yB9 . Guide to async programming with Vert.x for Java developers https: //goo.gl/AcWW3A
44. Q&A ! https://julien.ponge.org/ " @jponge # @jponge  https://www.mixcloud.com/hclcast/