Reactive microserviceinaction@devnexus
- 1. Reactive Microservices in Action Emily Jiang Java Champion STSM, IBM Liberty Microservice Architect, Advocate Senior Lead for MicroProfile and CDI @emilyfhjiang Clement Escoffier Java Champion Chief Architect, Red Hat @clementplop
- 5. data/client/test/hello data/service/hello h艶鉛鉛看 h艶鉛鉛看 Interacting using synchronous calls
- 7. Asynchronous calls (because its trendy) CompletionStage<String> cs = service.doSomething().thenApply(result -> { //next instruction });
- 8. Microservices are like kids... Need mudguards (a) (b) (c)
- 10. Sorry, Im out of context... Ive lost my thread locals! (User, Transaction, Correlation Id)
- 11. MicroProfile Context Propagation Restore the context Capture the context
- 13. Lets go back to this asynchronous calls...
- 14. Most asynchronous things ARENT non-blocking.
- 15. Dust under the carpet h艶鉛鉛看 h艶鉛鉛看 Hidden thread pool data/client/test/hello data/service/hello
- 16. You need asynchrony + non-blocking to use resources efficiently
- 17. Is this what you want? Non-Blocking IOAsynchronous, Fault-Tolerance Context Propagation
- 18. And they lived together happily ever after. ??? !!!
- 19. 19 Reactive
- 20. System eXtensions Programming Manifesto Streams Asynchrony Back-Pressure Resilience Elasticity Spreadsheets Actor Data Flows Observable Events Messages ReactorRX JavaResponsiveness Fibers Non-Blocking MicroProfile Spring RSocket Reactive all the things ???
- 21. 21 System eXtensions Programming Manifesto Streams Asynchrony Back-Pressure Resilience Elasticity Spreadsheets Actor Data Flows Observable Events Messages ReactorRX JavaResponsiveness Fibers Non-Blocking MicroProfile Spring RSocket Reactive all the things ???
- 25. 25 Reactive Streams - Java 9+ edition Observable Stream of <T> Stream Observer On new item On failure On completion
- 26. 26 Reactive Streams - Java 9+ edition The contract between the observer and the stream Stop the observation Request items
- 27. 27 Reactive Streams - How does that work? Subscriber Publisher (1)subscribe (2) onSubscribe(sub)
- 28. 28 Reactive Streams - How does that work? Subscriber Publisher (3) request(x) (4) onNext(i1) (5) onNext(i2) (6) onComplete()
- 29. 29 Reactive Streams - How does that work? Subscriber Processor Publisher subscribe request(x) subscribe request(x)
- 30. 30 How does it fix my two microservices
- 31. Applying reactive to microservices Temporal decoupling Back-Pressure Protocol
- 33. Using messages to achieve decoupling BA Sent to virtual addresses Can be durable (temporal decoupling) Use non-blocking IO
- 34. Messaging / Streaming MicroProfile Application Code Container Host / Operating System Async HTTP Messaging MicroProfile Application Code Container Host / Operating System MicroProfile Reactive Messaging MicroProfile Reactive Messaging
- 38. Reactive architecture BA Decoupling, Elasticity, Resilience, Back-Pressure, Asynchrony, Non-Blocking
- 40. Thank you 40 Emily Jiang, IBM @emilyfhjiang Clement Escoffier, Red Hat @clementplop