Book Image

Hands-On Reactive Programming with Reactor

By : Rahul Sharma
Book Image

Hands-On Reactive Programming with Reactor

By: Rahul Sharma

Overview of this book

Reactor is an implementation of the Java 9 Reactive Streams specification, an API for asynchronous data processing. This specification is based on a reactive programming paradigm, enabling developers to build enterprise-grade, robust applications with reduced complexity and in less time. Hands-On Reactive Programming with Reactor shows you how Reactor works, as well as how to use it to develop reactive applications in Java. The book begins with the fundamentals of Reactor and the role it plays in building effective applications. You will learn how to build fully non-blocking applications and will later be guided by the Publisher and Subscriber APIs. You will gain an understanding how to use two reactive composable APIs, Flux and Mono, which are used extensively to implement Reactive Extensions. All of these components are combined using various operations to build a complete solution. In addition to this, you will get to grips with the Flow API and understand backpressure in order to control overruns. You will also study the use of Spring WebFlux, an extension of the Reactor framework for building microservices. By the end of the book, you will have gained enough confidence to build reactive and scalable microservices.

Related Content you might be interested in

Current Title:

Small book image
Hands-On Reactive Programming with Reactor
Rahul Sharma
Sep, 2018 | 250 pages
Small book image
Hands-On Reactive Programming in Spring 5
Igor Lozynskyi | Oleh Dokuka
Oct, 2018 | 556 pages
Small book image
Reactive Programming With Java 9
Tejaswini Mandar Jog
Sep, 2017 | 402 pages
Small book image
Hands-On Spring Security 5 for Reactive Applications
Tomcy John
Jul, 2018 | 268 pages
Table of Contents (13 chapters)
Preface
Preface
Who this book is for
What this book covers
To get the most out of this book
Get in touch
Free Chapter
1
Getting Started with Reactive Streams
Getting Started with Reactive Streams
Technical requirements
Reactive architecture
ReactiveX
Reactive Streams
Reactor
Summary
Questions
Further reading
2
The Publisher and Subscriber APIs in a Reactor
The Publisher and Subscriber APIs in a Reactor
Technical requirements
Stream publisher
Stream subscriber
Reactive Streams comparison
The Flux API
The Mono API
Building subscribers to Flux and Mono
Summary
Questions
Further reading
3
Data and Stream Processing
Data and Stream Processing
Technical requirements
Filtering data
Converting data
Summary
Questions
4
Processors
Processors
Technical requirements
An introduction to processors
Hot versus Cold publishers
Summary
Questions
5
SpringWebFlux for Microservices
SpringWebFlux for Microservices
Technical requirements
Introduction to SpringWebFlux
Summary
Questions
6
Dynamic Rendering
Dynamic Rendering
Technical requirements
View templates
Learning about static resources
WebClient
Summary
Questions
7
Flow Control and Backpressure
Flow Control and Backpressure
Technical requirements
Flow control
Backpressure
Summary
Questions
8
Handling Errors
Handling Errors
Technical requirements
Generating errors
Error recovery
Timeout
WebClient
Summary
Questions
9
Execution Control
Execution Control
Technical requirements
Scheduler
Parallel processing
Broadcasting
Summary
Questions
10
Testing and Debugging
Testing and Debugging
Technical requirements
Testing Reactor pipelines
Debugging Reactor streams
Summary
Questions
11
Assessments
Assessments
Chapter 1: Getting Started with Reactive Streams
Chapter 2: The Publisher and Subscriber APIs in a Reactor
Chapter 3: Data and Stream Processing
Chapter 4: Processors
Chapter 5: SpringWebFlux for Microservices
Chapter 6: Dynamic Rendering
Chapter 7: Flow Control and Backpressure
Chapter 8: Handling Errors
Chapter 9: Execution Control
Chapter 10: Testing and Debugging
12
Other Books You May Enjoy
Other Books You May Enjoy
Leave a review - let other readers know what you think

Chapter 9: Execution Control

  1. What are the different types of schedulers available in Reactor?
  • Schedulers.immediate: This schedules on the current thread
  • Schedulers.single: This schedules on a single thread
  • Schedulers.parallel: This schedules on the thread pool
  • Schedulers.elastic: This schedules on a thread pool
  • Schedulers.fromExecutor: This schedules the configured executor service
  1. Which scheduler should be used for blocking operations?

Schedulers.elastic schedules on a thread pool.

  1. Which scheduler should be used for computation intensive operations?
  • Schedulers.single: This schedules on a single thread.
  • Schedulers.parallel: This schedules on the thread pool
  1. How are PublishOn and SubscriberOn different from each other?

The subscribeOn operator intercepts events from a publisher in the execution chain and sends them to a different scheduler for the complete chain. It...

Previous Section
End of Section 10
Next Section