[JCConf 2017] Reactive Programming with Reactor
?
10 likes?1,499 views
http://jcconf.tw/2017/speaker/swanky.html 維基百科中解釋Reactive Programming為「一種面向資料流和變化傳播的編程範式。這意味著可以在程式語言中很方便地表達靜態或動態的資料流，而相關的計算模型會自動將變化的值通過資料流進行傳播。」 字面上不是很容易體會，但實際從接觸學習到應用在現有程式的數個月親身經歷中，是很強烈地感受到它是多麼強大又很潮的一個新世代工具。 本議程會試著以一個開發者的角度，帶你使用在Spring 5全面現身的Reactor入門Reactive Programming。
![#JCConfTaiwan 2017
Ref. Future
? [JCConf 2015] 使?用 Java 的
Future/Promise API 來來撰寫非同
步程式 by kojilin?
https://youtu.be/_EqitUOUpes
? Reactive Programming Patterns
with Java 8 Futures?
https://youtu.be/tiJEL3oiHIY](https://image.slidesharecdn.com/jcconf2017reactiveprogrammingwithreactor-170929074258/85/JCConf-2017-Reactive-Programming-with-Reactor-30-320.jpg)
![#JCConfTaiwan 2017
Reactive Stream
[JDK 9]?
java.util.concurrent.Flow
http://www.reactive-streams.org/](https://image.slidesharecdn.com/jcconf2017reactiveprogrammingwithreactor-170929074258/85/JCConf-2017-Reactive-Programming-with-Reactor-31-320.jpg)
[JCConf 2017] Reactive Programming with Reactor
- 1. #JCConfTaiwan 2017 Reactive Programming with Reactor Swanky Hsiao (史旺基) http://swanky.github.io/
- 5. #JCConfTaiwan 2017 Operators + Functional Programming filter flatMap publishOn just fromArray fromIterable empty error never map collect subscribeOn zipWith
- 6. #JCConfTaiwan 2017 Blocking Synchronous Call class MyService {? ? boolean doSomething(){? // … sync & blocking ? }? ? }
- 8. #JCConfTaiwan 2017 史旺基 (蕭宇程) 《制服．女孩 × 史旺基》系列列與 《?高校制服戀物論》攝影作者 朱學恒「阿宅反抗軍」及? 「制服地圖」特約攝影師 國立臺灣師範?大學資訊?工程博?士 JWorld@TW認證版主 ?目前任職於資策會
- 11. #JCConfTaiwan 2017 Reactive Systems Reactive Programming Functional Reactive? Programming (FRP)
- 12. #JCConfTaiwan 2017 FRP ICFP 1997 Ref: http://conal.net/papers/icfp97/
- 13. #JCConfTaiwan 2017 Reactive Manifesto Ref: https://www.reactivemanifesto.org/
- 14. #JCConfTaiwan 2017 Responsive React to its users
- 15. #JCConfTaiwan 2017 Resilient React to failure and stay available
- 16. #JCConfTaiwan 2017 Elastic React to variable load conditions
- 17. #JCConfTaiwan 2017 Message-driven React to inputs
- 18. #JCConfTaiwan 2017 Reactive Programming Combination of ?Functional Programming ?Event Based Programming ?Loose Coupling ?Error Resilience
- 19. #JCConfTaiwan 2017 Blocking APIs Ref: https://www.lightbend.com/reactive-programming-versus-reactive-systems
- 20. #JCConfTaiwan 2017 call model makeup dress up photo shooting Ref: https://www.lightbend.com/reactive-programming-versus-reactive-systems
- 22. #JCConfTaiwan 2017 call model makeup dress up photo shooting Ref: https://www.lightbend.com/reactive-programming-versus-reactive-systems
- 26. #JCConfTaiwan 2017 Reactive API Implementation Callback-based Future/Promise Reactive Stream
- 28. #JCConfTaiwan 2017 Ref. Callback ? Event Handling and Callback Methods with Java in Android? https://youtu.be/8cufpQlHUOE
- 30. #JCConfTaiwan 2017 Ref. Future ? [JCConf 2015] 使?用 Java 的 Future/Promise API 來來撰寫非同 步程式 by kojilin? https://youtu.be/_EqitUOUpes ? Reactive Programming Patterns with Java 8 Futures? https://youtu.be/tiJEL3oiHIY
- 34. #JCConfTaiwan 2017 Ref. Stream ? Get a Taste of Lambdas and Get Addicted to Streams? https://youtu.be/1OpAgZvYXLQ
- 35. #JCConfTaiwan 2017 Project Reactor Start - 2012 Reactor 1.x - 2013 Reactor 2.0 - 2015 April Reactor 2.5 - 2016 Feb Reactor 3.0 - 2016 Aug Reactor 3.1 - 2017 https://projectreactor.io/
- 40. #JCConfTaiwan 2017 Reactor Core Features ? Flux, an asynchronous sequence of 0-n items ? Mono, an asynchronous 0-1 result ? Simple ways to create a Flux/Mono and to subscribe to it ? Programmatically creating a sequence ? Schedulers ? Handling Errors ? Processor
- 41. #JCConfTaiwan 2017 Flux / Mono
- 43. #JCConfTaiwan 2017 Operators ? Creating ? Transforming ? Filtering ? Combining ? Error Handling ? Utility ? Conditional and Boolean ? Mathematical and Aggregate ? Converting ? Connectable ? Backpressure
- 45. #JCConfTaiwan 2017 Creating Flux/Mono: just Flux<String> seq =? Flux.just("foo", "bar", "foobar"); Mono<String> data = Mono.just("foo");
- 46. #JCConfTaiwan 2017 Creating Flux: fromXxx List<String> iterable = Arrays.asList("foo", "bar", "foobar"); Flux<String> seq = Flux.fromIterable(iterable);
- 47. #JCConfTaiwan 2017 Creating Mono: fromXxx
- 48. #JCConfTaiwan 2017 Creating Flux: range Flux<Integer> ints = Flux.range(1, 3);
- 51. #JCConfTaiwan 2017 Publisher SubscriberProcessor Processor
- 52. #JCConfTaiwan 2017 Request to Start streaming data: subscribe
- 54. #JCConfTaiwan 2017 Scheduler Threading ? Schedulers.immediate()? current thread ? Schedulers.single()? single, reusable thread ? Schedulers.elastic()? elastic thread pool ? Schedulers.parallel()? fixed pool of workers(CPU cores) ?Schedulers.fromExecutorService(ExecutorService)
- 55. #JCConfTaiwan 2017 Scheduler Threading (ex: Flux) Ref: https://stackoverflow.com/a/41941592 Flux.just("a", "b", "c") .doOnNext(v -> System.out.println("before publishOn: " + Thread.currentThread().getName())) .publishOn(Schedulers.elastic()) .doOnNext(v -> System.out.println("after publishOn: " + Thread.currentThread().getName())) .subscribeOn(Schedulers.parallel()) .subscribe(v -> System.out.println("received " + v + " on " + Thread.currentThread().getName())); before publishOn: parallel-1 before publishOn: parallel-1 before publishOn: parallel-1 after publishOn: elastic-2 received a on elastic-2 after publishOn: elastic-2 received b on elastic-2 after publishOn: elastic-2 received c on elastic-2 Output:
- 56. #JCConfTaiwan 2017 Reactor Core Reactor Test Reactor Netty Reactor Adapter Reactor Kafka Reactor Extra
- 59. #JCConfTaiwan 2017 Ref. Reactive Programming with Reactor ? Project Reactor? https://projectreactor.io/ ? Reactive Programming versus Reactive Systems? https://www.lightbend.com/reactive-programming-versus-reactive-systems ? Reactive Programming with Reactor 3? https://tech.io/playgrounds/929/reactive-programming-with-reactor-3/Intro ? What Are Reactive Streams in Java?? https://dzone.com/articles/what-are-reactive-streams-in-java ? 5 Things to Know About Reactive Programming? https://dzone.com/articles/5-things-to-know-about-reactive-programming ? Java 9 Flow API – Reactive Streams? http://javasampleapproach.com/java/java-9/java-9-flow-api-reactive-streams